Struct QueryBuilder 

pub struct QueryBuilder { /* private fields */ }

Query builder for database operations

Implementations

impl QueryBuilder

pub fn max_rows(self, max_rows: u64) -> Self

Set maximum number of rows to return

Arguments

• max_rows - Maximum number of rows

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let result = client.databases()
        .query("my-app-db")
        .max_rows(100)
        .execute("SELECT * FROM users")
        .await?;
     
    Ok(())
}

pub fn timeout(self, timeout_ms: u64) -> Self

Set query timeout

Arguments

• timeout_ms - Timeout in milliseconds

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let result = client.databases()
        .query("my-app-db")
        .timeout(30000) // 30 seconds
        .execute("SELECT * FROM large_table")
        .await?;
     
    Ok(())
}

pub fn include_meta(self) -> Self

Include execution metadata in the response

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let result = client.databases()
        .query("my-app-db")
        .include_meta()
        .execute("SELECT * FROM users")
        .await?;
     
    if let Some(execution_time) = result.meta.execution_time_ms {
        println!("Query executed in {}ms", execution_time);
    }
     
    Ok(())
}

pub async fn execute<S: AsRef<str>>(self, sql: S) -> Result<QueryResult>

Execute a SQL query

Arguments

• sql - SQL query string

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let result = client.databases()
        .query("my-app-db")
        .execute("SELECT name, email FROM users WHERE active = true")
        .await?;
     
    for row in result.data.rows {
        println!("User: {} - {}", row[0], row[1]);
    }
     
    Ok(())
}

pub async fn batch<S: AsRef<str>>( self, queries: Vec<S>, ) -> Result<Vec<QueryResult>>

Execute multiple queries in a batch

Arguments

• queries - Vector of SQL query strings

Examples

use zero_trust_sdk::{ZeroTrustClient, Config};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let config = Config::new("https://api.zerotrust.com")?
        .with_token("your-jwt-token");
    let client = ZeroTrustClient::new(config).await?;
     
    let queries = vec![
        "SELECT COUNT(*) FROM users",
        "SELECT COUNT(*) FROM products",
        "SELECT COUNT(*) FROM orders"
    ];
     
    let results = client.databases()
        .query("my-app-db")
        .batch(queries)
        .await?;
     
    for result in results {
        println!("Query returned {} rows", result.meta.row_count);
    }
     
    Ok(())
}

Trait Implementations

impl Debug for QueryBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.