本文整理了Java中org.eclipse.rdf4j.repository.RepositoryConnection.getContextIDs
方法的一些代码示例,展示了RepositoryConnection.getContextIDs
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RepositoryConnection.getContextIDs
方法的具体详情如下:
包路径:org.eclipse.rdf4j.repository.RepositoryConnection
类名称: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()));
}
内容来源于网络,如有侵权,请联系作者删除!