基于xml配置事务

spring_aop/src/main/java/com/AopTest.java

@@ -27,5 +27,9 @@ public class AopTest {
     public void testInitAccount() {
         accountService.initAccount();
     }
-
+    @Test
+    public void transform() {
+        // 交易测试
+        accountService.transfer(5,4,1.0);
+    }
 }

spring_aop/src/main/java/com/transaction_/dao/AccountDao.java

@@ -4,6 +4,6 @@ package com.transaction_.dao;
 import com.transaction_.entity.AccountEntity;
 
 public interface AccountDao {
-    public int saveAccount(AccountEntity accountEntity);
-
+     int saveAccount(AccountEntity accountEntity);
+     int incomeAccount(AccountEntity accountEntity,String type);
 }

spring_aop/src/main/java/com/transaction_/dao/impl/AccountDaoImpl.java

@@ -8,8 +8,12 @@ import org.springframework.stereotype.Repository;
 
 @Repository
 public class AccountDaoImpl implements AccountDao {
-    @Autowired
     private JdbcTemplate jdbcTemplate;
+
+    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+    }
+
     @Override
     public int saveAccount(AccountEntity accountEntity) {
         String addsql = "insert into account(user_name,balance) values(?,?)";
@@ -17,4 +21,20 @@ public class AccountDaoImpl implements AccountDao {
         return jdbcTemplate.update(addsql,args);
         //返回值update代表添加了几行
     }
+
+    /**
+     * 账户转入或转出
+     * @param accountEntity
+     * @param type   in 转入 out 转出
+     * @return
+     */
+    @Override
+    public int incomeAccount(AccountEntity accountEntity,String type) {
+        String updateSql = "update account set balance=balance"
+                + (type == "in" ? "+" :"-")
+                + " ? where id =?";
+        Object[] args = {accountEntity.getBalance(),accountEntity.getId()};
+        return jdbcTemplate.update(updateSql,args);
+    }
+
 }

spring_aop/src/main/java/com/transaction_/entity/AccountEntity.java

@@ -1,14 +1,16 @@
 package com.transaction_.entity;
 
 import lombok.Data;
+import lombok.experimental.Accessors;
 
 import java.math.BigDecimal;
 import java.util.Date;
 
 @Data
+@Accessors(chain = true)
 public class AccountEntity {
     private Integer id;
     private String userName;
-    private BigDecimal balance;
+    private Double balance;
     private Date ctime;
 }

spring_aop/src/main/java/com/transaction_/service/AccountService.java

@@ -2,4 +2,6 @@ package com.transaction_.service;
 
 public interface AccountService {
      void initAccount();
+     // 模拟转账操作
+     boolean transfer(Integer fromId,Integer toId,Double balance);
 }

spring_aop/src/main/java/com/transaction_/service/impl/AccountServiceImpl.java

@@ -3,20 +3,34 @@ package com.transaction_.service.impl;
 import com.transaction_.dao.AccountDao;
 import com.transaction_.entity.AccountEntity;
 import com.transaction_.service.AccountService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
-import java.math.BigDecimal;
-
-@Service
 public class AccountServiceImpl implements AccountService {
-    @Autowired
     AccountDao accountDao;
+    public void setAccountDao(AccountDao accountDao) {
+        this.accountDao = accountDao;
+    }
+
     @Override
     public void initAccount() {
         AccountEntity accountEntity = new AccountEntity();
-        accountEntity.setUserName("mr.zhang");
-        accountEntity.setBalance(new BigDecimal("500.5"));
+        accountEntity.setUserName("李四");
+        accountEntity.setBalance(300.0);
         int i = accountDao.saveAccount(accountEntity);
     }
+    @Transactional(rollbackFor = Exception.class)
+    @Override
+    public boolean transfer(Integer fromId, Integer toId, Double balance) {
+        // 转账操作
+        AccountEntity fromEntity = new AccountEntity();
+        AccountEntity toEntity = new AccountEntity();
+        fromEntity.setId(fromId).setBalance(balance);
+        toEntity.setId(toId).setBalance(balance);
+        // 开启事务
+        accountDao.incomeAccount(toEntity,"to");
+//        int i = 1/0;
+        accountDao.incomeAccount(fromEntity,"in");
+        // 提交事务
+        return false;
+    }
 }

spring_aop/src/main/resources/context.xml

@@ -12,6 +12,7 @@
        https://www.springframework.org/schema/context/spring-context.xsd
 
     ">
+    <import resource="classpath:transaction_aop.xml"></import>
 <!--       1、配置目标对象 2、配置切面对象 3、配置织入告诉Spring 哪些方法（切点）需要增强 -->
     <bean id="target" class="com.aop.TargetImpl"></bean>
     <bean id="myaspect" class="com.aop.MyAspect">
@@ -32,9 +33,7 @@
             <aop:after method="after" pointcut-ref="save2" />
         </aop:aspect>
     </aop:config>
-    <context:component-scan base-package="com.anno"></context:component-scan>
-    <context:component-scan base-package="com.config"></context:component-scan>
-    <context:component-scan base-package="com.transaction_"></context:component-scan>
+    <context:component-scan base-package="com"></context:component-scan>
 <!--    aop自动代理-->
     <aop:aspectj-autoproxy />
 </beans>

spring_aop/src/main/resources/transaction_aop.xml

@@ -0,0 +1,32 @@
+<?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:tx="http://www.springframework.org/schema/tx"
+       xmlns:context="http://www.springframework.org/schema/context"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+       http://www.springframework.org/schema/beans/spring-beans.xsd
+       http://www.springframework.org/schema/tx
+       https://www.springframework.org/schema/tx/spring-tx.xsd
+       http://www.springframework.org/schema/context
+       https://www.springframework.org/schema/context/spring-context.xsd
+">
+    <context:property-placeholder location="jdbc.properties"></context:property-placeholder>
+    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
+        <property name="driverClassName" value="${jdbc.driver}"></property>
+        <property name="url" value="${jdbc.url}"></property>
+        <property name="username" value="${jdbc.username}"></property>
+        <property name="password" value="${jdbc.password}"></property>
+    </bean>
+    <bean id="jdbcTemp" class="org.springframework.jdbc.core.JdbcTemplate">
+        <property name="dataSource" ref="dataSource"></property>
+    </bean>
+    <bean id="accountDao" class="com.transaction_.dao.impl.AccountDaoImpl">
+        <property name="jdbcTemplate" ref="jdbcTemp"></property>
+    </bean>
+    <bean id="accountService" class="com.transaction_.service.impl.AccountServiceImpl">
+        <property name="accountDao" ref="accountDao">
+        </property>
+    </bean>
+
+
+</beans>