Menu
▾
▴
bigdata-commit
|
From: <mrp...@us...> - 2010-10-18 14:35:18
|
Revision: 3807
http://bigdata.svn.sourceforge.net/bigdata/?rev=3807&view=rev
Author: mrpersonick
Date: 2010-10-18 14:35:11 +0000 (Mon, 18 Oct 2010)
Log Message:
-----------
testing duplicate statements in multiple graphs
Modified Paths:
--------------
branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java
Modified: branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java
===================================================================
--- branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java 2010-10-18 12:32:05 UTC (rev 3806)
+++ branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java 2010-10-18 14:35:11 UTC (rev 3807)
@@ -44,6 +44,10 @@
import org.openrdf.query.TupleQuery;
import org.openrdf.query.TupleQueryResult;
import org.openrdf.query.impl.BindingImpl;
+import org.openrdf.repository.sail.SailRepository;
+import org.openrdf.repository.sail.SailRepositoryConnection;
+import org.openrdf.sail.Sail;
+import org.openrdf.sail.memory.MemoryStore;
import com.bigdata.rdf.axioms.NoAxioms;
import com.bigdata.rdf.lexicon.LexiconRelation;
import com.bigdata.rdf.store.BD;
@@ -448,4 +452,172 @@
}
+ public void testMultiGraphs() throws Exception {
+
+ final Sail sail;
+ final SailRepository repo;
+ final SailRepositoryConnection cxn;
+
+ /*
+ * You'll get the same answer whether you run with Bigdata or Sesame.
+ */
+ if (true) {
+ sail = getSail();
+ repo = new BigdataSailRepository((BigdataSail) sail);
+ } else {
+ sail = new MemoryStore();
+ repo = new SailRepository(sail);
+ }
+
+ repo.initialize();
+ cxn = repo.getConnection();
+ cxn.setAutoCommit(false);
+
+ try {
+
+ final ValueFactory vf = sail.getValueFactory();
+
+ final String ns = BD.NAMESPACE;
+
+ URI mike = vf.createURI(ns+"Mike");
+ URI bryan = vf.createURI(ns+"Bryan");
+ URI person = vf.createURI(ns+"Person");
+ URI likes = vf.createURI(ns+"likes");
+ URI rdf = vf.createURI(ns+"RDF");
+ Literal l1 = vf.createLiteral("Mike");
+ Literal l2 = vf.createLiteral("Bryan");
+ URI g1 = vf.createURI(ns+"graph1");
+ URI g2 = vf.createURI(ns+"graph2");
+/**/
+ cxn.setNamespace("ns", ns);
+
+ cxn.add(mike, RDF.TYPE, person, g1, g2);
+ cxn.add(mike, likes, rdf, g1, g2);
+ cxn.add(mike, RDFS.LABEL, l1, g1, g2);
+ cxn.add(bryan, RDF.TYPE, person, g1, g2);
+ cxn.add(bryan, likes, rdf, g1, g2);
+ cxn.add(bryan, RDFS.LABEL, l2, g1, g2);
+
+ /*
+ * Note: The either flush() or commit() is required to flush the
+ * statement buffers to the database before executing any operations
+ * that go around the sail.
+ */
+ cxn.commit();//
+
+ if (log.isInfoEnabled()) {
+ if (sail instanceof BigdataSail)
+ log.info("\n" + ((BigdataSail)sail).getDatabase().dumpStore());
+ }
+
+ {
+
+ String query =
+ "PREFIX rdf: <"+RDF.NAMESPACE+"> " +
+ "PREFIX rdfs: <"+RDFS.NAMESPACE+"> " +
+ "PREFIX ns: <"+ns+"> " +
+
+ "select ?p ?o " +
+ "WHERE { " +
+ " ns:Mike ?p ?o . " +
+ "}";
+
+ final TupleQuery tupleQuery =
+ cxn.prepareTupleQuery(QueryLanguage.SPARQL, query);
+ TupleQueryResult result = tupleQuery.evaluate();
+
+// while (result.hasNext()) {
+// System.err.println(result.next());
+// }
+
+ Collection<BindingSet> solution = new LinkedList<BindingSet>();
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDF.TYPE),
+ new BindingImpl("o", person),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", likes),
+ new BindingImpl("o", rdf),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDFS.LABEL),
+ new BindingImpl("o", l1),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDF.TYPE),
+ new BindingImpl("o", person),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", likes),
+ new BindingImpl("o", rdf),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDFS.LABEL),
+ new BindingImpl("o", l1),
+ }));
+
+ compare(result, solution);
+
+ }
+
+ {
+
+ String query =
+ "PREFIX rdf: <"+RDF.NAMESPACE+"> " +
+ "PREFIX rdfs: <"+RDFS.NAMESPACE+"> " +
+ "PREFIX ns: <"+ns+"> " +
+
+ "select ?p ?o " +
+ "from <"+g1+">" +
+ "from <"+g2+">" +
+ "WHERE { " +
+ " ns:Mike ?p ?o . " +
+ "}";
+
+ final TupleQuery tupleQuery =
+ cxn.prepareTupleQuery(QueryLanguage.SPARQL, query);
+ TupleQueryResult result = tupleQuery.evaluate();
+
+// while (result.hasNext()) {
+// System.err.println(result.next());
+// }
+
+ Collection<BindingSet> solution = new LinkedList<BindingSet>();
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDF.TYPE),
+ new BindingImpl("o", person),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", likes),
+ new BindingImpl("o", rdf),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDFS.LABEL),
+ new BindingImpl("o", l1),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDF.TYPE),
+ new BindingImpl("o", person),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", likes),
+ new BindingImpl("o", rdf),
+ }));
+ solution.add(createBindingSet(new Binding[] {
+ new BindingImpl("p", RDFS.LABEL),
+ new BindingImpl("o", l1),
+ }));
+
+ compare(result, solution);
+
+ }
+
+ } finally {
+ cxn.close();
+ if (sail instanceof BigdataSail)
+ ((BigdataSail)sail).__tearDownUnitTest();
+ }
+
+ }
+
}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <mrp...@us...> - 2010-10-18 16:56:03
|
Revision: 3809
http://bigdata.svn.sourceforge.net/bigdata/?rev=3809&view=rev
Author: mrpersonick
Date: 2010-10-18 16:55:57 +0000 (Mon, 18 Oct 2010)
Log Message:
-----------
testing duplicate statements in multiple graphs
Modified Paths:
--------------
branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java
Modified: branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java
===================================================================
--- branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java 2010-10-18 16:50:53 UTC (rev 3808)
+++ branches/QUADS_QUERY_BRANCH/bigdata-sails/src/test/com/bigdata/rdf/sail/TestBOps.java 2010-10-18 16:55:57 UTC (rev 3809)
@@ -452,172 +452,4 @@
}
- public void testMultiGraphs() throws Exception {
-
- final Sail sail;
- final SailRepository repo;
- final SailRepositoryConnection cxn;
-
- /*
- * You'll get the same answer whether you run with Bigdata or Sesame.
- */
- if (true) {
- sail = getSail();
- repo = new BigdataSailRepository((BigdataSail) sail);
- } else {
- sail = new MemoryStore();
- repo = new SailRepository(sail);
- }
-
- repo.initialize();
- cxn = repo.getConnection();
- cxn.setAutoCommit(false);
-
- try {
-
- final ValueFactory vf = sail.getValueFactory();
-
- final String ns = BD.NAMESPACE;
-
- URI mike = vf.createURI(ns+"Mike");
- URI bryan = vf.createURI(ns+"Bryan");
- URI person = vf.createURI(ns+"Person");
- URI likes = vf.createURI(ns+"likes");
- URI rdf = vf.createURI(ns+"RDF");
- Literal l1 = vf.createLiteral("Mike");
- Literal l2 = vf.createLiteral("Bryan");
- URI g1 = vf.createURI(ns+"graph1");
- URI g2 = vf.createURI(ns+"graph2");
-/**/
- cxn.setNamespace("ns", ns);
-
- cxn.add(mike, RDF.TYPE, person, g1, g2);
- cxn.add(mike, likes, rdf, g1, g2);
- cxn.add(mike, RDFS.LABEL, l1, g1, g2);
- cxn.add(bryan, RDF.TYPE, person, g1, g2);
- cxn.add(bryan, likes, rdf, g1, g2);
- cxn.add(bryan, RDFS.LABEL, l2, g1, g2);
-
- /*
- * Note: The either flush() or commit() is required to flush the
- * statement buffers to the database before executing any operations
- * that go around the sail.
- */
- cxn.commit();//
-
- if (log.isInfoEnabled()) {
- if (sail instanceof BigdataSail)
- log.info("\n" + ((BigdataSail)sail).getDatabase().dumpStore());
- }
-
- {
-
- String query =
- "PREFIX rdf: <"+RDF.NAMESPACE+"> " +
- "PREFIX rdfs: <"+RDFS.NAMESPACE+"> " +
- "PREFIX ns: <"+ns+"> " +
-
- "select ?p ?o " +
- "WHERE { " +
- " ns:Mike ?p ?o . " +
- "}";
-
- final TupleQuery tupleQuery =
- cxn.prepareTupleQuery(QueryLanguage.SPARQL, query);
- TupleQueryResult result = tupleQuery.evaluate();
-
-// while (result.hasNext()) {
-// System.err.println(result.next());
-// }
-
- Collection<BindingSet> solution = new LinkedList<BindingSet>();
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDF.TYPE),
- new BindingImpl("o", person),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", likes),
- new BindingImpl("o", rdf),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDFS.LABEL),
- new BindingImpl("o", l1),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDF.TYPE),
- new BindingImpl("o", person),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", likes),
- new BindingImpl("o", rdf),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDFS.LABEL),
- new BindingImpl("o", l1),
- }));
-
- compare(result, solution);
-
- }
-
- {
-
- String query =
- "PREFIX rdf: <"+RDF.NAMESPACE+"> " +
- "PREFIX rdfs: <"+RDFS.NAMESPACE+"> " +
- "PREFIX ns: <"+ns+"> " +
-
- "select ?p ?o " +
- "from <"+g1+">" +
- "from <"+g2+">" +
- "WHERE { " +
- " ns:Mike ?p ?o . " +
- "}";
-
- final TupleQuery tupleQuery =
- cxn.prepareTupleQuery(QueryLanguage.SPARQL, query);
- TupleQueryResult result = tupleQuery.evaluate();
-
-// while (result.hasNext()) {
-// System.err.println(result.next());
-// }
-
- Collection<BindingSet> solution = new LinkedList<BindingSet>();
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDF.TYPE),
- new BindingImpl("o", person),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", likes),
- new BindingImpl("o", rdf),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDFS.LABEL),
- new BindingImpl("o", l1),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDF.TYPE),
- new BindingImpl("o", person),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", likes),
- new BindingImpl("o", rdf),
- }));
- solution.add(createBindingSet(new Binding[] {
- new BindingImpl("p", RDFS.LABEL),
- new BindingImpl("o", l1),
- }));
-
- compare(result, solution);
-
- }
-
- } finally {
- cxn.close();
- if (sail instanceof BigdataSail)
- ((BigdataSail)sail).__tearDownUnitTest();
- }
-
- }
-
}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
×
Want the latest updates on software, tech news, and AI?
Get latest updates about software, tech news, and AI from SourceForge directly in your inbox once a month.
Thanks for helping keep SourceForge clean.
X