org.openrdf.query.Dataset类的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(8.3k)|赞(0)|评价(0)|浏览(140)

本文整理了Java中org.openrdf.query.Dataset类的一些代码示例，展示了Dataset类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Dataset类的具体详情如下：
包路径：org.openrdf.query.Dataset
类名称：Dataset

Dataset介绍

[英]Represents a dataset against which operations can be evaluated. A dataset consists of a default graph for read and using operations, which is the RDF merge of one or more graphs, a set of named graphs, and a single update graph for INSERT and DELETE. See SPARQL Query Language for RDF for more info.
[中]表示可以对其计算操作的数据集。数据集由一个用于读取和使用操作的默认图组成，该图是一个或多个图的RDF merge，一组命名图，以及一个用于插入和删除的更新图。有关更多信息，请参见SPARQL Query Language for RDF。

代码示例

代码示例来源：origin: org.openrdf.sesame/sesame-sail-rdbms

private Set<URI> getGraphs(StatementPattern sp) {
  if (dataset == null)
    return null;
  if (dataset.getDefaultGraphs().isEmpty() && dataset.getNamedGraphs().isEmpty())
    return null;
  if (sp.getScope() == Scope.DEFAULT_CONTEXTS)
    return dataset.getDefaultGraphs();
  return dataset.getNamedGraphs();
}

代码示例来源：origin: org.openrdf.sesame/sesame-http-client

for (IRI graphURI : dataset.getDefaultRemoveGraphs()) {
  queryParams.add(
      new BasicNameValuePair(Protocol.REMOVE_GRAPH_PARAM_NAME, String.valueOf(graphURI)));
if (dataset.getDefaultInsertGraph() != null) {
  queryParams.add(new BasicNameValuePair(Protocol.INSERT_GRAPH_PARAM_NAME,
      String.valueOf(dataset.getDefaultInsertGraph())));
for (IRI defaultGraphURI : dataset.getDefaultGraphs()) {
  queryParams.add(
      new BasicNameValuePair(Protocol.USING_GRAPH_PARAM_NAME, String.valueOf(defaultGraphURI)));
for (IRI namedGraphURI : dataset.getNamedGraphs()) {
  queryParams.add(new BasicNameValuePair(Protocol.USING_NAMED_GRAPH_PARAM_NAME,
      String.valueOf(namedGraphURI)));

代码示例来源：origin: org.openrdf.sesame/sesame-query

public Set<IRI> getDefaultGraphs() {
  Set<IRI> set = primary.getDefaultGraphs();
  if (set == null || set.isEmpty())
    return fallback.getDefaultGraphs();
  return set;
}

代码示例来源：origin: org.openrdf.sesame/sesame-query

public Set<IRI> getNamedGraphs() {
  Set<IRI> set = primary.getNamedGraphs();
  if (set == null || set.isEmpty())
    return fallback.getNamedGraphs();
  return set;
}

代码示例来源：origin: org.openrdf.sesame/sesame-query

public IRI getDefaultInsertGraph() {
  IRI graph = primary.getDefaultInsertGraph();
  if (graph == null)
    return fallback.getDefaultInsertGraph();
  return graph;
}

代码示例来源：origin: org.openrdf.sesame/sesame-query

public Set<IRI> getDefaultRemoveGraphs() {
  Set<IRI> set = primary.getDefaultRemoveGraphs();
  if (set == null || set.isEmpty())
    return fallback.getDefaultRemoveGraphs();
  return set;
}

代码示例来源：origin: anno4j/anno4j

logger.info("\nGRAPH CONTEXT = " + query.getDataset().getDefaultGraphs() + "\nFINAL QUERY :\n" + q);
} else {
  logger.info("\nFINAL QUERY :\n" + q);

代码示例来源：origin: org.openrdf.alibaba/alibaba-sail-auditing

@Override
public void executeDelete(UpdateExpr updateExpr, Dataset ds,
    BindingSet bindings, Resource subj, URI pred, Value obj,
    Resource... ctx) throws SailException {
  URI bundle = ds == null ? null : ds.getDefaultInsertGraph();
  if (bundle == null) {
    removeStatements(subj, pred, obj, ctx);
  } else {
    URI entity = entityResolver.getEntity(updateExpr, ds, bindings);
    removeInforming(bundle, entity, subj, pred, obj, ctx);
  }
}

代码示例来源：origin: org.openrdf.sesame/sesame-repository-sail

private IRI[] getDefaultRemoveGraphs(Dataset dataset) {
  if (dataset == null)
    return new IRI[0];
  Set<IRI> set = dataset.getDefaultRemoveGraphs();
  if (set == null || set.isEmpty())
    return new IRI[0];
  return set.toArray(new IRI[set.size()]);
}

代码示例来源：origin: blazegraph/database

public DatasetNode(final Dataset dataset, final boolean update) {
  
  this(DataSetSummary.toInternalValues(dataset.getDefaultGraphs()),
      DataSetSummary.toInternalValues(dataset.getNamedGraphs()),
      update);
}

代码示例来源：origin: blazegraph/database

private Dataset handleDataset(final AbstractTripleStore store, final Dataset dataset) {
  if (dataset != null) {
    DatasetImpl newDataset = new DatasetImpl();
    
    for (final URI uri: dataset.getDefaultGraphs()) {
      URI value = handleDatasetGraph(store, uri);
      newDataset.addDefaultGraph(value);
    }
    for (final URI uri: dataset.getDefaultRemoveGraphs()) {
      URI value = handleDatasetGraph(store, uri);
      newDataset.addDefaultRemoveGraph(value);
    }
    for (final URI uri: dataset.getNamedGraphs()) {
      URI value = handleDatasetGraph(store, uri);
      newDataset.addNamedGraph(value);
    }
    URI value = handleDatasetGraph(store, dataset.getDefaultInsertGraph());
    newDataset.setDefaultInsertGraph(value);
    return newDataset;
  }
  return dataset;
}

代码示例来源：origin: org.openrdf.alibaba/alibaba-sail-auditing

public synchronized URI getEntity(QueryModelNode node, Dataset dataset, BindingSet bindings) {
  if (dataset == null || node == null)
    return null;
  URI activity = dataset.getDefaultInsertGraph();
  if (activity == null || activity.stringValue().indexOf('#') >= 0)
    return null;

代码示例来源：origin: org.openrdf.sesame/sesame-repository-sail

final Set<IRI> removeGraphs = uc.getDataset().getDefaultRemoveGraphs();
if (!removeGraphs.isEmpty()) {
  con.removeStatement(uc, subj, pred, obj, new IRI[removeGraphs.size()]);

代码示例来源：origin: blazegraph/database

protected String readInputData(Dataset dataset) throws Exception {
  
  final StringBuilder sb = new StringBuilder();
  if (dataset != null) {
    Set<URI> graphURIs = new HashSet<URI>();
    graphURIs.addAll(dataset.getDefaultGraphs());
    graphURIs.addAll(dataset.getNamedGraphs());

    for (Resource graphURI : graphURIs) {
      URL graphURL = new URL(graphURI.toString());
      InputStream in = graphURL.openStream();
      sb.append(IOUtil.readString(in));
    }
  }
  
  return sb.toString();
  
}

代码示例来源：origin: com.blazegraph/bigdata-core

private Dataset handleDataset(final AbstractTripleStore store, final Dataset dataset) {
  if (dataset != null) {
    DatasetImpl newDataset = new DatasetImpl();
    
    for (final URI uri: dataset.getDefaultGraphs()) {
      URI value = handleDatasetGraph(store, uri);
      newDataset.addDefaultGraph(value);
    }
    for (final URI uri: dataset.getDefaultRemoveGraphs()) {
      URI value = handleDatasetGraph(store, uri);
      newDataset.addDefaultRemoveGraph(value);
    }
    for (final URI uri: dataset.getNamedGraphs()) {
      URI value = handleDatasetGraph(store, uri);
      newDataset.addNamedGraph(value);
    }
    URI value = handleDatasetGraph(store, dataset.getDefaultInsertGraph());
    newDataset.setDefaultInsertGraph(value);
    return newDataset;
  }
  return dataset;
}

代码示例来源：origin: org.openrdf.alibaba/alibaba-sail-auditing

@Override
public void executeUpdate(UpdateExpr updateExpr, Dataset ds,
    BindingSet bindings, boolean includeInferred) throws SailException {
  SailConnection remover = this;
  final URI bundle = ds == null ? null : ds.getDefaultInsertGraph();
  if (bundle != null) {
    QueryModelNode node = updateExpr;
    if (updateExpr instanceof Modify) {
      node = ((Modify) updateExpr).getDeleteExpr();
    }
    final URI entity = entityResolver.getEntity(node, ds, bindings);
    remover = new SailConnectionWrapper(this) {
      public void removeStatements(Resource subj, URI pred,
          Value obj, Resource... ctx) throws SailException {
        removeInforming(bundle, entity, subj, pred, obj, ctx);
      }
    };
  }
  SailUpdateExecutor executor = new SailUpdateExecutor(remover, vf, false);
  executor.executeUpdate(updateExpr, ds, bindings, includeInferred);
}

代码示例来源：origin: com.blazegraph/bigdata-core

public DatasetNode(final Dataset dataset, final boolean update) {
  
  this(DataSetSummary.toInternalValues(dataset.getDefaultGraphs()),
      DataSetSummary.toInternalValues(dataset.getNamedGraphs()),
      update);
}

代码示例来源：origin: org.openrdf.sesame/sesame-http-protocol

for (IRI defaultGraph : dataset.getDefaultGraphs()) {
  xmlWriter.textElement(TransactionXMLConstants.GRAPH_TAG, defaultGraph.stringValue());
for (IRI namedGraph : dataset.getNamedGraphs()) {
  xmlWriter.textElement(TransactionXMLConstants.GRAPH_TAG, namedGraph.stringValue());
for (IRI defaultRemoveGraph : dataset.getDefaultRemoveGraphs()) {
  xmlWriter.textElement(TransactionXMLConstants.GRAPH_TAG, defaultRemoveGraph.stringValue());
if (dataset.getDefaultInsertGraph() != null) {
  xmlWriter.textElement(TransactionXMLConstants.DEFAULT_INSERT_GRAPH,
      dataset.getDefaultInsertGraph().stringValue());

代码示例来源：origin: org.openrdf.sesame/sesame-repository-sail

@Override
protected void addStatement(Resource subj, IRI pred, Value obj, Resource ctxt) throws OpenRDFException
{
  if (enforcesContext()) {
    addStatement(uc, subj, pred, obj, contexts);
  }
  else {
    if (uc != null && ctxt == null) {
        final IRI insertGraph = uc.getDataset().getDefaultInsertGraph();
      if (insertGraph != null) {
        addStatement(uc, subj, pred, obj, insertGraph);
      }
      else {
        addStatement(uc, subj, pred, obj);
      }
    }
    else {
      addStatement(uc, subj, pred, obj, ctxt);
    }
  }
}

代码示例来源：origin: blazegraph/database

@Override
  protected void uploadDataset(Dataset dataset)
    throws Exception
  {
//        RepositoryConnection con = dataRep.getConnection();
//        try {
      // Merge default and named graphs to filter duplicates
      Set<URI> graphURIs = new HashSet<URI>();
      graphURIs.addAll(dataset.getDefaultGraphs());
      graphURIs.addAll(dataset.getNamedGraphs());

      for (Resource graphURI : graphURIs) {
        upload(((URI)graphURI), graphURI);
      }
//        }
//        finally {
//            con.close();
//        }
  }

内容来源于网络，如有侵权，请联系作者删除！

Dataset

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com