fraiseql-core 2.2.0

Core execution engine for FraiseQL v2 - Compiled GraphQL over SQL
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

#![allow(clippy::unwrap_used)] // Reason: test code, panics are acceptable

//! Test fraiseql-wire directly without adapter layer
//!
//! Run with: cargo test -p fraiseql-core --features wire-backend,test-postgres --test
//! `wire_direct_test`

#[cfg(all(feature = "wire-backend", feature = "test-postgres"))]
mod wire_direct_tests {
    use fraiseql_wire::FraiseClient;
    use futures::StreamExt;

    #[tokio::test]
    async fn test_direct_v_user_query() {
        let conn_str = std::env::var("DATABASE_URL").unwrap_or_else(|_| {
            "postgresql://fraiseql_test:fraiseql_test_password@localhost:5433/test_fraiseql"
                .to_string()
        });

        println!("Connecting to: {}", conn_str);

        let client = FraiseClient::connect(&conn_str).await.unwrap();

        println!("Querying v_user directly...");

        // Query v_user directly
        let stream_result =
            client.query::<serde_json::Value>("v_user").chunk_size(1024).execute().await;

        match &stream_result {
            Ok(_) => println!("Query executed successfully"),
            Err(e) => println!("Query failed with error: {:?}", e),
        }

        let mut stream = stream_result.unwrap();

        let mut count = 0;
        while let Some(result) = stream.next().await {
            match result {
                Ok(_item) => {
                    count += 1;
                    if count >= 10 {
                        break;
                    }
                },
                Err(e) => {
                    println!("ERROR: {}", e);
                    panic!("Query failed: {}", e);
                },
            }
        }

        println!("SUCCESS: Got {} rows", count);
        assert_eq!(count, 5, "Should get 5 rows (from test data)");
    }
}