public class MyBatisTxTest { 
 
  private static SqlSessionFactory sqlSessionFactory; 
  private static Reader reader; 
 
  @BeforeClass 
  public static void setUpBeforeClass() throws Exception { 
    try { 
      reader = Resources.getResourceAsReader("Configuration.xml"); 
      sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader); 
    } finally { 
      if (reader != null) { 
        reader.close(); 
      } 
    } 
  } 
   
  @Test 
  public void updateUserTxTest() { 
    SqlSession session = sqlSessionFactory.openSession(false); // 打開(kāi)會(huì)話，事務(wù)開(kāi)始 
     
    try { 
      IUserMapper mapper = session.getMapper(IUserMapper.class); 
      User user = new User(9, "Test transaction"); 
      int affectedCount = mapper.updateUser(user); // 因后面的異常而未執(zhí)行commit語(yǔ)句 
      User user = new User(10, "Test transaction continuously"); 
      int affectedCount2 = mapper.updateUser(user2); // 因后面的異常而未執(zhí)行commit語(yǔ)句 
      int i = 2 / 0; // 觸發(fā)運(yùn)行時(shí)異常 
      session.commit(); // 提交會(huì)話，即事務(wù)提交 
    } finally { 
      session.close(); // 關(guān)閉會(huì)話，釋放資源 
    } 
  } 
} 

<bean id="transactionManager" class="org.springframework.jdbc.datasource 
  .DataSourceTransactionManager"> 
  <property name="dataSource" ref="dataSource"/> 
</bean> 

<tx:jta-transaction-manager/> 

<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> 
  <property name="dataSource" ref="dataSource"/> 
  <property name="transactionFactoryClass"> 
    <value>org.apache.ibatis.transaction.managed.ManagedTransactionFactory"/> 
  </property> 
</bean> 

DefaultTransactionDefinition def = new DefaultTransactionDefinition(); 
def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); 
TransactionStatus status = txManager.getTransaction(def); 
try{ 
  userMapper.insertUser(user); 
}catch(MyException ex){ 
  throw ex; 
} 
txManager.commit(status); 

<!-- 事務(wù)管理器 --> 
<bean id="txManager" 
  class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
    <property name="dataSource" ref="dataSource" /> 
</bean> 
 
<!-- 事務(wù)注解驅(qū)動(dòng)，標(biāo)注@Transactional的類和方法將具有事務(wù)性 --> 
<tx:annotation-driven transaction-manager="txManager" /> 
 
<bean id="userService" class="com.john.hbatis.service.UserService" /> 

@Service("userService") 
public class UserService { 
 
  @Autowired 
  IUserMapper mapper; 
 
  public int batchUpdateUsersWhenException() { // 非事務(wù)性 
    User user = new User(9, "Before exception"); 
    int affectedCount = mapper.updateUser(user); // 執(zhí)行成功 
    User user2 = new User(10, "After exception"); 
    int i = 1 / 0; // 拋出運(yùn)行時(shí)異常 
    int affectedCount2 = mapper.updateUser(user2); // 未執(zhí)行 
    if (affectedCount == 1 && affectedCount2 == 1) { 
      return 1; 
    } 
    return 0; 
  } 
 
  @Transactional 
  public int txUpdateUsersWhenException() { // 事務(wù)性 
    User user = new User(9, "Before exception"); 
    int affectedCount = mapper.updateUser(user); // 因后面的異常而回滾 
    User user2 = new User(10, "After exception"); 
    int i = 1 / 0; // 拋出運(yùn)行時(shí)異常，事務(wù)回滾 
    int affectedCount2 = mapper.updateUser(user2); // 未執(zhí)行 
    if (affectedCount == 1 && affectedCount2 == 1) { 
      return 1; 
    } 
    return 0; 
  } 
} 

@RunWith(SpringJUnit4ClassRunner.class) 
@ContextConfiguration(locations = { "classpath:beans-da-tx.xml" }) 
public class SpringIntegrateTxTest { 
 
  @Resource 
  UserService userService; 
 
  @Test 
  public void updateUsersExceptionTest() { 
    userService.batchUpdateUsersWhenException(); 
  } 
 
  @Test 
  public void txUpdateUsersExceptionTest() { 
    userService.txUpdateUsersWhenException(); 
  } 
} 

<bean id="txTemplate" class="org.springframework.transaction.support.TransactionTemplate"> 
  <constructor-arg type="org.springframework.transaction.PlatformTransactionManager" ref="transactionManager" /> 
</bean> 

@Autowired(required = false) 
TransactionTemplate txTemplate; 
 
public int txUpdateUsersWhenExceptionViaTxTemplate() { 
  int retVal = txTemplate.execute(new TransactionCallback<Integer>() { 
 
    @Override 
    public Integer doInTransaction(TransactionStatus status) { // 事務(wù)操作 
      User user = new User(9, "Before exception"); 
      int affectedCount = mapper.updateUser(user); // 因后面的異常而回滾 
      User user2 = new User(10, "After exception"); 
      int i = 1 / 0; // 拋出運(yùn)行時(shí)異常并回滾 
      int affectedCount2 = mapper.updateUser(user2); // 未執(zhí)行 
      if (affectedCount == 1 && affectedCount2 == 1) { 
        return 1; 
      } 
      return 0; 
    } 
     
  }); 
  return retVal; 
} 

@Test 
public void updateUsersWhenExceptionViaTxTemplateTest() { 
  userService.txUpdateUsersWhenExceptionViaTxTemplate(); //  
} 

@Transactional 
public int txUpdateUsersWhenExceptionAndCatch() { // 事務(wù)性操作，但是外圍框架捕獲不到異常，認(rèn)為執(zhí)行正確而提交。 
  try { 
    User user = new User(9, "Before exception"); 
    int affectedCount = mapper.updateUser(user); // 執(zhí)行成功 
    User user2 = new User(10, "After exception"); 
    int i = 1 / 0; // 拋出運(yùn)行時(shí)異常 
    int affectedCount2 = mapper.updateUser(user2); // 未執(zhí)行 
    if (affectedCount == 1 && affectedCount2 == 1) { 
      return 1; 
    } 
  } catch (Exception e) { // 所有異常被捕獲而未拋出 
    e.printStackTrace(); 
  } 
  return 0; 
}