詳解Spring學(xué)習(xí)之編程式事務(wù)管理

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

   <!--開啟自動掃描-->
  <context:component-scan base-package="cn.xuhuanfeng.transaction"/>

  <!--配置數(shù)據(jù)源，這里采用dbcp-->
  <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
    <property name="url" value="jdbc:mysql://localhost:3306/spring"/>
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
    <property name="username" value="root"/>
    <property name="password" value="huanfeng"/>
  </bean>

  <!--配置JdbcTemplate-->
  <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <!--注入數(shù)據(jù)源-->
    <property name="dataSource" ref="dataSource"/>
  </bean>

  <!--配置事務(wù)管理-->
  <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    <!--注入數(shù)據(jù)源-->
    <property name="dataSource" ref="dataSource"/>
  </bean>
  <!--配置事務(wù)管理操作類-->
  <bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <!--注入事務(wù)管理-->
    <property name="transactionManager" ref="transactionManager"/>
    <!--定義事務(wù)隔離級別，這里-1代表默認-->
    <property name="isolationLevel" value="-1"/>
    <!--配置傳播行為，0代表PROPAGATION_REQUIRED-->
    <property name="propagationBehavior" value="0"/>
    <!--由于進行讀寫操作，所以這里的只讀設(shè)置為false，默認也是false，所以可以不用設(shè)置-->
    <property name="readOnly" value="false"/>
  </bean>
</beans>

  // 事務(wù)傳播行為
  int PROPAGATION_REQUIRED = 0;
  int PROPAGATION_SUPPORTS = 1;
  int PROPAGATION_MANDATORY = 2;
  int PROPAGATION_REQUIRES_NEW = 3;
  int PROPAGATION_NOT_SUPPORTED = 4;
  int PROPAGATION_NEVER = 5;
  int PROPAGATION_NESTED = 6;

  // 事務(wù)隔離級別
  int ISOLATION_DEFAULT = -1;
  int ISOLATION_READ_UNCOMMITTED = 1;
  int ISOLATION_READ_COMMITTED = 2;
  int ISOLATION_REPEATABLE_READ = 4;
  int ISOLATION_SERIALIZABLE = 8;
  int TIMEOUT_DEFAULT = -1;

@Repository
public class AccountDao {

  @Autowired
  private JdbcTemplate jdbcTemplate;

  public void transferIn(String name, double money){
    String sql = "update account set money = money + ? where name = ?";

    jdbcTemplate.update(sql, money, name);
  }

  public void transferOut(String name, double money){
    String sql = "update account set money = money - ? where name = ?";

    jdbcTemplate.update(sql, money, name);
  }
}

@Service
public class AccountService {

  @Autowired
  private AccountDao accountDao;

  // 轉(zhuǎn)賬
  public void transfer(String fromName, String toName, double money){

    accountDao.transferOut(fromName, money);
    accountDao.transferIn(toName, money);
  }
}

  accountDao.transferOut(fromName, money);
  int d = 1/0; // 除0異常
  accountDao.transferIn(toName, money);

@Service
public class AccountService {

  @Autowired
  private AccountDao accountDao;

  // 配置事務(wù)管理操作類
  @Autowired
  private TransactionTemplate transactionTemplate;


  public void transfer(final String fromName,final String toName,final double money){

    // 通過transactionTemplate進行事務(wù)的管理
    transactionTemplate.execute(new TransactionCallbackWithoutResult() {
      @Override
      protected void doInTransactionWithoutResult(TransactionStatus transactionStatus) {
        accountDao.transferOut(fromName, money);
        int d = 1/0; // 除0異常
        accountDao.transferIn(toName, money);
      }
    });

  }
}