javax.transaction.TransactionManager.commit()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(11.4k)|赞(0)|评价(0)|浏览(204)

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

TransactionManager.commit介绍

[英]Commit the transaction associated with the calling thread.
[中]提交与调用线程关联的事务。

代码示例

代码示例来源：origin: hibernate/hibernate-orm

  1. private <T> T doInNewTransaction(HibernateCallable<T> callable, TransactionManager transactionManager) {
  2.   try {
  3.     // start the new isolated transaction
  4.     transactionManager.begin();
  5.     try {
  6.       T result = callable.call();
  7.       // if everything went ok, commit the isolated transaction
  8.       transactionManager.commit();
  9.       return result;
  10.     }
  11.     catch (Exception e) {
  12.       try {
  13.         transactionManager.rollback();
  14.       }
  15.       catch (Exception ignore) {
  16.         LOG.unableToRollbackIsolatedTransaction( e, ignore );
  17.       }
  18.       throw new HibernateException( "Could not apply work", e );
  19.     }
  20.   }
  21.   catch (SystemException e) {
  22.     throw new HibernateException( "Unable to start isolated transaction", e );
  23.   }
  24.   catch (NotSupportedException e) {
  25.     throw new HibernateException( "Unable to start isolated transaction", e );
  26.   }
  27. }

代码示例来源：origin: spring-projects/spring-framework

  1. @Test
  2. public void jtaTransactionManagerWithPropagationRequiresNewAndAdapter() throws Exception {
  3.   TransactionManager tm = mock(TransactionManager.class);
  4.   Transaction tx = mock(Transaction.class);
  5.   given(tm.getStatus()).willReturn(Status.STATUS_ACTIVE);
  6.   given(tm.suspend()).willReturn(tx);
  7.   JtaTransactionManager ptm = newJtaTransactionManager(tm);
  8.   TransactionTemplate tt = new TransactionTemplate(ptm);
  9.   tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
  10.   assertFalse(TransactionSynchronizationManager.isSynchronizationActive());
  11.   tt.execute(new TransactionCallbackWithoutResult() {
  12.     @Override
  13.     protected void doInTransactionWithoutResult(TransactionStatus status) {
  14.       assertTrue(TransactionSynchronizationManager.isSynchronizationActive());
  15.     }
  16.   });
  17.   assertFalse(TransactionSynchronizationManager.isSynchronizationActive());
  18.   verify(tm).begin();
  19.   verify(tm).commit();
  20.   verify(tm).resume(tx);
  21. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. public void testPferNoAutoCommitExplicitTransaction() throws Exception {
  2.  tm().begin();
  3.  cache.putForExternalRead("k1","v");
  4.  tm().commit();
  5.  assert cache.get("k1").equals("v"); //here is the failure!
  6. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. public void testTxCleanupWithSize() throws Exception {
  2.    tm().begin();
  3.    assertEquals(0, cache.size());
  4.    TransactionTable txTable = getTransactionTable(cache);
  5.    assertEquals(1, txTable.getLocalTransactions().size());
  6.    tm().commit();
  7.    assertEquals(0, txTable.getLocalTransactions().size());
  8.   }
  9. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. public void testTransactionalReplace(Method m) throws Exception {
  2.  assertEquals(ComponentStatus.RUNNING, cache.getStatus());
  3.  assertNotInCacheAndStore(k(m, 1));
  4.  assertNotInCacheAndStore(k(m, 2));
  5.  cache.put(k(m, 2), v(m));
  6.  tm.begin();
  7.  cache.put(k(m, 1), v(m, 1));
  8.  cache.replace(k(m, 2), v(m, 1));
  9.  Transaction t = tm.suspend();
  10.  assertNotInCacheAndStore(k(m, 1));
  11.  assertInCacheAndStore(k(m, 2), v(m));
  12.  tm.resume(t);
  13.  tm.commit();
  14.  assertInCacheAndStore(k(m, 1), v(m, 1));
  15.  assertInCacheAndStore(k(m, 2), v(m, 1));
  16. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2.   public void test() throws Exception
  3.   {
  4.     javax.transaction.TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  6.     tm.begin();
  8.     javax.transaction.Transaction theTransaction = tm.getTransaction();
  10.     tm.commit();
  12.     tm.resume(theTransaction);
  13.   }
  14. }

代码示例来源：origin: jbosstm/narayana

  1. @Test
  2. public void test() throws Exception
  3. {
  4.   TransactionManager tm = com.arjuna.ats.jta.TransactionManager.transactionManager();
  5.   tm.begin();
  6.   Transaction tx = tm.suspend();
  7.   tm.begin();
  8.   tx.commit();
  9.   tm.commit();
  10. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. private void assertAllHaveNewValue(Object key) throws Exception {
  2.  for (Cache c : caches()) {
  3.    Object actual;
  4.    TestingUtil.getTransactionManager(c).begin();
  5.    actual = c.get(key);
  6.    TestingUtil.getTransactionManager(c).commit();
  7.    assertEquals(actual, "newValue");
  8.  }
  9. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. public void testRemoteCommit() throws Exception {
  2.  assertCommitRollback(0, 0, txInterceptor2);
  3.  tm.begin();
  4.  assertCommitRollback(0, 0, txInterceptor2);
  5.  //enlist another resource adapter to force TM to execute 2PC (otherwise 1PC)
  6.  tm.getTransaction().enlistResource(new XAResourceAdapter());
  7.  cache2.put("key", "value");
  8.  assertCommitRollback(0, 0, txInterceptor2);
  9.  tm.commit();
  10.  assertCommitRollback(1, 0, txInterceptor2);
  11. }

代码示例来源：origin: hibernate/hibernate-orm

  1. assertEquals( 0, sessionFactory().getStatistics().getEntityLoadCount() );
  2. bar.put( "description", "a small bar" );
  3. s.persist( "Item", bar );
  4. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  5. assertEquals(0, sessionFactory().getStatistics().getUpdateTimestampsCacheHitCount());
  6. assertEquals(2, sessionFactory().getStatistics().getUpdateTimestampsCachePutCount()); // One preinvalidate & one invalidate
  7. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().begin();
  8. Session s2 = openSession();
  9. foo = ( Map ) s2.get( "Item", "Foo" );
  10. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  11. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().resume( tx );
  12. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  13. s2.createCriteria( "Item" ).list();
  14. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  15. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().resume( tx );
  16. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  17. s2.createCriteria( "Item" ).list();
  18. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  19. s = openSession();
  20. s.createQuery( "delete from Item" ).executeUpdate();
  21. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();

代码示例来源：origin: kiegroup/optaplanner

  1. protected <S extends Score, E extends AbstractTestJpaEntity<S>> void findAndAssert(
  2.     Class<E> jpaEntityClass, Long id, S score) {
  3.   try {
  4.     transactionManager.begin();
  5.     EntityManager em = entityManagerFactory.createEntityManager();
  6.     E jpaEntity = em.find(jpaEntityClass, id);
  7.     assertEquals(score, jpaEntity.getScore());
  8.     transactionManager.commit();
  9.   } catch (NotSupportedException | SystemException | RollbackException | HeuristicMixedException | HeuristicRollbackException e) {
  10.     throw new RuntimeException("Transaction failed.", e);
  11.   }
  12. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. public void testTxCleanupWithEntrySet() throws Exception {
  2.  tm().begin();
  3.  assertEquals(0, cache.entrySet().size());
  4.  TransactionTable txTable = getTransactionTable(cache);
  5.  assertEquals(1, txTable.getLocalTransactions().size());
  6.  tm().commit();
  7.  assertEquals(0, txTable.getLocalTransactions().size());
  8. }

代码示例来源：origin: hibernate/hibernate-orm

  1. bar.put( "description", "a small bar" );
  2. s.persist( "Item", bar );
  3. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  4. Transaction tx1 = TestingJtaPlatformImpl.INSTANCE.getTransactionManager().suspend();
  5. assertEquals( r2.size(), 2 );
  6. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  7. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().resume( tx1 );
  8. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  9. s3.createCriteria( "Item" ).addOrder( Order.asc( "description" ) )
  10.     .setCacheable( true ).list();
  11. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  12. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().resume( tx4 );
  13. List r4 = s4.createCriteria( "Item" ).addOrder( Order.asc( "description" ) )
  14.     .setCacheable( true ).list();
  15. assertEquals( r4.size(), 2 );
  16. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  17. s = openSession();
  18. s.createQuery( "delete from Item" ).executeUpdate();
  19. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();

代码示例来源：origin: kiegroup/optaplanner

  1. protected <S extends Score, E extends AbstractTestJpaEntity<S>> Long persistAndAssert(E jpaEntity) {
  2.   try {
  3.     transactionManager.begin();
  4.     EntityManager em = entityManagerFactory.createEntityManager();
  5.     em.persist(jpaEntity);
  6.     transactionManager.commit();
  7.   } catch (NotSupportedException | SystemException | RollbackException | HeuristicRollbackException | HeuristicMixedException e) {
  8.     throw new RuntimeException("Transaction failed.", e);
  9.   }
  10.   Long id = jpaEntity.getId();
  11.   assertNotNull(id);
  12.   return id;
  13. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. public void testTxCleanupWithKeySet() throws Exception {
  2.  tm().begin();
  3.  assertEquals(0, cache.keySet().size());
  4.  TransactionTable txTable = getTransactionTable(cache);
  5.  assertEquals(1, txTable.getLocalTransactions().size());
  6.  tm().commit();
  7.  assertEquals(0, txTable.getLocalTransactions().size());
  8. }

代码示例来源：origin: hibernate/hibernate-orm

  1. bar.put( "description", "a small bar" );
  2. s.persist( "Item", bar );
  3. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  4.     .setCacheable( true ).list();
  5. assertEquals( r2.size(), 2 );
  6. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  7. assertEquals( sessionFactory().getStatistics().getUpdateTimestampsCachePutCount(), 0 );
  8. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().resume( tx1 );
  9. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  10. s3.createCriteria( "Item" ).addOrder( Order.asc( "description" ) )
  11.     .setCacheable( true ).list();
  12. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  13. assertEquals( sessionFactory().getStatistics().getUpdateTimestampsCacheMissCount(), 0 );
  14. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().resume( tx4 );
  15. List r4 = s4.createCriteria( "Item" ).addOrder( Order.asc( "description" ) )
  16.     .setCacheable( true ).list();
  17. assertEquals( r4.size(), 2 );
  18. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();
  19. s = openSession();
  20. s.createQuery( "delete from Item" ).executeUpdate();
  21. TestingJtaPlatformImpl.INSTANCE.getTransactionManager().commit();

代码示例来源：origin: kiegroup/optaplanner

  1. protected <S extends Score, E extends AbstractTestJpaEntity<S>> void findAssertAndChangeScore(
  2.     Class<E> jpaEntityClass, Long id, S oldScore, S newScore) {
  3.   try {
  4.     transactionManager.begin();
  5.     EntityManager em = entityManagerFactory.createEntityManager();
  6.     E jpaEntity = em.find(jpaEntityClass, id);
  7.     em.persist(jpaEntity);
  8.     assertEquals(oldScore, jpaEntity.getScore());
  9.     jpaEntity.setScore(newScore);
  10.     jpaEntity = em.merge(jpaEntity);
  11.     transactionManager.commit();
  12.   } catch (NotSupportedException | SystemException | RollbackException | HeuristicRollbackException | HeuristicMixedException e) {
  13.     throw new RuntimeException("Transaction failed.", e);
  14.   }
  15. }

代码示例来源：origin: org.infinispan/infinispan-core

  1. public void testTxCleanupWithValues() throws Exception {
  2.  tm().begin();
  3.  assertEquals(0, cache.values().size());
  4.  TransactionTable txTable = getTransactionTable(cache);
  5.  assertEquals(1, txTable.getLocalTransactions().size());
  6.  tm().commit();
  7.  assertEquals(0, txTable.getLocalTransactions().size());
  8. }

代码示例来源：origin: org.jberet/jberet-core

  1. private long getNextIdFor(final String key) {
  2.   final long nextId;
  3.   final TransactionManager infinispanTransactionManager = sequenceCache.getAdvancedCache().getTransactionManager();
  4.   try {
  5.     infinispanTransactionManager.begin();
  6.     sequenceCache.getAdvancedCache().lock(key);
  7.     nextId = sequenceCache.get(key) + 1;
  8.     sequenceCache.put(key, nextId);
  9.     infinispanTransactionManager.commit();
  10.     return nextId;
  11.   } catch (final Exception e) {
  12.     throw BatchMessages.MESSAGES.failToGetNextId(e, key);
  13.   }
  14. }

代码示例来源：origin: hibernate/hibernate-orm

  1. @Test
  2. public void testDropDuringActiveJtaTransaction() throws Exception {
  3.   final SessionFactory sessionFactory = buildSessionFactory();
  4.   JtaPlatformStandardTestingImpl.INSTANCE.transactionManager().begin();
  5.   try {
  6.     sessionFactory.close();
  7.   }
  8.   finally {
  9.     JtaPlatformStandardTestingImpl.INSTANCE.transactionManager().commit();
  10.   }
  11. }

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

transactionmanager

相关文章

    查看更多

    热门标签

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

    最新文章

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