如何在SQLAlchemy中加入两个查询？

在这个例子中，我使用样本MySQL classicmodels database。如何在SQLAlchemy中加入两个查询？

所以，我有两个查询：

products = session.query(Products) 
orderdetails = session.query(OrderDetails)

假设在此之后，我不能做任何更多的数据库查询，我只能从这点上加入这两个查询。

我想要做的外连接上他们能够做这样的事情：

for orderdetail, product in query: 
    print product.productName, product.productCode, orderdetails.quantityOrdered

但是，每当我在这做外连接，我只能似乎得到左连接。

query = orderdetails.outerjoin(Products)

这样的代码仅产生ORDERDETAILS列：

for q in query: 
    # Only gives orderdetails columns 
    print q

而且做这样的事情：

for orderdetails, product in query: 
    print orderdetails, product

给我一个错误：TypeError: 'OrderDetails' object is not iterable。

我在做什么错？我只是想要Products表中的列。

编辑：

感谢@ univerio的回答，我找到了我的解决方案。我真正的目标是对两个现有查询进行连接，然后对它们执行SUM和COUNT操作。

SQLAlchemy基本上只是将查询对象转换为SQL语句。 with_entities函数只是将SELECT表达式更改为传递给它的任何内容。这是我更新的解决方案，其中包括开箱和读取加入：

for productCode, numOrders, quantityOrdered in orderdetails.with_entities(
     OrderDetails.productCode, 
     func.count(OrderDetails.productCode), 
     func.sum(OrderDetails.quantityOrdered)).group_by(OrderDetails.productCode): 
    print productCode, numOrders, quantityOrdered

来源

2016-04-04 joshualan

您可以with_entities()覆盖实体列表：

orderdetails.outerjoin(Products).with_entities(OrderDetails, Products)

来源

2016-04-04 15:53:33 univerio

是的，我知道有一种方法，通过session.query做但是有没有办法通过两个会话查询来完成？ – joshualan

@joshualan我不知道我明白你为什么需要这样做。除非您遍历查询，否则不会执行SQL。或者你想加入两个子查询？或者，您想重新使用现有的查询，因为您已经有过滤器了吗？ – univerio

是的，我只是想重新使用这些现有的查询。看起来好像没有办法。 – joshualan

如何在SQLAlchemy中加入两个查询？

回答

相关问题