sqlalchemy1.3官方文档地址

    声明映射

    1. from sqlalchemy.ext.declarative import declarative_base
    3. Base = declarative_base()
    1. class User(Base):
    2.     #__tablename__是必须的(表名)
    3.     __tablename__ = 'users' 
    5.     #数据列,至少一个Column是主键的一部分
    6.     id = Column(Integer, primary_key=True)  
    7.     loginnum = Column(String(255))
    8.     password = Column(String(255))
    10.     #重写__repr__,输出实例化对象信息
    11.     def __repr__(self):
    12.         return "<User(id='%s', loginnum='%s',password='%s')>" % (
    13.             self.id, self.loginnum, self.password)

    创建会话

    2. def sql_connect():
    3.     #创建数据库连接
    4.     #针对不同类型的数据库，create_engine提供了不同的参数格式填写,这里使用的是mysql
    5.     engine = create_engine(
    6.         "mysql://root:root@localhost:3306/test?charset=utf8", encoding='utf-8')
    7.     #定义Session类
    8.     DBSession = sessionmaker(bind=engine)
    9.     #这个定制的Session类将创建绑定到我们数据库的新Session对象
    10.     session = DBSession()
    11.     #针对数据库中不存在的表,发出CREATE TABLE
    12.     Base.metadata.create_all(engine)
    13.     return session

    添加操作

    2. db = sql_connect()
    3. db_add = User(loginnum="a123",password="123")
    4. db.add(db_add)
    5. db.commit()
    6. db.close()

    查询操作

    2. db = sql_connect()
    3. db_user = db.query(User).filter().all() #使用all(),返回所有查询结果,数据类型为list
    4. db_user = db.query(User).filter().first() #使用first(),返回查询结果中的第一条数据
    5. print(db_user)
    7. 输出结果：
    8. [<User(id='1', loginnum='a123',password='123')>]

    更新操作

    2. db = sql_connect()
    3. db_user = db.query(User).filter().all()
    4. print(db_user)
    5. db_user[0].password = 456
    6. db_user = db.query(User).filter().all()
    7. print(db_user)
    8. db.commit()
    9. db.close()
    11. 输出结果：
    12. [<User(id='1', loginnum='a123',password='123')>]
    13. [<User(id='1', loginnum='a123',password='456')>]

    删除操作

    2. db = sql_connect()
    3. db = sql_connect()
    4. db_user = db.query(User).filter().first()
    5. print(db_user)
    6. db.delete(db_user)
    7. db.commit()
    8. db_user = db.query(User).filter().all()
    9. print(db_user)
    11. 输出结果：
    12. [<User(id='1', loginnum='a123',password='456')>]
    13. []
    14. 若以all()查询,执行delete方法时,直接给整个list会出现报错,必须指定list中的元素,或用first()单独查询一条数据进行删除