您好,欢迎访问一九零五行业门户网

python中flask_sqlalchemy操作数据库的方法示例

本篇文章给大家带来的内容是关于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 flaskfrom flask_sqlalchemy import sqlalchemyapp = flask(__name__)db = sqlalchemy(app)app.config['sqlalchemy_database_uri'] = 'mysql+pymysql://root:sheen@localhost/zaj_sql'app.config['sqlalchemy_track_modifications'] = trueclass 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() 方法来创建表和数据库:
   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 datetimefrom flask_bootstrap import bootstrapfrom flask_wtf import flaskformfrom flask_sqlalchemy import sqlalchemyfrom flask import flaskimport pymysqlfrom sqlalchemy import descapp = flask(__name__)db = sqlalchemy(app)app.config['sqlalchemy_database_uri'] = 'mysql+pymysql://root:sheen@localhost/zaj_sql'app.config['sqlalchemy_track_modifications'] = truebootstrap = 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)
以上就是python中flask_sqlalchemy操作数据库的方法示例的详细内容。
其它类似信息

推荐信息