ashb commented on a change in pull request #4584: [AIRFLOW-3741] Add extra
config to Oracle hook
URL: https://github.com/apache/airflow/pull/4584#discussion_r251025721
##########
File path: airflow/hooks/oracle_hook.py
##########
@@ -128,13 +181,33 @@ def bulk_insert_rows(self, table, rows,
target_fields=None, commit_every=5000):
A performant bulk insert for cx_Oracle
that uses prepared statements via `executemany()`.
For best performance, pass in `rows` as an iterator.
+
+ :param table: target Oracle table, use dot notation to target a
+ specific database
+ :type table: str
+ :param rows: the rows to insert into the table
+ :type rows: iterable of tuples
+ :param target_fields: the names of the columns to fill in the table,
default None.
+ If None, each rows should have some order as table columns name
+ :type target_fields: iterable of str Or None
+ :param commit_every: the maximum number of rows to insert in one
transaction
+ Default 5000. Set greater than 0. Set 1 to insert each row in each
transaction
+ :type commit_every: int
"""
+ if not rows:
+ raise ValueError("rows could not be null or None.")
conn = self.get_conn()
cursor = conn.cursor()
- values = ', '.join(':%s' % i for i in range(1, len(target_fields) + 1))
- prepared_stm = 'insert into {tablename} ({columns}) values
({values})'.format(
+ if target_fields:
Review comment:
Your PR is "Add extra config to Oracle hook" - that sounds like a different
issue. Please could you open that as a separate PR?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
