typora-copy-images-to: img
Spring_03
学习目标
- 能够掌握基于注解的AOP配置
- 能够使用spring的jdbc的模板
- 能够配置spring的连接池
- 能够使用jdbc模板完成增删改查的操作
- 能够应用声明式事务
- 能够理解事务的传播行为
第一章-Spring中的AOP
知识点-基于XML的AOP配置
1.目标
- 能够编写Spring的AOP中不同通知的代码
2.路径
- 前置通知
- 后置通知
- 环绕通知
- 异常通知
- 最终通知
3.讲解
3.1前置通知
需求: 在service的增删改查方法调用之前进行权限的校验
实现步骤:
- 导入坐标
- 定义Dao和增强的逻辑, 进行注册
配置AOP
- 配置切入点
- 配置切面(切入点和通知结合)
实现:
- 导入坐标
<dependencies>
<!--Spring核心容器-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--SpringAOP相关的坐标-->
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.7</version>
</dependency>
<!--Spring整合单元测试-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--单元测试-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
</dependencies>
- 导入约束
<?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:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd">
</beans>
- 定义被增强的业务逻辑类和切面类(增强的) ```java package com.itheima.service.impl;
import com.itheima.service.UserService;
/**
- 包名:com.itheima.service.impl *
- @author Leevi
- 日期2020-08-12 08:36
- 目标1:在执行增删改查方法之前,都做权限校验 前置通知: before
- 目标2:在执行增删改查方法之后(没有出现异常), 都打印日志 后置通知: after-returning
- 目标3:在执行增删改查方法出现异常之后,都进行友好的提示 异常通知: after-throwing
- 目标4:在执行增删改查方法之后,无论出没出现异常,均打印一句”执行完毕” 最终通知: after
目标5:计算update方法的执行时间 环绕通知: around */ public class UserServiceImpl implements UserService { @Override public void add() {
System.out.println("执行添加...");
int num = 10/0;
}
@Override public void delete() {
System.out.println("执行删除...");
}
@Override public void update() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("执行修改...");
}
@Override public void select() {
System.out.println("执行查询...");
} } ```
package com.itheima.aspect;
import org.aspectj.lang.ProceedingJoinPoint;
/**
* 包名:com.itheima.aspect
*
* @author Leevi
* 日期2020-08-12 08:39
*/
public class PermissionAspect {
public void checkPermission(){
System.out.println("校验权限...");
}
public void printLog(){
System.out.println("打印日志...");
}
public void showException(){
System.out.println("出现异常了,请检查...");
}
public void showEnd(){
System.out.println("执行完毕...");
}
//计算目标方法的执行时长
public void showMillions(ProceedingJoinPoint joinPoint){
//1. 记录当前时间
long timeMillis1 = System.currentTimeMillis();
//2. 执行目标方法
try {
joinPoint.proceed();
} catch (Throwable throwable) {
throwable.printStackTrace();
}
//3. 再记录当前时间
long timeMillis2 = System.currentTimeMillis();
//4. 将两次的时间相减,得到方法的执行时长
System.out.println(timeMillis2 - timeMillis1);
}
}
applicationContext.xml配置文件中进行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:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop.xsd">
<!--全部采用纯配置文件方式-->
<!--1. 对UserServiceImpl进行IOC配置-->
<bean id="userService" class="com.itheima.service.impl.UserServiceImpl"></bean>
<!--2. 对切面类PermissionAspect进行IOC配置-->
<bean id="permissionAspect" class="com.itheima.aspect.PermissionAspect"></bean>
<!--
3. 配置AOP <aop:config>
1. 配置切入点 <aop:pointcut id="" expression=""/>
id: 切入点的唯一标识
expression: 切入点表达式
2. 配置通知
3. 配置切面关联通知和切入点
-->
<aop:config>
<!--配置切入点-->
<aop:pointcut id="pt1"
expression="execution(* com.itheima.service.impl.UserServiceImpl.*(..))"/>
<aop:pointcut id="pt2" expression="execution(* com.itheima.service.impl.UserServiceImpl.update(..))"/>
<!--配置切面-->
<aop:aspect id="aspect1" ref="permissionAspect">
<!--配置前置通知-->
<aop:before method="checkPermission" pointcut-ref="pt1"></aop:before>
<!--配置后置通知-->
<aop:after-returning method="printLog" pointcut-ref="pt1"></aop:after-returning>
<!--配置异常通知-->
<aop:after-throwing method="showException" pointcut-ref="pt1"></aop:after-throwing>
<!--配置最终通知-->
<aop:after method="showEnd" pointcut-ref="pt1"></aop:after>
<!--配置环绕通知-->
<aop:around method="showMillions" pointcut-ref="pt2"></aop:around>
</aop:aspect>
</aop:config>
</beans>
知识点-基于注解的AOP配置
1.目标
- 能够理解spring的AOP的注解
2.分析
2.1路径
- 前置通知
- 后置通知
- 环绕通知
- 异常通知
- 最终通知
2.2步骤
- 创建工程, 导入坐标
- 创建Dao和增强的类, 注册
- 开启AOP的注解支持
- 在增强类上面添加@Aspect
在增强类的增强方法上面添加
- @Before()
- @AfterReturning()
- @Around()
- @AfterThrowing()
- @After()
3.讲解
3.1前置通知
- 添加坐标
<dependencies>
<!--Spring核心容器-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--SpringAOP相关的坐标-->
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.7</version>
</dependency>
<!--Spring整合单元测试-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--单元测试-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
</dependencies>
- 定义被增强的业务逻辑类 ```java package com.itheima.service.impl;
import com.itheima.service.UserService; import org.springframework.stereotype.Service;
/**
- 包名:com.itheima.service.impl *
- @author Leevi
- 日期2020-08-12 08:36
- 目标1:在执行增删改查方法之前,都做权限校验 前置通知: before
- 目标2:在执行增删改查方法之后(没有出现异常), 都打印日志 后置通知: after-returning
- 目标3:在执行增删改查方法出现异常之后,都进行友好的提示 异常通知: after-throwing
- 目标4:在执行增删改查方法之后,无论出没出现异常,均打印一句”执行完毕” 最终通知: after
目标5:计算update方法的执行时间 环绕通知: around */ @Service public class UserServiceImpl implements UserService { @Override public void add() {
System.out.println("执行添加...");
int num = 10/0;
}
@Override public void delete() {
System.out.println("执行删除...");
}
@Override public void update() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("执行修改...");
}
@Override public void select() {
System.out.println("执行查询...");
} } ```
- 定义切面类,在切面增强类上面使用注解 @Aspect并且在切面类中定义切入点方法 ```java package com.itheima.aspect;
import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.*; import org.springframework.stereotype.Component;
/**
- 包名:com.itheima.aspect *
- @author Leevi
- 日期2020-08-12 08:39 *
- 注解方式配置切入点 在方法上添加Pointcut注解配置切入点,方法的名字就是切入点的唯一标识
- 配置通知
- 前置通知 Before注解
- 后置通知 AfterReturning注解
- 异常通知 AfterThrowing注解
- 最终通知 After注解
- 环绕通知 Around注解
配置切面:在切面类上添加Aspect注解 / @Component @Aspect public class PermissionAspect { @Pointcut(“execution( com.itheima.service.impl.UserServiceImpl.*(..))”) public void pt1(){
}
@Pointcut(“execution(* com.itheima.service.impl.UserServiceImpl.update(..))”) public void pt2(){
}
@Before(“pt1()”) public void checkPermission(){ System.out.println(“校验权限…”); }
@AfterReturning(“pt1()”) public void printLog(){ System.out.println(“打印日志…”); }
@AfterThrowing(“pt1()”) public void showException(){ System.out.println(“出现异常了,请检查…”); }
@After(“pt1()”) public void showEnd(){ System.out.println(“执行完毕…”); }
//计算目标方法的执行时长 @Around(“pt2()”) public void showMillions(ProceedingJoinPoint joinPoint){ //1. 记录当前时间 long timeMillis1 = System.currentTimeMillis(); //2. 执行目标方法 try {
joinPoint.proceed();
} catch (Throwable throwable) {
throwable.printStackTrace();
} //3. 再记录当前时间 long timeMillis2 = System.currentTimeMillis(); //4. 将两次的时间相减,得到方法的执行时长 System.out.println(timeMillis2 - timeMillis1); } } ```
创建配置文件
<?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:aop="http://www.springframework.org/schema/aop"
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/aop
http://www.springframework.org/schema/aop/spring-aop.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd">
<!--1. 包扫描-->
<context:component-scan base-package="com.itheima"/>
<!--
2. 加载aop的注解驱动
-->
<aop:aspectj-autoproxy />
</beans>
第二章 - Spring中的JdbcTemplate 【了解】
知识点-JdbcTemplate基本使用
1.目标
- 能够使用JdbcTemplate
2.路径
- JdbcTemplate介绍
- JdbcTemplate入门
- 使用JdbcTemplate完成CRUD
3.讲解
3.1JdbcTemplate介绍
Spring除了IOC 和 AOP之外,还对Dao层的提供了支持。 就算没有框架,也对原生的JDBC提供了支持。它是spring框架中提供的一个对象,是对原始Jdbc API对象的简单封装。spring框架为我们提供了很多的操作模板类。
持久化技术 | 模版类 |
---|---|
JDBC | org.springframework.jdbc.core.JdbcTemplate |
Hibrenate | org.springframework.orm.hibernate5.HibernateTemplate |
MyBatis | org.mybatis.spring.SqlSessionTemplate |
3.2JDBC模版入门案例
- 创建Maven工程,导入坐标
<dependencies>
<!--Spring核心容器-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--SpringJdbc-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.6</version>
</dependency>
<!--Spring整合单元测试-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--单元测试-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.12</version>
</dependency>
<!--druid连接池-->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.18</version>
</dependency>
</dependencies>
- Account
package com.itheima.pojo;
import lombok.Data;
/**
* 包名:com.itheima.pojo
*
* @author Leevi
* 日期2020-08-09 14:55
*/
@Data
public class Account {
private String name;
private Integer id;
private Double money;
}
- 使用JDBC模版API
//使用JDBC模版保存
public void save(Account account) {
//1. 创建数据源
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/spring_day03");
dataSource.setUsername("root");
dataSource.setPassword("123456");
//2. 创建JDBC模版
JdbcTemplate jdbcTemplate = new JdbcTemplate();
jdbcTemplate.setDataSource(dataSource);
//3.操作数据库
String sql = "insert into account values(?,?,?)";
jdbcTemplate.update(sql, null,account.getName(),account.getMoney())
}
3.3.使用JDBC模版完成CRUD
- 增加
String sql = "insert into account values(?,?,?)";
jdbcTemplate.update(sql, null,account.getName(),account.getMoney());
- 修改
String sql ="update account set name = ? where id = ?";
Object[] objects = {user.getName(), user.getId()};
jdbcTemplate.update(sql,objects);
- 删除
String sql = "delete from account where id=?";
jdbcTemplate.update(sql, 6);
- 查询单个值
String sql = "select count(*) from t_user";
Long n = jdbcTemplate.queryForObject(sql, Long.class);
String sql = "select name from t_user where id=?";
String name = jdbcTemplate.queryForObject(sql, String.class, 4);
System.out.println(name);
- 查询单个对象
String sql = "select * from account where id = ?";
User user = jdbcTemplate.queryForObject(sql,new BeanPropertyRowMapper<>(Account.class),id);
- 查询集合
String sql = "select * from account";
List<Map<String, Object>> list = jdbcTemplate.queryForList(sql);
System.out.println(list);
String sql = "select * from account";
List<Account> list = List<User> list = jdbcTemplate.query(sql, new BeanPropertyRowMapper<>(Account.class));
4.小结
- JdbcTemplate是Spring里面的持久层一个工具包, 封装了Jdbc
使用步骤
- 创建DataSource
- 创建JDBCTemplate
- 调用update(), query(), queryForObject()
知识点-在dao中使用JdbcTemplate
1.目标
- 能够使用spring的jdbc的模板
2.路径
- 方式一在dao中定义JdbcTemplate
- 方式二dao继承JdbcDaoSupport
3.讲解
3.1方式一
这种方式我们采取在dao中定义JdbcTemplate
- AccountDaoImpl.java
public class AccountDaoImpl implements AccountDao {
@Autowired
private JdbcTemplate jdbcTemplate;
@Override
public Account findAccountById(Integer id) {
List<Account> list = jdbcTemplate.query("select * from account where id = ? ",new AccountRowMapper(),id);
return list.isEmpty()?null:list.get(0);
}
@Override
public Account findAccountByName(String name) {
List<Account> list = jdbcTemplate.query("select * from account where name = ? ",new AccountRowMapper(),name);
if(list.isEmpty()){
return null;
}
if(list.size()>1){
throw new RuntimeException("结果集不唯一,不是只有一个账户对象");
}
return list.get(0);
}
@Override
public void updateAccount(Account account) {
jdbcTemplate.update("update account set money = ? where id = ? ",account.getMoney(),account.getId());
}
}
- applicationContext.xml
<!-- 配置一个dao -->
<bean id="accountDao" class="com.itheima.dao.impl.AccountDaoImpl">
<!-- 注入jdbcTemplate -->
<property name="jdbcTemplate" ref="jdbcTemplate"></property>
</bean>
<!-- 配置一个数据库的操作模板:JdbcTemplate -->
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource"></property>
</bean>
<!-- 配置数据源 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
<property name="url" value="jdbc:mysql:///spring_day04"></property>
<property name="username" value="root"></property>
<property name="password" value="123456"></property>
</bean>
3.2方式二
这种方式我们采取让dao继承JdbcDaoSupport
- AccountDaoImpl.java
public class AccountDaoImpl extends JdbcDaoSupport implements AccountDao {
@Override
public Account findAccountById(Integer id) {
//getJdbcTemplate()方法是从父类上继承下来的。
List<Account> list = getJdbcTemplate().query("select * from account where id = ? ",new AccountRowMapper(),id);
return list.isEmpty()?null:list.get(0);
}
@Override
public Account findAccountByName(String name) {
//getJdbcTemplate()方法是从父类上继承下来的。
List<Account> list = getJdbcTemplate().query("select * from account where name = ? ",new AccountRowMapper(),name);
if(list.isEmpty()){
return null;
}
if(list.size()>1){
throw new RuntimeException("结果集不唯一,不是只有一个账户对象");
}
return list.get(0);
}
@Override
public void updateAccount(Account account) {
//getJdbcTemplate()方法是从父类上继承下来的。
getJdbcTemplate().update("update account set money = ? where id = ? ",account.getMoney(),account.getId());
}
}
- applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd">
<!-- 配置dao2 -->
<bean id="accountDao" class="com.itheima.dao.impl.AccountDaoImpl">
<!-- 注入dataSource -->
<property name="dataSource" ref="dataSource"></property>
</bean>
<!-- 配置数据源 -->
<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
<property name="url" value="jdbc:mysql:///spring_day04"></property>
<property name="username" value="root"></property>
<property name="password" value="123456"></property>
</bean>
</beans>
4.小结
方式一: 自己注册JDBCTemplate, 自己在Dao注入JDBCTemplate
方式二: 继承JdbcDaoSupport, 不需要自己注册JDBCTemplate, 也不需要自己注入JDBCTemplate
需要注入DataSource
第三章-Spring配置第三方连接池
知识点-Spring配置第三方连接池
1.目标
- 能够配置spring的连接池
2.路径
- Spring配置C3P0连接池
- Spring配置Druid连接池
- Spring配置HikariCP连接池【扩展】
3.讲解
3.1Spring配置C3P0连接池
官网:http://www.mchange.com/projects/c3p0/
步骤:
- 导入c3p0的坐标
- 注册连接池(修改DataSource的class以及四个基本项)
实现:
- 导入坐标
<dependency>
<groupId>c3p0</groupId>
<artifactId>c3p0</artifactId>
<version>0.9.1.2</version>
</dependency>
- 配置数据源连接池
<!-- 配置C3P0数据库连接池 -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
<property name="jdbcUrl" value="jdbc:mysql:///spring_jdbc" />
<property name="driverClass" value="com.mysql.jdbc.Driver" />
<property name="user" value="root" />
<property name="password" value="123456" />
</bean>
<!-- 管理JDBC模版 -->
<bean id="jdbcTemplete" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource" />
</bean>
核心类:`com.mchange.v2.c3p0.ComboPooledDataSource
3.2.Spring配置Druid连接池
步骤:
- 导入Druid坐标
- 修改DataSource的class(四个基本项)
实现:
- 导入坐标
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.0.9</version>
</dependency>
- 配置数据源连接池
<!--注册dataSource -->
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
<property name="url" value="jdbc:mysql://localhost:3306/spring_day03"></property>
<property name="username" value="root"></property>
<property name="password" value="123456"></property>
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
<constructor-arg name="dataSource" ref="dataSource"></constructor-arg>
</bean>
3.3.Spring配置HikariCP连接池【扩展】
官网:https://github.com/brettwooldridge/HikariCP
步骤:
- 添加HikariCP坐标
- 修改DataSource的class(四个基本项)
实现:
- 导入HikariCP坐标
<dependency>
<groupId>com.zaxxer</groupId>
<artifactId>HikariCP</artifactId>
<version>3.1.0</version>
</dependency>
配置数据源连接池
<!-- 配置HikariCP数据库连接池 -->
<bean id="dataSource" class="com.zaxxer.hikari.HikariDataSource">
<property name="jdbcUrl" value="jdbc:mysql:///spring_jdbc" />
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="username" value="root" />
<property name="password" value="123456" />
</bean>
<!-- 管理JDBC模版 -->
<bean id="jdbcTemplete" class="org.springframework.jdbc.core.JdbcTemplate">
<property name="dataSource" ref="dataSource" />
</bean>
> 核心类:`com.zaxxer.hikari.HikariDataSource`
+ 为什么HikariCP为什么越来越火?
+ 效率高
+ 一直在维护
+ ==SpringBoot2.0 现在已经把HikariCP作为默认的连接池了==
+ 为什么HikariCP被号称为性能最好的Java数据库连接池?
+ 优化并精简字节码: HikariCP利用了一个第三方的Java字节码修改类库Javassist来生成委托实现动态代理
+ 优化代理和拦截器:减少代码,代码量越少。一般意味着运行效率越高、发生bug的可能性越低.
![1540557295765](img/1540557295765.png)
+ 自定义集合类型ConcurrentBag:ConcurrentBag的实现借鉴于C#中的同名类,是一个专门为连接池设计的lock-less集合,实现了比LinkedBlockingQueue、LinkedTransferQueue更好的并发性能。ConcurrentBag内部同时使用了ThreadLocal和CopyOnWriteArrayList来存储元素,其中CopyOnWriteArrayList是线程共享的。ConcurrentBag采用了queue-stealing的机制获取元素:首先尝试从ThreadLocal中获取属于当前线程的元素来避免锁竞争,如果没有可用元素则再次从共享的CopyOnWriteArrayList中获取。此外,ThreadLocal和CopyOnWriteArrayList在ConcurrentBag中都是成员变量,线程间不共享,避免了伪共享(false sharing)的发生。
+ 使用FastList替代ArrayList: FastList是一个List接口的精简实现,只实现了接口中必要的几个方法。JDK ArrayList每次调用get()方法时都会进行rangeCheck检查索引是否越界,FastList的实现中去除了这一检查,只要保证索引合法那么rangeCheck就成为了不必要的计算开销(当然开销极小)。
### 4.小结
1. 导入连接池坐标
2. 改DataSource的class属性值, 配置属性名
## 知识点-Spring引入Properties配置文件
### 1.目标
- [ ] 掌握Spring引入Properties配置文件
### 2.步骤
1. 定义jdbc.properties
2. 把jdbc.properties引入applicationContext.xml
3. 使用表达式根据key获得value
### 3.实现
#### 3.1jdbc.properties
```properties
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/spring_day03
jdbc.username=root
jdbc.password=123456
3.2 引入外部properties文件
- 引入配置文件方式一(不推荐使用)
<!-- 引入properties配置文件:方式一 (繁琐不推荐使用) -->
<bean id="properties" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location" value="classpath:jdbc.properties" />
</bean>
- 引入配置文件方式二【推荐使用】
<!-- 引入properties配置文件:方式二 (简单推荐使用) -->
<context:property-placeholder location="classpath:jdbc.properties" />
classpath表示的是类路径,对于配置文件而言也就是那个resources根目录
- bean标签中引用配置文件内容
<!-- hikariCP 连接池 -->
<bean id="dataSource" class="com.zaxxer.hikari.HikariDataSource">
<property name="jdbcUrl" value="${jdbc.url}" />
<property name="driverClassName" value="${jdbc.driver}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
</bean>
注意:在使用
<context:property-placeholder/>
标签时,properties配置文件中的key一定要是带点分隔的。例如jdbc.url
4.小结
- 定义jdbc.properties
- 把jdbc.properties引入到applicationContext.xml
- 根据key读取value
第四章-Spring管理事务
知识点-Spring管理事务概述(了解即可)
1.目标
- 知道Spring管理事务相关的API
2.路径
- 概述
- 相关的API
3.讲解
3.1概述
由于Spring对持久层的很多框架都有支持 , Hibernate 、 jdbc 、JdbcTemplate , MyBatis ,由于使用的框架不同,所以使用事务管理操作API 也不尽相同。 为了规范这些操作, Spring统一定义一个事务的规范 ,这其实是一个接口 。这个接口的名称 : PlatformTrasactionManager.并且它对已经做好的框架都有支持.
如果dao层使用的是JDBC, JdbcTemplate 或者mybatis,那么 可以使用DataSourceTransactionManager 来处理事务
如果dao层使用的是 Hibernate, 那么可以使用HibernateTransactionManager 来处理事务
3.2相关的API
3.2.1PlatformTransactionManager
平台事务管理器是一个接口,实现类就是Spring真正管理事务的对象。
常用的实现类:
**DataSourceTransactionManager** :JDBC开发的时候(JDBCTemplate,MyBatis),使用事务管理。
HibernateTransactionManager :Hibernate开发的时候,使用事务管理。
3.2.2 TransactionDefinition
事务定义信息中定义了事务的隔离级别,传播行为,超时信息,只读。
3.2.3 TransactionStatus:事务的状态信息
事务状态信息中定义事务是否是新事务,是否有保存点。
4.小结
Spring管理事务是通过事务管理器. 定义了一个接口PlatformTransactionManager
- DataSourceTransactionManager JDBC,MyBatis,JDBCTemplate
- HibernateTransactionManager Hibernate
知识点-编程式(通过代码)(硬编码)事务【了解】
1.目标
- 了解Spring编程式事务
2.步骤
- 创建DataSource对象
- 创建JDBCTemplate对象
- 创建事务管理器, 传入DataSource. DataSourceTransactionManager
- 创建事务模版
- 通过事务模版进行事务处理
- 在事务里面操作数据库
3.实现
- 添加依赖
<dependencies>
<!--依赖-->
<!--1. spring的核心依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--2. spring-jdbc的依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--3. spring-test-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--10. aop的依赖-->
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.7</version>
</dependency>
<!--4. mysql-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.6</version>
</dependency>
<!--5. mybatis-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.3</version>
</dependency>
<!--6. mybatis-spring-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.3.0</version>
</dependency>
<!--7. Junit的依赖-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<!--8. lombok的依赖-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.10</version>
</dependency>
<!--9. 日志的依赖-->
<!-- log start -->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.12</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.6.6</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.6.6</version>
</dependency>
<!-- log end -->
</dependencies>
- 代码
package com.itheima.service.impl;
import com.itheima.dao.AccountDao;
import com.itheima.pojo.Account;
import com.itheima.service.AccountService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionTemplate;
import javax.sql.DataSource;
/**
* 包名:com.itheima.service.impl
* @author Leevi
* 日期2020-08-12 10:57
* 持久层不同的框架有不同的事务控制方案:
* 1. 原始的JDBC:
* 1.1 开启事务: connection.setAutoCommit(false);
* 1.2 提交事务: connection.commit();
* 1.3 回滚事务: connection.rollback();
*
* 2. DBUtils框架: 和原始的JDBC是一样的
* 3. mybatis框架: 底层也是使用的JDBC的事务
* 3.1 开启事务: sqlSessionFactory.openSession(); 开启事务
* 3.2 提交事务: sqlSession.commit();
* 3.3 回滚事务: sqlSession.rollback();
* 4. 只要某个持久层框架和spring整合了,那么事务相关的操作就都交给spring控制
* 4.1 编程式事务(了解)
* 4.2 声明式事务(重点掌握)
*/
@Service
public class AccountServiceImpl implements AccountService{
@Autowired
private AccountDao accountDao;
@Autowired
private DataSource dataSource;
@Override
public void transfer(String fromName, String toName, double money) {
//创建事务管理者
DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
transactionManager.setDataSource(dataSource);
//创建事务模板
TransactionTemplate transactionTemplate = new TransactionTemplate();
//给事务模板配置事务管理者
transactionTemplate.setTransactionManager(transactionManager);
transactionTemplate.execute(new TransactionCallback<Object>() {
@Override
public Object doInTransaction(TransactionStatus status) {
//1. 转出账户扣款
accountDao.updateAccount(new Account(null,fromName,-money));
//出现异常
int num = 10/0;
//2. 转入账户收款
accountDao.updateAccount(new Account(null,toName,money));
return null;
}
});
}
}
4.小结
我们项目开发 一般不会使用编程式(硬编码)方式. 一般使用声明式(配置)事务
- xml方式
- 注解方式
知识点-Spring声明式事务-xml配置方式【重点】
Spring的声明式事务的作用是: 无论spring集成什么dao框架,事务代码都不需要我们再编写了
声明式的事务管理的思想就是AOP的思想。面向切面的方式完成事务的管理。声明式事务有两种,xml配置方式和注解方式.
1.目标
- 使用xml方式配置事务
2.步骤
- 注册事务管理器, 配置数据源
- 配置事务建议(事务规则: 事务隔离级别, 遇到什么异常回滚,是否只读…)
配置AOP
- 配置切入点
- 配置切面
3.讲解
3.1实现
<dependencies>
<!--依赖-->
<!--1. spring的核心依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--2. spring-jdbc的依赖-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--3. spring-test-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.0.2.RELEASE</version>
</dependency>
<!--10. aop的依赖-->
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.7</version>
</dependency>
<!--4. mysql-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.6</version>
</dependency>
<!--5. mybatis-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.3</version>
</dependency>
<!--6. mybatis-spring-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.3.0</version>
</dependency>
<!--7. Junit的依赖-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<!--8. lombok的依赖-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.10</version>
</dependency>
<!--9. 日志的依赖-->
<!-- log start -->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.12</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.6.6</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.6.6</version>
</dependency>
<!-- log end -->
</dependencies>
- 配置事务管理器
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean>
配置事务建议(事务的规则)
<!--配置事务规则-->
<tx:advice id="transferAdvice" transaction-manager="transactionManager">
<!--配置事务的属性-->
<tx:attributes>
<!--
哪个方法需要使用什么样的事务配置
rollback-for="java.lang.Exception" 什么时候回滚:遇到所有的Exception都会回滚
no-rollback-for="java.lang.NullPointerException" 什么时候不回滚:遇到NullPointerException不回滚
timeout="-1" 事务的超时时间,默认不超时
read-only="false" 是否是只读事务,默认不是只读事务,只读事务只会针对于查询方法,如果是增删改一定不能设置为只读
isolation="" 事务的隔离级别: 目的是为了防止不同事务之间相互影响
1. Read Uncommitted 读取到未提交的事务,在这种隔离级别下,可能发生脏读、不可重复读、幻读
2. Read Committed(Oracle的默认隔离级别) 读取到已提交的事务,在这种隔离级别下,不可能发生脏读,但是可能发生不可重复读和幻读
3. Repeatable Read(mysql的默认隔离级别) 可重复读,在这种隔离级别下不会发生脏读、不可重复读,但是有可能发生幻读
4. Serializable 串行化的,在这种隔离级别下不会发生脏读、不可重复读、幻读
propagation="" 事务的传播行为
- PROPAGATION_REQUIRED:默认值,也是最常用的场景.
如果当前没有事务,就新建一个事务,
如果已经存在一个事务中,加入到这个事务中。
- PROPAGATION_SUPPORTS:
如果当前没有事务,就以非事务方式执行。
如果已经存在一个事务中,加入到这个事务中。
- PROPAGATION_MANDATORY
如果当前没有有事务,就抛出异常;
如果已经存在一个事务中,加入到这个事务中。
保证不在同一个事务里:
- PROPAGATION_REQUIRES_NEW
如果当前有事务,把当前事务挂起,创建新的事务但独自执行
- PROPAGATION_NOT_SUPPORTED
如果当前存在事务,就把当前事务挂起。不创建事务
- PROPAGATION_NEVER
如果当前存在事务,抛出异常
-->
<tx:method name="transfer"
rollback-for="java.lang.Exception"
no-rollback-for="java.lang.NullPointerException"/>
</tx:attributes>
</tx:advice>
- 配置事务的AOP
<aop:config>
<!--声明切入点-->
<aop:pointcut id="pt1" expression="execution(* com.itheima.service.impl.AccountServiceImpl.transfer(..))"/>
<!--绑定切入点和事务-->
<aop:advisor advice-ref="transferAdvice" pointcut-ref="pt1"></aop:advisor>
</aop:config>
3.2事务的传播行为
3.2.1事务的传播行为的作用
我们一般都是将事务设置在Service层,那么当我们调用Service层的一个方法的时候, 它能够保证我们的这个方法中,执行的所有的对数据库的更新操作保持在一个事务中, 在事务层里面调用的这些方法要么全部成功,要么全部失败。
如果你的Service层的这个方法中,除了调用了Dao层的方法之外, 还调用了本类的其他的Service方法,那么在调用其他的Service方法的时候, 我必须保证两个service处在同一个事务中,确保事物的一致性。
事务的传播特性就是解决这个问题的。
3.2.2 事务的传播行为的取值
保证在同一个事务里面:
PROPAGATION_REQUIRED:默认值,也是最常用的场景.
如果当前没有事务,就新建一个事务,
如果已经存在一个事务中,加入到这个事务中。PROPAGATION_SUPPORTS:
如果当前没有事务,就以非事务方式执行。
如果已经存在一个事务中,加入到这个事务中。PROPAGATION_MANDATORY
如果当前没有有事务,就抛出异常;
如果已经存在一个事务中,加入到这个事务中。
保证不在同一个事物里:
PROPAGATION_REQUIRES_NEW
如果当前有事务,把当前事务挂起,创建新的事务但独自执行PROPAGATION_NOT_SUPPORTED
如果当前存在事务,就把当前事务挂起。不创建事务PROPAGATION_NEVER
如果当前存在事务,抛出异常
4.小结
- 注册事务管理器, 需要注入DataSource
- 配置事务建议(规则: 隔离级别, 事务传播行为…)
配置AOP
- 配置切入点
- 配置切面
知识点-spring声明式事务-注解方式【重点】
1.目标
- 使用注解方式配置事务
2.步骤
注册事务管理器
开启事务注解支持
在业务类上面添加@Transactional
3.实现
- 在applicationContext里面打开注解驱动
<?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: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/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">
<import resource="classpath:application-mybatis.xml"></import>
<!--配置申明式事务-->
<!--
注解方式配置声明式事务
1. 配置事务管理者
2. 加载事务注解驱动
3. 在代码中使用Transactional注解来标注,哪个方法需要使用事务
-->
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean>
<tx:annotation-driven transaction-manager="transactionManager"/>
</beans>
- 在业务逻辑类上面使用注解
@Transactional : 如果在类上声明,那么标记着该类中的所有方法都使用事务管理。也可以作用于方法上, 那么这就表示只有具体的方法才会使用事务。
4.小结
4.1步骤
- 注册事务管理器
- 开启事务注解支持
- 在业务类上面添加@Transactional
4.2两种方式比较
xml方式
- 优点: 只需要配一次, 全局生效, 容易维护
- 缺点: 相对注解而言 要麻烦一点
注解方式
- 优点: 配置简单
- 缺点: 写一个业务类就配置一次, 事务细节不好处理, 不好维护