Spring事务管理（转账例子）

avatar 2017年08月08日19:31:54 1 3709 views
博主分享免费Java教学视频，B站账号：Java刘哥 ，长期提供技术问题解决、项目定制：本站商品点此

搭建转账环境


1、创建数据库，添加数据



2、 创建service和dao类，完成注入关系



（1）service层又叫业务逻辑层



（2）dao层，单纯对数据库操作层，在dao层不添加业务



（3）需求：Jerry 转账 300 给 Tom

- Jerry 少 300

- Tom 多 300

详细代码，见下面



3、解决问题

（1）如果 Jerry 转出了 300 之后，出现异常（比如银行停电之类的），Tom 不会多 300，钱丢失了



4、解决

（1）添加事务解决，出现异常进行回滚操作


声明式事务管理（xml配置）


1、 配置文件方式使用aop思想配置

第一步、 配置事务管理器



第二步、 配置事务增强



第三步 、配置切面





2、完整代码如下
  • AccountDao.java

  1. package com.liuyanzhao.spring.demo1;
  3. import org.springframework.jdbc.core.JdbcTemplate;
  5. /**
  6.  * Created by 言曌 on 2017/8/8.
  7.  */
  8. public class AccountDao {
  9.     //注入JdbcTemplate对象
  10.     private JdbcTemplate jdbcTemplate;
  11.     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
  12.         this.jdbcTemplate = jdbcTemplate;
  13.     }
  15.     /**
  16.      * @param name      转账人
  17.      * @param money     转账金额
  18.      */
  19.     public void outMoney(String name,double money) {
  20.         String sql = "update account set money = money - ? where name = ?";
  21.         jdbcTemplate.update(sql,money,name);
  22.     }
  24.     /**
  25.      * @param name      收账人
  26.      * @param money     收账金额
  27.      */
  28.     public void inMoney(String name,double money) {
  29.         String sql = "update account set money = money + ? where name = ?";
  30.         jdbcTemplate.update(sql,money,name);
  31.     }
  32. }

  • AccountService.java

  1. package com.liuyanzhao.spring.demo1;
  3. /**
  4.  * Created by 言曌 on 2017/8/8.
  5.  */
  6. public class AccountService {
  7.     //注入ordersDao对象
  8.     private AccountDao accountDao;
  10.     public void setAccountDao(AccountDao accountDao) {
  11.         this.accountDao = accountDao;
  12.     }
  14.     /**
  15.      * @param Transfer_person   转账人
  16.      * @param account_holder    收账人
  17.      * @param money             交易金额
  18.      */
  19.     public void accountMoney(String Transfer_person,String account_holder,double money) {
  20.         //转账
  21.         accountDao.outMoney(Transfer_person,money);
  23.         /**
  24.          * 假如，转账过程中，出现异常
  25.          * 如果我们不配置事务管理，会出现 转账成功，收账失败
  26.          * 如果我们配置了事务管理，两者必然是同时成功，同时失败
  27.          */
  28.         //int i = 10/0;
  30.         //收账
  31.         accountDao.inMoney(account_holder,money);
  33.     }
  34. }

  • applicationContext.xml   配置文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xmlns:context="http://www.springframework.org/schema/context"
  5.        xmlns:aop="http://www.springframework.org/schema/aop"
  6.        xmlns:tx="http://www.springframework.org/schema/tx"
  7.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  8.     http://www.springframework.org/schema/beans/spring-beans.xsd
  9.     http://www.springframework.org/schema/context
  10.     http://www.springframework.org/schema/context/spring-context.xsd
  11.     http://www.springframework.org/schema/aop
  12.     http://www.springframework.org/schema/aop/spring-aop.xsd
  13.     http://www.springframework.org/schema/tx
  14.     http://www.springframework.org/schema/tx/spring-tx.xsd">
  16.     <context:component-scan base-package="com.liuyanzhao.spring.demo1"/>
  18.     <!-- 引入外部属性文件 -->
  19.     <context:property-placeholder location="classpath:jdbc.properties"/>
  21.     <!-- 配置C3P0连接池 -->
  22.     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  23.         <property name="driverClass" value="${jdbc.driverClass}"/>
  24.         <property name="jdbcUrl" value="${jdbc.url}"/>
  25.         <property name="user" value="${jdbc.username}"/>
  26.         <property name="password" value=""/>
  27.     </bean>
  29.     <!--
  30.         id值可以随便写，与ref对应；
  31.         name值 是 类中的要注入的属性
  32.     -->
  33.     <bean id="accountService" class="com.liuyanzhao.spring.demo1.AccountService">
  34.         <property name="accountDao" ref="accountDao"></property>
  35.     </bean>
  36.     <bean id="accountDao" class="com.liuyanzhao.spring.demo1.AccountDao">
  37.         <property name="jdbcTemplate" ref="jdbcTemplate"></property>
  38.     </bean>
  39.     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
  40.         <property name="dataSource" ref="dataSource"></property>
  41.     </bean>
  44.     <!--第一步、配置事务管理器-->
  45.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  46.         <!--注入DataSource-->
  47.         <property name="dataSource" ref="dataSource"></property>
  48.     </bean>
  50.     <!--第二步、配置事务增强-->
  51.     <tx:advice id="txadvice" transaction-manager="transactionManager">
  52.         <!--做事务操作-->
  53.         <tx:attributes>
  54.             <!--设置事务操作的方法匹配规则-->
  55.             <tx:method name="account*" propagation="REQUIRED" />
  56.         </tx:attributes>
  57.     </tx:advice>
  59.     <!--第三步、配置切面-->
  60.     <aop:config>
  61.         <!--切入点-->
  62.         <aop:pointcut id="pointcut1" expression="execution(* com.liuyanzhao.spring.demo1.AccountService.*(..))"/>
  63.         <!--切面-->
  64.         <aop:advisor advice-ref="txadvice" pointcut-ref="pointcut1"/>
  65.     </aop:config>
  67. </beans>

  • ServiceTest.java  测试类

  1. package com.liuyanzhao.spring.demo1;
  3. import org.junit.Test;
  4. import org.springframework.context.ApplicationContext;
  5. import org.springframework.context.support.ClassPathXmlApplicationContext;
  7. /**
  8.  * Created by 言曌 on 2017/8/8.
  9.  */
  10. public class ServiceTest {
  11.     @Test
  12.     public void test() {
  13.         ApplicationContext context =
  14.             new ClassPathXmlApplicationContext("applicationContext.xml");
  15.         AccountService accountService = (AccountService) context.getBean("accountService");
  16.         //Jerry 给 Tom 转账 300
  17.         accountService.accountMoney("Jerry","Tom",300);
  18.     }
  19. }


声明式事务管理（注解）


1、注解的形式更简单

第一步 配置事务管理器



第二步 配置事务注解



第三步 在要使用事务的方法所在类上面添加注解





以上三步 替代 xml方式 的三步，相对更简单。

2、完整代码如下
  • AccountDao.java


同上
  • ServiceTest.java


同上
  • AccountService.java

  1. package com.liuyanzhao.spring.demo1;
  3. import org.springframework.transaction.annotation.Transactional;
  5. /**
  6.  * Created by 言曌 on 2017/8/8.
  7.  */
  9. @Transactional
  10. public class AccountService {
  12.     //注入ordersDao对象
  13.     private AccountDao accountDao;
  15.     public void setAccountDao(AccountDao accountDao) {
  16.         this.accountDao = accountDao;
  17.     }
  19.     /**
  20.      * @param Transfer_person   转账人
  21.      * @param account_holder    收账人
  22.      * @param money             交易金额
  23.      */
  24.     public void accountMoney(String Transfer_person,String account_holder,double money) {
  25.         //转账
  26.         accountDao.outMoney(Transfer_person,money);
  28.         /**
  29.          * 假如，转账过程中，出现异常
  30.          * 如果我们不配置事务管理，会出现 转账成功，收账失败
  31.          * 如果我们配置了事务管理，两者必然是同时成功，同时失败
  32.          */
  33.         //int i = 10/0;
  35.         //收账
  36.         accountDao.inMoney(account_holder,money);
  38.     }
  39. }

  • applicationContext.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.        xmlns:context="http://www.springframework.org/schema/context"
  5.        xmlns:aop="http://www.springframework.org/schema/aop"
  6.        xmlns:tx="http://www.springframework.org/schema/tx"
  7.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  8.     http://www.springframework.org/schema/beans/spring-beans.xsd
  9.     http://www.springframework.org/schema/context
  10.     http://www.springframework.org/schema/context/spring-context.xsd
  11.     http://www.springframework.org/schema/aop
  12.     http://www.springframework.org/schema/aop/spring-aop.xsd
  13.     http://www.springframework.org/schema/tx
  14.     http://www.springframework.org/schema/tx/spring-tx.xsd">
  16.     <context:component-scan base-package="com.liuyanzhao.spring.demo1"/>
  18.     <!-- 引入外部属性文件 -->
  19.     <context:property-placeholder location="classpath:jdbc.properties"/>
  21.     <!-- 配置C3P0连接池 -->
  22.     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  23.         <property name="driverClass" value="${jdbc.driverClass}"/>
  24.         <property name="jdbcUrl" value="${jdbc.url}"/>
  25.         <property name="user" value="${jdbc.username}"/>
  26.         <property name="password" value=""/>
  27.     </bean>
  29.     <!--
  30.         id值可以随便写，与ref对应；
  31.         name值 是 类中的要注入的属性
  32.     -->
  33.     <bean id="accountService" class="com.liuyanzhao.spring.demo1.AccountService">
  34.         <property name="accountDao" ref="accountDao"></property>
  35.     </bean>
  36.     <bean id="accountDao" class="com.liuyanzhao.spring.demo1.AccountDao">
  37.         <property name="jdbcTemplate" ref="jdbcTemplate"></property>
  38.     </bean>
  39.     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
  40.         <property name="dataSource" ref="dataSource"></property>
  41.     </bean>
  43.     <!--第一步 配置事务管理器-->
  44.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  45.         <property name="dataSource" ref="dataSource"></property>
  46.     </bean>
  48.     <!--第二步 开启事务注解-->
  49.     <tx:annotation-driven transaction-manager="transactionManager"/>
  51. </beans>



参考：传智播客视频

本文链接：https://liuyanzhao.com/5717.html
历史上的今天
八月
08日
  • 微信
  • 交流学习，资料分享
  • weinxin
  • 个人淘宝
  • 店铺名：言曌博客咨询部

  • (部分商品未及时上架淘宝)
avatar

发表评论

avatar 登录者：匿名
匿名评论，评论回复后会有邮件通知

  

已通过评论：0   待审核评论数：0