kmax / cqels Goto Github PK

@Test
public void simpleRemoteTest(){
    final String rmtService = "http://dbpedia.org/sparql";
    RDFStream stream = new DefaultRDFStream(context, STREAM_ID_PREFIX);

    ContinuousSelect query = context.registerSelect(""
            +"PREFIX rdf:<http://www.w3.org/1999/02/22-rdf-syntax-ns#>"
            + "SELECT ?x ?y ?z ?p WHERE {"
            + "STREAM <" + STREAM_ID_PREFIX + "> [NOW] {?x ?y ?z}"
            + "SERVICE <"+rmtService+"> { ?x rdf:type ?p} "                
            + "}");

    SelectAssertListener listener = new SelectAssertListener();
    query.register(listener);

    stream.stream(new Triple(
            Node.createURI("http://www.w3.org/2002/07/owl#inverseOf"),                
            Node.createURI("http://example.org/ontology#hasValue"),
            Node.createLiteral("123")));
    List<Mapping> mappings = await().until(listener, hasSize(1));
    List<Node> nodes = Helpers.toNodeList(context, mappings.get(0));

    Helpers.print(context, mappings);
    assertEquals("http://www.w3.org/2002/07/owl#inverseOf", nodes.get(0).getURI());
    assertEquals("http://example.org/ontology#hasValue",
            nodes.get(1).getURI());
    assertEquals("123", nodes.get(2).getLiteralValue());
    assertEquals("http://www.w3.org/1999/02/22-rdf-syntax-ns#Property", nodes.get(3).getURI());
}

    @Override
    public void removeRouter(OpRouter from, OpRouter to) {
        next.remove(from.getId(), to);
    }

CONSTRUCT { [] ?p ?o . }
WHERE {
   STREAM <http://example.org/stream> [RANGE 1s] {
      ?s ?p ?o .
   }
}

CONSTRUCT { ?bnode ?p ?o . }
WHERE {
   STREAM <http://example.org/stream> [RANGE 1s] {
      ?s ?p ?o .
   }
   BIND(BNODE() AS ?bnode)
}