org.eclipse.rdf4j.repository.RepositoryConnection.getContextIDs()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.7k)|赞(0)|评价(0)|浏览(57)

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

RepositoryConnection.getContextIDs介绍

[英]Gets all resources that are used as content identifiers. Care should be taken that the returned RepositoryResult is closed to free any resources that it keeps hold of.
[中]获取用作内容标识符的所有资源。应注意关闭返回的RepositoryResult以释放其保留的任何资源。

代码示例

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-client

@Override
public RepositoryResult<Resource> getContextIDs()
  throws RepositoryException
{
  return getDelegate().getContextIDs();
}

代码示例来源:origin: eclipse/rdf4j

@Override
public RepositoryResult<Resource> getContextIDs()
  throws RepositoryException
{
  return getDelegate().getContextIDs();
}

代码示例来源:origin: com.powsybl/powsybl-triple-store-impl-rdf4j

@Override
public Set<String> contextNames() {
  try (RepositoryConnection conn = repo.getConnection()) {
    return Iterations.stream(conn.getContextIDs()).map(Resource::stringValue).collect(Collectors.toSet());
  }
}

代码示例来源:origin: joshsh/sesametools

protected CloseableIteration<? extends Resource, SailException> getContextIDsInternal()
    throws SailException {
  try {
    return new RepositoryResourceIteration(repoConnection.getContextIDs());
  } catch (RepositoryException e) {
    throw new SailException(e);
  }
}

代码示例来源:origin: com.powsybl/powsybl-triple-store-impl-rdf4j

@Override
public void print(PrintStream out) {
  out.println("TripleStore based on RDF4J. Graph names and sizes");
  try (RepositoryConnection conn = repo.getConnection()) {
    RepositoryResult<Resource> ctxs = conn.getContextIDs();
    while (ctxs.hasNext()) {
      Resource ctx = ctxs.next();
      int size = statementsCount(conn, ctx);
      out.println("    " + ctx + " : " + size);
    }
  }
}

代码示例来源:origin: streampipes/streampipes-ce

public List<String> getAvailableContexts() {
  List<String> contexts = new ArrayList<>();
  
  try {
    RepositoryConnection conn = getConnection();
    {
      RepositoryResult<Resource> result = conn.getContextIDs();
      while(result.hasNext())
      {
        Resource resource = result.next();
        contexts.add(resource.stringValue());
      }
    }
    closeConnection(conn);
  } catch (Exception e)
  {
    e.printStackTrace();
  }
  
  return contexts;
}

代码示例来源:origin: org.streampipes/streampipes-storage-rdf4j

public List<String> getAvailableContexts() {
  List<String> contexts = new ArrayList<>();
  
  try {
    RepositoryConnection conn = getConnection();
    {
      RepositoryResult<Resource> result = conn.getContextIDs();
      while(result.hasNext())
      {
        Resource resource = result.next();
        contexts.add(resource.stringValue());
      }
    }
    closeConnection(conn);
  } catch (Exception e)
  {
    e.printStackTrace();
  }
  
  return contexts;
}

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-http-server-spring

RepositoryConnection repositoryCon = RepositoryInterceptor.getRepositoryConnection(request);
try {
  CloseableIteration<? extends Resource, RepositoryException> contextIter = repositoryCon.getContextIDs();

代码示例来源:origin: com.powsybl/powsybl-triple-store-impl-rdf4j

@Override
public void write(DataSource ds) {
  try (RepositoryConnection conn = repo.getConnection()) {
    RepositoryResult<Resource> contexts = conn.getContextIDs();
    while (contexts.hasNext()) {
      Resource context = contexts.next();
      LOGGER.info("Writing context {}", context);
      RepositoryResult<Statement> statements;
      statements = conn.getStatements(null, null, null, context);
      Model model = QueryResults.asModel(statements);
      copyNamespacesToModel(conn, model);
      String outname = context.toString();
      write(model, outputStream(ds, outname));
    }
  }
}

代码示例来源:origin: com.powsybl/powsybl-triple-store-impl-rdf4j

@Override
public void add(String graph, String objType, PropertyBags statements) {
  try (RepositoryConnection conn = repo.getConnection()) {
    conn.setIsolationLevel(IsolationLevels.NONE);
    String name = null;
    RepositoryResult<Resource> ctxs = conn.getContextIDs();
    while (ctxs.hasNext()) {
      String ctx = ctxs.next().stringValue();
      if (ctx.contains("EQ")) {
        name = ctx.replace("EQ", graph);
        break;
      }
    }
    Resource context = conn.getValueFactory().createIRI(name);
    statements.forEach(statement -> createStatements(conn, objType, statement, context));
  }
}

代码示例来源:origin: franzinc/agraph-java-client

@Test
public void testGetContextIDs()
    throws Exception {
  assertEquals(0, testCon.getContextIDs().asList().size());
  // load data
  testCon.setAutoCommit(false);
  testCon.add(bob, name, nameBob, context1);
  assertEquals(Arrays.asList(context1), Iterations.asList(testCon.getContextIDs()));
  testCon.remove(bob, name, nameBob, context1);
  assertEquals(0, Iterations.asList(testCon.getContextIDs()).size());
  testCon.setAutoCommit(true);
  assertEquals(0, Iterations.asList(testCon.getContextIDs()).size());
  testCon.add(bob, name, nameBob, context2);
  assertEquals(Arrays.asList(context2), Iterations.asList(testCon.getContextIDs()));
}

相关文章

微信公众号

最新文章

更多