• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java SailRepositoryConnection类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了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;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java FixedBackOffPolicy类代码示例发布时间:2022-05-22
下一篇:
Java CpuFeatures类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap