Function test_result_cache_invalidation_on_ddl

tests/result_cache_test.rs:66–95

()

#[tokio::test]
async fn test_result_cache_invalidation_on_ddl() {
    let test_server = setup_test_server_with_init(|db| {
        Box::pin(async move {
            // Create initial table
            db.execute("CREATE TABLE ddl_test (id INTEGER PRIMARY KEY, data TEXT)").await?;
            db.execute("INSERT INTO ddl_test VALUES (1, 'original')").await?;
            Ok(())
        })
    }).await;
    
    let client = &test_server.client;
    
    // Execute a query that should be cached
    let query = "SELECT * FROM ddl_test";
    let rows1 = client.query(query, &[]).await.unwrap();
    assert_eq!(rows1.len(), 1);
    assert_eq!(rows1[0].get::<_, String>(1), "original");
    
    // Execute DDL which should clear the cache
    client.execute("ALTER TABLE ddl_test ADD COLUMN extra INTEGER DEFAULT 0", &[]).await.unwrap();
    
    // Insert new data
    client.execute("INSERT INTO ddl_test (id, data) VALUES (2, 'new')", &[]).await.unwrap();
    
    // Execute the same query - should not use cached result
    let rows2 = client.query(query, &[]).await.unwrap();
    assert_eq!(rows2.len(), 2); // Should see both rows, not cached single row
    
    test_server.abort();
}

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