bi_etl.bulk_loaders.postgresql_copy module

class bi_etl.bulk_loaders.postgresql_copy.PostgreSQLCopy(config: PostgreSQLBulkLoaderConfig)

Bases: BulkLoader

__init__(config: PostgreSQLBulkLoaderConfig)

apply_updates(table_object: Table, update_rows: Sequence[Row])

NOT TESTED !

load_from_files(local_files: List[str | Path], table_object: Table, table_to_load: str = None, perform_rename: bool = False, file_compression: str = '', options: str = '', analyze_compression: str = None) → int

load_from_iterable(iterable: Iterable, table_object: Table, table_to_load: str = None, perform_rename: bool = False, progress_frequency: int = 10, analyze_compression: str = None, parent_task: ETLTask | None = None) → int

load_from_iterator(iterator: Iterator, table_object: Table, table_to_load: str = None, perform_rename: bool = False, progress_frequency: int = 10, analyze_compression: str = None, parent_task: ETLTask | None = None) → int

load_table_from_cache(table_object: Table, table_to_load: str = None, perform_rename: bool = False, progress_frequency: int = 10, analyze_compression: str = None) → int

property needs_all_columns

rename_table(temp_table_name: str, table_object: Table)