Add SqlExecuteQueryOperator
#25259
Labels
area:providers
kind:task
A task that needs to be completed as part of a larger issue
provider:amazon-aws
AWS/Amazon - related issues
provider:common-sql
provider:google
Google (including GCP) related issues
provider:microsoft-azure
Azure-related issues
provider:snowflake
Issues related to Snowflake provider
Body
There has been previous attempt to add this operator in #10011
But now after #23971 is completed this should be much easier as
DbApiHook
has unified run method that works for all providers (with some configuration of parameters likesplit_statements
etc..)We can now explore again the option of
SqlExecuteQueryOperator
There are two approaches that I can think of:
BaseSqlExecuteQueryOperator
that all Sql related operators (PostgresOperator
,MySqlOperator
,SnowflakeOperator
) will inherit from.SqlExecuteQueryOperator
(just like Add SQLExecuteQueryOperator operator #10011 attempted to do)Personally I prefer to try the 2nd approach first (It should be similar to what we do in
SqlSensor
orSqlBranchOperator
the issue to resolve is how to handle the batch queries in some of the DBs and that is now should be possible thanks to #23971 inSqlSensor
/SqlBranchOperator
executing batch queries was never an issue as they are expected to execute only 1 SQL statement )FYI @potiuk @kazanzhy
Committer
The text was updated successfully, but these errors were encountered: