本文整理汇总了Java中org.openrdf.repository.sail.SailRepositoryConnection类的典型用法代码示例。如果您正苦于以下问题:Java SailRepositoryConnection类的具体用法?Java SailRepositoryConnection怎么用?Java SailRepositoryConnection使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
SailRepositoryConnection类属于org.openrdf.repository.sail包,在下文中一共展示了SailRepositoryConnection类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: performUpdate
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
private void performUpdate(final String query, final SailRepositoryConnection conn, final ServletOutputStream os, final String infer, final String vis) throws RepositoryException, MalformedQueryException, IOException {
final Update update = conn.prepareUpdate(QueryLanguage.SPARQL, query);
if (infer != null && infer.length() > 0) {
update.setBinding(RdfCloudTripleStoreConfiguration.CONF_INFER, VALUE_FACTORY.createLiteral(Boolean.parseBoolean(infer)));
}
if (conn.getSailConnection() instanceof RdfCloudTripleStoreConnection && vis != null) {
final RdfCloudTripleStoreConnection<?> sailConnection = (RdfCloudTripleStoreConnection<?>) conn.getSailConnection();
sailConnection.getConf().set(RdfCloudTripleStoreConfiguration.CONF_CV, vis);
}
final long startTime = System.currentTimeMillis();
try {
update.execute();
} catch (final UpdateExecutionException e) {
final String message = "Update could not be successfully completed for query: ";
os.print(String.format(message + "%s\n\n", StringEscapeUtils.escapeHtml4(query)));
log.error(message + LogUtils.clean(query), e);
}
log.info(String.format("Update Time = %.3f\n", (System.currentTimeMillis() - startTime) / 1000.));
}
开发者ID:apache,项目名称:incubator-rya,代码行数:24,代码来源:RdfController.java
示例2: loadData
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
private String loadData(final String sparql, final Collection<Statement> statements) throws Exception {
requireNonNull(sparql);
requireNonNull(statements);
// Register the PCJ with Rya.
final RyaClient ryaClient = AccumuloRyaClientFactory.build(createConnectionDetails(), getAccumuloConnector());
final String pcjId = ryaClient.getCreatePCJ().createPCJ(getRyaInstanceName(), sparql, Sets.newHashSet());
// Write the data to Rya.
final SailRepositoryConnection ryaConn = getRyaSailRepository().getConnection();
ryaConn.begin();
ryaConn.add(statements);
ryaConn.commit();
ryaConn.close();
// Wait for the Fluo application to finish computing the end result.
getMiniFluo().waitForObservers();
// The PCJ Id is the topic name the results will be written to.
return pcjId;
}
开发者ID:apache,项目名称:incubator-rya,代码行数:23,代码来源:CreateDeleteIT.java
示例3: ensureInEntityStore_Test
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Test
public void ensureInEntityStore_Test() throws Exception {
final Sail sail = RyaSailFactory.getInstance(conf);
SailRepositoryConnection conn = new SailRepository(sail).getConnection();
conn.begin();
try(MongoEntityIndexer indexer = new MongoEntityIndexer()) {
indexer.setConf(conf);
indexer.init();
setupTypes(indexer);
addStatements(conn);
final EntityStorage entities = indexer.getEntityStorage();
final RyaURI subject = new RyaURI("urn:alice");
final Optional<Entity> alice = entities.get(subject);
assertTrue(alice.isPresent());
} finally {
conn.close();
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:22,代码来源:MongoEntityIndexIT.java
示例4: near_invalidDistance
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Test(expected = MalformedQueryException.class)
public void near_invalidDistance() throws Exception {
final Sail sail = GeoRyaSailFactory.getInstance(conf);
final SailRepositoryConnection conn = new SailRepository(sail).getConnection();
try {
populateRya(conn);
//Only captial
final String query =
"PREFIX geo: <http://www.opengis.net/ont/geosparql#>\n"
+ "PREFIX geof: <http://www.opengis.net/def/function/geosparql/>\n"
+ "SELECT * \n" //
+ "WHERE { \n"
+ " <urn:geo> geo:asWKT ?point .\n"
+ " FILTER(geof:sfNear(?point, \"POINT(38.8895 77.0353)\"^^geo:wktLiteral, distance))"
+ "}";
conn.prepareTupleQuery(QueryLanguage.SPARQL, query).evaluate();
} finally {
conn.close();
sail.shutDown();
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:24,代码来源:MongoGeoIndexerFilterIT.java
示例5: near_negativeDistance
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Test(expected = IllegalArgumentException.class)
public void near_negativeDistance() throws Exception {
final Sail sail = GeoRyaSailFactory.getInstance(conf);
final SailRepositoryConnection conn = new SailRepository(sail).getConnection();
try {
populateRya(conn);
//Only captial
final String query =
"PREFIX geo: <http://www.opengis.net/ont/geosparql#>\n"
+ "PREFIX geof: <http://www.opengis.net/def/function/geosparql/>\n"
+ "SELECT * \n" //
+ "WHERE { \n"
+ " <urn:geo> geo:asWKT ?point .\n"
+ " FILTER(geof:sfNear(?point, \"POINT(38.8895 77.0353)\"^^geo:wktLiteral, -100))"
+ "}";
final TupleQueryResult rez = conn.prepareTupleQuery(QueryLanguage.SPARQL, query).evaluate();
while(rez.hasNext()) {
rez.next();
}
} finally {
conn.close();
sail.shutDown();
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:27,代码来源:MongoGeoIndexerFilterIT.java
示例6: tooManyArgumentsTest
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Test(expected = QueryEvaluationException.class)
public void tooManyArgumentsTest() throws Exception {
final Sail sail = GeoRyaSailFactory.getInstance(conf);
final SailRepositoryConnection conn = new SailRepository(sail).getConnection();
try {
populateRya(conn);
// Only captial
final String query =
"PREFIX geo: <http://www.opengis.net/ont/geosparql#>\n"
+ "PREFIX geof: <http://www.opengis.net/def/function/geosparql/>\n"
+ "SELECT * \n" //
+ "WHERE { \n" + " <urn:geo> geo:asWKT ?point .\n"
+ " FILTER(geof:sfNear(?point, \"POINT(38.8895 77.0353)\"^^geo:wktLiteral, 100, 1000, 10))"
+ "}";
conn.prepareTupleQuery(QueryLanguage.SPARQL, query).evaluate();
} finally {
conn.close();
sail.shutDown();
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:23,代码来源:MongoGeoIndexerFilterIT.java
示例7: addStatements
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
private void addStatements(final SailRepositoryConnection conn) throws Exception {
URI subject = VF.createURI("urn:event1");
final URI predicate = VF.createURI(URI_PROPERTY_AT_TIME);
Value object = VF.createLiteral(new TemporalInstantRfc3339(2015, 12, 30, 12, 00, 0).toString());
conn.add(VF.createStatement(subject, predicate, object));
object = VF.createLiteral("Point(0 0)", GeoConstants.XMLSCHEMA_OGC_WKT);
conn.add(VF.createStatement(subject, GeoConstants.GEO_AS_WKT, object));
subject = VF.createURI("urn:event2");
object = VF.createLiteral(new TemporalInstantRfc3339(2015, 12, 30, 12, 00, 0).toString());
conn.add(VF.createStatement(subject, predicate, object));
object = VF.createLiteral("Point(1 1)", GeoConstants.XMLSCHEMA_OGC_WKT);
conn.add(VF.createStatement(subject, GeoConstants.GEO_AS_WKT, object));
}
开发者ID:apache,项目名称:incubator-rya,代码行数:17,代码来源:MongoGeoTemporalIndexIT.java
示例8: executeQuery
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
Set<BindingSet> executeQuery(URL queryFile) throws Exception {
SailRepositoryConnection conn = repository.getConnection();
try {
InputStream queryIS = queryFile.openStream();
BufferedReader br = new BufferedReader(new java.io.InputStreamReader(queryIS, "UTF-8"));
String query = br.lines().collect(Collectors.joining("\n"));
br.close();
TupleQuery tupleQuery = conn.prepareTupleQuery(QueryLanguage.SPARQL, query);
TupleQueryResult result = tupleQuery.evaluate();
Set<BindingSet> solutions = new HashSet<>();
while (result.hasNext()) {
solutions.add(result.next());
}
return solutions;
} finally {
closeQuietly(conn);
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:19,代码来源:MongoSpinIT.java
示例9: query
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
public ArrayList<String> query(String queryString, SailRepositoryConnection con)
throws MalformedQueryException, QueryEvaluationException, IOException,
TupleQueryResultHandlerException {
TupleQuery tupleQuery = null;
ArrayList<String> ret = new ArrayList<String>();
try {
tupleQuery = con.prepareTupleQuery(QueryLanguage.SPARQL, queryString);
TupleQueryResult result = tupleQuery.evaluate();
while (result.hasNext()) {
BindingSet bindingSet = result.next();
ret.add(bindingSet.toString());
}
} catch (RepositoryException e) {
logger.error("[Strabon.query] Error in preparing tuple query.", e);
}
return ret;
}
开发者ID:esarbanis,项目名称:strabon,代码行数:24,代码来源:Strabon.java
示例10: loadHistory
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Override
public JSONArray loadHistory(String filename) throws Exception {
File file = new File(filename);
// String encoding = EncodingDetector.detect(file);
// String contents = EncodingDetector.getString(file, encoding);
SailRepository myRepository = new SailRepository(new MemoryStore());
myRepository.initialize();
SailRepositoryConnection con = myRepository.getConnection();
con.add(file, "", RDFFormat.TURTLE);
RepositoryResult<Statement> result = con.getStatements(null, new URIImpl("http://isi.edu/integration/karma/dev#hasWorksheetHistory"), null, false);
if(result.hasNext()) {
Statement stmt = result.next();
String history = stmt.getObject().stringValue();
return new JSONArray(history);
}
return new JSONArray();
}
开发者ID:therelaxist,项目名称:spring-usc,代码行数:20,代码来源:R2RMLAlignmentFileSaver.java
示例11: getQueryType
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Override
public QueryType getQueryType(String query) {
SailRepositoryConnection connection;
try {
connection = sr.getConnection();
final Query prepareQuery = connection.prepareQuery(
QueryLanguage.SPARQL, query);
if (prepareQuery instanceof BooleanQuery)
return QueryType.BOOLEANQUERY;
if (prepareQuery instanceof GraphQuery)
return QueryType.CONSTRUCTQUERY;
if (prepareQuery instanceof TupleQuery)
return QueryType.TUPLEQUERY;
} catch (RepositoryException | MalformedQueryException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return QueryType.DESCRIBEQUERY;
}
开发者ID:JervenBolleman,项目名称:sparql-identifiers,代码行数:21,代码来源:SesameSparqlService.java
示例12: setUp
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Before
public void setUp() {
try {
final SailRepositoryConnection conn = repository.getConnection();
try {
conn.begin();
resource = createURI("foo", "Start");
prop = createURI("ex", "text");
conn.add(resource, prop, conn.getValueFactory().createLiteral(XML_TEXT));
conn.commit();
} catch (final Throwable t) {
conn.rollback();
fail(t.getMessage());
} finally {
conn.close();
}
} catch (RepositoryException e) {
fail("Could not create test-data");
}
}
开发者ID:apache,项目名称:marmotta,代码行数:23,代码来源:XmlTextFunctionTest.java
示例13: setUp
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Before
public void setUp() throws Exception {
textLen = text.length();
Assert.assertTrue(textLen > 4);
testWindow = 1+rnd.nextInt((textLen / 4));
errSalt = UUID.randomUUID().toString();
subject = repository.getValueFactory().createURI(ns("foo", UUID.randomUUID().toString()));
predicate = repository.getValueFactory().createURI(ns("foo", UUID.randomUUID().toString()));
final SailRepositoryConnection con = repository.getConnection();
try {
final ValueFactory vf = con.getValueFactory();
con.add(vf.createStatement(subject, predicate, vf.createLiteral(text)));
con.commit();
} finally {
con.close();
}
}
开发者ID:apache,项目名称:marmotta,代码行数:23,代码来源:StringTestTest.java
示例14: setUp
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Before
public void setUp() throws RepositoryException {
subject = repository.getValueFactory().createURI(ns("foo", UUID.randomUUID().toString()));
predicate = repository.getValueFactory().createURI(ns("foo", UUID.randomUUID().toString()));
final SailRepositoryConnection con = repository.getConnection();
try {
final ValueFactory vf = con.getValueFactory();
con.add(vf.createStatement(subject, predicate, vf.createLiteral(text)));
con.commit();
} finally {
con.close();
}
}
开发者ID:apache,项目名称:marmotta,代码行数:18,代码来源:TextFunctionsTest.java
示例15: RepositorySource
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
/**
* Updates the set of rules used for query rewriting.
*
* @param conn the connection to use
*/
public final synchronized void
updateOntology(SailRepositoryConnection conn) {
try {
// reload the graph and if not empty load rules from the graph
URI ctx = conn.getValueFactory().createURI(ontologyContext);
if (conn.size(ctx) > 0) {
rules = Rules.fromOntology(new RepositorySource());
}
} catch (RepositoryException ex) {
throw new RuntimeException(ex);
}
}
开发者ID:lszeremeta,项目名称:neo4j-sparql-extension-yars,代码行数:18,代码来源:QueryRewriterFactory.java
示例16: QueryRewriter
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
/**
* Create a new query rewriter with a set of rules.
*
* @param conn the repository connection used for query execution
* @param rules the set of rules used for rewriting
*/
public QueryRewriter(
SailRepositoryConnection conn,
List<Rule> rules) {
this.rules = new ArrayList<>(rules);
this.conn = conn;
this.vf = conn.getValueFactory();
for (Rule r : rules) {
r.setValueFactory(vf);
}
}
开发者ID:lszeremeta,项目名称:neo4j-sparql-extension-yars,代码行数:17,代码来源:QueryRewriter.java
示例17: loadRdf
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@RequestMapping(value = "/loadrdf", method = RequestMethod.POST)
public void loadRdf(@RequestParam(required = false) final String format,
@RequestParam(value = RdfCloudTripleStoreConfiguration.CONF_CV, required = false) final String cv,
@RequestParam(required = false) final String graph,
@RequestBody final String body,
final HttpServletResponse response)
throws RepositoryException, IOException, RDFParseException {
final List<Resource> authList = new ArrayList<Resource>();
RDFFormat format_r = RDFFormat.RDFXML;
if (format != null) {
format_r = RDFFormat.valueOf(format);
if (format_r == null) {
throw new RuntimeException("RDFFormat[" + format + "] not found");
}
}
if (graph != null) {
authList.add(VALUE_FACTORY.createURI(graph));
}
SailRepositoryConnection conn = null;
try {
conn = repository.getConnection();
if (conn.getSailConnection() instanceof RdfCloudTripleStoreConnection && cv != null) {
final RdfCloudTripleStoreConnection<?> sailConnection = (RdfCloudTripleStoreConnection<?>) conn.getSailConnection();
sailConnection.getConf().set(RdfCloudTripleStoreConfiguration.CONF_CV, cv);
}
conn.add(new StringReader(body), "", format_r);
conn.commit();
} finally {
if (conn != null) {
conn.close();
}
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:36,代码来源:RdfController.java
示例18: getConnection
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Override
public SailRepositoryConnection getConnection() throws RepositoryException {
try
{
return new RyaSailRepositoryConnection(this, this.getSail().getConnection());
}
catch(SailException e)
{
throw new RepositoryException(e);
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:12,代码来源:RyaSailRepository.java
示例19: testGraphConfiguration
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
@Test
public void testGraphConfiguration() throws Exception {
// build a connection
RdfCloudTripleStore store = new RdfCloudTripleStore();
store.setConf(conf);
store.setRyaDAO(ryaDAO);
InferenceEngine inferenceEngine = new InferenceEngine();
inferenceEngine.setRyaDAO(ryaDAO);
store.setInferenceEngine(inferenceEngine);
inferenceEngine.refreshGraph();
store.initialize();
SailRepository repository = new SailRepository(store);
SailRepositoryConnection conn = repository.getConnection();
String query = "INSERT DATA\n"//
+ "{ GRAPH <http://updated/test> {\n"//
+ " <urn:greatMother> owl:propertyChainAxiom <urn:12342> . " +
" <urn:12342> <http://www.w3.org/1999/02/22-rdf-syntax-ns#first> _:node1atjakcvbx15023 . " +
" _:node1atjakcvbx15023 <http://www.w3.org/2002/07/owl#inverseOf> <urn:isChildOf> . " +
" <urn:12342> <http://www.w3.org/1999/02/22-rdf-syntax-ns#rest> _:node1atjakcvbx15123 . " +
" _:node1atjakcvbx15123 <http://www.w3.org/1999/02/22-rdf-syntax-ns#rest> <http://www.w3.org/1999/02/22-rdf-syntax-ns#nil> . " +
" _:node1atjakcvbx15123 <http://www.w3.org/1999/02/22-rdf-syntax-ns#first> <urn:MotherOf> . }}";
Update update = conn.prepareUpdate(QueryLanguage.SPARQL, query);
update.execute();
inferenceEngine.refreshGraph();
List<URI> chain = inferenceEngine.getPropertyChain(vf.createURI("urn:greatMother"));
Assert.assertEquals(chain.size(), 2);
Assert.assertEquals(chain.get(0), new InverseURI(vf.createURI("urn:isChildOf")));
Assert.assertEquals(chain.get(1), vf.createURI("urn:MotherOf"));
}
开发者ID:apache,项目名称:incubator-rya,代码行数:34,代码来源:PropertyChainTest.java
示例20: runTest
import org.openrdf.repository.sail.SailRepositoryConnection; //导入依赖的package包/类
public void runTest(final String sparql, final Collection<Statement> statements, final Collection<BindingSet> expectedResults) throws Exception {
requireNonNull(sparql);
requireNonNull(statements);
requireNonNull(expectedResults);
// Register the PCJ with Rya.
final Instance accInstance = super.getAccumuloConnector().getInstance();
final Connector accumuloConn = super.getAccumuloConnector();
final RyaClient ryaClient = AccumuloRyaClientFactory.build(new AccumuloConnectionDetails(
getUsername(),
getPassword().toCharArray(),
accInstance.getInstanceName(),
accInstance.getZooKeepers()), accumuloConn);
ryaClient.getCreatePCJ().createPCJ(getRyaInstanceName(), sparql);
// Write the data to Rya.
final SailRepositoryConnection ryaConn = super.getRyaSailRepository().getConnection();
ryaConn.begin();
ryaConn.add(statements);
ryaConn.commit();
ryaConn.close();
// Wait for the Fluo application to finish computing the end result.
super.getMiniFluo().waitForObservers();
// Fetch the value that is stored within the PCJ table.
try(final PrecomputedJoinStorage pcjStorage = new AccumuloPcjStorage(accumuloConn, getRyaInstanceName())) {
final String pcjId = pcjStorage.listPcjs().get(0);
final Set<BindingSet> results = Sets.newHashSet( pcjStorage.listResults(pcjId) );
// Ensure the result of the query matches the expected result.
assertEquals(expectedResults, results);
}
}
开发者ID:apache,项目名称:incubator-rya,代码行数:37,代码来源:GeoFunctionsIT.java
注:本文中的org.openrdf.repository.sail.SailRepositoryConnection类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论