Merge pull request #368 from datayoga-io/367-relationalwrite-malforme…

…d-merge-statement-for-oracle-and-sqlserver-for-multiple-keys

`relational.write` - Malformed MERGE statement for Oracle and SQLServer for multiple keys #367

core/src/datayoga_core/blocks/relational/write/block.py

@@ -152,7 +152,7 @@ def generate_upsert_stmt(self) -> Any:
                 relational_utils.construct_table_reference(self.tbl, with_brackets=True),
                 ", ".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]),
                 ", ".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])
@@ -166,7 +166,7 @@ def generate_upsert_stmt(self) -> Any:
                     WHEN MATCHED THEN UPDATE SET %s
                     """ % (
                 relational_utils.construct_table_reference(self.tbl),
-                "AND ".join([f"target.{column} = :{column}" for column in self.business_key_columns]),
+                " AND ".join([f"target.{column} = :{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])