本篇文章给大家带来的内容是关于python中flask_sqlalchemy操作数据库的方法示例，有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。
flask_sqlalchemy
使用对象关系映射（object-relational mapper, orm）框架，它将低层的数据库操作指令抽象成高层的面向对象操作。也就是说，如果我们直接使用数据库引擎，我们就要写 sql 操作语句，但是，如果我们使用了 orm 框架，我们对诸如表、文档此类的数据库实体就可以简化成对 python 对象的操作
SQLAlchemy已经成为了python世界里面orm的标准，flask是一个轻巧的web框架，可以自由的使用orm，其中flask-sqlalchemy是专门为flask指定的插件。
在 Flask-SQLAlchemy 中，数据库使用 URL 指定。
MySQL --> mysql://username:password@hostname/database
安装
pip install flask-sqlalchemy
对数据库操作
1. 如何创建数据库操作连接
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
db = SQLAlchemy(app)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:sheen@localhost/zaj_sql'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
class User(db.Model):
id = db.Column(db.Integer, primary_key=True)
username = db.Column(db.String(80), unique=True)
email = db.Column(db.String(120), unique=True)为了创建初始数据库，调用 SQLAlchemy.create_all() 方法来创建表和数据库:
立即学习“Python免费学习笔记（深入）”；
db.create_all()
您的数据库已经生成。现在来创建一些用户
admin = User('admin', 'admin@example.com')
guest = User('guest', 'guest@example.com')但是它们还没有真正地写入到数据库中，因此让我们来确保它们已经写入到数据库中
db.session.add(admin) db.session.add(guest) db.session.commit()
2.创建关系型数据库表
SQLAlchemy 连接到关系型数据库，关系型数据最擅长的东西就是关系。因此，我们将创建一个使用两张相互关联的表的应用作为例子。
最为常见的关系就是一对多的关系。因为关系在它们建立之前就已经声明，您可以使用 字符串来指代还没有创建的类
关系使用 relationship() 函数表示。然而外键必须用类 sqlalchemy.schema.ForeignKey 来单独声明.
from datetime import datetime
from flask_bootstrap import Bootstrap
from flask_wtf import FlaskForm
from flask_sqlalchemy import SQLAlchemy
from flask import Flask
import pymysql
from sqlalchemy import desc
app = Flask(__name__)
db = SQLAlchemy(app)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:sheen@localhost/zaj_sql'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
bootstrap = Bootstrap(app)
class User(db.Model):
id = db.Column(db.Integer,autoincrement=True,primary_key=True)
name = db.Column(db.String(50),unique=True)
passwd = db.Column(db.String(100))
add_time = db.Column(db.DATETIME,default=datetime.now())
gender = db.Column(db.BOOLEAN,default=True)
role_id = db.Column(db.INTEGER,db.ForeignKey('role.id'))
def __repr__(self):
return '<User:%s>' %(self.name)
class Role(db.Model):
id = db.Column(db.INTEGER,autoincrement=True,primary_key=True)
name = db.Column(db.String(50),unique=True)
users = db.relationship('User',backref='role')
# 给Role模型添加users属性
# backref 是定义反向引用
def __repr__(self):
return '<Role:%s>' % (self.name)
if __name__ =='__main__':
# 1. 创建数据库表
# db.drop_all()
# db.create_all()
# # 2. 创建role数据库表数据
role_1 = Role(name='超级会员')
role_2 = Role(name='普通会员')
db.session.add(role_1)
db.session.add(role_2)
db.session.commit()
# # # 3. 添加user表内数据，100个用户，50个为超级会员，50个为普通会员
for i in range(1,13):
if i%2 == 0:
u = User(name='sheen'+str(i),passwd='sheen',role_id=1)
db.session.add(u)
else:
u = User(name='star'+str(i),passwd='star',role_id=2)
db.session.add(u)
db.session.commit()backref 是定义反向引用，可以通过User.role访问Role对象和属性。
查询所有数据
print('角色',Role.query.all())
print('用户',User.query.all())根据条件查询数据
# select * from tablename where xxx=xxxxx
print(User.query.filter_by(role_id=1).all())
print(Role.query.filter_by().all())
print(User.query.filter_by(role_id=2).all())
对于找到的数据进行更新
print('进行数据更新',end='\n')
u =User.query.filter_by(name='sheen2').first()
print(u)
u.passwd = '123'
db.session.add(u)
db.session.commit()
筛选数据方法2(filter),这种方法可以看见原生的sql语句
print('数据筛选', end='\n')
user = User.query.filter(User.role_id==1)
print(user)
对于查询的信息进行显示限制
print('限制查询数据的显示', end='\n')
users = User.query.filter_by(role_id=1).limit(3).all()
print(users)对于查询的信息进行排序输出(默认情况由小到大进行排序)， 如果想要由大到小： desc(User.add_time)
print('数据再处理', end='\n')
users = User.query.filter_by(role_id=1).order_by(desc(User.name)).all()
print(users)多个过滤函数
print('多个过滤函数', end='\n')
users = User.query.filter_by(role_id=1).order_by(desc(User.name)).limit(3).offset(1).all()
print(users)
users = User.query.filter_by(role_id=1).order_by(desc(User.name)).slice(1,4).all()
print(users)
分页,第一个参数表示显示第几页数据，第二个参数表示每页显示多少条数据
print('分页显示', end='\n')
users = User.query.paginate(1,5)
print(users.items)
users = User.query.paginate(2, 5)
print(users.items)
