Function setup_test_db

tests/decimal_integration_test.rs:29–79

()

}

async fn setup_test_db() -> TestContext {
    // Use unique temporary file for each test to avoid conflicts
    let unique_id = Uuid::new_v4();
    let db_path = format!("/tmp/decimal_test_{}.db", unique_id);
    let db_handler = DbHandler::new(&db_path).unwrap();
    let session_id = Uuid::new_v4();

    // Create session connection
    db_handler.create_session_connection(session_id).await.unwrap();

    let ctx = TestContext {
        db_handler,
        session_id,
        db_path: db_path.clone(),
    };

    // Create tables with NUMERIC columns
    ctx.execute(
        "CREATE TABLE accounts (
            id INTEGER PRIMARY KEY,
            name TEXT,
            balance TEXT,
            credit_limit TEXT
        )"
    ).await.unwrap();

    // Insert type metadata (use INSERT OR IGNORE to avoid conflicts)
    ctx.execute(
        "INSERT OR IGNORE INTO __pgsqlite_schema (table_name, column_name, pg_type, sqlite_type) VALUES
         ('accounts', 'balance', 'NUMERIC', 'DECIMAL'),
         ('accounts', 'credit_limit', 'NUMERIC', 'DECIMAL')"
    ).await.unwrap();

    ctx.execute(
        "CREATE TABLE transactions (
            id INTEGER PRIMARY KEY,
            account_id INTEGER,
            amount TEXT,
            fee TEXT,
            type TEXT
        )"
    ).await.unwrap();

    ctx.execute(
        "INSERT OR IGNORE INTO __pgsqlite_schema (table_name, column_name, pg_type, sqlite_type) VALUES
         ('transactions', 'amount', 'NUMERIC', 'DECIMAL'),
         ('transactions', 'fee', 'NUMERIC', 'DECIMAL')"
    ).await.unwrap();

    ctx
}

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