solidb-client 0.7.0

Official Rust client for SoliDB database with HTTP and TCP transport
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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82

use solidb_client::{SoliDBClientBuilder, HttpClient};
use std::time::Instant;

#[tokio::main]
async fn main() -> Result<(), solidb_client::DriverError> {
    let http_url = "http://127.0.0.1:6745";
    let tcp_addr = "127.0.0.1:6745";
    let iterations = 1000;

    println!("========================================");
    println!("SoliDB Rust Client Benchmark");
    println!("========================================");

    // Test HTTP Client
    println!("\n--- HTTP CLIENT BENCHMARK ---");

    let mut http_client = HttpClient::new(http_url);
    http_client.login("_system", "admin", "admin").await?;
    http_client.create_database("bench_db").await.ok();
    http_client.set_database("bench_db");
    http_client.create_collection("bench_collection").await.ok();

    println!("Inserting {} documents...", iterations);
    let start = Instant::now();
    for i in 0..iterations {
        let doc = serde_json::json!({
            "id": i,
            "data": format!("benchmark data {}", i),
            "timestamp": chrono::Utc::now().timestamp_millis()
        });
        http_client.insert("bench_collection", doc, Some(&format!("http_{}", i))).await?;
    }
    let duration = start.elapsed();
    let ops = iterations as f64 / duration.as_secs_f64();
    println!("HTTP INSERT: {:.2} ops/sec", ops);

    println!("Reading {} documents...", iterations);
    let start = Instant::now();
    for i in 0..iterations {
        let _ = http_client.get("bench_collection", &format!("http_{}", i)).await?;
    }
    let duration = start.elapsed();
    let ops = iterations as f64 / duration.as_secs_f64();
    println!("HTTP READ: {:.2} ops/sec", ops);

    // Test TCP Client
    println!("\n--- TCP CLIENT BENCHMARK ---");

    let mut tcp_client = SoliDBClientBuilder::new(tcp_addr)
        .auth("_system", "admin", "admin")
        .build()
        .await?;

    println!("Inserting {} documents...", iterations);
    let start = Instant::now();
    for i in 0..iterations {
        let doc = serde_json::json!({
            "id": i,
            "data": format!("benchmark data {}", i),
            "timestamp": chrono::Utc::now().timestamp_millis()
        });
        tcp_client.insert("bench_db", "bench_collection", Some(&format!("tcp_{}", i)), doc).await?;
    }
    let duration = start.elapsed();
    let ops = iterations as f64 / duration.as_secs_f64();
    println!("TCP INSERT: {:.2} ops/sec", ops);

    println!("Reading {} documents...", iterations);
    let start = Instant::now();
    for i in 0..iterations {
        let _ = tcp_client.get("bench_db", "bench_collection", &format!("tcp_{}", i)).await?;
    }
    let duration = start.elapsed();
    let ops = iterations as f64 / duration.as_secs_f64();
    println!("TCP READ: {:.2} ops/sec", ops);

    println!("\n========================================");
    println!("Benchmark complete!");
    println!("========================================");

    Ok(())
}