javax.jdo.Transaction.commit()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(5.9k)|赞(0)|评价(0)|浏览(122)

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

Transaction.commit介绍

[英]Commit the current transaction.
[中]提交当前事务。

代码示例

代码示例来源:origin: apache/hive

currentTransaction.commit();

代码示例来源:origin: apache/hive

} finally {
 if (doCommit) {
  tx.commit();

代码示例来源:origin: apache/hive

private boolean runTestQuery() {
 Transaction tx = pm.currentTransaction();
 boolean doCommit = false;
 if (!tx.isActive()) {
  tx.begin();
  doCommit = true;
 }
 Query query = null;
 // Run a self-test query. If it doesn't work, we will self-disable. What a PITA...
 String selfTestQuery = "select \"DB_ID\" from " + DBS + "";
 try {
  prepareTxn();
  query = pm.newQuery("javax.jdo.query.SQL", selfTestQuery);
  query.execute();
  return true;
 } catch (Throwable t) {
  doCommit = false;
  LOG.warn("Self-test query [" + selfTestQuery + "] failed; direct SQL is disabled", t);
  tx.rollback();
  return false;
 } finally {
  if (doCommit) {
   tx.commit();
  }
  if (query != null) {
   query.closeAll();
  }
 }
}

代码示例来源:origin: org.apache.isis.core/isis-core-runtime

public void endTransaction() {
  final javax.jdo.Transaction transaction = persistenceManager.currentTransaction();
  if (transaction.isActive()) {
    transaction.commit();
  }
}

代码示例来源:origin: apache/incubator-sentry

public void commitTransaction(PersistenceManager pm) {
 Transaction currentTransaction = pm.currentTransaction();
 try {
  Preconditions.checkState(currentTransaction.isActive(), "Transaction is not active");
  currentTransaction.commit();
 } finally {
  pm.close();
 }
}

代码示例来源:origin: tangram/tangram-jdo

@Override
public void commitTransaction() {
  if (manager.currentTransaction().isActive()) {
    manager.currentTransaction().commit();
  } // if
} // commitTransaction()

代码示例来源:origin: tangram/tangram-jdo

@Override
public void rollbackTransaction() {
  if (manager.currentTransaction().isActive()) {
    manager.currentTransaction().commit();
  } // if
} // rollbackTransaction()

代码示例来源:origin: apache/incubator-sentry

private void commitTransaction(PersistenceManager pm) {
 Transaction currentTransaction = pm.currentTransaction();
 try {
  Preconditions.checkState(currentTransaction.isActive(), "Transaction is not active");
  currentTransaction.commit();
 } finally {
  pm.close();
 }
}

代码示例来源:origin: apache/sentry

private void commitTransaction(PersistenceManager pm) {
 Transaction currentTransaction = pm.currentTransaction();
 try {
  Preconditions.checkState(currentTransaction.isActive(), "Transaction is not active");
  currentTransaction.commit();
 } finally {
  pm.close();
 }
}

代码示例来源:origin: tzaeschke/zoodb

@Override
  public void run() {
    TestSuper t = (TestSuper) pm.getObjectById(oids.get(n));
    n++;
    t.setId(t.getId()+DELTA);
    if (n % COMMIT_INTERVAL == 0) {
      pm.currentTransaction().commit();
      pm.currentTransaction().begin();
    }
  }
});

代码示例来源:origin: tzaeschke/zoodb

private void checkResults(String queryFilter, int nRes) {
  pm.currentTransaction().commit();
  pm.currentTransaction().begin();
  Query q = pm.newQuery(TestClass.class, queryFilter);
  Collection<?> c = (Collection<?>) q.execute();
  int n = 0;
  for (Object o: c) {
    assertNotNull(o);
    n++;
  }
  assertEquals(nRes, n);
}

代码示例来源:origin: tzaeschke/zoodb

@Test
public void testSchemaCreationWithNullArray() {
  PersistenceManager pm = TestTools.openPM(props);
  pm.currentTransaction().begin();
  TestClassWithArray t = new TestClassWithArray();
  t.array = null;
  pm.makePersistent(t);
  pm.currentTransaction().commit();
  TestTools.closePM();
}

代码示例来源:origin: tzaeschke/zoodb

@Test
public void testActivationOutsideTx2() {
  PersistenceManager pm = TestTools.openPM();
  pm.currentTransaction().begin();
  pm.currentTransaction().commit();
  pm.close();
  
  TestClass tc = new TestClass();
  tc.setInt(5);
  tc.getInt();
}

代码示例来源:origin: tzaeschke/zoodb

@Test 
public void testThatPrintingDoesntThrowExceptions() {
  pm.currentTransaction().commit();
  pm.currentTransaction().begin();
  ZooClassDef def = getDef(TestClass.class);
  QueryParserV3 qp = new QueryParserV3(
      "(_int > 1 && _int < 52) || _int > 50", def, null, null, 0, Long.MAX_VALUE);
  QueryTreeNode qtn = qp.parseQuery();
  assertNotNull(qtn.print());
}

代码示例来源:origin: tzaeschke/zoodb

@Test 
  public void testThatPrintingDoesntThrowExceptions() {
    pm.currentTransaction().commit();
    pm.currentTransaction().begin();
    ZooClassDef def = getDef(TestClass.class);
    QueryParser qp = new QueryParser("(_int > 1 && _int < 52) || _int > 50", def, null, null);
    QueryTreeNode qtn = qp.parseQuery();
    assertNotNull(qtn.print());
  }
}

代码示例来源:origin: tzaeschke/zoodb

@Test
public void testQueryStatsWithData() {
  PersistenceManager pm = TestTools.openPM();
  pm.currentTransaction().begin();
  TestClass tc = new TestClass(); 
  pm.makePersistent(tc);
  pm.currentTransaction().commit();
  TestTools.closePM();
  runQueries(false);
}

代码示例来源:origin: tzaeschke/zoodb

@Test
public void testSchemaCreationHierarchy() {
  PersistenceManager pm = TestTools.openPM(props);
  pm.currentTransaction().begin();
  pm.makePersistent(new TestClassTiny());
  pm.makePersistent(new TestClassTiny2());
  pm.currentTransaction().commit();
  TestTools.closePM();
}

代码示例来源:origin: tzaeschke/zoodb

@After
public void afterTest() {
  TestTools.closePM();
  PersistenceManager pm = TestTools.openPM();
  pm.currentTransaction().begin();
  pm.newQuery(TestClassTiny2.class).deletePersistentAll();
  pm.newQuery(TestClassTiny.class).deletePersistentAll();
  pm.currentTransaction().commit();
  TestTools.closePM();
}

代码示例来源:origin: tzaeschke/zoodb

@Before
public void before() {
  TestTools.createDb();
  TestTools.closePM();
  pm = TestTools.openPM();
  pm.currentTransaction().begin();
  ZooJdoHelper.schema(pm).addClass(TestClassTiny.class);
  ZooJdoHelper.schema(pm).addClass(TestClassTiny2.class);
  pm.currentTransaction().commit();
  pm.currentTransaction().begin();
}

代码示例来源:origin: tzaeschke/zoodb

@Before
public void beforeTest() {
  PersistenceManager pm = TestTools.openPM();
  pm.currentTransaction().begin();
  pm.newQuery(pm.getExtent(TestClass.class)).deletePersistentAll();
  pm.newQuery(pm.getExtent(TestClassTiny.class)).deletePersistentAll();
  pm.newQuery(pm.getExtent(TestClassTiny2.class)).deletePersistentAll();
  pm.currentTransaction().commit();
  TestTools.closePM();
}

相关文章