From 2624056719436cfb53c05c079edcb1587473d724 Mon Sep 17 00:00:00 2001 From: spicy-sauce Date: Wed, 29 Nov 2023 12:40:13 +0200 Subject: [PATCH] revert --- core/src/datayoga_core/blocks/relational/write/block.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/core/src/datayoga_core/blocks/relational/write/block.py b/core/src/datayoga_core/blocks/relational/write/block.py index 4266b79f..951a381e 100644 --- a/core/src/datayoga_core/blocks/relational/write/block.py +++ b/core/src/datayoga_core/blocks/relational/write/block.py @@ -179,10 +179,12 @@ def generate_upsert_stmt(self) -> Any: relational_utils.construct_table_reference(self.tbl), ", ".join([f"{sa.bindparam(column)}" for column in self.business_key_columns]), ", ".join([f"{column}" for column in self.business_key_columns]), - " AND ".join([f'target."{column}" = source."{column}"' for column in self.business_key_columns]), + " AND ".join([f"target.{column} = source.{column}" for column in self.business_key_columns]), + # " AND ".join([f'target."{column}" = source."{column}"' for column in self.business_key_columns]), ", ".join([f"{column}" for column in self.columns]), ", ".join([f"{sa.bindparam(column)}" for column in self.columns]), - ", ".join([f'target."{column}" = {sa.bindparam(column)}' for column in self.mapping_columns]) + ", ".join([f"target.{column} = {sa.bindparam(column)}" for column in self.mapping_columns]) + # ", ".join([f'target."{column}" = {sa.bindparam(column)}' for column in self.mapping_columns]) )) def execute(self, statement: Any, records: List[Dict[str, Any]]):