Function test_fast_path_performance

tests/fast_path_test.rs:7–64

()

#[tokio::test]
async fn test_fast_path_performance() -> Result<(), Box<dyn std::error::Error>> {
    // Use a temporary file instead of in-memory database
    let test_id = Uuid::new_v4().to_string().replace("-", "");
    let db_path = format!("/tmp/pgsqlite_test_{test_id}.db");
    
    // Create database handler
    let db_handler = Arc::new(DbHandler::new(&db_path)?);
    
    // Create a simple table without DECIMAL columns (should use fast path)
    db_handler.execute("CREATE TABLE users (id INTEGER PRIMARY KEY, name TEXT, age INTEGER)").await?;
    
    // Warm up
    for i in 0..10 {
        db_handler.execute(&format!("INSERT INTO users (name, age) VALUES ('user{}', {})", i, i + 20)).await?;
    }
    
    // Measure INSERT performance
    let start = Instant::now();
    for i in 10..110 {
        db_handler.execute(&format!("INSERT INTO users (name, age) VALUES ('user{}', {})", i, i + 20)).await?;
    }
    let insert_duration = start.elapsed();
    println!("100 INSERTs took: {:?} ({:.3}ms per insert)", insert_duration, insert_duration.as_secs_f64() * 1000.0 / 100.0);
    
    // Measure SELECT performance
    let start = Instant::now();
    for _ in 0..100 {
        let result = db_handler.query("SELECT * FROM users WHERE age > 25").await?;
        assert!(!result.rows.is_empty());
    }
    let select_duration = start.elapsed();
    println!("100 SELECTs took: {:?} ({:.3}ms per select)", select_duration, select_duration.as_secs_f64() * 1000.0 / 100.0);
    
    // Now test with DECIMAL table (should NOT use fast path)
    db_handler.execute("CREATE TABLE products (id INTEGER PRIMARY KEY, name TEXT, price DECIMAL(10,2))").await?;
    
    let start = Instant::now();
    for i in 0..100 {
        db_handler.execute(&format!("INSERT INTO products (name, price) VALUES ('product{i}', {i}.99)")).await?;
    }
    let decimal_insert_duration = start.elapsed();
    println!("100 DECIMAL INSERTs took: {:?} ({:.3}ms per insert)", decimal_insert_duration, decimal_insert_duration.as_secs_f64() * 1000.0 / 100.0);
    
    // Fast path should generally be faster, but with our optimized implementation
    // the difference might be small. Log the results for analysis.
    if insert_duration >= decimal_insert_duration {
        println!("WARNING: Fast path INSERT ({insert_duration:?}) was not faster than decimal path ({decimal_insert_duration:?})");
    }
    
    // Clean up
    drop(db_handler);
    let _ = std::fs::remove_file(&db_path);
    let _ = std::fs::remove_file(format!("{db_path}-journal"));
    let _ = std::fs::remove_file(format!("{db_path}-wal"));
    let _ = std::fs::remove_file(format!("{db_path}-shm"));
    
    Ok(())
}