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

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

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

TransactionManager.getStatus介绍

[英]Get the status of the transaction associated with the calling thread.
[中]

代码示例

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

  1. @Override
  2. public int getStatus() throws SystemException {
  3. return this.transactionManager.getStatus();
  4. }

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

  1. @Override
  2. public int getCurrentStatus() throws SystemException {
  3. return this.transactionManager.getStatus();
  4. }

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

  1. @Override
  2. public int getStatus() throws SystemException {
  3. return this.transactionManager.getStatus();
  4. }

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

  1. /** {@inheritDoc} */
  2. @Override public int getStatus() throws SystemException {
  3. return mgr.getStatus();
  4. }

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

  1. /**
  2. * Calls getStatus() of the transaction manager owning this user transaction
  3. *
  4. * @see javax.transaction.UserTransaction#getStatus()
  5. */
  6. @Override
  7. public int getStatus() throws SystemException {
  8. return tm.getStatus();
  9. }

代码示例来源:origin: org.springframework/spring-tx

  1. @Override
  2. public int getStatus() throws SystemException {
  3. return this.transactionManager.getStatus();
  4. }

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

  1. @Override
  2. public boolean canRegisterSynchronization() {
  3. try {
  4. return (this.transactionManager.getStatus() == Status.STATUS_ACTIVE);
  5. }
  6. catch (SystemException ex) {
  7. throw new TransactionException("Could not determine JTA transaction status", ex);
  8. }
  9. }

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

  1. @SneakyThrows
  2. @Override
  3. public boolean isInTransaction() {
  4. return Status.STATUS_NO_TRANSACTION != xaTransactionManager.getTransactionManager().getStatus();
  5. }

代码示例来源:origin: Activiti/Activiti

  1. private boolean isExisting() {
  2. try {
  3. return transactionManager.getStatus() != Status.STATUS_NO_TRANSACTION;
  4. } catch (SystemException e) {
  5. throw new TransactionException("Unable to retrieve transaction status", e);
  6. }
  7. }

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

  1. @Override
  2. public int getCurrentStatus() throws SystemException {
  3. return retrieveTransactionManager().getStatus();
  4. }
  5. }

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

  1. @Override
  2. public int getCurrentStatus() throws SystemException {
  3. return retrieveTransactionManager().getStatus();
  4. }

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

  1. public int getCurrentStatus() throws SystemException {
  2. return retrieveTransactionManager().getStatus();
  3. }

代码示例来源:origin: org.springframework/spring-orm

  1. @Override
  2. public boolean canRegisterSynchronization() {
  3. try {
  4. return (this.transactionManager.getStatus() == Status.STATUS_ACTIVE);
  5. }
  6. catch (SystemException ex) {
  7. throw new TransactionException("Could not determine JTA transaction status", ex);
  8. }
  9. }

代码示例来源:origin: Activiti/Activiti

  1. protected boolean calledInsideTransaction() {
  2. try {
  3. return transactionManager.getStatus() != Status.STATUS_NO_TRANSACTION;
  4. } catch (SystemException e) {
  5. throw new ActivitiException("Could not determine the current status of the transaction manager: " + e.getMessage(), e);
  6. }
  7. }

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

  1. public static void tryCommit(TransactionManager tm) throws Exception {
  2. if ( tm.getStatus() == Status.STATUS_MARKED_ROLLBACK ) {
  3. tm.rollback();
  4. }
  5. else {
  6. tm.commit();
  7. }
  8. }
  9. }

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

  1. @Override
  2. public TransactionStatus getStatus() {
  3. try {
  4. return StatusTranslator.translate( transactionManager.getStatus() );
  5. }
  6. catch (SystemException e) {
  7. throw new TransactionException( "JTA TransactionManager#getStatus failed", e );
  8. }
  9. }

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

  1. /**
  2. * Used by envers...
  3. */
  4. public static void tryCommit() throws Exception {
  5. if ( transactionManager().getStatus() == Status.STATUS_MARKED_ROLLBACK ) {
  6. transactionManager().rollback();
  7. }
  8. else {
  9. transactionManager().commit();
  10. }
  11. }

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

  1. public void reset() throws SystemException {
  2. if ( transactionManager != null ) {
  3. if ( transactionManager.getStatus() != Status.STATUS_NO_TRANSACTION ) {
  4. transactionManager.rollback();
  5. }
  6. }
  7. if ( userTransaction != null ) {
  8. if ( userTransaction.getStatus() != Status.STATUS_NO_TRANSACTION ) {
  9. userTransaction.rollback();
  10. }
  11. }
  12. }

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

  1. @Test
  2. @SuppressWarnings("EmptyCatchBlock")
  3. public void explicitJoinOutsideTxnTest() throws Exception {
  4. // pre conditions
  5. final TransactionManager tm = JtaPlatformStandardTestingImpl.INSTANCE.transactionManager();
  6. assertEquals( Status.STATUS_NO_TRANSACTION, tm.getStatus() );
  7. final JtaTransactionCoordinatorImpl transactionCoordinator = buildTransactionCoordinator( false );
  8. assertEquals( Status.STATUS_NO_TRANSACTION, tm.getStatus() );
  9. // try to force a join, should fail...
  10. try {
  11. transactionCoordinator.explicitJoin();
  12. fail( "Expecting explicitJoin() call outside of transaction to fail" );
  13. }
  14. catch (TransactionRequiredForJoinException expected) {
  15. }
  16. }

代码示例来源: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. }

相关文章