sql.to() 函数

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

函数类型签名

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

参数

驱动程序名称

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

支持的驱动程序:

• 大查询
• hdb
• mysql
• 邮政服务
• 雪花
• sqlite3 (不适用于 InfluxDB OSS 或 InfluxDB Cloud)
• sqlserver
• 维尔蒂卡，眩晕

数据源名称

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

表格

(必填) 目标表。

批处理大小

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

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

表格

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