SQL client and result parser for Kinetica’s HTTP API

Statements are sent to /execute/sql over the same Kinetica connection used by the rest of the API, so they share its authentication, TLS and HA failover. For the PostgreSQL wire protocol, see the sqlx_support module (feature sqlx).

Overview

SqlClient - Executes SQL, with paging support for large result sets
SqlResult / Row - Wrap RawExecuteSqlResponse with convenient parsing methods
SqlHints - Kinetica-specific execution options and inline hints
BatchingSqlClient - Routes INSERT statements through BulkInserter

Quick Start

use gpudb_api::{Kinetica, KineticaOptions, SqlClient};
use std::sync::Arc;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let options = KineticaOptions::new();
    let kinetica = Arc::new(
        Kinetica::new(vec!["http://localhost:9191".to_string()], options).await?
    );

    let client = SqlClient::new(kinetica);
    let mut result = client
        .execute("SELECT id, name FROM my_table WHERE value > 100 ORDER BY id LIMIT 10")
        .await?;

    for row in result.rows()? {
        let id: i64 = row.get("id")?;
        let name: String = row.get("name")?;
        println!("id={}, name={}", id, name);
    }

    Ok(())
}

Result Parsing

use gpudb_api::SqlResult;

// Get total count
let total = result.total_records();

// Check if there are more records
if result.has_more() {
    println!("More records available");
}

// Get a single scalar value
let count: i64 = result.scalar()?;

// Get a column as a vector
let names: Vec<String> = result.column("name")?;

// Iterate over rows
for row in result.rows()? {
    let id: i64 = row.get("id")?;
    let name: String = row.get("name")?;
    // Process row...
}

// Deserialize into structs
#[derive(serde::Deserialize)]
struct User { id: i64, name: String }
let users: Vec<User> = result.deserialize()?;