2.5 KiB
2.5 KiB
title | list_title | description | menu | weight | related | list_code_example | |||||||||
---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
Write to CockroachDB | CockroachDB | Use [`sql.to()`](/flux/v0/stdlib/sql/to/) with the `postgres` driver to write data to CockroachDB. |
|
101 |
|
```js 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", ) ``` |
To write data to CockroachDB with Flux:
-
Import the
sql
package. -
Pipe-forward data into
sql.to()
and provide the following parameters:- driverName: postgres
- dataSourceName: See data source name
- table: Table to write to
- batchSize: Number of parameters or columns that can be queued within
each call to
Exec
(default is10000
)
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 data source name
The postgres
driver uses the following DSN syntax (also known as a connection string):
postgres://username:password@localhost:26257/cluster_name.defaultdb?sslmode=verify-full&sslrootcert=certs_dir/cc-ca.crt
{{% note %}}
The postgres
driver uses the Go pq
implementation
to interact with CockroachDB.
{{% /note %}}
Flux to CockroachDB data type conversion
sql.to()
converts Flux data types to PostgreSQL and CockroachDB data types.
Flux data type | CockroachDB data type |
---|---|
float | FLOAT |
int | BIGINT |
uint | BIGINT |
string | TEXT |
bool | BOOL |
time | TIMESTAMP |