Java UpdateFactory类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

本文整理汇总了Java中com.hp.hpl.jena.update.UpdateFactory类的典型用法代码示例。如果您正苦于以下问题：Java UpdateFactory类的具体用法？Java UpdateFactory怎么用？Java UpdateFactory使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

UpdateFactory类属于com.hp.hpl.jena.update包，在下文中一共展示了UpdateFactory类的9个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: executeUpdateQuerySparqlEndpoint

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
/**
 * It executes an UPDATE SPARQL query on the SPARQL endpoint.
 *
 * @param sparqlEndpointURI		the SPARQL endpoint URI.  
 * @param user					the user name for the SPARQl endpoint.
 * @param password				the password for the SPARQl endpoint.
 * @param query					the UPDATE query to execute.
 * @return true if the SPARQL has been executed. False otherwise.
 * @since 1.0
 */
public boolean executeUpdateQuerySparqlEndpoint(final String sparqlEndpointURI, final String user, final String password, final String query) {
	boolean done = false;
	try {
		UpdateExecutionFactory.createRemoteForm(
				UpdateFactory.create(query), 
				sparqlEndpointURI, 
				context(),
				auth(sparqlEndpointURI, user, password))
			.execute();
		done = true;
	} catch (Exception exception) {
		LOGGER.error(MessageCatalog._00035_SPARQL_FAILED, exception, query);
	}
	return done;
}

开发者ID:ALIADA，项目名称:aliada-tool，代码行数:26，代码来源:RDFStoreDAO.java

示例2: executeUpdate

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
/**
 * Executes a given update command both on remote and local model.
 * 
 * @param data the object holding test data (i.e. commands, queries, datafiles).
 * @throws Exception hopefully never otherwise the corresponding test fails.
 */
protected void executeUpdate(final MisteryGuest data) throws Exception {
	load(data);
	
	final String updateCommandString = readFile(data.query);
	UpdateExecutionFactory.createRemote(UpdateFactory.create(updateCommandString), SPARQL_ENDPOINT_URI).execute();

	SOLRDF_CLIENT.commit();

	UpdateAction.parseExecute(updateCommandString, memoryDataset.asDatasetGraph());
	
	final Iterator<Node> nodes = memoryDataset.asDatasetGraph().listGraphNodes();
	if (nodes != null) {
		while (nodes.hasNext()) {
			final Node graphNode = nodes.next();
			final String graphUri = graphNode.getURI();
			final Model inMemoryNamedModel = memoryDataset.getNamedModel(graphUri);
			assertIsomorphic(inMemoryNamedModel, SOLRDF_CLIENT.getNamedModel(graphUri), graphUri);		
		}
	}
	
	assertIsomorphic(memoryDataset.getDefaultModel(), SOLRDF_CLIENT.getDefaultModel(), null);			
}

开发者ID:spaziocodice，项目名称:SolRDF，代码行数:29，代码来源:IntegrationTestSupertypeLayer.java

示例3: save

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
public void save(Observation o) {
    cache.add(o);
    batchSize++;

    if (batchSize >= CONFIG.sparqlMaxBatchSize()) {
        try {
            logger.debug("Flushing the cache...");
            UpdateRequest request = UpdateFactory.create(modelToQuery(cache));
            UpdateExecutionFactory.createRemote(
                    request, endpoint, authenticator).execute();
            batchSize = 0;
            cache.clear();
        } catch (IOException ex) {
            logger.warn(ex.getMessage(), ex);
        }
    }
}

开发者ID:ailabitmo，项目名称:DAAFSE，代码行数:18，代码来源:Store.java

示例4: entailSKOSModel

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
private void entailSKOSModel() {
  GraphStore graphStore = GraphStoreFactory.create(skosModel) ;
  String sparqlQuery = StringUtils.join(new String[]{
      "PREFIX skos: <http://www.w3.org/2004/02/skos/core#>",
      "PREFIX skos-ehri: <http://data.ehri-project.eu/skos-extension#>",
      "PREFIX rdf:<http://www.w3.org/1999/02/22-rdf-syntax-ns#>",
      "INSERT { ?subject rdf:type skos:Concept }",
      "WHERE {",
        "{ ?subject skos:prefLabel ?text } UNION",
        "{ ?subject skos:altLabel ?text } UNION",
        "{ ?subject skos-ehri:prefMaleLabel ?text } UNION",
        "{ ?subject skos-ehri:prefFemaleLabel ?text } UNION",
        "{ ?subject skos-ehri:prefNeuterLabel ?text } UNION",
        "{ ?subject skos-ehri:altMaleLabel ?text } UNION",
        "{ ?subject skos-ehri:altFemaleLabel ?text } UNION",
        "{ ?subject skos-ehri:altNeuterLabel ?text } UNION",
        "{ ?subject skos:hiddenLabel ?text }",
       "}",
      }, "\n");
  UpdateRequest request = UpdateFactory.create(sparqlQuery);
  UpdateAction.execute(request, graphStore) ;
}

开发者ID:KepaJRodriguez，项目名称:lucene-skos-ehri，代码行数:23，代码来源:SKOSEngineImpl.java

示例5: executeInsert

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
/**
 * It executes an INSERT SPARQL query on the SPARQL endpoint.
 *
 * @param sparqlEndpointURI		the SPARQL endpoint URI.  
 * @param user					the user name for the SPARQl endpoint.
 * @param password				the password for the SPARQl endpoint.
 * @param triples				the triples that will be added.
 * throws Exception in case the INSERT goes wrong.
 * @since 1.0
 */
public void executeInsert(
		final String sparqlEndpointURI, 
		final String graphName, 
		final String user, 
		final String password, 
		final String triples) throws Exception {
	UpdateExecutionFactory.createRemoteForm(
			UpdateFactory.create(buildInsertQuery(graphName, triples)), 
			sparqlEndpointURI, 
			context(),
			auth(sparqlEndpointURI, user, password))
		.execute();
}

开发者ID:ALIADA，项目名称:aliada-tool，代码行数:24，代码来源:RDFStoreDAO.java

示例6: executeDelete

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
/**
 * It executes an DELETE SPARQL query on the SPARQL endpoint.
 *
 * @param sparqlEndpointURI		the SPARQL endpoint URI.  
 * @param graphName the graphName, null in case of default graph.
 * @param user					the user name for the SPARQl endpoint.
 * @param password				the password for the SPARQl endpoint.
 * @param triples				the triples that will be removed.
 * throws Exception in case the DELETE goes wrong.
 * @since 2.0
 */
public void executeDelete(
		final String sparqlEndpointURI, 
		final String graphName, 
		final String user, 
		final String password, 
		final String triples) throws Exception {
	UpdateExecutionFactory.createRemoteForm(
			UpdateFactory.create(buildDeleteQuery(graphName, triples)), 
			sparqlEndpointURI, 
			context(),
			auth(sparqlEndpointURI, user, password))
		.execute();
}

开发者ID:ALIADA，项目名称:aliada-tool，代码行数:25，代码来源:RDFStoreDAO.java

示例7: updateDataset

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
private void updateDataset(String updateString, HttpServletRequest request, HttpServletResponse response) 
		throws IOException {
	Config config = new Config(request);
	Dataset tdbstore = TDBFactory.createDataset(config.getTripleStoreDir());
	UpdateRequest update = UpdateFactory.create(updateString);
	UpdateAction.execute(update, tdbstore);
	out.print("Updated");
	TDB.sync(tdbstore);
}

开发者ID:IKCAP，项目名称:turbosoft，代码行数:10，代码来源:SparqlEndpoint.java

示例8: clearAll

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
public void clearAll() {
    UpdateRequest request = null;
    if (CONFIG.sparqlVendor().equalsIgnoreCase(PublisherConfig.VIRTUOSO)) {
        Query select = QueryFactory.create(
                "SELECT DISTINCT ?g { GRAPH ?g {?x ?y ?z}"
                + "FILTER(strStarts(str(?g), \"" + Observation.METERS + "\"))}");
        ResultSet result = QueryExecutionFactory.createServiceRequest(
                endpoint, select, authenticator).execSelect();
        StringBuilder cleanQuery = new StringBuilder();
        int count = 0;
        while (result.hasNext()) {
            String graphUri = result.next().getResource("g").getURI();
            cleanQuery.append("CLEAR GRAPH <").append(graphUri).append("> ;\n");
            if (++count > 4) {
                request = UpdateFactory.create(cleanQuery.toString());
                UpdateExecutionFactory.createRemote(
                        request, endpoint, authenticator).execute();
                count = 0;
                cleanQuery = new StringBuilder();
            }
            if (count > 0) {
                request = UpdateFactory.create(cleanQuery.toString());
                UpdateExecutionFactory.createRemote(
                        request, endpoint, authenticator).execute();
            }
        }
    } else {
        request = UpdateFactory.create("CLEAR ALL");
        UpdateExecutionFactory.createRemote(
                request, endpoint, authenticator).execute();
    }
}

开发者ID:ailabitmo，项目名称:DAAFSE，代码行数:33，代码来源:Store.java

示例9: main

import com.hp.hpl.jena.update.UpdateFactory; //导入依赖的package包/类
public static void main(String [] args)
{
	// Set up the ModelD2RQ using a mapping file
	String workingDir = System.getProperty("user.dir");		
	String propFile = workingDir + "/mapping-iswc2.ttl";
	
	String pckg = "de.fuberlin.wiwiss.d2rq.";
	Logger rdqlLogger = Logger.getLogger(pckg + "RDQL");
	
	org.apache.log4j.BasicConfigurator.configure();
	
	rdqlLogger.setLevel(Level.DEBUG);

	Model m = new de.fuberlin.wiwiss.d2rq.ModelD2RQ("file:" + propFile);
	
	String sparql = "CONSTRUCT {?s ?p ?o.} WHERE {?s ?p ?o.}";
	Query q = QueryFactory.create(sparql); 
	//ResultSet rs = QueryExecutionFactory.create(q, m).execSelect();
	Model m2 = QueryExecutionFactory.create(q, m).execConstruct();
	/*while (rs.hasNext()) {
	    QuerySolution row = rs.nextSolution();
	    System.out.println("Got here ");
	    //System.out.println(row.)
	};*/
	StmtIterator stmti = m2.listStatements();
	while(stmti.hasNext())
	{
		Statement stmt = stmti.next();
		System.out.println(stmt.getSubject()+ "<<>>" + stmt.getPredicate() + "<<>>" + stmt.getObject());
	}
	
	//String sparql = "SELECT ?s ?p ?o WHERE {?s <http://annotation.semanticweb.org/iswc/iswc.daml#FirstName> \"Yolanda\"^^<http://www.w3.org/2001/XMLSchema#string>}";
	//String sparql = "SELECT ?s ?p ?o WHERE {?s <http://annotation.semanticweb.org/iswc/iswc.daml#phone> ?o}";
	/*Query q2 = QueryFactory.create(sparql); 
	ResultSet rs = QueryExecutionFactory.create(q2, m).execSelect();
	while (rs.hasNext()) {
	    QuerySolution row = rs.nextSolution();
	    
	    System.out.println("-->" + row.get("s") + "<<>>" + row.get("p") + "<<>>" +row.get("o"));
	    
	    //System.out.println("Title: " + row.getLiteral("paperTitle").getString());
	    //System.out.println("Author: " + row.getLiteral("authorName").getString());
	};*/
	
	// Trying sparql insert
	System.out.println("Trying insert ");
	
	Model m3 = new ModelD2RQUpdate("file:" + propFile);

	
	String sparql2 = "DELETE {?person <http://annotation.semanticweb.org/iswc/iswc.daml#phone> \"666\"^^<http://www.w3.org/2001/XMLSchema#string>} WHERE { ?person <http://annotation.semanticweb.org/iswc/iswc.daml#FirstName> \"Yolanda\"^^<http://www.w3.org/2001/XMLSchema#string>}";
	String sparql4 = "INSERT {<http://conferences.org/comp/confno#90> <http://annotation.semanticweb.org/iswc/iswc.daml#phone> \"666\"^^<http://www.w3.org/2001/XMLSchema#string>}";
	String sparql3 = "MODIFY DELETE " + "{?person <http://annotation.semanticweb.org/iswc/iswc.daml#phone> \"666\"^^<http://www.w3.org/2001/XMLSchema#string>}" +
		"INSERT { ?person <http://annotation.semanticweb.org/iswc/iswc.daml#phone> \"667\"^^<http://www.w3.org/2001/XMLSchema#string> }" + 
		"WHERE { ?person <http://annotation.semanticweb.org/iswc/iswc.daml#FirstName> \"Varun\"^^<http://www.w3.org/2001/XMLSchema#string>}";
	
	UpdateRequest u = UpdateFactory.create(sparql4);
	UpdateAction.execute(u, m2);
	System.out.println("Done Inserts ");
	
	m2.close();
	m.close();
}

开发者ID:SEMOSS，项目名称:semoss，代码行数:64，代码来源:D2RQTester.java

注：本文中的com.hp.hpl.jena.update.UpdateFactory类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。