qail-pg 0.26.7

Fastest async PostgreSQL driver - AST to wire protocol, optional io_uring on Linux
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

//! LRU Cache Stress Test

use qail_core::prelude::*;
use qail_pg::driver::PgDriver;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🧪 LRU Cache Stress Test (limit: 100)");
    println!("=====================================\n");

    let mut driver = PgDriver::connect("127.0.0.1", 5432, "orion", "qail_test_migration").await?;

    // Create test table
    driver
        .execute_raw("DROP TABLE IF EXISTS cache_test")
        .await?;
    driver
        .execute_raw("CREATE TABLE cache_test (id INT)")
        .await?;
    driver
        .execute_raw("INSERT INTO cache_test VALUES (1)")
        .await?;

    let (size, cap) = driver.cache_stats();
    println!("Initial: {}/{}", size, cap);

    // 200 unique AST queries (different LIMIT values = different SQL)
    println!("\n📊 200 unique queries (should evict at 100)...");
    for i in 1..=200 {
        let query = Qail::get("cache_test").column("id").limit(i as i64);
        let _ = driver.fetch_all(&query).await?;

        if i % 50 == 0 {
            let (size, cap) = driver.cache_stats();
            println!("  Query {}: cache {}/{}", i, size, cap);
        }
    }

    let (final_size, cap) = driver.cache_stats();
    println!("\nFinal: {}/{}", final_size, cap);

    if final_size == cap {
        println!("✅ LRU at capacity - eviction working!");
    }

    driver.clear_cache();
    let (size, _) = driver.cache_stats();
    println!("\nAfter clear_cache(): {} ✅", size);

    driver.execute_raw("DROP TABLE cache_test").await?;
    Ok(())
}