基于注解的事务控制

spring_aop/src/main/java/com/TestTx.java

@@ -0,0 +1,23 @@
+package com;
+
+
+import com.transaction_anno.service.AccountService;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.test.context.ContextConfiguration;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+@RunWith(SpringJUnit4ClassRunner.class)
+@ContextConfiguration("classpath:context.xml")
+public class TestTx {
+
+    @Autowired
+    AccountService accountService;
+
+    @Test
+    public void transformAnno() {
+        // 交易测试
+        accountService.transfer(5,4,3.0);
+    }
+}

spring_aop/src/main/java/com/config/JdbcConfig.java

@@ -9,8 +9,8 @@ import org.springframework.jdbc.core.JdbcTemplate;
 
 import javax.sql.DataSource;
 
-@Configuration
-@PropertySource("classpath:jdbc.properties")
+//@Configuration
+//@PropertySource("classpath:jdbc.properties")
 public class JdbcConfig {
     // 写一个dataSource
     @Value("${jdbc.url}")

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

@@ -0,0 +1,9 @@
+package com.transaction_anno.dao;
+
+
+import com.transaction_anno.entity.AccountEntity;
+
+public interface AccountDao {
+     int saveAccount(AccountEntity accountEntity);
+     int incomeAccount(AccountEntity accountEntity, String type);
+}

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

@@ -0,0 +1,36 @@
+package com.transaction_anno.dao.impl;
+
+import com.transaction_anno.dao.AccountDao;
+import com.transaction_anno.entity.AccountEntity;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Repository;
+
+@Repository("anno_AccountDao")
+public class AccountDaoImpl implements AccountDao {
+    @Autowired
+    private JdbcTemplate jdbcTemplate;
+    @Override
+    public int saveAccount(AccountEntity accountEntity) {
+        String addsql = "insert into account(user_name,balance) values(?,?)";
+        Object[] args = {accountEntity.getUserName(),accountEntity.getBalance()};
+        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_anno/entity/AccountEntity.java

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

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

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

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

@@ -0,0 +1,39 @@
+package com.transaction_anno.service.impl;
+
+import com.transaction_anno.dao.AccountDao;
+import com.transaction_anno.entity.AccountEntity;
+import com.transaction_anno.service.AccountService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service("account_anno")
+public class AccountServiceImpl implements AccountService {
+    @Autowired
+    AccountDao accountDao;
+
+    @Override
+    public void initAccount() {
+        AccountEntity accountEntity = new AccountEntity();
+        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) {
+        // 转账操作
+        boolean b;
+        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/transaction_aop.xml

@@ -34,13 +34,15 @@
     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
         <property name="dataSource" ref="dataSource"></property>
     </bean>
-<!--    <tx:advice id="interceptor" transaction-manager="transactionManager">-->
-<!--        <tx:attributes>-->
-<!--            <tx:method name="transfer" rollback-for="java.lang.Exception" timeout="-1"/>-->
-<!--        </tx:attributes>-->
-<!--    </tx:advice>-->
-<!--    <aop:config>-->
-<!--        <aop:advisor advice-ref="interceptor" pointcut="execution(* com.transaction_.service.impl.AccountServiceImpl.*(..))"></aop:advisor>-->
-<!--    </aop:config>-->
-
+    <tx:advice id="interceptor" transaction-manager="transactionManager">
+        <tx:attributes>
+            <tx:method name="transfer*" isolation="DEFAULT" rollback-for="java.lang.Exception" timeout="-1"/>
+        </tx:attributes>
+    </tx:advice>
+    <aop:config>
+        <aop:pointcut id="txPointCut" expression="execution(* com.transaction_.service.impl.AccountServiceImpl.*(..))"/>
+        <aop:advisor advice-ref="interceptor"
+                     pointcut-ref="txPointCut"/>
+    </aop:config>
+    <tx:annotation-driven />
 </beans>