在SQLalchemy中的左连接进行过滤

发布时间：2020-12-12 16:33:06 所属栏目：MsSql教程来源：网络整理

导读：使用SQLalchemy我想执行一个左外连接,并过滤出在连接的表中有匹配的行. 我发送推送通知,所以我有一个通知表.这意味着我也有一个ExpiredDeviceId表来存储不再有效的device_ids. (我不想只是删除受影响的通知,因为用户以后可能会重新安装该应用程序,此时应根据A

使用SQLalchemy我想执行一个左外连接,并过滤出在连接的表中有匹配的行.

我发送推送通知,所以我有一个通知表.这意味着我也有一个ExpiredDeviceId表来存储不再有效的device_ids. (我不想只是删除受影响的通知,因为用户以后可能会重新安装该应用程序,此时应根据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 == NULL

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

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

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

解决方法

你需要在元组中拉回ExpiredDeviceId吗？如果你没有(即你只是关心live device_ids),那么你不能这样做：

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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!