utils.rcclient.datasources.mysql

Module Contents

Classes

MySQL

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)