Mercurial > libervia-pubsub

comparison src/pgsql_storage.py @ 390:fba96e95e329

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
storage (pgsql): fixed filtering in getItemsPublishers
author Goffi <goffi@goffi.org>
date Fri, 15 Feb 2019 18:04:05 +0100
parents aa3a464df605
children 728b08c0d000
comparison
equal deleted inserted replaced
389:66128656f76c 390:fba96e95e329
1262 def _getItemsPublishers(self, cursor, itemIdentifiers): 1262 def _getItemsPublishers(self, cursor, itemIdentifiers):
1263 self._checkNodeExists(cursor) 1263 self._checkNodeExists(cursor)
1264 ret = {} 1264 ret = {}
1265 for itemIdentifier in itemIdentifiers: 1265 for itemIdentifier in itemIdentifiers:
1266 cursor.execute("""SELECT publisher FROM items 1266 cursor.execute("""SELECT publisher FROM items
1267 WHERE item=%s""", 1267 WHERE node_id=%s AND item=%s""",
1268 (itemIdentifier,)) 1268 (self.nodeDbId, itemIdentifier,))
1269 result = cursor.fetchone() 1269 result = cursor.fetchone()
1270 if result: 1270 if result:
1271 ret[itemIdentifier] = jid.JID(result[0]) 1271 ret[itemIdentifier] = jid.JID(result[0])
1272 return ret 1272 return ret
1273 1273