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

RepositoryConnection.rollback介绍

[英]Rolls back all updates in the active transaction. This operation ends the active transaction.
[中]回滚活动事务中的所有更新。此操作将结束活动事务。

代码示例

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

@Override
public void rollback()
  throws RepositoryException
{
  getDelegate().rollback();
}

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

@Override
public void rollback()
  throws RepositoryException
{
  getDelegate().rollback();
}

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

protected void rollbackInternal() throws SailException {
  try {
    repoConnection.rollback();
  } catch (RepositoryException e) {
    throw new SailException(e);
  }
}

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

/**
 * Rolls back all updates in the transaction.
 * 
 * @throws ExecutionException
 * @throws InterruptedException
 */
void rollback()
  throws InterruptedException, ExecutionException
{
  Future<Boolean> result = submit(() -> {
    txnConnection.rollback();
    return true;
  });
  getFromFuture(result);
}

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

/**
 * Closes the connection, freeing resources. If a {@link #begin() transaction} is {@link #isActive()
 * active} on the connection, all non-committed operations will be lost by actively calling
 * {@link #rollback()} on any active transactions.
 * <p>
 * Implementation note: All implementations must override this method if they have any resources that they
 * need to free.
 * 
 * @throws RepositoryException
 *         If the connection could not be closed.
 */
@Override
public default void close()
  throws RepositoryException
{
  if (isOpen() && isActive()) {
    rollback();
  }
}

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

/**
 * Closes the connection, freeing resources. If a {@link #begin() transaction} is {@link #isActive()
 * active} on the connection, all non-committed operations will be lost by actively calling
 * {@link #rollback()} on any active transactions.
 * <p>
 * Implementation note: All implementations must override this method if they have any resources that they
 * need to free.
 * 
 * @throws RepositoryException
 *         If the connection could not be closed.
 */
@Override
public default void close()
  throws RepositoryException
{
  if (isOpen() && isActive()) {
    rollback();
  }
}

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

@Override
public void rollback()
  throws RepositoryException
{
  getDelegate().rollback();
  if (activated) {
    for (RepositoryConnectionListener listener : listeners) {
      listener.rollback(getDelegate());
    }
  }
}

代码示例来源：origin: org.eclipse.rdf4j/rdf4j-repository-event

@Override
public void rollback()
  throws RepositoryException
{
  getDelegate().rollback();
  if (activated) {
    for (RepositoryConnectionListener listener : listeners) {
      listener.rollback(getDelegate());
    }
  }
}

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

@Override
public void rollback()
  throws RepositoryException
{
  getDelegate().rollback();
  if (activated) {
    for (RepositoryConnectionListener listener : listeners) {
      listener.rollback(getDelegate());
    }
  }
}

代码示例来源：origin: org.eclipse.rdf4j/rdf4j-repository-event

@Override
public void rollback()
  throws RepositoryException
{
  boolean denied = false;
  if (activated) {
    for (RepositoryConnectionInterceptor interceptor : interceptors) {
      denied = interceptor.rollback(getDelegate());
      if (denied) {
        break;
      }
    }
  }
  if (!denied) {
    getDelegate().rollback();
  }
}

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

@Override
public void rollback()
  throws RepositoryException
{
  boolean denied = false;
  if (activated) {
    for (RepositoryConnectionInterceptor interceptor : interceptors) {
      denied = interceptor.rollback(getDelegate());
      if (denied) {
        break;
      }
    }
  }
  if (!denied) {
    getDelegate().rollback();
  }
}

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

@Override
public void rollback()
  throws RepositoryException
{
  boolean denied = false;
  if (activated) {
    for (RepositoryConnectionInterceptor interceptor : interceptors) {
      denied = interceptor.rollback(getDelegate());
      if (denied) {
        break;
      }
    }
  }
  if (!denied) {
    getDelegate().rollback();
  }
}

代码示例来源：origin: de.tudarmstadt.ukp.inception.app/inception-kb

@Override
public KBHandle update(KnowledgeBase kb, UpdateAction aAction)
{
  if (kb.isReadOnly()) {
    log.warn("Knowledge base [{}] is read only, will not alter!", kb.getName());
    return null;
  }
  KBHandle result = null;
  try (RepositoryConnection conn = getConnection(kb)) {
    boolean error = true;
    try {
      conn.begin();
      result = aAction.accept(conn);
      conn.commit();
      error = false;
    }
    finally {
      if (error) {
        conn.rollback();
      }
    }
  }
  return result;
}

代码示例来源：origin: inception-project/inception

@Override
public KBHandle update(KnowledgeBase kb, UpdateAction aAction)
{
  if (kb.isReadOnly()) {
    log.warn("Knowledge base [{}] is read only, will not alter!", kb.getName());
    return null;
  }
  KBHandle result = null;
  try (RepositoryConnection conn = getConnection(kb)) {
    boolean error = true;
    try {
      conn.begin();
      result = aAction.accept(conn);
      conn.commit();
      error = false;
    }
    finally {
      if (error) {
        conn.rollback();
      }
    }
  }
  return result;
}

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

@Test
public void testCreateExistingGraph()
    throws Exception {
  logger.debug("executing testCreateExistingGraph");
  StringBuilder update = new StringBuilder();
  update.append(getNamespaceDeclarations());
  update.append("CREATE GRAPH <" + graph1 + "> ");
  Update operation = con.prepareUpdate(QueryLanguage.SPARQL, update.toString());
  try {
    operation.execute();
    fail("creation of existing graph should have resulted in error.");
  } catch (UpdateExecutionException e) {
    // expected behavior
    con.rollback();
  }
}

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

@Test
public void testBeginRollback() throws Exception {
  assertFalse(testCon.isActive());
  testCon.begin();
  assertTrue(testCon.isActive());
  testCon.add(bob, name, nameBob);
  testCon.rollback();
  // Sesame 2.6 transaction semantics are inverse of Sesame 2.7 transaction semantics.
  // Therefore, this test as it passes for 2.6 will fail in 2.7
  // So I have commented out below assert statement
  // assertFalse(testCon.isActive());
}

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

con.commit();
} catch (RDFHandlerException e) {
  con.rollback();
  con.rollback();

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

@Test
public void testRollback()
    throws Exception {
  testCon.setAutoCommit(false);
  testCon.add(alice, name, nameAlice);
  assertTrue("Uncommitted updates should be visible to own connection", testCon.hasStatement(alice, name,
      nameAlice, false));
  testCon.rollback();
  assertFalse("Repository should not contain statement after rollback", testCon.hasStatement(alice, name,
      nameAlice, false));
  testCon.setAutoCommit(true);
}

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

@Test
public void testEmptyRollback()
    throws Exception {
  assertTrue(testCon.isEmpty());
  assertTrue(testCon2.isEmpty());
  testCon.setAutoCommit(false);
  testCon.add(vf.createBNode(), vf.createIRI("urn:pred"), vf.createBNode());
  assertFalse(testCon.isEmpty());
  assertTrue(testCon2.isEmpty());
  testCon.rollback();
  assertTrue(testCon.isEmpty());
  assertTrue(testCon2.isEmpty());
}

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

@Test
public void testSizeRollback()
    throws Exception {
  assertEquals(0, testCon.size());
  assertEquals(0, testCon2.size());
  testCon.setAutoCommit(false);
  testCon.add(vf.createBNode(), vf.createIRI("urn:pred"), vf.createBNode());
  assertEquals(1, testCon.size());
  assertEquals(0, testCon2.size());
  testCon.add(vf.createBNode(), vf.createIRI("urn:pred"), vf.createBNode());
  assertEquals(2, testCon.size());
  assertEquals(0, testCon2.size());
  testCon.rollback();
  assertEquals(0, testCon.size());
  assertEquals(0, testCon2.size());
}