使用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
)
