Skip to content

Commit

Permalink
fix: Ensure table name is quoted in merge statement (#231)
Browse files Browse the repository at this point in the history
Closes #230
  • Loading branch information
edgarrmondragon authored Jul 25, 2024
1 parent 156034a commit 03c428e
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions target_snowflake/connector.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,7 @@
from snowflake.sqlalchemy import URL
from snowflake.sqlalchemy.base import SnowflakeIdentifierPreparer
from snowflake.sqlalchemy.snowdialect import SnowflakeDialect
from sqlalchemy.sql import text
from sqlalchemy.sql import quoted_name, text

from target_snowflake.snowflake_types import NUMBER, TIMESTAMP_NTZ, VARIANT

Expand Down Expand Up @@ -388,7 +388,7 @@ def _get_merge_from_stage_statement( # noqa: ANN202
dedup = f"QUALIFY ROW_NUMBER() OVER (PARTITION BY {dedup_cols} ORDER BY SEQ8() DESC) = 1"
return (
text(
f"merge into {full_table_name} d using " # noqa: ISC003
f"merge into {quoted_name(full_table_name, quote=True)} d using " # noqa: ISC003
+ f"(select {json_casting_selects} from '@~/target-snowflake/{sync_id}'" # noqa: S608
+ f"(file_format => {file_format}) {dedup}) s "
+ f"on {join_expr} "
Expand Down

0 comments on commit 03c428e

Please sign in to comment.