fusetools.db_etl_tools.Teradata

class fusetools.db_etl_tools.Teradata

Bases: object

Generic functions for Teradata SQL queries and ETL.

Methods

insert_td	Executes an INSERT INTO statement for a given Pandas DataFrame.
make_tbl_complete_td	Executes a series of SQL statements to CREATE and INSERT into a table from a Pandas DataFrame.
make_tbl_td	Creates SQL to run a CREATE TABLE statement based on a Pandas DataFrame.
run_query_td	Executes a SQL statement with a Teradata database connection.

classmethod insert_td(tbl, df, conn, batch_size=False, date_cols=False)

Executes an INSERT INTO statement for a given Pandas DataFrame.

Parameters

• tbl – Teradata table name.

• df – Pandas DataFrame.

• conn – Teradata connection object.

• batch_size – Records to load per batch.

• date_cols – A list of date columns to convert to Pandas datetime.

Returns

Printed SQL statements for each step.

classmethod make_tbl_complete_td(df, tbl_name, conn, batch_size=False)

Executes a series of SQL statements to CREATE and INSERT into a table from a Pandas DataFrame.

Parameters

• df – Pandas DataFrame to create a table from.

• tbl_name – Name of table to be created.

• conn – Teradata database connection object.

• batch_size – Records to load per batch.

Returns

Elapsed time to execute query.

classmethod make_tbl_td(df, tbl_name)

Creates SQL to run a CREATE TABLE statement based on a Pandas DataFrame.

Parameters

• df – Pandas DataFrame.

• tbl_name – Teradata table name.

Returns

CREATE TABLE SQL statement.

classmethod run_query_td(conn, sql)

Executes a SQL statement with a Teradata database connection.

Parameters

• conn – Teradata database connection object.

• sql – SQL statement to execute.

Returns

Elapsed time to execute query.