athena_rs 3.3.0

Database gateway API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

//! Example: insert a row via `/gateway/insert`.
use athena_rs::AthenaClient;
use athena_rs::client::backend::QueryResult;
use serde_json::json;
use std::error::Error;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let client: AthenaClient =
        AthenaClient::new("http://localhost:4052", "secret", "reporting").await?;

    let insert_result: QueryResult = client
        .insert("users")
        .payload(json!({
            "email": "new.user@example.com",
            "status": "active",
            "name": "New User"
        }))
        .execute()
        .await?;

    println!("Inserted rows: {}", insert_result.rows.len());
    Ok(())
}