查询 Snowflake

使用 Flux 查询 Snowflake:

1. 导入 sql 包。

2. 使用 sql.from() 并提供以下参数：

   • driverName: 雪花
   • dataSourceName: 查看数据源名称
   • query: 要执行的SQL查询

import "sql"

sql.from(
    driverName: "snowflake",
    dataSourceName: "user:password@account/db/exampleschema?warehouse=wh",
    query: "SELECT * FROM example_table",
)

雪花数据源名称

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

username[:password]@accountname/dbname/schemaname?param1=value1&paramN=valueN
username[:password]@accountname/dbname?param1=value1&paramN=valueN
username[:password]@hostname:port/dbname/schemaname?account=<your_account>&param1=value1&paramN=valueN

Snowflake到Flux数据类型转换

sql.from() 将Snowflake数据类型转换为Flux数据类型。