将 group by 子句动态添加到 sql alchemy

Question

我有一个基本查询（带有要查询的必要列），我正在尝试使用 SQL Alchemy ORM 将 join 和 group by 子句动态添加到基本查询 我已经在这里找到了添加连接的操作 SQLAlchemy - How to add dynamic left joins to a query?

我从中创建了一个函数-

    add_join_conditions(query,join_conditions):
      for condition in join_conditions:
        query = query.join(*condition)

谁能帮我创建一个类似的函数 - add_group_by_columns(query,group_by_columns)

Answer 1

一个简单的解决方案是这样的

 def add_group_by_columns(query, group_by_columns):
   return query.group_by(*group_by_columns)

你可以这样使用它

q = db.session.query(Order.product_id, Order.seller_id, func.count(Order.id)).filter(Order.user_id==12)

q1 = add_group_by_columns(q, [Order.product_category_id, Order.seller_id])

q1.all()