在SQLalchemy中过滤左连接

Question

使用SQLalchemy，我希望执行左外部联接，并过滤出联接表中确实匹配的行。

我正在发送推送通知，所以我有一个Notification表。这意味着我还有一个ExpiredDeviceId表来存储不再有效的设备id。（我不想删除受影响的通知，因为用户可能稍后重新安装应用程序，此时通知应该根据苹果的文档恢复。）

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

注意：每个设备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)子句来实现，但这似乎效率要低得多。

Answer 1

你需要把过期的设备以元组的形式拉回来吗？如果你不这样做（即你只关心实时设备ID），那你就不能这样做：

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