python中orm框架sqlalchemy使⽤
python中orm框架sqlalchemy使⽤
⽂章⽬录
⼀、简介
sqlalchemy是python中开源的orm框架，⽤于简化在python中对数据库的操作。这⾥对sqlalchemy中的常⽤操作进⾏介绍。⼆、准备
2.1 官⽹地址
2.2 依赖包安装
pip3 install sqlalchemy
批量更新sql语句三、使⽤
3.1 创建映射对象
定义对象类，属性字段与对应表字段关联，同时可指定默认值等属性，⽰例如下：
# 基类
Base = declarative_base()
class Stu(Base):
# 设置表名
__tablename__ ='stu'
# 属性名与表中字段名映射
id= Column('id', Integer, primary_key=True)
no = Column('no', String)
# server_default为默认值,text为⽂本表⽰
stuName = Column('stu_name', String, server_default='')
createTime = Column('create_time', DateTime, server_default=text('NOW()'))
# 返回对象的字符串表⽰
def__repr__(self)->str:
return str(self.__dict__)
3.2 创建数据库连接
指定要连接的数据库，创建会话，同时可根据需要设置相关参数，⽰例如下：
# 连接地址，格式为 mysql+pymysql://[账号]:[密码]@[主机]:[端⼝]/[数据库]?charset=utf8"
url ='mysql+pymysql://root:root@127.0.0.1:3306/school?charset=utf8'
# echo为True时，打印sql，可⽤于调试
engine = create_engine(url, echo=False, encoding='utf-8', pool_size=5)
sessionClass = sessionmaker(bind=engine)
# 创建会话
session = sessionClass()
# 使⽤完后关闭会话
# session.close()
3.3 查询
3.3.1 常⽤查询
这⾥列中常⽤查询，包含排序、分组、条件查询、个数查询、单个查询、列表查询等，具体请看⽰例代码：# 查所有，并排序
stuList = session.query(Stu).order_by(Stu.id).all()
# 查询指定属性并遍历,⽅式⼀
for id, no in session.query(Stu.id, ):
print("id:{} no:{}".format(id, no))
# 查询指定属性并遍历,⽅式⼆
for t in session.query(Stu.id, ).all():
print("id:{} no:{}".format(t.id, t.no))
# 查所有，并排序
stuList = session.query(Stu).order_by(Stu.id).all()
# 分页查询
stuList = session.query(Stu).limit(2).offset(0).all()
# 查询个数
stuList = session.query(Stu).count()
# 查询个数，scalar（）表⽰返回第⼀个结果的第⼀个元素
cnt = session.unt('*')).select_from(Stu).scalar()
# 查询个数，带条件统计
cnt = session.unt('*')).select_from(Stu).filter(Stu.id>2).scalar()
# 根据id统计
cnt = session.unt(Stu.id)).scalar()
# 指定条件查询
stuList = session.query(Stu).filter(Stu.id>2, ateTime < w()).all()
# 获取第⼀个，没有则抛异常
# stu = session.query(Stu).filter(Stu.id==2).one()
# 获取第⼀个，没有则返回None
stu = session.query(Stu).filter(Stu.id==1).first()
# 获取第⼀个，没有则返回None
stu = session.query(Stu).filter(Stu.id==2).one_or_none()
# group by查询
stuList = session.unt('*'), Stu.stuName).filter(or_(Stu.id>2, Stu.stuName =='apple1')).group_by(
Stu.stuName).all()
3.3.2 条件查询
这⾥列出常⽤的条件查询，⽰例如下：
# 相等查询
stuList = session.query(Stu).filter(Stu.id==2).all()
# 不等查询
stuList = session.query(Stu).filter(Stu.id!=2).all()
# ⼤于查询
stuList = session.query(Stu).filter(Stu.id>2).all()
# in查询
stuList = session.query(Stu).filter(Stu.id.in_([82,83])).all()
# not in 查询
stuList = session.query(Stu).filter(~Stu.id.in_([82,83])).all()
# 嵌套查询
stuList = session.query(Stu).filter(Stu.id.in_(session.query(Stu.id).filter(Stu.id<=83))).all()
# like查询(不同后端时，有时⼤⼩写不敏感)
stuList = session.query(Stu).filter(Stu.stuName.like('Apple%')).all()
# like查询(明确⼤⼩写不敏感)
stuList = session.query(Stu).filter(Stu.stuName.ilike('Apple%')).all()
# null查询
stuList = session.query(Stu).filter(Stu.stuName.is_(None)).all()
# not null查询
stuList = session.query(Stu).filter(Stu.stuName.isnot(None)).all()
# and查询
stuList = session.query(Stu).filter(Stu.id>2, Stu.stuName =='apple1').all()
# or查询
stuList = session.query(Stu).filter(or_(Stu.id>2, Stu.stuName =='apple1')).all()
# 多级过滤
stuList = session.query(Stu).filter(Stu.id>2).filter(Stu.stuName =='apple1').all()
3.3.3 直接sql语句查询
除了sqlalchemy带的查询⽅法，还可直接使⽤sql语句查询，使⽤如下：
# 直接使⽤sql语句查询(只有条件sql语句)
stuList = session.query(Stu).filter(text("id>2 and stu_name='apple1'")).order_by(text("id")).all()
# 直接使⽤sql语句查询(完整的sql语句)
stuList = session.query(Stu).from_statement(
text("select * from stu where id>:id and stu_name=:name order by id").params(id=2, name='apple1')).all()
3.4 插⼊
3.4.1 单条插⼊
# 单条插⼊
stu = Stu(no='86', stuName='apple86', createTime=w())
session.add(stu)
sessionmit()
3.4.2 批量插⼊
# 批量插⼊
stuList =[Stu(id=83, no='83', stuName='apple83', createTime=w()), Stu(id=84, no='84', stuName='apple84')] session.add_all(stuList)
sessionmit()
3.4.3 使⽤sql语句插⼊
# 直接使⽤sql语句,⽤Stu对象转dict插⼊
stu = Stu(id=91, no='2', stuName='tree4', createTime=w())
# 直接使⽤sql语句,⽤stu映射
stu_obj ={'id':3,'no':'3','stuName':'tree3','createTime': w()}
3.4.4 忽略已存在的插⼊
若数据已经存在，则不插⼊，否则直接插⼊。
# 直接使⽤sql语句,⽤stu映射，若对象已存在，则忽略
stu = Stu(id=91, no='2', stuName='tree4', createTime=w())
3.4.5 更新插⼊
若数据已经存在，则做更新操作，否则直接插⼊。
# 直接使⽤sql语句，若对象已存在，则更新
stu = Stu(id=91, no='2', stuName='tree4', createTime=w())
更新时，流程是先查出对象，再对对象修改，最后直接commit。使⽤⽰例如下：
# 更新，流程：先查出对象，再对对象修改，最后直接commit
stu = session.query(Stu).filter(Stu.id==82).first()
stu.stuName ='rice1'
sessionmit()
# 更新(根据条件可批量更新)，流程：查对象同时进⾏修改，最后直接commit
session.query(Stu).filter(Stu.id>=85).update({Stu.stuName:'tree1'})
sessionmit()
3.6 删除
删除同更新类似，流程是先查出对象，再删除对象delete，最后直接commit。使⽤⽰例如下：
# 删除，流程：先查出对象，再删除对象delete，最后直接commit
stu = session.query(Stu).filter(Stu.id==83).first()
session.delete(stu)
sessionmit()
# 删除(根据条件可批量删除)，流程：查出对象同时删除对象delete，最后直接commit
session.query(Stu).filter(Stu.id>=85).delete()
sessionmit()
四、结尾
上⾯列出了sqlalchemy中的常⽤部分操作，更多操作可查看官⽹或源码。
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论