Function test_insert_performance_comparison

tests/insert_performance_benchmark.rs:7–122

()

#[tokio::test] 
async fn test_insert_performance_comparison() {
    println!("\n=== INSERT PERFORMANCE COMPARISON ===\n");
    
    let iterations = 1000;
    
    // Test 1: Direct SQLite (baseline)
    println!("1. Direct SQLite (baseline):");
    let conn = Connection::open_in_memory().expect("Failed to create SQLite connection");
    conn.execute("CREATE TABLE baseline_test (id INTEGER PRIMARY KEY, name TEXT, value INTEGER)", [])
        .expect("Failed to create table");
    
    let start = Instant::now();
    for i in 0..iterations {
        conn.execute(
            "INSERT INTO baseline_test (name, value) VALUES (?1, ?2)", 
            rusqlite::params![format!("test{}", i), i]
        ).expect("Failed to execute INSERT");
    }
    let sqlite_time = start.elapsed();
    let sqlite_avg = sqlite_time / iterations as u32;
    println!("  Total: {sqlite_time:?}, Average: {sqlite_avg:?}");
    
    // Test 2: pgsqlite with non-decimal table (fast path)
    println!("\n2. pgsqlite - Non-decimal table (fast path):");
    let db = DbHandler::new(":memory:").expect("Failed to create database");
    
    // Create a session
    let session_id = Uuid::new_v4();
    db.create_session_connection(session_id).await.expect("Failed to create session connection");
    
    db.execute_with_session("CREATE TABLE fast_test (id INTEGER PRIMARY KEY, name TEXT, value INTEGER)", &session_id)
        .await
        .expect("Failed to create table");
    
    let start = Instant::now();
    for i in 0..iterations {
        let query = format!("INSERT INTO fast_test (name, value) VALUES ('test{i}', {i})");
        db.execute_with_session(&query, &session_id).await.expect("Failed to execute INSERT");
    }
    let fast_time = start.elapsed();
    let fast_avg = fast_time / iterations as u32;
    println!("  Total: {fast_time:?}, Average: {fast_avg:?}");
    println!("  Overhead vs SQLite: {:.1}x", fast_avg.as_secs_f64() / sqlite_avg.as_secs_f64());
    
    // Test 3: pgsqlite with decimal table (slow path)
    println!("\n3. pgsqlite - Decimal table (slow path):");
    db.execute_with_session("CREATE TABLE decimal_test (id INTEGER PRIMARY KEY, price DECIMAL(10,2), name TEXT)", &session_id)
        .await
        .expect("Failed to create table");
    
    let start = Instant::now();
    for i in 0..iterations {
        let query = format!("INSERT INTO decimal_test (price, name) VALUES ({i}.99, 'test{i}')");
        db.execute_with_session(&query, &session_id).await.expect("Failed to execute INSERT");
    }
    let decimal_time = start.elapsed();
    let decimal_avg = decimal_time / iterations as u32;
    println!("  Total: {decimal_time:?}, Average: {decimal_avg:?}");