MySQLDest

class

class MySQLDest(
    tables: MySQLTableNamesSpec,
    if_table_exists: IfTableExistsSpec = 'append',
    transactional: bool = True,
    dest_cfg: DestCfgSpec | None = None,
)

Bases: Dest

Categories: destination

MySQL destination for @subscriber -- one target table per slot.

Parameters

parameter

tablesMySQLTableNamesSpec (list[str])

Target table names, qualified or bare (see MySQLTableNameSpec); one input slot per table, in order.

parameter

if_table_existsIfTableExistsSpec (Literal['append', 'replace'])

"append" (default) adds rows; "replace" truncates the table before inserting.

parameter

transactionalbool

When True (default), wrap every table write in one transactional session.

parameter

dest_cfgDestCfgSpec | None (Mapping[Literal['mysql.logging_level', 'tabsdata.sql.write_engine', 'tabsdata.sql.chunk_size'], Any] | None)

Optional config mapping over the allowed keys only (mysql.logging_level, tabsdata.sql.write_engine, tabsdata.sql.chunk_size).