Function test_query_execution

src/optimization/read_only_optimizer.rs:581–613

()

    #[test]
    fn test_query_execution() {
        let optimizer = ReadOnlyOptimizer::new(100);
        let conn = rusqlite::Connection::open_in_memory().unwrap();
        let schema_cache = SchemaCache::new(3600);
        
        // Create a test table
        conn.execute("CREATE TABLE users (id INTEGER, name TEXT, active BOOLEAN)", []).unwrap();
        conn.execute("INSERT INTO users VALUES (1, 'Alice', 1), (2, 'Bob', 0)", []).unwrap();
        
        // Test simple query execution
        let result = optimizer.execute_read_only_query(&conn, "SELECT * FROM users", &schema_cache).unwrap();
        assert!(result.is_some());
        
        let response = result.unwrap();
        assert_eq!(response.columns, vec!["id", "name", "active"]);
        assert_eq!(response.rows.len(), 2);
        
        // Test that stats are updated
        let stats = optimizer.get_stats();
        assert_eq!(stats.total_queries, 1);
        assert_eq!(stats.cache_misses, 1);
        assert_eq!(stats.successful_optimizations, 1);
        
        // Test cache hit on second execution
        let result2 = optimizer.execute_read_only_query(&conn, "SELECT * FROM users", &schema_cache).unwrap();
        assert!(result2.is_some());
        
        let stats2 = optimizer.get_stats();
        assert_eq!(stats2.total_queries, 2);
        assert_eq!(stats2.cache_hits, 1);
        assert_eq!(stats2.cache_misses, 1);
        assert!(optimizer.get_cache_hit_rate() > 0.0);
    }
}