Revision: 3946
http://bigdata.svn.sourceforge.net/bigdata/?rev=3946&view=rev
Author: thompsonbry
Date: 2010-11-12 21:02:48 +0000 (Fri, 12 Nov 2010)
Log Message:
-----------
Added LUBM Q8 to the test class.
Modified Paths:
--------------
branches/QUADS_QUERY_BRANCH/bigdata-rdf/src/test/com/bigdata/bop/rdf/joinGraph/TestJoinGraphOnLubm.java
Modified: branches/QUADS_QUERY_BRANCH/bigdata-rdf/src/test/com/bigdata/bop/rdf/joinGraph/TestJoinGraphOnLubm.java
===================================================================
--- branches/QUADS_QUERY_BRANCH/bigdata-rdf/src/test/com/bigdata/bop/rdf/joinGraph/TestJoinGraphOnLubm.java 2010-11-12 20:47:51 UTC (rev 3945)
+++ branches/QUADS_QUERY_BRANCH/bigdata-rdf/src/test/com/bigdata/bop/rdf/joinGraph/TestJoinGraphOnLubm.java 2010-11-12 21:02:48 UTC (rev 3946)
@@ -616,4 +616,144 @@
} // test_Q9
+ /**
+ * LUBM Query 8
+ *
+ * <pre>
+ * PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>
+ * PREFIX ub: <http://www.lehigh.edu/~zhp2/2004/0401/univ-bench.owl#>
+ * SELECT ?x ?y ?z
+ * WHERE{
+ * ?y a ub:Department .
+ * ?x a ub:Student;
+ * ub:memberOf ?y .
+ * ?y ub:subOrganizationOf <http://www.University0.edu> .
+ * ?x ub:emailAddress ?z .
+ * }
+ * </pre>
+ * @throws Exception
+ */
+ public void test_query8() throws Exception {
+ final AbstractTripleStore database = (AbstractTripleStore) jnl
+ .getResourceLocator()
+ .locate(namespace, jnl.getLastCommitTime());
+
+ if (database == null)
+ throw new RuntimeException("Not found: " + namespace);
+
+ /*
+ * Resolve terms against the lexicon.
+ */
+ final BigdataValueFactory f = database.getLexiconRelation()
+ .getValueFactory();
+
+ final BigdataURI rdfType = f
+ .createURI("http://www.w3.org/1999/02/22-rdf-syntax-ns#type");
+
+ final BigdataURI department = f
+ .createURI("http://www.lehigh.edu/~zhp2/2004/0401/univ-bench.owl#Department");
+
+ final BigdataURI student = f
+ .createURI("http://www.lehigh.edu/~zhp2/2004/0401/univ-bench.owl#Student");
+
+ final BigdataURI memberOf = f
+ .createURI("http://www.lehigh.edu/~zhp2/2004/0401/univ-bench.owl#memberOf");
+
+ final BigdataURI subOrganizationOf = f
+ .createURI("http://www.lehigh.edu/~zhp2/2004/0401/univ-bench.owl#subOrganizationOf");
+
+ final BigdataURI emailAddress = f
+ .createURI("http://www.lehigh.edu/~zhp2/2004/0401/univ-bench.owl#emailAddress");
+
+ final BigdataURI university0 = f
+ .createURI("http://www.University0.edu");
+
+ final BigdataValue[] terms = new BigdataValue[] { rdfType, department,
+ student, memberOf, subOrganizationOf, emailAddress, university0 };
+
+ // resolve terms.
+ database.getLexiconRelation()
+ .addTerms(terms, terms.length, true/* readOnly */);
+
+ {
+ for (BigdataValue tmp : terms) {
+ System.out.println(tmp + " : " + tmp.getIV());
+ if (tmp.getIV() == null)
+ throw new RuntimeException("Not defined: " + tmp);
+ }
+ }
+
+ final IPredicate[] preds;
+ {
+ final IVariable<?> x = Var.var("x");
+ final IVariable<?> y = Var.var("y");
+ final IVariable<?> z = Var.var("z");
+
+ // The name space for the SPO relation.
+ final String[] relation = new String[] { namespace + ".spo" };
+
+ final long timestamp = jnl.getLastCommitTime();
+
+ int nextId = 0;
+
+ // ?y a ub:Department .
+ final IPredicate p0 = new SPOPredicate(new BOp[] { y,
+ new Constant(rdfType.getIV()),
+ new Constant(department.getIV()) },//
+ new NV(BOp.Annotations.BOP_ID, nextId++),//
+ new NV(IPredicate.Annotations.TIMESTAMP, timestamp),//
+ new NV(IPredicate.Annotations.RELATION_NAME, relation)//
+ );
+
+ // ?x a ub:Student;
+ final IPredicate p1 = new SPOPredicate(new BOp[] { x,
+ new Constant(rdfType.getIV()),
+ new Constant(student.getIV()) },//
+ new NV(BOp.Annotations.BOP_ID, nextId++),//
+ new NV(IPredicate.Annotations.TIMESTAMP, timestamp),//
+ new NV(IPredicate.Annotations.RELATION_NAME, relation)//
+ );
+
+ // (?x) ub:memberOf ?y .
+ final IPredicate p2 = new SPOPredicate(new BOp[] { x,
+ new Constant(memberOf.getIV()), y },//
+ new NV(BOp.Annotations.BOP_ID, nextId++),//
+ new NV(IPredicate.Annotations.TIMESTAMP, timestamp),//
+ new NV(IPredicate.Annotations.RELATION_NAME, relation)//
+ );
+
+ // ?y ub:subOrganizationOf <http://www.University0.edu> .
+ final IPredicate p3 = new SPOPredicate(new BOp[] { y,
+ new Constant(subOrganizationOf.getIV()),
+ new Constant(university0.getIV()) },//
+ new NV(BOp.Annotations.BOP_ID, nextId++),//
+ new NV(IPredicate.Annotations.TIMESTAMP, timestamp),//
+ new NV(IPredicate.Annotations.RELATION_NAME, relation)//
+ );
+
+ // ?x ub:emailAddress ?z .
+ final IPredicate p4 = new SPOPredicate(new BOp[] { x,
+ new Constant(emailAddress.getIV()), z },//
+ new NV(BOp.Annotations.BOP_ID, nextId++),//
+ new NV(IPredicate.Annotations.TIMESTAMP, timestamp),//
+ new NV(IPredicate.Annotations.RELATION_NAME, relation)//
+ );
+
+ // the vertices of the join graph (the predicates).
+ preds = new IPredicate[] { p0, p1, p2, p3, p4 };
+ }
+
+ {
+ final int limit = 100;
+
+ final QueryEngine queryEngine = QueryEngineFactory
+ .getQueryController(jnl/* indexManager */);
+
+ final JGraph g = new JGraph(preds);
+
+ g.runtimeOptimizer(queryEngine, limit);
+
+ }
+ }
+
}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
