GitHub user dabla added a comment to the discussion: SAP HANA Provider Package

We actually use SAP Hana, but will ditch it very soon, with the SQL hooks and 
operators without any issues.  For the replace/upsert statements you only need 
to pass the 'replace_statement_format' hook parameter, and it should work.

```
transfer_table_task = GenericTransfer(
        task_id="transfer_table",
        source_conn_id="jdbc_hana_conn",
        destination_conn_id="jdbc_hana_conn",
        destination_hook_params={"replace_statement_format": "UPSERT {} {} 
VALUES ({}) WITH PRIMARY KEY"},
        insert_args={
            "commit_every": "5000",
            "executemany": True,
            "fast_executemany": True,
            "replace": True,
        },
        dag=dag,
        sql="SELECT * FROM STG_USERS",
        destination_table="USERS",
)
```

GitHub link: 
https://github.com/apache/airflow/discussions/44768#discussioncomment-11511070

----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]

Reply via email to