Mercurial > libervia-pubsub

diff src/pgsql_storage.py @ 390:fba96e95e329
storage (pgsql): fixed filtering in getItemsPublishers
author: Goffi <goffi@goffi.org>
date: Fri, 15 Feb 2019 18:04:05 +0100
parents: aa3a464df605
children: 728b08c0d000
--- a/src/pgsql_storage.py	Fri Feb 15 16:31:38 2019 +0100
+++ b/src/pgsql_storage.py	Fri Feb 15 18:04:05 2019 +0100
@@ -1264,8 +1264,8 @@
         ret = {}
         for itemIdentifier in itemIdentifiers:
             cursor.execute("""SELECT publisher FROM items
-                              WHERE item=%s""",
-                            (itemIdentifier,))
+                              WHERE node_id=%s AND item=%s""",
+                            (self.nodeDbId, itemIdentifier,))
             result = cursor.fetchone()
             if result:
                 ret[itemIdentifier] = jid.JID(result[0])