数据库的连接、创建会话与模型

import pymysql
# 连接数据库connection = pymysql.connect(    host='localhost',    user='root',    password='0908',    database='db_flask_demo_school',    charset='utf8mb4')
try:    with connection.cursor() as cursor:        # 执行 SQL 查询        sql = "SELECT * FROM tb_student"        cursor.execute(sql)        result = cursor.fetchall()        for row in result:            print(row)finally:    connection.close()

from sqlalchemy import create_engine, Column, Integer, String, Booleanfrom sqlalchemy.orm import declarative_base, sessionmaker
# 创建数据库引擎engine = create_engine('mysql+pymysql://root:0908@localhost:3306/db_flask_demo_school?charset=utf8mb4')Base = declarative_base()
# 定义模型class Student(Base):    __tablename__ = 'tb_student'    id = Column(Integer, primary_key=True)    name = Column(String(20))    sex = Column(Boolean, default=True)    age = Column(Integer)
# 创建会话SessionLocal = sessionmaker(bind=engine)session = SessionLocal()
# 查询数据students = session.query(Student).all()for student in students:    print(student.name)

CREATE DATABASE db_flask_demo_school CHARSET=utf8mb4

from sqlalchemy import create_engine
engine = create_engine(    # url = '驱动://账户:密码@地址:端口/数据库名?charset=编码'    url='mysql+pymysql://root:0908@localhost:3306/db_flask_demo_school?charset=utf8mb4',    echo=True,  # 在控制台输出SQL语句，方便调试    pool_size=8,  # 连接池的数据库连接数量    max_overflow=30,  # 连接池的数据库连接最大数量    pool_recycle=60 * 30,  # 设置秒数限制数据库多久没连接自动断开)

from sqlalchemy.orm import sessionmaker
SessionLocal = sessionmaker(bind=engine)  # 工厂函数，创建新的会话类session = SessionLocal()  # 实例化。用于与数据库进行交互

from sqlalchemy.orm import Session
# 目前官方文档上的案例使用的这种# 大多数机构教学或者旧的学习资料中可能是上述方式session = Session(bind=engine)

from sqlalchemy.orm import declarative_base
Model = declarative_base()

from sqlalchemy.orm import DeclarativeBase
class Model(DeclarativeBase):    pass

import dbimport datetime
class Student(db.Model):    __tablename__ = 'tb_student'  #  数据表的名字    # db.Column 是一个字段对象，对应表字段，接受很多很多的参数（没啥好记的，浪费大脑为数不多的空间，参见末尾的表），常用字段属性是字段类型、是否为主键、备注描述、默认值指定等等    # 整型 + 主键 + 告知这是学生编号（默认自增）    id = db.Column(db.Integer, primary_key=True, comment='学生编号')    # 20位字符串 + 告知这是学生姓名    name = db.Column(db.String(20), comment='学生姓名')    # 布尔型（实际上存储是0或1），默认是 True（存储是1）    sex = db.Column(db.Boolean, default=True, comment='学生性别')    # 精度更小的整型    age = db.Column(db.SmallInteger, comment='学生年龄')    # 'class' 这里不是类型，而是别名，因为 class = xxx，在python中是不行的（关键字）    class_ = db.Column('class', db.SMALLINT, comment='学生班级')    # 文本类型    description = db.Column(db.Text, comment='个性签名')    # 布尔型，默认值也可以写成 1    status = db.Column(db.Boolean, default=1, comment='登录状态')    # 日期时间类型，默认值需要特别注意，引用了 datetime 库，使用的是 now函数的地址，而不是它的调用结果。如果使用调用结果，将以项目执行启动的时间为准    addtime = db.Column(db.DateTime, default=datetime.datetime.now, comment='入学时间')    orders = db.Column(db.SMALLINT, default=1, comment='学生排序')
    def __repr__(self):        # 便于打印列表时，显示 [ <Student: 老王(12)>,...]        return f'<{self.__class__.__name__}: {self.name}({self.id})>'
    def to_dict(self):        # 便于对象直接转成字符串，实现方式很多，比如 __dict__ 拷贝一份，然后筛选非'_'字符开头的键也行。        return {            'id': self.id,            'name': self.name,            'sex': self.sex,            'age': self.age,            'class': self.class_,            'description': self.description,            'status': self.status,            'addtime': self.addtime.strftime('%Y-%m-%d %H:%M:%S'),  # 需要注意获取到的是 DateTime 对象，参见 datetime 库            'orders': self.orders,        }
if __name__ == '__main__':    # 建表操作，如果如果你所在的公司或者团队或者你自身负责数据库的设计（DBA），那么建表无需执行 create_all    # 当然，也有一些坑13，如果没有为你建表甚至没有设计，emmmm……，那就自己来吧！    db.Model.metadata.create_all(db.engine)