【发布时间】:2017-04-24 08:34:10
【问题描述】:
我正在尝试将这个 sql 查询构造成 sqlalchemy:
select distinct
processed_by_user_uuid,
sum(case when audited_result_uuid = PASSED_RESULT_UUID then 1 else 0 end) as "passed",
sum(case when audited_result_uuid <> PASSED_RESULT_UUID then 1 else 0 end) as "failed",
count(distinct processed_using) as "total audits"
from audit
where
audited_at is not null
and processed_at > [start_time]
and processed_at < [end_time]
group by 1
我的尝试:
query = Session.query(audit_table).with_entities(
audit_table.c.processed_by_user_uuid,
func.sum(
case([audit_table.c.audited_result_uuid == PASSED_RESULT_UUID, 1], else_=0)
).label('passed'),
func.sum(
case([audit_table.c.audited_result_uuid != PASSED_RESULT_UUID, 1], else_=0)
).label('failed'),
func.count(distinct(audit_table.c.processed_using)).label('total audits')
).filter(
audit_table.c.audited_at is not None,
audit_table.c.processed_at > start_time,
audit_table.c.processed_at < end_time
).group_by(
1
)
当我尝试这个时,我得到了异常:
NotImplementedError: Operator 'getitem' is not supported on this expression
通过一些挖掘,它对这条线不满意:
func.sum(
case([audit_table.c.audited_result_uuid == PASSED_RESULT_UUID, 1], else_=0)
).label('passed')
【问题讨论】:
标签: python postgresql sqlalchemy