一、引入依赖
<?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"><modelVersion>4.0.0</modelVersion><groupId>com.william</groupId><artifactId>spring_day04_05_tx_aop_xml</artifactId><version>1.0-SNAPSHOT</version><properties><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target></properties><dependencies><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>5.1.47</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-context-support</artifactId><version>5.0.2.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>5.0.2.RELEASE</version></dependency><dependency><groupId>com.mchange</groupId><artifactId>c3p0</artifactId><version>0.9.5.2</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version></dependency><dependency><groupId>commons-dbutils</groupId><artifactId>commons-dbutils</artifactId><version>1.4</version></dependency><dependency><groupId>cglib</groupId><artifactId>cglib</artifactId><version>2.2.2</version></dependency><dependency><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId><version>1.8.9</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>5.0.2.RELEASE</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>5.0.2.RELEASE</version></dependency></dependencies>
</project>
二、配置xml文件
1.开启注解扫描
2 创建数据源SpringdataSource
3 引入属性文件
4、 创建JdbcTemplate对象
5、创建事务管理器对象: 增强(通知)
6 事务增强:对方法的过滤
name: 方法名,可以使用通配符的方式配置
propagation: 传播的行为,查询方法SUPPORTS, 增删改方法:REQUIRED
(REQUIRED:如果当前没有事务,就新建一个事务,如果已经存在一个事务中,加入到这个事务中。一般的选 择(默认值)
SUPPORTS:支持当前事务,如果当前没有事务,就以非事务方式执行(没有事务) )
isolation: 隔离级别:一般选择数据库默认的隔离级别(一般不用配置)
read-only: 只读,查询使用只读操作,增删改使用非只读操作
time-out: 超时的时间定义,默认-1 ,永不超时(一般不用配置)
7配置aop
<?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:context="http://www.springframework.org/schema/context"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/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"><!--开启注解扫描--><context:component-scan base-package="com.william"></context:component-scan><!--创建dataSource--><bean id="SpringdataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"><property name="driverClassName" value="${jdbc.driverClass}"></property><property name="url" value="${jdbc.jdbcUrl}"></property><property name="username" value="${jdbc.user}"></property><property name="password" value="${jdbc.password}"></property></bean><!--引入属性文件--><context:property-placeholder location="classpath:db.properties"></context:property-placeholder><!--创建JdbcTemplate对象--><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"><constructor-arg name="dataSource" ref="SpringdataSource"></constructor-arg></bean><!--创建事务管理器对象: 增强(通知)--><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"><!--操作事务需要连接对象,连接对象在连接池中(数据源)--><property name="dataSource" ref="SpringdataSource"></property></bean><!--事务增强:对方法的过滤--><tx:advice id="txAdvice" transaction-manager="transactionManager"><tx:attributes><tx:method name="*"/></tx:attributes><!--<tx:method name="insert*"></tx:method>--><!--<tx:method name="update*"></tx:method>--><!--<tx:method name="del*"></tx:method>--><!--<tx:method name="add*"></tx:method>--><!--<tx:method name="transfer"></tx:method>--><!--name="*" 其他方法--><!--<tx:method name="*" propagation="SUPPORTS" read-only="true"></tx:method>--><!--name: 方法名,可以使用通配符的方式配置propagation: 传播的行为,查询方法SUPPORTS, 增删改方法:REQUIREDisolation: 隔离级别:一般选择数据库默认的隔离级别(一般不用配置)read-only: 只读,查询使用只读操作,增删改使用非只读操作time-out: 超时的时间定义,默认-1 ,永不超时(一般不用配置)--><!--非事务运行--></tx:advice><!--配置aop--><aop:config><!--切入点表达式--><aop:pointcut id="pc" expression="execution(* com.itheima.service.impl.*.*(..))"></aop:pointcut><!--织入--><aop:advisor advice-ref="txAdvice" pointcut-ref="pc" ></aop:advisor></aop:config><!--声明式事务管理 - 结束--><!--编程式事务管理: 在业务层字节编写事务 -->
</beans>
二、Class文件
1.目录结构
2.AccountDaoImpl 代码
package com.william.Dao.Impl;import com.william.Dao.AccountDao;
import com.william.domain.Account;import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;import java.sql.SQLException;
import java.util.List;/*** @author :lijunxuan* @date :Created in 2019/5/27 16:00* @description :* @version: 1.0*/
@Repository
public class AccountDaoImpl implements AccountDao {@AutowiredJdbcTemplate jdbcTemplate;@Overridepublic Account findByUserName(String username ) {String sql="select * from account where name = ?";Account account = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(Account.class), username);return account;}@Overridepublic void Update(Account account) {String sql =" update account set money = ? where id =?";Object [] params= {account.getMoney(),account.getId()};jdbcTemplate.update(sql,params);}
}
3.AccountServiceImpl
AccountServiceImpl代码:
package com.william.service.Impl;import com.william.Dao.AccountDao;
import com.william.domain.Account;
import com.william.service.AccountService;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** @author :lijunxuan* @date :Created in 2019/5/27 16:14* @description :* @version: 1.0*/
@Service
public class AccountServiceImpl implements AccountService {@AutowiredAccountDao accountDao;@Overridepublic void transfer(String FromMoney, String ToMoney, Float money) {//开启事务:transactionManager//查询账户名称 两个账户名称Account FromuserName = accountDao.findByUserName(FromMoney);Account ToUserName = accountDao.findByUserName(ToMoney);//修改金额FromuserName.setMoney(FromuserName.getMoney()-money);ToUserName.setMoney(ToUserName.getMoney()+money);int i=1/0;//修改账户表accountDao.Update(FromuserName);accountDao.Update(ToUserName);}
}
3.TestTrasfer
代码TestTrasfer
package com.william;
import com.william.service.AccountService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
/**
- @author :lijunxuan
- @date :Created in 2019/5/27 16:22
- @description :
- @version: 1.0
*/
@Component
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(“classpath:applicationContext.xml”)
public class TestTrasfer {
@Autowired
AccountService accountService;
@Test
public void testTrasferMoney(){
accountService.transfer(“william”,“william-Li”,500f);
}
}