1 > POM文件需要的依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <parent>
        <artifactId>spring_dome</artifactId>
        <groupId>com.parent</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring_transcation</artifactId>

    <packaging>jar</packaging>
    <dependencies>
        <!-- IOC容器 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>

        <!-- aop切面 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aop</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>

        <!-- spring事务 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>5.3.9</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.springframework/spring-jdbc -->
       	<!-- spring jdbc -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.0.2.RELEASE</version>
        </dependency>

        <!-- aop切面 -->
        <dependency>
            <groupId>org.aspectj</groupId>
            <artifactId>aspectjweaver</artifactId>
            <version>1.8.7</version>
        </dependency>

        <!-- 单元测试 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>

        <!-- spring test -->
        <!-- https://mvnrepository.com/artifact/org.springframework/spring-test -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.0.2.RELEASE</version>
            <scope>test</scope>
        </dependency>

        <!-- mysql 驱动包 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.26</version>
        </dependency>
    </dependencies>

</project>

2 > 编写需要用到的类

在这里插入图片描述

2.1 Dao层接口及其实现类

2.1.1 > AccountDao 接口

package com.tran.dao;

import com.tran.domain.Account;

import java.util.List;

public interface AccountDao {
    // 查询所有
    List<Account> findAllAccount();

    // 保存账户
    Integer saveAccount(Account account);

    // 更新账户
    Integer updateAccount(Account account);

    // 转账
    Integer updateAccountToAccount(Account source , Account target,Float transferMoney);
}

2.1.2 > AccountDaoImpl 接口实现类，此实现类只负责逻辑代码的实现，事物控制由spring实现

package com.tran.dao.impl;

import com.tran.dao.AccountDao;
import com.tran.domain.Account;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;

import java.util.List;

public class AccountDaoImpl implements AccountDao {

    // 设置公用的数据源
    private DriverManagerDataSource dataSource;
    private JdbcTemplate jdbcTemplate;

    // 设置set方法对该对象进行赋值
    public void setDataSource(DriverManagerDataSource dataSource) {
        this.dataSource = dataSource;
    }

    // 设置set方法对该对象进行赋值
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }


    @Override // 查询所有用户
    public List<Account> findAllAccount() {
        return jdbcTemplate.query("select * from account", new BeanPropertyRowMapper<Account>(Account.class));
    }

    @Override // 不好意思  保存账户没有用到
    public Integer saveAccount(Account account) {
        return null;
    }

    @Override
    public Integer updateAccount(Account account) {
        /*
        * 一次判断account对象中那些属性存在 哪些属性不存在
        * */
        StringBuilder sb = new StringBuilder("update account set ");
        // 判断 account 对象是否为空
        if (account == null || account.getId() == null) {
            // 对象为空 抛出异常 触发事务，进行回滚操作
            System.out.println("Id is null ~");
            throw new RuntimeException("Execute Fail ~~ : by ID Field is null ~~");
        } else {
            // account不为空
            if (account.getName() == null) {
                // name is null ---- name值为空，输出提示
                System.out.println("Name is null ~");

                // 并且判断money是否为空
                if (account.getMoney() != null) {
                    // money value not null  ----  不为空，进行sql语句的拼接
                    System.out.println("Money is : " + account.getMoney());
                    sb.append("money = " + account.getMoney() + " ");
                } else {
                    // money value is null --- 当name,金额都为空时，抛出异常，触发回滚操作
                    System.out.println("Money is null ~");
                    throw new RuntimeException("Need's Values is null ~ \ncannot update ~ \nBy id is : " + account.getId());
                }
            } else {
                // name is not null 名字不为空 ，拼接sql
                System.out.println("Name is : " + account.getName());
                sb.append("name = '" + account.getName() + "' ");
                if (account.getMoney() != null) {
                    // money value not null 金额不为空，拼接字符串
                    System.out.println("Money is : " + account.getMoney());
                    sb.append(", money = " + account.getMoney() + " ");
                } else {
                    // money value is null
                    System.out.println("Money is null ~");
                }

            }
            // 拼接为哪个id更新
            sb.append("where id = " + account.getId());
            String sql_update = sb.toString();
            System.out.println("SQL is : " + sql_update);
            int i = 0;
            i = jdbcTemplate.update(sql_update); // 返回更新的行数
            return i;
        }
    }

    @Override // 转账方法
    public Integer updateAccountToAccount(Account source, Account target, Float transferMoney) {

        // 设置影响的行数
        Integer update_line = 0;

        // 获取当前source账户的金额 这里可以写一个findAccountById的方法，然后进行调用(我忘了写了)
        String sql_findById = "select * from account where id = ?";
        Account account_source = jdbcTemplate.queryForObject(sql_findById, new BeanPropertyRowMapper<Account>(Account.class), source.getId());
        Account account_target = jdbcTemplate.queryForObject(sql_findById, new BeanPropertyRowMapper<Account>(Account.class), target.getId());

        // 判断获取到的数据是否为空
        if (account_source != null && account_target != null) {
            // 判断转账金额是否大于0
            if (transferMoney > 0.0f) {
                // 判断要转账用户内的金额是否大于 转账金额
                if (account_source.getMoney() > transferMoney) {
                	// 显示提示信息 source -> target : money( money )
                    System.out.println(account_source.getName() + " --> " + 
                    account_target.getName() + " : Money( "+ transferMoney +" )");
                    account_source.setMoney(account_source.getMoney() - transferMoney);
                    account_target.setMoney(account_target.getMoney() + transferMoney);
                    update_line += this.updateAccount(account_source);
                    update_line += this.updateAccount(account_target);
                } else {
                    throw new RuntimeException("余额不足！！ 请重新输入！！");
                }
            } else {
                throw new RuntimeException("您输入的金额为负数！！ 请重新输入！！");
            }
        } else {
            throw new RuntimeException("获取到的值是空的！！  请检查您输入的账户是否存在 ！！");
        }

        System.out.println("Update line is : " + update_line);

        // 因为转账影响为两个账户，所以进行最后一次判断，判断转账是否出现异常
        if (update_line == 2) {
            // 影响账户数为2时，则证明转账成功 反之则失败
            System.out.println("Update success !!!");
        } else {
            System.out.println("Update fail !!");
            throw new RuntimeException();
        }

        return update_line;
    }
}

2.2 Service 层接口及其实现类

2.2.1 AccountService 接口

package com.tran.service;

import com.tran.domain.Account;

import java.util.List;

public interface AccountService {
    List<Account> findAllAccount();
    Integer transferAccount(Account source,Account target,Float money);
}

2.2.2 AccountServiceImpl 实现类

package com.tran.service.impl;

import com.tran.dao.AccountDao;
import com.tran.domain.Account;
import com.tran.service.AccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

public class AccountServiceImpl implements AccountService {
    private AccountDao accountDao;

    public void setAccountDao(AccountDao accountDao) {
        this.accountDao = accountDao;
    }

    @Override
    public List<Account> findAllAccount() {
        return accountDao.findAllAccount();
    }

    @Override
    public Integer transferAccount(Account source, Account target, Float money) {
        return accountDao.updateAccountToAccount(source,target,money);
    }
}

3 > bean.xml (springIOC容器配置，配置需要加载进IOC容器的类)

同时配置需要加载的spring的事务管理类

<?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:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="
        http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://www.springframework.org/schema/tx
        http://www.springframework.org/schema/tx/spring-tx.xsd
        http://www.springframework.org/schema/aop
        http://www.springframework.org/schema/aop/spring-aop.xsd">

    <!-- 设置DataSource -->
    <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://159.75.19.211:3306/dome02"/>
        <property name="username" value="root"/>
        <property name="password" value="111222333"/>
    </bean>

    <!-- JdbcTemplate设置数据源 -->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <constructor-arg ref="dataSource"/>
    </bean>

    <!-- 设置Dao层 -->
    <bean id="accountDao" class="com.tran.dao.impl.AccountDaoImpl">
        <property name="dataSource" ref="dataSource"/>
        <property name="jdbcTemplate" ref="jdbcTemplate"/>
    </bean>

    <!-- 配置Service层 -->
    <bean id="accountService" class="com.tran.service.impl.AccountServiceImpl">
        <property name="accountDao" ref="accountDao"/>
    </bean>



    <!-- 生成事务管理器 -->
    <bean id="transactionManger" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
    	<!-- 这快需要池，就很好理解了，事务肯定要对某一个或者多个链接产生一个约束，因此需要一个被管理的链接池 -->
        <property name="dataSource" ref="dataSource"/>
    </bean>

    <!-- 设置事务通知 -->
    <tx:advice id="txAdvice" transaction-manager="transactionManger">
        <tx:attributes>
            <!--
            isolation:用于指定事务的隔离级别。默认值是DEFAULT，表示使用数据库的默认隔离级别。
            propagation:用于指定事务的传播行为。默认值是REQUIRED，表示一定会有事务，增删改的选择。查询方法可以选择SUPPORTS。
            read-only:用于指定事务是否只读。只有查询方法才能设置为true。默认值是false，表示读写。
            timeout:用于指定事务的超时时间，默认值是-1，表示永不超时。如果指定了数值，以秒为单位。
            rollback-for:用于指定一个异常，当产生该异常时，事务回滚，产生其他异常时，事务不回滚。没有默认值。表示任何异常都回滚。
            no-rollback-for:用于指定一个异常，当产生该异常时，事务不回滚，产生其他异常时事务回滚。没有默认值。表示任何异常都回滚。
            -->
            <!-- find*表示AccountDaoimpl下的所有方法 -->
            <tx:method name="find*" propagation="SUPPORTS" read-only="true"/>
            <tx:method name="update*" propagation="REQUIRED" read-only="false"/>
        </tx:attributes>
    </tx:advice>

    <!-- 配置Aop切面 -->
    <aop:config>
        <!-- 配置切入点 切入点为AccountDaoImpl中的一个方法 -->
        <aop:pointcut id="pointcut01" expression="execution(* com.tran.dao.impl.AccountDaoImpl.*(..))"/>
        <!-- 配置事务管理通知,txAdvice表示事务通知,与上面设置的事物通知相对应 -->
        <aop:advisor pointcut-ref="pointcut01" advice-ref="txAdvice"/>
    </aop:config>
</beans>