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 数据库接口

Download history • Rust 包仓库 317/week @ 2024-05-03 • Rust 包仓库 371/week @ 2024-05-10 • Rust 包仓库 584/week @ 2024-05-17 • Rust 包仓库 1009/week @ 2024-05-24 • Rust 包仓库 859/week @ 2024-05-31 • Rust 包仓库 744/week @ 2024-06-07 • Rust 包仓库 616/week @ 2024-06-14 • Rust 包仓库 832/week @ 2024-06-21 • Rust 包仓库 384/week @ 2024-06-28 • Rust 包仓库 460/week @ 2024-07-05 • Rust 包仓库 430/week @ 2024-07-12 • Rust 包仓库 336/week @ 2024-07-19 • Rust 包仓库 727/week @ 2024-07-26 • Rust 包仓库 2215/week @ 2024-08-02 • Rust 包仓库 1108/week @ 2024-08-09 • Rust 包仓库 768/week @ 2024-08-16 • Rust 包仓库

每月下载量 4,912

MIT 许可证

38KB
903 代码行

Snowflake Connector for Rust

test Crates.io

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