Function test_insert_performance_improvement

tests/insert_optimization_test.rs:52–89

()

#[tokio::test]
async fn test_insert_performance_improvement() {
    use pgsqlite::session::DbHandler;
    use std::time::Instant;

    // Create in-memory database
    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");

    // Create test table without decimal columns (should use fast path)
    db.execute_with_session("CREATE TABLE test_table (id INTEGER, name TEXT)", &session_id).await.expect("Failed to create table");

    // Test fast path INSERT performance
    let start = Instant::now();
    for i in 0..100 {
        let query = format!("INSERT INTO test_table (id, name) VALUES ({i}, 'test{i}')");
        db.execute_with_session(&query, &session_id).await.expect("Failed to execute INSERT");
    }
    let duration = start.elapsed();
    
    println!("100 INSERT operations (fast path) took: {duration:?}");
    println!("Average per INSERT: {:?}", duration / 100);
    
    // Verify data was inserted
    let result = db.query_with_session("SELECT COUNT(*) FROM test_table", &session_id).await.expect("Failed to count rows");
    assert_eq!(result.rows.len(), 1);
    
    // The actual count should be 100
    if let Some(Some(count_bytes)) = result.rows[0].first() {
        let count_str = String::from_utf8_lossy(count_bytes);
        assert_eq!(count_str, "100");
    }
    
    // Clean up
    db.remove_session_connection(&session_id);
}

#[tokio::test]
async fn test_insert_with_decimal_columns_fallback() {