airflow.providers.exasol.hooks.exasol

Module Contents

Classes

ExasolHook

Interact with Exasol.
class airflow.providers.exasol.hooks.exasol.ExasolHook(*args, **kwargs)[source]

Bases: airflow.hooks.dbapi.DbApiHook

Interact with Exasol. You can specify the pyexasol compression, encryption, json_lib and client_name parameters in the extra field of your connection as {"compression": True, "json_lib": "rapidjson", etc}. See pyexasol reference for more details.

conn_name_attr = exasol_conn_id[source]
default_conn_name = exasol_default[source]
conn_type = exasol[source]
hook_name = Exasol[source]
supports_autocommit = True[source]
get_conn(self)[source]

Returns a connection object

get_pandas_df(self, sql, parameters=None, **kwargs)[source]

Executes the sql and returns a pandas dataframe

Parameters

  • sql (Union[str, list]) -- the sql statement to be executed (str) or a list of sql statements to execute

  • parameters (Optional[dict]) -- The parameters to render the SQL query with.

  • kwargs -- (optional) passed into pyexasol.ExaConnection.export_to_pandas method

get_records(self, sql, parameters=None)[source]

Executes the sql and returns a set of records.

Parameters

  • sql (Union[str, list]) -- the sql statement to be executed (str) or a list of sql statements to execute

  • parameters (Optional[dict]) -- The parameters to render the SQL query with.

get_first(self, sql, parameters=None)[source]

Executes the sql and returns the first resulting row.

Parameters

  • sql (Union[str, list]) -- the sql statement to be executed (str) or a list of sql statements to execute

  • parameters (Optional[dict]) -- The parameters to render the SQL query with.

export_to_file(self, filename, query_or_table, query_params=None, export_params=None)[source]

Exports data to a file.

Parameters

  • filename (str) -- Path to the file to which the data has to be exported

  • query_or_table (str) -- the sql statement to be executed or table name to export

  • query_params (Optional[Dict]) -- Query parameters passed to underlying export_to_file method of ExaConnection.

  • export_params (Optional[Dict]) -- Extra parameters passed to underlying export_to_file method of ExaConnection.

run(self, sql, autocommit=False, parameters=None, handler=None)[source]

Runs a command or a list of commands. Pass a list of sql statements to the sql parameter to get them to execute sequentially

Parameters

  • sql (Union[str, list]) -- the sql statement to be executed (str) or a list of sql statements to execute

  • autocommit (bool) -- What to set the connection's autocommit setting to before executing the query.

  • parameters (Optional[dict]) -- The parameters to render the SQL query with.

  • handler -- The result handler which is called with the result of each statement.

set_autocommit(self, conn, autocommit)[source]

Sets the autocommit flag on the connection

Parameters

  • conn -- Connection to set autocommit setting to.

  • autocommit (bool) -- The autocommit setting to set.

get_autocommit(self, conn)[source]

Get autocommit setting for the provided connection. Return True if autocommit is set. Return False if autocommit is not set or set to False or conn does not support autocommit.

Parameters

conn -- Connection to get autocommit setting from.

Returns

connection autocommit setting.

Return type

bool

Was this entry helpful?