Function test_unwind_remove_basic

graphlite/tests/match_with_tests.rs:1709–1783

()

#[test]
fn test_unwind_remove_basic() {
    let fixture = TestFixture::empty().expect("Failed to create test fixture");

    // Create test graph
    fixture
        .query(&format!(
            "CREATE SCHEMA IF NOT EXISTS /{}",
            fixture.schema_name()
        ))
        .unwrap();
    fixture
        .query(&format!(
            "CREATE GRAPH /{}/unwind_remove_basic",
            fixture.schema_name()
        ))
        .unwrap();
    fixture
        .query(&format!(
            "SESSION SET GRAPH /{}/unwind_remove_basic",
            fixture.schema_name()
        ))
        .unwrap();

    // Insert test nodes with temp_flag - using id field like other tests
    fixture.assert_query_succeeds(
        "INSERT (p1:Product {id: 1, name: 'Product1', price: 30.0, temp_flag: true}),
                (p2:Product {id: 2, name: 'Product2', price: 20.0, temp_flag: true})",
    );

    // Verify initial state
    let result = fixture
        .query("MATCH (p:Product) RETURN p.name as name, p.temp_flag as flag ORDER BY p.name")
        .unwrap();
    for row in &result.rows {
        assert_eq!(row.values.get("flag").unwrap(), &Value::Boolean(true));
    }

    // Test UNWIND REMOVE - should use UNWIND preprocessor
    fixture.assert_query_succeeds(
        "MATCH (p:Product)
         WITH collect(p) as products
         UNWIND products as product
         WHERE product.price > 25
         REMOVE product.temp_flag",
    );

    // Verify result - should be Null for expensive products, true for others
    let result = fixture
        .query("MATCH (p:Product) RETURN p.name as name, p.temp_flag as flag ORDER BY p.name")
        .unwrap();

    for row in &result.rows {
        let name = match row.values.get("name").unwrap() {
            Value::String(s) => s.as_str(),
            _ => panic!("Expected string name"),
        };
        let flag = row.values.get("flag").unwrap();