rudof_lib 0.2.17

RDF data shapes implementation in Rust
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79

use crate::{
    Rudof, RudofConfig,
    api::query::implementations::load_query::load_query,
    api::query::implementations::run_query::run_query,
    api::query::implementations::serialize_query_results::serialize_query_results,
    formats::{InputSpec, ResultQueryFormat},
};

/// Helper: load RDF data into Rudof instance
fn setup_test_rudof_with_data() -> Rudof {
    let mut rudof = Rudof::new(RudofConfig::default());

    let rdf_data_str = r#"
prefix : <http://example.org/>
prefix schema: <http://schema.org/>

:a schema:name  "Alice" ;
   :status      :Active ;
   schema:knows :a, :b  .

:b schema:name  "Bob"    ;
   :status      :Waiting ;
   schema:knows :c       .

:c schema:name  "Carol"  .

:d schema:name  23      .  # Should fail

:e schema:name  "Emily" ;  # Should fail
   schema:knows :d      .
    "#;

    let rdf_data = InputSpec::str(rdf_data_str);
    rudof
        .load_data()
        .with_data(&[rdf_data])
        .execute()
        .expect("Failed to load test RDF data");

    rudof
}

/// Helper: serialize query results to string
fn serialize_results_to_string(rudof: &Rudof, format: Option<ResultQueryFormat>) -> String {
    let mut buffer = Vec::new();

    serialize_query_results(rudof, format.as_ref(), &mut buffer).unwrap();

    String::from_utf8(buffer).unwrap()
}

#[test]
fn test_run_and_serialize_select_query() {
    let mut rudof = setup_test_rudof_with_data();

    let query_input = InputSpec::str(
        r#"
prefix : <http://example.org/>
prefix schema: <http://schema.org/>

select ?person ?name ?status where {
  ?person schema:name ?name ;
          :status ?status .
}"#,
    );

    load_query(&mut rudof, &query_input, None).unwrap();
    run_query(&mut rudof, None).unwrap();

    let serialized = serialize_results_to_string(&rudof, Some(ResultQueryFormat::Internal));

    assert!(serialized.contains("Alice"));
    assert!(serialized.contains("Bob"));

    println!(
        "\n===== test_run_and_serialize_select_query =====\n{}\n============================================",
        serialized
    );
}