sqlAlchemy 모델의 조인 된 쿼리에서 sum 및 count를 사용하는 방법

Question

SQLAlchemy를 ORM으로 사용하는 작업용 Flask 응용 프로그램에서 나타내는 데 필요한 SQL을 작업하고 있습니다. 조인 등을 나타낼 수는 있지만 합계, 개수 및 다른 특정 선택 요소 인 u.firstname || ' ' || u.lastname을 묶는 데는 아무런 변화가 없습니다.

SQL

select 
    u.firstname || ' ' || u.lastname SELLER, 
    count(i.id) UNIQUE_ITEMS, 
    sum(i.qty) ITEMS_TOTAL, 
    sum(i.qty * p.price) ORDER_AMOUNT 
from 
    orders o 
    INNER JOIN order_items i 
    on o.id = i.order_id 
    and o.campaign_id = 133 
    INNER JOIN products p 
     ON i.product_id = p.id 
    INNER JOIN users u 
     ON o.user_id = u.id 
GROUP BY u.id 
ORDER BY sum(i.qty) DESC, sum(i.qty * p.price) DESC; 

및 작업 플라스크 구현 : 나는 group_by(User.id)를 추가하면 그것뿐만 아니라 내가 Order에서 다른 모든 요소에 배치되지 않았 음을 불평

orders = Order.query.filter_by(campaign_id=campaign_id). 
    join(OrderItem). 
    join(Product). 
    join(User). 
    order_by(OrderItem.qty.desc()) 

.

는 경우 기능은 I 당신은 Order를 조회하려는 포스트 그레스 9.5

Answer 1

에 대해 실행하고있어,이 문제입니다,하지만 당신은 당신의 원시 SQL에서 쿼리하는 게 아니에요. 무슨 일이 일어나고 있는지를 보여주는 예제에 모두 함께 넣어하기

query = session.query(
    (User.first_name + ' ' + User.last_name).label('seller'), 
    sa.func.count(OrderItem.id).label('unique_items'), 
    sa.func.sum(OrderItem.qty).label('items_total'), 
    sa.func.sum(OrderItem.qty * Product.price).label('order_amount'), 
).join(OrderItem).join(Product).group_by(User.id).order_by('items_total', 
                  'order_amount') 

: 당신은 같은 뭔가가 필요

import sqlalchemy as sa 
from sqlalchemy.ext.declarative import declarative_base 
from decimal import Decimal 

engine = sa.create_engine('sqlite:///:memory:') 
Base = declarative_base() 
session = sa.orm.sessionmaker(bind=engine)() 

class OrderItem(Base): 
    __tablename__ = 'order' 

    id = sa.Column('id', sa.Integer, primary_key=True) 
    product_id = sa.Column('product_id', sa.Integer, sa.ForeignKey('product.id')) 
    user_id = sa.Column('user_id', sa.Integer, sa.ForeignKey('user.id')) 
    qty = sa.Column('qty', sa.Integer) 

class Product(Base): 
    __tablename__ = 'product' 

    id = sa.Column('id', sa.Integer, primary_key=True) 
    price = sa.Column('price', sa.Numeric(14,2)) 

class User(Base): 
    __tablename__ = 'user' 

    id = sa.Column('id', sa.Integer, primary_key=True) 
    first_name = sa.Column('first_name', sa.Text) 
    last_name = sa.Column('last_name', sa.Text) 

Base.metadata.create_all(engine) 

engine.echo = True 

session.add(User(id=42, first_name='John', last_name='Cleese')) 
session.add(User(id=13, first_name='Sir', last_name='Robin')) 
session.add(Product(id=1, price=Decimal('2.10'))) 
session.add(OrderItem(product_id=1, user_id=42, qty=9)) 
session.add(OrderItem(product_id=1, user_id=42, qty=2)) 
session.add(OrderItem(product_id=1, user_id=13, qty=2)) 
session.add(OrderItem(product_id=1, user_id=13, qty=3)) 
session.add(OrderItem(product_id=1, user_id=13, qty=20)) 
session.commit() 

query = session.query(
    (User.first_name + ' ' + User.last_name).label('seller'), 
    sa.func.count(OrderItem.id).label('unique_items'), 
    sa.func.sum(OrderItem.qty).label('items_total'), 
    sa.func.sum(OrderItem.qty * Product.price).label('order_amount'), 
).join(OrderItem).join(Product).group_by(User.id).order_by('items_total', 
                  'order_amount') 


print('{0:=^40}\n{1:^40}\n{0:=^40}'.format('=', 'Query')) 
results = [row for row in session.execute(query)] 
print('{0:=^40}\n{1:^40}\n{0:=^40}'.format('=', 'Results')) 
for row in results: 
    print(dict(row))