写入到 CockroachDB

使用 Flux 将数据写入到 CockroachDB

1. 导入 sql 包。

2. 将数据管道传输到 sql.to() 中，并提供以下参数

   • driverName: postgres
   • dataSourceName: 请参阅 数据源名称
   • table: 要写入的表
   • batchSize: 可以在每次调用 Exec 中排队的参数或列的数量（默认为 10000）

import "sql"

data
    |> sql.to(
        driverName: "postgres",
        dataSourceName:
            "postgresql://username:password@localhost:26257/cluster_name.defaultdb?sslmode=verify-full&sslrootcert=certs_dir/cc-ca.crt",
        table: "example_table",
    )

CockroachDB 数据源名称

postgres 驱动程序使用以下 DSN 语法（也称为连接字符串）

postgres://username:password@localhost:26257/cluster_name.defaultdb?sslmode=verify-full&sslrootcert=certs_dir/cc-ca.crt

Flux 到 CockroachDB 数据类型转换

sql.to() 将 Flux 数据类型转换为 PostgreSQL 和 CockroachDB 数据类型。