python访问数据库, SQLAlchemy中的Query方法

1、SQLAlchemy中的Query方法在SQLAlchemy中执行查询是通过session对象的query方法完成的。query方法非常灵活，你可以根据需要使用不同的查询方式查找数据，下面一一举例。1.直接通过映射类查找：#Querying user instancefor instance in session.query(User).order_by(User.id): print ,instance.fullname这种方法只要在query方法中，将映射类作为参数，就可以查询出这个映射类代表的数据库表中的数据。其相当于下面的SQL语句：SELECT users.

2、id AS users_id, AS users_name,users.fullname AS users_fullname, users.password AS users_passwordFROM users ORDER BY users.id2.通过映射类的属性字段查询：#Querying by ORM-instrumentfor name,fullname in session.query(U,User.fullname): print name,fullname这种方法指定了查询的具体字段，而不是像第一种方法那样把映射类的所有字段都查询出来，其相

3、当于执行了下面的SQL语句：SELECT AS users_name, users.fullname AS users_fullnameFROM users3.query查询的结果是保存在一个元组中的，所以我们可以在query中指定返回整个的映射类对象和其中的部分属性字段：#Querying as a Python objectfor row in session.query(User,U).all(): print row.User,这种查询方法可以返回一个User对象以及它的name属性字段的值，其相当于执行了下面的SQL语句：SELE

4、CT users.id AS users_id, AS users_name, users.fullname AS users_fullname, users.password AS users_passwordFROM users其输出结果为一个元组和一个字符串：user(ed,Ed Jones,f8x902) eduser(Wendy,Wendy Williams,foobar) Wendyuser(Marry,Marry Contrary,xxg527) Marryuser(Fred,Fred Flinstone,blah) Fred4.我们还可以给返回的结果起一个

5、别名，或者叫标签：#Querying labeledfor row in session.query(U.label(name_label).all(): print (_label)这里的关键是label方法，它的意思是把User的name字段改个名字叫name_label，其相当于执行以下的SQL语句：SELECT AS name_labelFROM users6.除了给映射类字段起别名，我们还可以给映射类起个别名：#Querying with aliasedfrom sqlalchemy.orm import aliaseduser_

6、alias=aliased(User,name=user_alias)for row in session.query(user_alias,user_).all(): print row.user_alias这里要注意的是，我们引入了aliased函数，并且给User映射类起了个别名叫user_alias。然后我们就可以在query中使用这个别名了，它相当于是User对象。上面的代码相当于执行了以下SQL语句：SELECT user_alias.id AS user_alias_id, user_ AS user_alias_name,user_ali

7、as.fullname AS user_alias_fullname, user_alias.password AS user_alias_passwordFROM users AS user_alias7.由于query的查询返回的是一个元组，所以我们可以利用Python对数组类对象进行“分片”的操作，来限制返回的结果集范围：#Querying with limit and offsetfor u in session.query(User).order_by(User.id)1:3: print u这里我们对返回的结果加上了1:3，来限制返回的结果集范围。其执行相当于下面的SQL语句：SE

8、LECT users.id AS users_id, AS users_name,users.fullname AS users_fullname, users.password AS users_passwordFROM users ORDER BY users.id LIMIT ? OFFSET ?8.前面的查询都没有涉及到子查询，也就是SQL的where子句。在SQLAlchemy框架中，query的子查询可以通过filter_by来实现：#Qyering with filter byfor name, in session.query(U).fil

9、ter_by(fullname=Ed Jones): print name上面的查询相当于要找出User映射表中fullname为Ed Jones的数据，其相当于执行了下面的SQL语句：SELECT AS users_nameFROM usersWHERE users.fullname = ?9.除了filter_by之外，我们还可以使用filter方法，这种方式看起来更灵活，我们可以按照映射类对象的属性来指定查询条件：#Querying with filterfor name, in session.query(U).filter(User.fullna

10、me=Ed Jones): print name其参数与filter_by不同，这里使用了映射类名加属性字段的方式来指定查询子句参数，其相当于执行了下面的SQL语句：SELECT AS users_nameFROM usersWHERE users.fullname = ?如果我们想要嵌套多个查询条件，可以嵌套多个filter：#Querying with fully generativefor name, in session.query(U).filter(User.fullname=Ed Jones).filter(U=ed): pr

11、int name可以看到我们在filter方法后面又嵌套了一个filter，理论上可以嵌套无数个，其相当于执行了下面的SQL语句：SELECT AS users_nameFROM usersWHERE users.fullname = ? AND = ?完整的示例代码如下：from sqlalchemy.ext.declarative import declarative_basefrom sqlalchemy import Column,Integer,Stringfrom sqlalchemy import Sequencefrom sqlalc

12、hemy.orm import sessionmakerBase=declarative_base()from sqlalchemy import create_engineengine=create_engine(sqlite:/:memory:,echo=True)class User(Base): _tablename_=users id=Column(Integer,Sequence(user_id_seq),primary_key=True) name=Column(String(50) fullname=Column(String(50) password=Column(Strin

13、g(12) def _init_(self,name,fullname,password): =name self.fullname=fullname self.password=password def _repr_(self): return %(,self.fullname,self.password)Base.metadata.create_all(engine)Session=sessionmaker(bind=engine)session=Session()#Add on usered_user=User(ed,Ed Jones,edpasswo

14、rd)session.add(ed_user)#Retrive saved ed_userour_user=session.query(User).filter_by(name=ed).first()print our_user is:,our_userprint our_user id is:,our_user.idprint our_user is ed_user,our_user=ed_user#Add multiple objectsession.add_all( User(Wendy,Wendy Williams,foobar), User(Marry,Marry Contrary,

15、xxg527), User(Fred,Fred Flinstone,blah) )#Detective the dirty dataed_user.password=f8x902print Dirty data,session.dirty#Detective the new dataprint New data,session.new#Commit mit()#=Querying=#Querying user instancefor instance in session.query(User).order_by(User.id): print instance.

16、name,instance.fullname#Querying by ORM-instrumentfor name,fullname in session.query(U,User.fullname): print name,fullname#Querying as a Python objectfor row in session.query(User,U).all(): print row.User,#Querying labeledfor row in session.query(U.label(name_label).al

17、l(): print (_label)#Querying with aliasedfrom sqlalchemy.orm import aliaseduser_alias=aliased(User,name=user_alias)for row in session.query(user_alias,user_).all(): print row.user_alias#Querying with limit and offsetfor u in session.query(User).order_by(User.id)1:3: print u#Qyering with filter byfor name, in session.query(U).filter_by(fullname=Ed Jon