13 个版本 (5 个破坏性更新)
0.6.0 | 2024年8月15日 |
---|---|
0.5.1 | 2024年6月13日 |
0.4.0 | 2024年5月30日 |
0.3.3 | 2024年5月25日 |
0.1.0 | 2023年12月4日 |
#653 in 数据库接口
每月下载量 4,912
38KB
903 代码行
Snowflake Connector for Rust
Snowflake的Rust客户端,允许您连接到Snowflake并运行查询。
let client = SnowflakeClient::new(
"USERNAME",
SnowflakeAuthMethod::Password("PASSWORD".to_string()),
SnowflakeClientConfig {
account: "ACCOUNT".to_string(),
role: Some("ROLE".to_string()),
warehouse: Some("WAREHOUSE".to_string()),
database: Some("DATABASE".to_string()),
schema: Some("SCHEMA".to_string()),
timeout: Some(std::time::Duration::from_secs(30)),
},
)?;
let session = client.create_session().await?;
let query = "CREATE TEMPORARY TABLE example (id NUMBER, value STRING)";
session.query(query).await?;
let query = "INSERT INTO example (id, value) VALUES (1, 'hello'), (2, 'world')";
session.query(query).await?;
let query = "SELECT * FROM example ORDER BY id";
let rows = session.query(query).await?;
assert_eq!(rows.len(), 2);
assert_eq!(rows[0].get::<i64>("ID")?, 1);
assert_eq!(rows[0].get::<String>("VALUE")?, "hello");
依赖项
~11–25MB
~401K SLoC