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

    <!-- 配置 C3P0 连接池数据源, 作为 DAO 层的数据源-->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="jdbcUrl">
            <value>jdbc:mysql://localhost:3306/test?useUnicode=true&amp;characterEncoding=UTF-8</value>
        </property>
        <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
        <property name="user" value="root"></property>
        <property name="password" value="920619"></property>
    </bean>
    
    <!-- 配置 DAO 层, 把 C3P0 连接池作为数据源注入到 DAO 层 -->
    <bean id="accountDao" class="spring.things_2.AccountDao">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    
    <!-- 配置 SERVICE 层, 把 DAO 层注入到 SERVICE 层 -->
    <bean id="accountService" class="spring.things_2.AccountService">
        <property name="accountDao" ref="accountDao"></property>
    </bean>
    
    <!-- 配置事物管理类 -->
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    
    <!-- 开启注解事物 -->
    <tx:annotation-driven transaction-manager="transactionManager" />
    
</beans>

package spring.things_2;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class AccountDao extends JdbcDaoSupport implements IAccountDao {
    
    @Override
    public void outMoney(String outName, double money) {
        String sql = "update User set money = money - ? where UserName = ?";
        this.getJdbcTemplate().update(sql, money, outName);
    }

    @Override
    public void inMoney(String inName, double money) {
        String sql = "update User set money = money + ? where UserName = ?";
        this.getJdbcTemplate().update(sql, money, inName);
    }
    
}

package spring.things_2;

import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

/**
 * 注解该类为事物类( 参数类型如下 )
 * propagation:   事物的传播行为
 * isolation:     事物的隔离级别
 * readOnly:      是否只读
 * rollbackFor:   被回滚的异常类型
 * noRollbackFor: 不会滚的异常类型
 */
@Transactional(propagation=Propagation.REQUIRED, isolation=Isolation.DEFAULT)
public class AccountService implements IAccountService {
    
    // 注入的 Dao 层
    private AccountDao accountDao;
    public void setAccountDao(AccountDao accountDao) {
        this.accountDao = accountDao;
    }
    
    // 这个方法在测试中是一个事物单元
    @Override
    public void transfer(String outName, String inName, double money) {
        accountDao.outMoney(outName, money);
        accountDao.inMoney(inName, money);
    }

}

package spring.things_2;

import org.springframework.jdbc.core.support.JdbcDaoSupport;

public class AccountDao extends JdbcDaoSupport implements IAccountDao {
    
    @Override
    public void outMoney(String outName, double money) {
        String sql = "update User set money = money - ? where UserName = ?";
        this.getJdbcTemplate().update(sql, money, outName);
    }

    @Override
    public void inMoney(String inName, double money) {
        String sql = "update User set money = money + ? where UserName = ?";
        this.getJdbcTemplate().update(sql, money, inName);
    }
    
}

package spring.things_2;

import org.springframework.transaction.annotation.Isolation;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

/**
 * 注解该类为事物类( 参数类型如下 )
 * propagation:   事物的传播行为
 * isolation:     事物的隔离级别
 * readOnly:      是否只读
 * rollbackFor:   被回滚的异常类型
 * noRollbackFor: 不会滚的异常类型
 */
@Transactional(propagation=Propagation.REQUIRED, isolation=Isolation.DEFAULT)
public class AccountService implements IAccountService {
    
    // 注入的 Dao 层
    private AccountDao accountDao;
    public void setAccountDao(AccountDao accountDao) {
        this.accountDao = accountDao;
    }
    
    // 这个方法在测试中是一个事物单元
    @Override
    public void transfer(String outName, String inName, double money) {
        accountDao.outMoney(outName, money);
        accountDao.inMoney(inName, money);
    }

}