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