事务的传播行为 测试

spring_aop/pom.xml

@@ -33,9 +33,16 @@
             <scope>test</scope>
         </dependency>
         <dependency>
-            <groupId>log4j</groupId>
-            <artifactId>log4j</artifactId>
-            <version>1.2.17</version>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>2.7</version>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-api</artifactId>
+            <version>2.7</version>
+            <scope>provided</scope>
         </dependency>
         <dependency>
             <groupId>junit</groupId>
@@ -68,6 +75,11 @@
             <artifactId>mysql-connector-java</artifactId>
             <version>8.0.17</version>
         </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-nop</artifactId>
+            <version>1.7.2</version>
+        </dependency>
     </dependencies>
 
 </project>

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

@@ -1,12 +1,16 @@
 package com;
 
 
+import com.transaction_anno.entity.AccountEntity;
 import com.transaction_anno.service.AccountService;
+import com.transaction_anno.service.AccountTwoService;
 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;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
 
 @RunWith(SpringJUnit4ClassRunner.class)
 @ContextConfiguration("classpath:context.xml")
@@ -14,10 +18,16 @@ public class TestTx {
 
     @Autowired
     AccountService accountService;
-
+    @Autowired
+    AccountTwoService accountTwoService;
     @Test
     public void transformAnno() {
-        // 交易测试
-        accountService.transfer(16,17,3.0);
+        // 转账操作
+        AccountEntity reduceEntity = new AccountEntity();
+        AccountEntity addEntity = new AccountEntity();
+        reduceEntity.setId(16).setBalance(3.0);
+        addEntity.setId(17).setBalance(3.0);
+        accountService.reduceAccount(reduceEntity);
+        accountTwoService.addAccountBalance(addEntity);
     }
 }

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

@@ -0,0 +1,7 @@
+package com.transaction_.service;
+
+import com.transaction_.entity.AccountEntity;
+
+public interface AccountTwoService {
+    void addAccountBalance(AccountEntity addEntity);
+}

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

@@ -0,0 +1,18 @@
+package com.transaction_.service.impl;
+
+import com.transaction_.dao.AccountDao;
+import com.transaction_.entity.AccountEntity;
+import com.transaction_.service.AccountTwoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+@Service
+public class AccountTwoServiceImpl implements AccountTwoService {
+    @Autowired
+    AccountDao accountDao;
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void addAccountBalance(AccountEntity addEntity) {
+        int in = accountDao.incomeAccount(addEntity, "in");
+    }
+}

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

@@ -1,7 +1,9 @@
 package com.transaction_anno.service;
 
+import com.transaction_anno.entity.AccountEntity;
+
 public interface AccountService {
       void initAccount();
-     // 模拟转账操作
-      boolean transfer(Integer fromId,Integer toId,Double balance);
+     // 扣除
+      int reduceAccount(AccountEntity toEntity);
 }

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

@@ -0,0 +1,7 @@
+package com.transaction_anno.service;
+
+import com.transaction_anno.entity.AccountEntity;
+
+public interface AccountTwoService {
+    void addAccountBalance(AccountEntity addEntity);
+}

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

@@ -1,5 +1,6 @@
 package com.transaction_anno.service.impl;
 
+import com.transaction_anno.service.AccountTwoService;
 import com.transaction_anno.dao.AccountDao;
 import com.transaction_anno.entity.AccountEntity;
 import com.transaction_anno.service.AccountService;
@@ -12,7 +13,6 @@ import org.springframework.transaction.annotation.Transactional;
 public class AccountServiceImpl implements AccountService {
     @Autowired
     AccountDao accountDao;
-
     @Override
     public void initAccount() {
         AccountEntity accountEntity = new AccountEntity();
@@ -22,25 +22,8 @@ public class AccountServiceImpl implements AccountService {
     }
     @Transactional(rollbackFor = Exception.class,propagation = Propagation.REQUIRED)
     @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);
-        // 开启事务
-        try {
-            toAccount(toEntity);
-        }catch (Exception e) {
-            System.out.println(e.getMessage());
-        }
-        int in = accountDao.incomeAccount(fromEntity, "in");
-        int i = 1/0;
-        // 提交事务
-        return false;
-    }
-    public int toAccount(AccountEntity toEntity) {
-        int to = accountDao.incomeAccount(toEntity, "to");
-        return to;
+    public int reduceAccount(AccountEntity toEntity) {
+        int in = accountDao.incomeAccount(toEntity, "to");
+        return 0;
     }
 }

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

@@ -0,0 +1,19 @@
+package com.transaction_anno.service.impl;
+
+import com.transaction_anno.dao.AccountDao;
+import com.transaction_anno.entity.AccountEntity;
+import com.transaction_anno.service.AccountTwoService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service("annoAccountTwo")
+public class AccountTwoServiceImpl implements AccountTwoService {
+    @Autowired
+    AccountDao accountDao;
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void addAccountBalance(AccountEntity addEntity) {
+        int in = accountDao.incomeAccount(addEntity, "in");
+    }
+}

spring_aop/src/main/resources/log4j.properties

@@ -1,16 +1,30 @@
-log4j.rootCategory=INFO, stdout , R
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%d-[HL] %p %t %c - %m%n
+log4j.rootLogger=INFO,Console
 
-log4j.appender.R=org.apache.log4j.RollingFileAppender
-log4j.appender.R.File=${\u5E94\u7528\u540D.root}/WEB-INF/logs/xx.log
-log4j.appender.R.MaxFileSize=1024KB
-log4j.appender.R.MaxBackupIndex=10
-log4j.appender.R.layout=org.apache.log4j.PatternLayout
-log4j.appender.R.layout.ConversionPattern=%d-[HL] %p %t %c - %m%n
+log4j.appender.Console=org.apache.log4j.ConsoleAppender
+log4j.appender.Console.Target=System.out
+log4j.appender.Console.Threshold=DEBUG
+log4j.appender.Console.layout=org.apache.log4j.PatternLayout
+log4j.appender.Console.layout.ConversionPattern=[%d]%l%5p:%m%n
 
-log4j.logger.org.springframework=DEBUG
-log4j.logger.org.hibernate=DEBUG
-log4j.logger.org.hibernate.ps.PreparedStatementCache=WARN
-log4j.logger.com.lagooo.as=DEBUG
+log4j.appender.DebugFile=org.apache.log4j.RollingFileAppender
+log4j.appender.DebugFile.File=../log/debugFile.log
+#log4j.appender.DebugFile.File=debugFile.log
+log4j.appender.DebugFile.Append=true
+log4j.appender.DebugFile.Threshold=DEBUG
+log4j.appender.DebugFile.layout=org.apache.log4j.PatternLayout
+log4j.appender.DebugFile.layout.ConversionPattern=[%d]%l%5p:%m%n
+log4j.appender.DebugFile.MaxFileSize=20MB
+log4j.appender.DebugFile.MaxBackupIndex=10
+
+log4j.logger.com.ibatis=DEBUG
+log4j.logger.com.ibatis.common.jdbc.SimpleDataSource=DEBUG
+log4j.logger.com.ibatis.common.jdbc.ScriptRunner=DEBUG
+log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate=DEBUG
+
+log4j.logger.java.sql=DEBUG
+log4j.logger.java.sql.Connection = INFO
+log4j.logger.java.sql.Statement = DEBUG
+log4j.logger.java.sql.PreparedStatement = DEBUG
+log4j.logger.java.sql.ResultSet = DEBUG
+
+log4j.logger.com.yuetao=DEBUG

spring_aop/src/main/resources/log4j2.xml

@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<Configuration>
+    <Appenders>
+        <Console name="STDOUT" target="SYSTEM_OUT">
+            <PatternLayout pattern="%d %-5p [%t] %C{2} (%F:%L) - %m%n"/>
+        </Console>
+        <RollingFile name="RollingFile" fileName="logs/strutslog1.log"
+                     filePattern="logs/$${date:yyyy-MM}/app-%d{MM-dd-yyyy}-%i.log.gz">
+            <PatternLayout>
+                <Pattern>%d{MM-dd-yyyy} %p %c{1.} [%t] -%M-%L- %m%n</Pattern>
+            </PatternLayout>
+            <Policies>
+                <TimeBasedTriggeringPolicy />
+                <SizeBasedTriggeringPolicy size="1 KB"/>
+            </Policies>
+            <DefaultRolloverStrategy fileIndex="max" max="2"/>
+        </RollingFile>
+    </Appenders>
+    <Loggers>
+        <Logger name="com.opensymphony.xwork2" level="WAN"/>
+        <Logger name="org.apache.struts2" level="WAN"/>
+        <Logger name="org.springframework.jdbc.core" level="debug"/>
+        <Logger name="org.springframework.jdbc.core.StatementCreatorUtils" level="trace"/>
+        <Root level="warn">
+            <AppenderRef ref="STDOUT"/>
+        </Root>
+    </Loggers>
+
+</Configuration>