小编典典

在SQLalchemy中的左联接上过滤

sql

使用SQLalchemy,我想执行左外部联接并 过滤出联接表中确实有匹配项的行

我正在发送推送通知,所以我有一张Notification桌子。这意味着我还有一个ExpiredDeviceId表来存储不再有效的device_id。(我不想删除受影响的通知,因为用户以后可能会重新安装该应用,此时通知应根据Apple的文档恢复。)

CREATE TABLE Notification (device_id TEXT, time DATETIME);
CREATE TABLE ExpiredDeviceId (device_id TEXT PRIMARY KEY, expiration_time DATETIME);

注意:每个device_id可能有多个通知。 每个设备没有“设备”表。

因此,在执行操作时,SELECT FROM Notification我应该进行相应的过滤。我可以在SQL中执行此操作:

SELECT * FROM Notification 
    LEFT OUTER JOIN ExpiredDeviceId 
    ON Notification.device_id = ExpiredDeviceId.device_id
WHERE expiration_time IS NULL

但是如何在SQLalchemy中做到这一点?

sess.query(
    Notification, 
    ExpiredDeviceId
).outerjoin(
    (ExpiredDeviceId, Notification.device_id == ExpiredDeviceId.device_id)
).filter(
    ???
)

或者,我可以使用一个device_id NOT IN (SELECT device_id FROM ExpiredDeviceId)子句来执行此操作,但这似乎效率较低。


阅读 198

收藏
2021-04-22

共1个答案

小编典典

您是否需要在元组中拉回ExpiredDeviceId?如果您不这样做(即您只关心实时的device_ids),那么您就不能这样做:

sess.query(
    Notification
).outerjoin(
    (ExpiredDeviceId, Notification.device_id == ExpiredDeviceId.device_id)
).filter(
    ExpiredDeviceId.expiration_time == None
)
2021-04-22