airflow.providers.oracle.hooks.oracle

Module Contents

class airflow.providers.oracle.hooks.oracle.OracleHook[source]

Bases: airflow.hooks.dbapi.DbApiHook

Interact with Oracle SQL.

conn_name_attr = oracle_conn_id[source]
default_conn_name = oracle_default[source]
conn_type = oracle[source]
hook_name = Oracle[source]
supports_autocommit = False[source]
get_conn(self)[source]

Returns a oracle connection object Optional parameters for using a custom DSN connection (instead of using a server alias from tnsnames.ora) The dsn (data source name) is the TNS entry (from the Oracle names server or tnsnames.ora file) or is a string like the one returned from makedsn().

Parameters

  • dsn -- the host address for the Oracle server

  • service_name -- the db_unique_name of the database that you are connecting to (CONNECT_DATA part of TNS)

You can set these parameters in the extra fields of your connection as in { "dsn":"some.host.address" , "service_name":"some.service.name" } see more param detail in cx_Oracle.connect

insert_rows(self, table: str, rows: List[tuple], target_fields=None, commit_every: int = 1000, replace: Optional[bool] = False, **kwargs)[source]

A generic way to insert a set of tuples into a table, the whole set of inserts is treated as one transaction Changes from standard DbApiHook implementation:

  • Oracle SQL queries in cx_Oracle can not be terminated with a semicolon (;)

  • Replace NaN values with NULL using numpy.nan_to_num (not using is_nan() because of input types error for strings)

  • Coerce datetime cells to Oracle DATETIME format during insert

Parameters

  • table (str) -- target Oracle table, use dot notation to target a specific database

  • rows (iterable of tuples) -- the rows to insert into the table

  • target_fields (iterable of str) -- the names of the columns to fill in the table

  • commit_every (int) -- the maximum number of rows to insert in one transaction Default 1000, Set greater than 0. Set 1 to insert each row in each single transaction

  • replace (bool) -- Whether to replace instead of insert

bulk_insert_rows(self, table: str, rows: List[tuple], target_fields: Optional[List[str]] = None, commit_every: int = 5000)[source]

A performant bulk insert for cx_Oracle that uses prepared statements via executemany(). For best performance, pass in rows as an iterator.

Parameters

  • table (str) -- target Oracle table, use dot notation to target a specific database

  • rows (iterable of tuples) -- the rows to insert into the table

  • target_fields (iterable of str Or None) -- the names of the columns to fill in the table, default None. If None, each rows should have some order as table columns name

  • commit_every (int) -- 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

Was this entry helpful?