如何解决SQLAlchemy执行Union操作时抛出的错误？

问题根源 #

你两次报错的核心原因完全一致：调用.all()方法后，query1和query2已经变成了Python列表（比如[('Joseph',),('Alan',),('Joseph',)]），而SQLAlchemy的union()方法需要接收的是未执行的Query查询对象，不是已经查询出来的结果集合。

正确代码写法 #

去掉.all()，直接对Query对象执行Union操作，最后再用.all()获取结果：

query1 = db.query(Employee.LastName).filter(Employee.Age == 30)
query2 = db.query(Employee.LastName).filter(Employee.Salary > 25000)
query3 = union(query1, query2).all()

或者也可以用Query对象的union()方法：

query1 = db.query(Employee.LastName).filter(Employee.Age == 30)
query2 = db.query(Employee.LastName).filter(Employee.Salary > 25000)
query3 = query1.union(query2).all()

额外说明 #

• union()会自动去重，如果你需要保留重复结果，改用union_all()即可
• 确保两个查询返回的字段数量、类型完全一致，否则也会抛出错误

内容的提问来源于stack exchange，提问作者Ra m