sql.to() 函数

sql.to() 将数据写入 SQL 数据库。

函数类型签名

(
    <-tables: stream[A],
    dataSourceName: string,
    driverName: string,
    table: string,
    ?batchSize: int,
) => stream[A]

参数

driverName

(必需) 用于连接到 SQL 数据库的驱动程序。

支持的驱动程序:

• bigquery
• hdb
• mysql
• postgres
• snowflake
• sqlite3 (不适用于 InfluxDB OSS 或 InfluxDB Cloud)
• sqlserver
• vertica, vertigo

dataSourceName

(必需) 用于连接到 SQL 数据库的数据源名称 (DNS) 或连接字符串。

table

(必需) 目标表。

batchSize

每次调用 Exec 时可以排队的参数或列的数量。默认为 10000。

如果写入 SQLite 数据库，请将 batchSize 设置为 999 或更小。

tables

输入数据。默认为管道转发数据 (<-)。