Function benchmark_batch_operations

tests/benchmark_batch_operations.rs:9–240

()

#[tokio::test]
#[ignore]
async fn benchmark_batch_operations() {
    // Test parameters
    const TOTAL_ROWS: usize = 1000;
    const OPERATIONS: usize = 500;
    
    // Setup test database
    let db_path = "/tmp/pgsqlite_batch_ops_bench.db";
    let _ = std::fs::remove_file(db_path);
    
    let conn = Connection::open(db_path).unwrap();
    
    // Create test table
    conn.execute(
        "CREATE TABLE batch_ops_test (
            id INTEGER PRIMARY KEY,
            name TEXT NOT NULL,
            value INTEGER NOT NULL,
            status TEXT DEFAULT 'active'
        )",
        [],
    ).unwrap();
    
    // Insert test data
    for i in 0..TOTAL_ROWS {
        conn.execute(
            "INSERT INTO batch_ops_test (id, name, value) VALUES (?1, ?2, ?3)",
            rusqlite::params![i as i32, format!("item_{}", i), i as i32 * 10],
        ).unwrap();
    }
    
    drop(conn); // Close connection before starting server
    
    // Run migration
    let output = tokio::process::Command::new("cargo")
        .args(["run", "--release", "--bin", "pgsqlite", "--", "-d", db_path, "--migrate"])
        .output()
        .await
        .expect("Failed to run migration");
    
    if !output.status.success() {
        panic!("Migration failed: {}", String::from_utf8_lossy(&output.stderr));
    }
    
    // Insert schema info
    let conn = Connection::open(db_path).unwrap();
    conn.execute("INSERT OR IGNORE INTO __pgsqlite_schema (table_name, column_name, pg_type) VALUES ('batch_ops_test', 'id', 'int4')", []).unwrap();
    conn.execute("INSERT OR IGNORE INTO __pgsqlite_schema (table_name, column_name, pg_type) VALUES ('batch_ops_test', 'name', 'text')", []).unwrap();
    conn.execute("INSERT OR IGNORE INTO __pgsqlite_schema (table_name, column_name, pg_type) VALUES ('batch_ops_test', 'value', 'int4')", []).unwrap();
    conn.execute("INSERT OR IGNORE INTO __pgsqlite_schema (table_name, column_name, pg_type) VALUES ('batch_ops_test', 'status', 'text')", []).unwrap();
    drop(conn);
    
    // Start pgsqlite server
    let port = 25438;
    let _ = tokio::process::Command::new("pkill")
        .args(["-f", &format!("pgsqlite.*{port}")])
        .output()
        .await;