Function benchmark_single_thread_baseline

tests/benchmark_baseline.rs:9–70

()

    /// Simple baseline benchmark using direct DbHandler calls
    #[tokio::test]
    async fn benchmark_single_thread_baseline() {
        eprintln!("\n=== Single Thread Baseline Benchmark ===");
        
        let db_handler = Arc::new(DbHandler::new(":memory:").unwrap());
        
        // Setup test data
        db_handler.execute("
            CREATE TABLE baseline_test (
                id INTEGER PRIMARY KEY,
                name TEXT,
                value INTEGER
            )
        ").await.expect("Failed to create table");

        for i in 0..1000 {
            db_handler.execute(&format!(
                "INSERT INTO baseline_test (id, name, value) VALUES ({}, 'name_{}', {})",
                i, i, i * 10
            )).await.expect("Failed to insert");
        }
        
        eprintln!("Data setup complete: 1,000 rows");
        
        // Benchmark queries
        let iterations = 100;
        let mut query_times = Vec::new();
        
        let start_time = Instant::now();
        
        for i in 0..iterations {
            let query_start = Instant::now();
            let id = i % 1000;
            
            let result = db_handler.query(
                &format!("SELECT * FROM baseline_test WHERE id = {}", id)
            ).await.expect("Query failed");
            
            assert!(!result.rows.is_empty());
            query_times.push(query_start.elapsed());
        }
        
        let total_duration = start_time.elapsed();
        let qps = iterations as f64 / total_duration.as_secs_f64();
        
        // Calculate statistics
        query_times.sort();
        let avg = query_times.iter().sum::<Duration>() / query_times.len() as u32;
        let min = query_times[0];
        let max = query_times[query_times.len() - 1];
        let p50 = query_times[query_times.len() / 2];
        let p95 = query_times[query_times.len() * 95 / 100];
        
        eprintln!("\nDirect DbHandler Baseline Results:");
        eprintln!("  Iterations: {}", iterations);
        eprintln!("  Duration: {:.3}s", total_duration.as_secs_f64());
        eprintln!("  QPS: {:.1}", qps);
        eprintln!("  Latency (avg): {:.3}ms", avg.as_secs_f64() * 1000.0);
        eprintln!("  Latency (min): {:.3}ms", min.as_secs_f64() * 1000.0);