flask-sqlalchemy 秒速五厘米 2023-06-03 02:44 76阅读 0赞 ### 配置和连接 ### * 安装 `pip install flask-sqlalchemy` * ModuleNotFoundError: No module named 'MySQLdb' ： `pip install mysqlclient` ### 创建连接 ### ![1552472-20190821185823401-1883707843.png][] from flask import Flask from flask_sqlalchemy import SQLAlchemy app = Flask(__name__) # 设置数据库的连接地址 app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@127.0.0.1:3306/test28' # 设置是否追踪数据库变化 一般不会开启, 影响性能 app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # 设置是否打印底层执行的SQL语句 app.config['SQLALCHEMY_ECHO'] = True # 创建数据库连接对象 db = SQLAlchemy(app) # 类->表 类属性->字段 对象->记录 class User(db.Model): __tablename__ = 't_user' # 设置表名, 表名默认为类名小写 id = db.Column(db.Integer, primary_key=True) # 主键, 默认自增 name = db.Column(db.String(20), unique=True) # 设置唯一 age = db.Column(db.Integer) @app.route('/') def index(): """增加数据""" # sqlalchemy会自动创建一个隐式事务, 并将sql操作添加到事务中 # 创建模型对象 user1 = User(name='zs', age=20) # user1.name = 'zs' # 另一种设置数据的方式 # 将对象添加到会话中 转换对应的sql语句 db.session.add(user1) # db.session.add_all([user1, user2, user3]) # 批量添加数据 # 提交会话 就会提交事务, 而且事务失败会自动回滚 db.session.commit() return "index" if __name__ == '__main__': # 删除所有继承自db.Model的表 db.drop_all() # 创建所有继承自db.Model的表 db.create_all() app.run(debug=True) ### 增加数据 ### ![1552472-20190821190253146-1877941271.png][] ### 查询数据 ### from flask import Flask from flask_sqlalchemy import SQLAlchemy app = Flask(__name__) # 设置数据库连接地址 app.config["SQLALCHEMY_DATABASE_URI"] = "mysql://root:mysql@127.0.0.1:3306/test28" # 设置是否跟踪数据库改变 app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = False app.config["SQLALCHEMY_ECHO"] = True # 创建数据库连接 db = SQLAlchemy(app) # 自定义类 继承db.Model 对应 表 class User(db.Model): __tablename__ = "users" # 表名 默认使用类名的小写 # 定义类属性 记录字段 id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String(64)) email = db.Column(db.String(64)) age = db.Column(db.Integer) def __repr__(self): # 自定义 交互模式 & print() 的对象打印 return "(%s, %s, %s, %s)" % (self.id, self.name, self.email, self.age) @app.route('/') def index(): """ 查询所有用户数据 User.query.all() 返回列表,里边包含的是数据对象 查询有多少个用户 User.query.count() 查询第1个用户 User.query.first() 返回对象 查询id为4的用户[3种方式] User.query.get(4) # 根据id查询 返回对象 BaseQuery类型 允许续接其他具体的查询条件 如all/first/count等 User.query.filter_by(id=4).all() # 简单查询器 关键字实参的方式来匹配字段 返回BaseQuery对象 User.query.filter(User.id==4).first() # 复杂查询器 恒等式/函数形式来匹配 返回BaseQuery对象 查询名字结尾字符为g的所有用户[开始 / 包含] User.query.filter(User.name.endswith('g')).all() User.query.filter(User.name.startswith('w')).all() User.query.filter(User.name.contains('n')).all() User.query.filter(User.name.like('w%n%g')).all() # 模拟查询 查询名字和邮箱都以li开头的所有用户[2种方式] User.query.filter(User.name.startswith('li'), User.email.startswith('li')).all() from sqlalchemy import and_ User.query.filter(and_(User.name.startswith('li'), User.email.startswith('li'))).all() 查询age是25 或者 `email`以`itheima.com`结尾的所有用户 from sqlalchemy import or_ User.query.filter(or_(User.age==25, User.email.endswith("itheima.com"))).all() 查询名字不等于wang的所有用户[2种方式] from sqlalchemy import not_ User.query.filter(not_(User.name=='wang')).all() User.query.filter(User.name!='wang').all() 查询id为[1, 3, 5, 7, 9]的用户 User.query.filter(User.id.in_([1, 3, 5, 7, 9])).all() 所有用户先按年龄从小到大, 再按id从大到小排序, 取前5个 User.query.order_by(User.age, User.id.desc()).limit(5).all() 查询年龄从小到大第2-5位的数据 User.query.order_by(User.age).offset(1).limit(4).all() 分页查询, 每页3个, 查询第2页的数据 pn = User.query.paginate(2, 3) pn.pages 总页数 pn.page 当前页数 pn.items 当前页的数据 查询每个年龄的人数 select age, count(name) from t_user group by age 分组聚合 from sqlalchemy import func db.session.query(User.age, func.count(User.name)).group_by(User.age).all() 只查询所有人的姓名和邮箱 优化查询 默认使用select * from sqlalchemy.orm import load_only users = User.query.options(load_only(User.name, User.email)).all() # 返回对象列表 # for user in users: # print(user.name, user.email) data = db.session.query(User.name, User.email).all() # 返回元组列表 """ return 'index' if __name__ == '__main__': # 删除所有表 db.drop_all() # 创建所有表 db.create_all() # 添加测试数据 user1 = User(name='wang', email='wang@163.com', age=20) user2 = User(name='zhang', email='zhang@189.com', age=33) user3 = User(name='chen', email='chen@126.com', age=23) user4 = User(name='zhou', email='zhou@163.com', age=29) user5 = User(name='tang', email='tang@itheima.com', age=25) user6 = User(name='wu', email='wu@gmail.com', age=25) user7 = User(name='qian', email='qian@gmail.com', age=23) user8 = User(name='liu', email='liu@itheima.com', age=30) user9 = User(name='li', email='li@163.com', age=28) user10 = User(name='sun', email='sun@163.com', age=26) # 一次添加多条数据 db.session.add_all([user1, user2, user3, user4, user5, user6, user7, user8, user9, user10]) db.session.commit() app.run(debug=True) ### 更新和删除数据 ### ![1552472-20190821191346043-1426173779.png][] @app.route('/') def index(): """更新数据""" # 方式1: 先查询数据, 再更新数据 # user = User.query.filter_by(name='zs').first() # user.age = 30 # 提交会话 # db.session.commit() # 方式2: update子查询 update t_order set count=count-1 where count > 0; # User.query.filter_by(name='zs').update({'age': 30}) # 提交会话 # db.session.commit() """删除数据""" # 方式1: 先查询数据, 再删除数据 # user = User.query.filter_by(name='zs').first() # db.session.delete(user) # db.session.commit() # 方式2: delete子查询 User.query.filter_by(name='zs').delete() # 提交会话 db.session.commit() return "index" 转载于:https://www.cnblogs.com/oklizz/p/11390532.html [1552472-20190821185823401-1883707843.png]: /images/20230601/871c636bbf7a4239bf4b8643006f1409.png [1552472-20190821190253146-1877941271.png]: /images/20230601/4be5c40674be4116abd48b7d3a004811.png [1552472-20190821191346043-1426173779.png]: /images/20230601/09d1e651d8474aacb44eb97a565efd11.png
还没有评论，来说两句吧...