# 高級版查詢操作,厲害了哦 #老規矩
from my_create_table import User,engine from sqlalchemy.orm import sessionmaker Session = sessionmaker(engine) db_session = Session() # 查詢數據表操作 # and or
from sqlalchemy.sql import and_ , or_ ret = db_session.query(User).filter(and_(User.id > 3, User.name == 'DragonFire')).all() ret = db_session.query(User).filter(or_(User.id < 2, User.name == 'DragonFire')).all() # 查詢所有數據
r1 = db_session.query(User).all() # 查詢數據 指定查詢數據列 加入別名
r2 = db_session.query(User.name.label('username'), User.id).first() print(r2.id,r2.username) # 15 NBDragon
# 表達式篩選條件
r3 = db_session.query(User).filter(User.name == "DragonFire").all() # 原生SQL篩選條件
r4 = db_session.query(User).filter_by(name='DragonFire').all() r5 = db_session.query(User).filter_by(name='DragonFire').first() # 字符串匹配方式篩選條件 並使用 order_by進行排序
r6 = db_session.query(User).filter(text("id<:value and name=:name")).params(value=224, name='DragonFire').order_by(User.id).all() #原生SQL查詢
r7 = db_session.query(User).from_statement(text("SELECT * FROM User where name=:name")).params(name='DragonFire').all() # 篩選查詢列 # query的時候我們不在使用User ORM對象,而是使用User.name來對內容進行選取
user_list = db_session.query(User.name).all() print(user_list) for row in user_list: print(row.name) # 別名映射 name as nick
user_list = db_session.query(User.name.label("nick")).all() print(user_list) for row in user_list: print(row.nick) # 這里要寫別名了
# 篩選條件格式
user_list = db_session.query(User).filter(User.name == "DragonFire").all() user_list = db_session.query(User).filter(User.name == "DragonFire").first() user_list = db_session.query(User).filter_by(name="DragonFire").first() for row in user_list: print(row.nick) # 復雜查詢
from sqlalchemy.sql import text user_list = db_session.query(User).filter(text("id<:value and name=:name")).params(value=3,name="DragonFire") # 查詢語句
from sqlalchemy.sql import text user_list = db_session.query(User).filter(text("select * from User id<:value and name=:name")).params(value=3,name="DragonFire") # 排序 :
user_list = db_session.query(User).order_by(User.id).all() user_list = db_session.query(User).order_by(User.id.desc()).all() for row in user_list: print(row.name,row.id) #其他查詢條件
""" ret = session.query(User).filter_by(name='DragonFire').all() ret = session.query(User).filter(User.id > 1, User.name == 'DragonFire').all() ret = session.query(User).filter(User.id.between(1, 3), User.name == 'DragonFire').all() # between 大於1小於3的 ret = session.query(User).filter(User.id.in_([1,3,4])).all() # in_([1,3,4]) 只查詢id等於1,3,4的 ret = session.query(User).filter(~User.id.in_([1,3,4])).all() # ~xxxx.in_([1,3,4]) 查詢不等於1,3,4的 ret = session.query(User).filter(User.id.in_(session.query(User.id).filter_by(name='DragonFire'))).all() 子查詢 from sqlalchemy import and_, or_ ret = session.query(User).filter(and_(User.id > 3, User.name == 'DragonFire')).all() ret = session.query(User).filter(or_(User.id < 2, User.name == 'DragonFire')).all() ret = session.query(User).filter( or_( User.id < 2, and_(User.name == 'eric', User.id > 3), User.extra != "" )).all() # select * from User where id<2 or (name="eric" and id>3) or extra != "" # 通配符 ret = db_session.query(User).filter(User.name.like('e%')).all() ret = db_session.query(User).filter(~User.name.like('e%')).all() # 限制 ret = db_session.query(User)[1:2] # 排序 ret = db_session.query(User).order_by(User.name.desc()).all() ret = db_session.query(User).order_by(User.name.desc(), User.id.asc()).all() # 分組 from sqlalchemy.sql import func ret = db_session.query(User).group_by(User.extra).all() ret = db_session.query( func.max(User.id), func.sum(User.id), func.min(User.id)).group_by(User.name).all() ret = db_session.query( func.max(User.id), func.sum(User.id), func.min(User.id)).group_by(User.name).having(func.min(User.id) >2).all() """
# 關閉連接
db_session.close() orm_select_more
更新：
#高級版更新操作
from my_create_table import User,engine from sqlalchemy.orm import sessionmaker Session = sessionmaker(engine) db_session = Session() #直接修改
db_session.query(User).filter(User.id > 0).update({"name" : "099"}) #在原有值基礎上添加 - 1
db_session.query(User).filter(User.id > 0).update({User.name: User.name + "099"}, synchronize_session=False) #在原有值基礎上添加 - 2
db_session.query(User).filter(User.id > 0).update({"age": User.age + 1}, synchronize_session="evaluate") db_session.commit() orm_update_more