2016-08-04 59 views
0

我的目标是,我有两个表选择计数,每介绍一个用户,无论是“国家队”或“公司”之间的关系SQLAlchemy的 - 如何从联合查询

如果有任何行,说“用户名”表中的“管理员”,然后我想知道,否则,如果没有行,那么我也需要知道这一点。

我到目前为止的内容如下(UserTeamLink和UserCompanyLink)是Orm标签。

obj = UserTeamLink 
q1 = session.query(func.count(obj.type).label("cnt")).filter(obj.type == 'admin').filter(obj.user_id == id) ; str(q1) ; q1.all() 
obj = UserCompanyLink 
q2 = session.query(func.count(obj.type).label("cnt")).filter(obj.type == 'admin').filter(obj.user_id == id) ; str(q2) ; q2.all() 

my_union = q1.union_all(q2) 
query = select([func.sum(my_union.c.cnt).label("total_cnt")], from_obj=my_union) 
query.all() 

然而,行 “查询=选择([func.sum(my_union.c.cnt).label(” total_cnt “)],from_obj = my_union)” 符用:

AttributeError: 'BaseQuery' object has no attribute 'c' 

整个输出如下:

>>> obj = UserTeamLink 
>>> q1 = session.query(func.count(obj.type).label("cnt")).filter(obj.type == 'admin').filter(obj.user_id == id) ; str(q1) ; q1.all() 
'SELECT count(user_team.type) AS cnt \nFROM user_team \nWHERE user_team.type = :type_1 AND user_team.user_id = :user_id_1' 
[(0L,)] 
>>> obj = UserCompanyLink 
>>> q2 = session.query(func.count(obj.type).label("cnt")).filter(obj.type == 'admin').filter(obj.user_id == id) ; str(q2) ; q2.all() 
'SELECT count(user_company.type) AS cnt \nFROM user_company \nWHERE user_company.type = :type_1 AND user_company.user_id = :user_id_1' 
[(0L,)] 
>>> 
>>> my_union = q1.union_all(q2) 
>>> query = select([func.sum(my_union.c.cnt).label("total_cnt")], from_obj=my_union) 
Traceback (most recent call last): 
    File "<stdin>", line 1, in <module> 
AttributeError: 'BaseQuery' object has no attribute 'c' 

是有办法解决这一问题?

总之,我试图做的是从两个表中选择计数,然后联合到另一个表中,然后添加它们。

谢谢。

回答

0

您需要使用my_union作为子查询

my_union = q1.union_all(q2).subquery() 
query = select([func.sum(my_union.c.cnt).label("total_cnt")], from_obj=my_union) 
+0

谢谢!这实际上是我结束: ''' q_union = q1.union_all(q2) q_union_cnt = db.session.query(func.sum(q_union.subquery()。columns.cnt).label(“ total_cnt“)) admin_points = q_union_cnt.scalar() ''' –

0

这是我自己的问题解决了,我用了一个稍微不同的方法比@ RMN真实但我认为两者都应该工作:

q_union = q1.union_all(q2) 
    q_union_cnt = db.session.query(func.sum(q_union.subquery().columns.cnt).label("total_cnt")) 
    admin_points = q_union_cnt.scalar()