Python  Flask框架操作数据库的方法

mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]

pip install flask_sqlalchemy

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
# 设置数据库链接地址
app.config['SQLALCHEMY_DATABASE_URI']='mysql+pymysql://root:123456@127.0.0.1:3306/test'
# 设置显示底层执行的sql语句
app.config['SQLALCHEMY_ECHO'] = True
# 初始化组件对象，关联flask应用
db = SQLAlchemy(app)

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import datetime
app = Flask(__name__)
# 设置数据库链接地址
app.config['SQLALCHEMY_DATABASE_URI']='mysql+pymysql://root:123456@127.0.0.1:3306/test'
# 设置显示底层执行的sql语句
app.config['SQLALCHEMY_ECHO'] = True
# 初始化组件对象，关联flask应用
db = SQLAlchemy(app)
# 构建模型类
class User(db.Model):
    # 设置表名，表名默认为类名小写
    __tablename__ = 'user'
    id = db.Column(db.Integer,primary_key=True)   # 设置主键，默认自增
    name = db.Column(db.String(20))
    age = db.Column(db.Integer,default=20)  #设置默认值
    createtime=db.Column(db.DateTime())
    def __repr__(self):  # 自定义 交互模式 & print() 的对象打印
      return "(%s, %s, %s, %s)" % (self.id, self.name, self.age,self.createtime)
if __name__ == '__main__':
    app.run(debug=True)

@app.route("/initDB")
def init_db():
    # 删除所有继承睡在db.Model的表
    db.drop_all()
    # 创建所有继承自 db.Model的表
    db.create_all()
    return "initdb"

@app.route("/add")
def add():
    # 添加数据
    user1 = User(name='zhao', age=33, createtime=datetime.datetime.now())
    # 将模型添加到会话中
    db.session.add(user1)
    # 添加多条记录
    # db.session.add_all([user1,user2,user3])
    # 提交会话， sqlalchemy会自动创建隐式事务，失败会自动回滚
    db.session.commit()
    return "add" 

@app.route("/query")
def query():
    # 查询所有用户数据, 返回User列表,
    data = User.query.all()
    for item in data:
        print(item.name,item.age)
    # 查询有多少个用户，返回结果数
    data = User.query.count()
    print(data)
    # 查询第1个用户 ， 返回User对象
    data = User.query.first()
    print(data)
    # 查询id为4的用户， 返回User对象
    data = User.query.get(4)
    print(data)
    return "query"

@app.route("/query2")
def query2():
    # 查询 name 等于 zhao 的记录集中第一条记录
    data = User.query.filter(User.name =='zhao').first()
    # 查询 name 不等于 zhao 的所有记录
    data = User.query.filter(User.name != 'zhao').all()
    # 前模糊查询
    data = User.query.filter(User.name.like("%zhao")).all()
    print(data)
    # 查询名字以 zhao 开头的用户
    data = User.query.filter(User.name.startswith('zhao')).all()
    # 查询名字是 zhao，并且年龄是22岁的用户
    from sqlalchemy import and_
    data = User.query.filter(and_(User.name=='zhao', User.age==22)).all()
    # 查询名字是 zhao或者hong的用户
    from sqlalchemy import or_
    data = User.query.filter(or_(User.name=='zhao', User.name=='hong')).all()
    # 查询id为[1, 2, 3]的用户
    data = User.query.filter(User.id.in_([1, 2, 3])).all()
    # 分页查询
    # 所有用户先按年龄从小到大, 再按id从大到小排序, 取前5个
    data = User.query.order_by(User.age, User.id.desc()).limit(5).all()
    # 分页查询, 每页1个, 查询第2页的数据  paginate(页码, 每页条数)
    pn = User.query.paginate(page=2, per_page=1)
    print("总页数:"+str(pn.pages)+" 当前页码:"+str(pn.page)+"当前页的数据："+ str(pn.items)+" 总条数:"+str(pn.total))
    # 分组查询
    # 查询每个年龄的人数    select age, count(name) from t_user group by age  分组聚合
    from sqlalchemy import func
    data = db.session.query(User.age, func.count(User.id).label("count")).group_by(User.age).all()
    return "query2"

@app.route("/update")
def update():
    # 更新用户年龄为44，条件是：用户名=zhao
    # 相当于：update user set age = 44 where name = 'zhao';
    User.query.filter(User.name == 'zhao').update({'age': 44})
    # 提交会话
    db.session.commit()
    return "update"

@app.route("/del")
def delete():
    # 删除id=1的用户
    # 相当于：delete from user where id=1
    User.query.filter(User.id == 1).delete()
    # 提交会话
    db.session.commit()
    return "del"

from flask import Flask
from flask_sqlalchemy import SQLAlchemy
import datetime
app = Flask(__name__)
# 设置数据库链接地址
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:123456@127.0.0.1:3306/test'
# 设置显示底层执行的sql语句
app.config['SQLALCHEMY_ECHO'] = True
# 初始化组件对象，关联flask应用
db = SQLAlchemy(app)
# 构建模型类
class User(db.Model):
    # 设置表名，表名默认为类名小写
    __tablename__ = 'user'
    id = db.Column(db.Integer, primary_key=True)  # 设置主键，默认自增
    name = db.Column(db.String(20))
    age = db.Column(db.Integer, default=20)  # 设置默认值
    createtime = db.Column(db.DateTime())
    def __repr__(self):  # 自定义 交互模式 & print() 的对象打印
        return "(%s, %s, %s, %s)" % (self.id, self.name, self.age, self.createtime)
class Address(db.Model):
    __tablename__ = 'address'
    id = db.Column(db.Integer, primary_key=True)
    detail = db.Column(db.String(20))
    user_id = db.Column(db.Integer)  # 定义外键
if __name__ == '__main__':
    app.run(debug=True)
@app.route("/")
def index():
    return "index"
@app.route("/query")
def query():
    """ 查询多表数据  需求: 查询姓名为"hong" 的用户id和地址信息"""
    # sqlalchemy的join查询
    # 相当于：SELECT user.id AS user_id, address.detail AS address_detail
    #           FROM user INNER JOIN address ON user.id = address.user_id
    data = db.session.query(User.id, Address.detail).join(Address, User.id == Address.user_id).filter(
        User.name == 'hong').all()
    for item in data:
        print(item.detail, item.id)
    return "query"