Skip to main content

SQL Insert

Inserts rows into a SQL database.

FieldTypeDefaultDescription
Driverstring—Database driver
DSNstring—Connection string
Tablestring—Target table
Columnsarray—Column names
Args MappingBloblang—Maps message fields to column values
Suffixstring—Optional SQL suffix (e.g., ON CONFLICT DO NOTHING)
Max In Flightinteger64Maximum parallel inserts
Batchingobject—Batching policy

Supported drivers: mysql, postgres, clickhouse, mssql, sqlite, oracle, snowflake, trino, cosmos, spanner.