From e7fd1b622c1bde4b421eb9637a8561c2ce7e5b9e Mon Sep 17 00:00:00 2001 From: "dunhong.tang" Date: Tue, 1 Nov 2022 12:15:56 +0800 Subject: [PATCH] #remove unused searching for doc_id --- pgsync/sync.py | 38 -------------------------------------- 1 file changed, 38 deletions(-) diff --git a/pgsync/sync.py b/pgsync/sync.py index 791630c2..8b762fa6 100644 --- a/pgsync/sync.py +++ b/pgsync/sync.py @@ -595,44 +595,6 @@ def _update_op( where[key] = params[i] _filters.append(where) - # also handle foreign_keys - if node.parent: - fields = defaultdict(list) - - try: - foreign_keys = self.query_builder.get_foreign_keys( - node.parent, - node, - ) - except ForeignKeyError: - foreign_keys = self.query_builder._get_foreign_keys( - node.parent, - node, - ) - - foreign_values = [ - payload.new.get(k) for k in foreign_keys[node.name] - ] - - for key in [key.name for key in node.primary_keys]: - for value in foreign_values: - if value: - fields[key].append(value) - # TODO: we should combine this with the filter above - # so we only hit Elasticsearch once - for doc_id in self.es._search( - self.index, - node.parent.table, - fields, - ): - where: dict = {} - params = doc_id.split(PRIMARY_KEY_DELIMITER) - for i, key in enumerate( - self.tree.root.model.primary_keys - ): - where[key] = params[i] - _filters.append(where) - if _filters: filters[self.tree.root.table].extend(_filters)