`utils.rcclient.datasources.mysql`

Module Contents

Classes

class utils.rcclient.datasources.mysql.MySQL(options)

Bases: utils.rcclient.datasources.conn.Conn

property connection

__connection

get_connection()

validate_builder_options()

validate_writer_options()

validate_source_options()

is_hive_connection()

list_files(local_dir)

get_tables()

__save_key_file(key_contents)

__delete_key_file(key_path)

__does_connection_has_ssh_tunnel(connect_string_original)

__get_ssh_tunnel(connect_string_original)

get_table_metadata()

get_data(query=None)

_get_data(query)

build(entityFolder)

__write_df_via_ssh_tunnel(df, table_name, if_exists, connect_string_original)

write_data(df, table_name, options)

write(entity_input_file_path, entity_input_schema_path)