devbox
小丑西瓜9
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Spring详解（学习总结）_spring中文学习

作者：小丑西瓜9 | 2024-02-15 19:27:12

赞

踩

spring中文学习

目录

一、Spring概述

（一）、Spring是什么？

（二）、Spring框架发展历程

（三）、Spring框架的优势

（四）、Spring的体系结构

二、程序耦合与解耦合

（一）什么是程序的耦合

（二）解决程序耦合的思路

1、编译不依赖，运行时才依赖

2、使用工厂模式解耦合

三、SpringIOC机制的详解

（一）、IOC概述及作用

1、IOC的简介，设计思想

2、IOC作用

（二）SpringIOC入门案例前期准备

1、构建maven工程，添加Spring框架的依赖

2、创建持久层接口和实现类

3、创建业务层接口和实现类

4、在resources文件夹中创建一个任意名称的xml文件

5、让Spring管理资源，在配置文件中配置service和dao

6、测试IOC配置是否成功

（三）Spring基于XML的IOC细节

1、IOC配置文件详解：配置标签书写规范，配置标签的属性

2、SpringIOC机制源码解析

  （1） IOC容器解析

   （2）IOC容器底层bean初始化过程

（四）手动实现自己的IOC容器

1、分析IOC实现思路

2、IOC原理实现—环境搭建：构建maven工程，引入依赖

3、设计接口和类以及编写配置文件

4、使用xml技术解析配置文件

5、编写测试文件，展示测试结果

（五）Spring管理bean细节

1、bean实例化方式

（1）构造方法的方式

1）创建User类

2）配置Spring容器管理user类型对象

3）测试容器实例化User对象是否成功）

（2）静态工厂方式

1）创建静态工厂ItemFactory

2）配置Spring容器管理User类型对象

3）测试容器实例化User对象是否成功

（3）实例工厂方式

1）创建实例工厂NewItemFactory

2）配置Spring容器管理NewItemFactory类型对象

3）测试容器实例化User对象是否成功

2、bean作用域

（1）bean作用域介绍

（2）bean作用域的解析

1）当scope的取值为singleton时

2）当scope的取值为prototype时

3）当Scope的取值为其他值

四、Spring依赖注入（DI）

 （一）介绍

定义

（二）注入方式

1、构造函数注入

（1）构建Account类，提供所有属性的构造方法

（2）配置Account类（使用构造方法注入依赖数据）

（3）构造函数注入测试方法

2、setter注入

（1）修改Account类，添加属性的setter方法

（2）配置Account类（利用setter方法注入依赖数据）

（3）setter注入测试方法

3、注入集合数据

（1）修改Account类，添加集合属性

（2）配置Account类（利用setter注入依赖集合数据）

（3）集合注入测试方法

五、Spring配置文件模块化

（一）Spring模块化的介绍

（二）Spring模块化的配置

1、Spring模块化配置方式一

2、Spring模块化配置方式二

六、模块设计模式解析

（一）模块化设计模式介绍

（二）模板设计模式的应用场景

（三）模板设计模式实现

1、需求：用模块方法模式实现出国留学手续设计程序

2、代码实现

七、Spring整合JDBC实现用户的CRUD

（一）整合思路分析

（二）构建maven工程，添加技术依赖

（三）构建数据库表并编写实体类Account

（四）编写持久层代码AccountDao以及实现类AccountDaoImpl

（五）编写业务层代码Accountservice以及实现类AccountServiceImpl

（六）创建并编写配置文件：配置容器管理对象

（七）测试代码

 八、常用注解

（一）创建对象的注解

（二）用于注入数据的注解

（三）用于改变作用范围的注解

九、基于注解的IOC案例

（一）构建工程，添加依赖

（二）使用注解配置

（三）创建配置文件并开启对注解的支持

（四）编写测试代码

十、纯注解配置

（一）新注解说明

（二）通过注解获取容器

十一、Spring整合Junit

（一）IOC测试类中的问题和解决思路

（二）整合Junit配置步骤

1、添加技术依赖

2、使用@RunWith注解替换原有运行器

3、使用@ContextConfiguration 指定 Spring 配置文件的位置

4、使用@Autowired 给测试类中的变量注入数据

十二、Spring整合DButils实现转账业务

（一）添加转账方法，并演示事务问题

1、转账Account表以及对应的实体bean

2、引入DBUtils依赖坐标

3、创建Account接口和对应实现类

4、创建AccountService接口和实现类

5、测试转账业务

（二）编写ConnectionUtils工具类管理数据库连接

（三）编写事务管理工具类

（四）编写业务层和持久层控制代码并配置Spring的IOC

（五）测试转账

（六）转账业务案例中存在的问题

（七）使用动态代理实现事务控制

1、创建代理工具类

2、配置并测试动态代理转账业务

十三、SpringAOP机制详解

 （一）AOP概述

1、什么是AOP

2、AOP编程思想

3、Spring中的常用术语

4、AOP编程底层的实现机制

（1）JDK动态代理

（2）CGLB动态代理

5、AOP的作用及优势

（二）Spring基于XML的AOP配置

1、环境搭建

（1）添加依赖 

（2）添加代码

（3）创建配置文件并导入约束

（4）配置Spring的IOC

（5）抽取公共代码制作成通知

2、AOP配置步骤

（1）配置bean标签

（2）使用aop：config 声明AOP配置

（3）使用aop：aspect 配置切面

（4）使用aop：pointcut配置切入点表达式

（5）使用aop：xxx配置对应的通知类型

3、切入点表达式说明

4、环绕通知配置事务管理

（三）Spring基于注解的AOP配置

1、环境搭建

（1）构建maven工程添加AOP注解的相关依赖

（2）导入代码

（3）在配置文件中导入context的名称空间且配置

（4）资源使用注解配置

（5）在配置文件中指定spring要扫描的包

2、配置步骤

（1）通知类使用注解配置

（2）通知类使用@Aspect注解声明为切面

（3）增强方法上使用注解配置通知

（4）开启Spring对注解AOP的支持

（5）环绕通知注解配置

（6）切入点表达式注解

十四、Spring事务详解

（一）Spring基于XML的事务配置

1、环境搭建

（1）构建工程，添加依赖

（2）创建Spring的配置文件，导入约束

（3）沿用转账业务

2、事务管理配置步骤

（1）配置事务管理器

（2）配置事务的通知引用事务管理器

（3）配置事务的属性

（4）配置AOP切入点表达式

（5）配置切入点表达式和事务通知的对应关系

（二）Spring基于注解的事务配置

1、环境搭建

（1）构建maven工程，添加相关依赖

（2）创建Spring配置文件

（3）沿用转账业务的代码：dao实现类和service实现类采用注解的形式，添加到容器中管理

2、事务管理配置步骤

（1）配置事务管理器并注入数据源

（2）在业务层使用@Transactional注解

（3）配置文件中开启Spring对注解事务的支持

十五、Spring整合Mybatis实现用户的CRUD

（一）整理思路分析

（二）构建maven工程，添加依赖

（三）构建数据库表并创建实体类

（四）编写dao层的接口UserMapper

（五）构建mapper接口对应的sql配置文件

（六）构建服务层接口UserService

（七）构建服务层实现类UserServiceImpl

（八）构建配置文件

（九）测试代码

一、Spring概述

（一）、Spring是什么？

Spring是一个分层的java SE/EE full-stack（一站式）轻量级开源框架，以IOC（控制反转）和AOP（面向切面编程）为内核。

在java三层架构当中分别提供了相应的技术：

表现层（web层）：SpringMVC框架

业务层（service层）：Bean管理（IOC容器）

持久层（dao层）：jdbcTemplate模板对象以及提供了ORM模块整合其他优秀的持久层技术。

（二）、Spring框架发展历程

1997年，IBM提出了EJB的思想。1998年，SUN制定开发标准规范EJB1.0.。199年EJB1.1发布。2001年，EJB2.0发布。2006年EJB3.0发布。

Rod Johnson （ Spring 之父） Expert One-to-One J2EE Design and Development(2002) 阐述了 J2EE
使用EJB 开发设计的优点及解决方案 Expert One-to-One J2EE Development without EJB(2004) 阐述了 J2EE 开发不使用 EJB的解决方式（Spring 雏形）
2017 年 9 月份发布了 Spring 的最新版本 Spring5.0 通用版（GA）

（三）、Spring框架的优势

方便解耦，简化开发：Spring就是一个工厂，可以管理所有对象的创建和依赖关系维护，交给Spring管理。

AOP编程的支持：可以方便的实现对程序进行权限拦截，日志记录，运行的监控。

声明式事务的支持：通过配置的方式完成对事务的管理，无需手动编程。

方便程序的测试：对Junit支持，可以通过注解方式方便的对Spring程序进行测试。

整合外部优秀技术：Spring内部提供了对各种优秀框架（Hibernate，Mybatis）的直接支持。

javaEE技术的封装;Spring对javaEE开发当中复杂难用的API进行封装，降低了这些API的使用难度。

（四）、Spring的体系结构

二、程序耦合与解耦合

（一）什么是程序的耦合

程序的耦合是程序之间的关联性，也就是多个类的联系是否紧密，多个对象之间的关系是否密切。

生活中的案例：
你的房子里面有窗子，那么房子和窗子就有了关联
耦合度是松还是紧就看你的关联是强还是弱，也就是修改的代价，比如你窗子是扣死在墙里的那么你修改窗子就必须修改墙 这就比较紧密了，反应在程序上就是耦合度高，不利于程序的扩展和维护。
但是如果你窗子是按照某种规格的 可以自由拆装的，那么修改的代价就小，耦合度也就低了，反应在程 序上就是耦合度低，利于程序的扩展和维护。
我们写程序的目标就是 高内聚 低耦合！

（二）解决程序耦合的思路

1、编译不依赖，运行时才依赖

当我们讲解jdbc时，是通过反射来注册驱动的，代码如下：

Class.forName("com.mysql.jdbc.Driver");//使用的驱动类是指定了一个字符串

我们的类中在编译阶段不再需要具体的驱动类，就算删除mysql的驱动jar包，依然可以通过编译。在运行阶段才会依赖驱动包。实际开发当中，我们应该做到编译不依赖，运行时才依赖。

上述代码产生的新问题，mysql驱动类的全限定类名作为一个字符串java类中是写死的，一旦发生改变，还需要修改源码。

使用配置文件结合反射就可以解决上述问题。

2、使用工厂模式解耦合

在实际开发中我们可以把三层的对象都使用配置文件配置起来，当启动服务器应用加载的时候，让一个类中的方法通过读取配置文件，把这些对象创建出来并存起来。在接下来的使用的时候，直接拿过来用就好了。

那么这个读取配置文件，创建和获取三层对象的类就是工厂。

三、SpringIOC机制的详解

（一）、IOC概述及作用

1、IOC的简介，设计思想

SpringIOC：IOC是Inversion of Control的缩写，多数书籍翻译成“控制反转”。

IOC这个概念简单来说就是把复杂系统分解成相互合作的对象，这些对象类通过封装以后，内部实现对外部透明的，从而降低了解决问题的复杂度，而且可以灵活的被重用和扩展。

IOC理论提出的观点大体是这样的：借助于第三方实现具有依赖关系的对象之间的解耦。

                

 由于引进了中间位置“第三方”，也就是IOC容器，使得A、B、C、D这四个对象没有了耦合关系，齿轮之间的传动全部依靠IOC容器，全部对象的控制权上交给IOC容器，所以IOC容器成了整个系统的关键核心，它起到一个“粘合剂”的作用，把系统中所有对象粘合在一起发挥作用。

                        

当把图中的IOC容器拿掉，可以发现A、B、C、D这四个 对象之间没有耦合关系。这样的话，当我们去实现A的时候，根本无需去考虑其他几个对象，对象之间的依赖关系已经讲到了最低程度。

2、IOC作用

IOc本质上就是一个大工程，大容器。主要作用就是创建和管理对象的依赖关系，削减计算机程序的耦合（解除我们代码间的依赖关系），提高程序的可扩展性和可维护性。

（二）SpringIOC入门案例前期准备

1、构建maven工程，添加Spring框架的依赖

  1. <properties>
  2.     <spring.version>5.2.5.RELEASE</spring.version>
  3. </properties>
  4. <!--导入spring的context坐标，context依赖core、beans、expression aop-->
  5. <dependencies>
  6.     <dependency>
  7.         <groupId>org.springframework</groupId>
  8.         <artifactId>spring-context</artifactId>
  9.         <version>${spring.version}</version>
  10.     </dependency>
  11. </dependencies>

2、创建持久层接口和实现类

  1. public interface UserDao {
  2.     public void save();
  3. }
  4.  
  5. public class UserDaoImpl implements UserDao {
  6.     @Override
  7.     public void save() {
  8.         System.out.println("userDao save method running...... ");
  9.     }
  10. }

3、创建业务层接口和实现类

  1. public interface UserService {
  2.     public void saveService();
  3. }
  4.  
  5. public class UserServiceImpl implements UserService {
  6.     @Override
  7.     public void saveService() {
  8.         System.out.println("userSerivce save method running......");
  9.     }
  10. }

4、在resources文件夹中创建一个任意名称的xml文件

  1. <?xml version="1.0" encoding="UTF-8"?><beans
  2. xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4. xsi:schemaLocation="http://www.springframework.org/schema/beans
  5. http://www.springframework.org/schema/beans/springbeans.xsd">
  6. </beans>

5、让Spring管理资源，在配置文件中配置service和dao

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.         xsi:schemaLocation="http://www.springframework.org/schema/beans
  5.         http://www.springframework.org/schema/beans/spring-beans.xsd">
  6.  
  7.     <!--配置userDaoImpl-->
  8.     <bean id="userDao" class="com.ujiuye.dao.impl.UserDaoImpl"></bean>
  9.     <!--配置userServiceImpl-->
  10.     <bean id="userService" class="com.ujiuye.service.UserServiceImpl"></bean>
  11. </beans>

6、测试IOC配置是否成功

  1. @Test
  2. public void test1(){
  3.     //1：获得spring IOC容器对象：
  4.     ApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
  5.  
  6.     //2:从容器当中根据id获得UserDaoImpl 对象,执行userDao对象的save方法
  7.     UserDao userDao = (UserDao) applicationContext.getBean("userDao");
  8.     userDao.save();
  9.  
  10.     //3:从容器当中根据id获得UserServiceImpl 对象,执行userService对象的saveService
  11. 方法
  12.     UserService userService = (UserService)applicationContext.getBean("userService");
  13.     userService.saveService();
  14. }

运行结果：

 

（三）Spring基于XML的IOC细节

1、IOC配置文件详解：配置标签书写规范，配置标签的属性

bean标签：用于配置对象交给Spring来创建

        默认情况下他会调用类中无参数的构造器，如果没有无参数构造器则不能创建成功。

基本属性：

        id：Bean实例对象在Spring容器中的唯一标识

        class：Bean的全限定类名

2、SpringIOC机制源码解析

  （1） IOC容器解析

        IOC思想基于IOC容器完成，IOC容器底层就是对象工厂，Spring中工厂的类结构图如下;

                

         1）BeanFactory：IOC容器的基本实现，是Spring内部使用的接口，不提供开发人员使用，加载配置文件时，不会创建对象，在获得（使用）对象时才采取创建对象。

        2）HierarchicalBeanFactory：这个工厂接口非常简单，实现了Bean工厂的分层。工厂接口也是继承自BeanFactory，也是一个二级接口，相对于父接口，他只是扩展了一个重要的功能———工厂分层

        3）AutowireCapableBeanFactory：该接口有自动配置能力，需要注意的是，ApplicationContext接口并实现此接口，因为应用代码很少用到此功能，如果确实需要的话，可以调用ApplicationContext的getAutowireCapableBeanFactory方法，来获取此接口的实例

        4）ListableBeanFactory：获取bean时，Spring鼓励使用这个接口定义的api，如查看bean

的个数、获取某一类型Bean的配置名、查看容器中是否包括某一Bean等方法。

        5）ApplicationContext：BeanFactory接口的子接口，提供更多强大的功能，一般由开发人员使用。接口提供了bean基础性操作同时，扩展了国际化等功能。ApplicationContext接口在加载配置文件时候就会配置文件当中的对象进行创建，存放IOC容器当中

        6）AnnotationConfigApplicationContext：当使用注解配置容器对象时，需要使用此类来创建spring容器。他用来读取注解。

        7）ClassPathXmlApplicationContext：它是从类的根路径下加载配置文件

        8）FileSystemXmlApplicationContext：它是从磁盘路径上加载配置文件，配置文件可以在磁盘的任意位置。

   （2）IOC容器底层bean初始化过程

        

        1）BeanFactionPostProcessor

        作用：定义了在bean工厂对象创建后，bean对象创建前执行的动作，用于对工厂进行创建后业务处理

        运行时机：操作用于对工厂进行处理，仅运行一次

        2) BeanPostProcessor

        作用：定义了所有bean初始化前后进行的统一动作，用于对bean进行创建前业务处理与创建后业务处理

        运行时机：当前操作伴随着每个bean的创建过程，每次创建bean均运行该操作。

        3）InitializingBean

        作用：定义了每个bean的初始化前进行的动作，属于非统一性动作，用于对bean进行创建前业务处理。

        运行时机：当前操作伴随着任意一个bean的创建过程，保障其个性化业务处理

（四）手动实现自己的IOC容器

1、分析IOC实现思路

        

2、IOC原理实现—环境搭建：构建maven工程，引入依赖

  1. <properties>
  2.         <spring.version>5.2.5.RELEASE</spring.version>
  3.     </properties>
  4.  
  5.     <dependencies>
  6.         <!--导入spring的context坐标-->
  7.         <dependency>
  8.             <groupId>org.springframework</groupId>
  9.             <artifactId>spring-context</artifactId>
  10.             <version>${spring.version}</version>
  11.         </dependency>
  12.         <!--导入junit单元测试-->
  13.         <dependency>
  14.             <groupId>junit</groupId>
  15.             <artifactId>junit</artifactId>
  16.             <version>4.12</version>
  17.             <scope>test</scope>
  18.         </dependency>
  19.     </dependencies>

3、设计接口和类以及编写配置文件

  1. //设定UserDao接口
  2. public interface UserDao {
  3.     public void save();
  4. }
  5. //设定UserDao接口实现类
  6. public class UserDaoImpl implements UserDao {
  7.     @Override
  8.     public void save() {
  9.         System.out.println("userDao save method running...... ");
  10.     }
  11. }

配置文件：

  1. <!--配置userDaoImpl-->
  2. <bean id="userDao" class="com.ujiuye.dao.impl.UserDaoImpl"></bean>

4、使用xml技术解析配置文件

  1. <!--引入dom4J-->
  2. <dependency>
  3.     <groupId>dom4j</groupId>
  4.     <artifactId>dom4j</artifactId>
  5.     <version>1.6.1</version>
  6. </dependency>
  1. /**
  2. * 创建自己的工厂类
  3. */
  4. public class MyBeanFactory {
  5.  
  6.     //创建一个map集合，模拟IOC容器
  7.     private static Map<String,Object> map = new HashMap<>();
  8.  
  9.     static{
  10.         try {
  11.             //使用dom4J 解析xml文件：
  12.             //第一步：获得一个解析器：
  13.             SAXReader reader = new SAXReader();
  14.             //第二： 读取外部的配置文件：
  15.             String path = "src/main/resources/applicationContext.xml";
  16.             //第三: 读取了整个文档对象
  17.             Document document = reader.read(path);
  18.             //第四： 获得根节点：
  19.             Element rootElement = document.getRootElement();//beans
  20.             //第五： 获得根节点下的所有的bean 标签对应的节点：
  21.             List<Element> bean = rootElement.elements("bean");// bean
  22.             for (Element element : bean) {
  23.                 //获得id属性对应的值：
  24.                 String id1 = element.attributeValue("id");
  25.                 //获得class属性对应的值：【全限定类名】
  26.                 String aClass = element.attributeValue("class");//获得class对应的值： 全限定类名。
  27.                 //通过反射创建对象：
  28.                 Class clz = Class.forName(aClass);
  29.                 Object object = clz.newInstance();
  30.                 //存容器 id做key，创建出来的对象value
  31.                 map.put(id1,object);
  32.             }
  33.  
  34.         } catch (Exception e) {
  35.             e.printStackTrace();
  36.     }
  37. }
  1. /**
  2. * 根据id从容器当中获得对象
  3. * @param id id的名称
  4. * @return 返回Object类型对象
  5. */
  6. public static Object getBean(String id){
  7.     Object o = map.get(id);
  8.     return o;
  9.     }
  10. }

5、编写测试文件，展示测试结果

  1. @Test
  2. public void testMyFactory(){
  3.     //1：创建工厂对象
  4.     MyBeanFactory factory =new MyBeanFactory();
  5.     //2：从容器当中根据id获得对象
  6.     UserDao userDao = (UserDao) factory.getBean("userDao");
  7.     System.out.println(userDao);
  8.     userDao.save();
  9. }

（五）Spring管理bean细节

1、bean实例化方式

（1）构造方法的方式
1）创建User类
  1. public class User implements Serializable {
  2.     public User(){
  3.         System.out.println("user created...");
  4.     }
  5. }

2）配置Spring容器管理user类型对象
  1. <!--配置user对象-->
  2. <bean id="user" class="com.ujiuye.pojo.User"></bean>

3）测试容器实例化User对象是否成功）
  1. @Test
  2. public void testUser(){
  3.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  4.     User user = (User) context.getBean("user");
  5.     System.out.println(user);
  6. }

（2）静态工厂方式
1）创建静态工厂ItemFactory
  1. public class ItemFactory {
  2.     //静态方法返回实例bean
  3.     public static User createUser(){
  4.         System.out.println("static method running create bean ......");
  5.         return new User();
  6.     }
  7. }

2）配置Spring容器管理User类型对象
  1. <!--静态工厂实例化对象-->
  2. <bean id="user" class="com.ujiuye.factory.ItemFactory"></bean>

3）测试容器实例化User对象是否成功
  1. @Test
  2. public void testItemFactory(){
  3.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  4.     User user = (User) context.getBean("user");
  5.     System.out.println(user);
  6. }

（3）实例工厂方式
1）创建实例工厂NewItemFactory
  1. public class NewItemFactory {
  2.     //工厂的非静态方法返回bean实例
  3.     public User createUser(){
  4.         System.out.println("Dynamic method running create bean ......");
  5.         return new User();
  6.     }
  7. }

2）配置Spring容器管理NewItemFactory类型对象
  1. ​
  2. <!--实例工厂-->
  3. <bean id="itemFactory" class="com.ujiuye.factory.NewItemFactory"></bean>
  4. <bean id="user" factory-bean="itemFactory" factory-method="createUser"></bean>
  5.  
  6.  
  7. ​
3）测试容器实例化User对象是否成功
  1. @Test
  2. public void testNewItemFactory(){
  3.     ApplicationContext context =
  4.     new ClassPathXmlApplicationContext("applicationContext.xml");
  5.     User user = (User) context.getBean("user");
  6.     System.out.println(user);
  7. }

2、bean作用域

（1）bean作用域介绍

所谓Bean的作用域其实就是指Spring给我们创建出的对象的存活范围，在配置文件中通过bean的scope属性指定

scope：指对象的作用范围，取值如下：

取值范围说明
singleton默认值，单例的
prototype多例的
requestWEB 项目中，Spring 创建一个 Bean 的对象，将对象存入到 request 域中
sessionWEB 项目中，Spring 创建一个 Bean 的对象，将对象存入到 session 域中
global sessionWEB 项目中，应用在 Portlet 环境，如果没有 Portlet 环境那么globalSession 相当于 session

（2）bean作用域的解析
1）当scope的取值为singleton时

Bean的实例化个数：1个

Bean的实例化时机：当Spring核心文件被加载时，实例化配置的Bean实例

2）当scope的取值为prototype时

Bean的实例化个数：多个

Bean的实例化时机：当调用getBean()方法时实例化Bean

3）当Scope的取值为其他值

scope指定为其他值，需要在特定的环境下使用。

四、Spring依赖注入（DI）

 （一）介绍

定义

它是SpringBoot框架核心IOC的具体实现。组件之间的依赖关系由容器在应用系统运行期来决定，也就是由动态地将某种依赖关系的目标对象实例注入到应用系统中的各个关联的组件之中。

（二）注入方式

1、构造函数注入

（1）构建Account类，提供所有属性的构造方法
顾名思义，就是使用类中的构造函数，给成员变量赋值。注意，赋值的操作不是我们自己做的，而是通过配置的方式，让 Spring 框架来为我们注入。具体代码如下： 
  1. public class Account {
  2. private String name;
  3. private Integer age;
  4. private Date birthday;
  5.  
  6. public Account(String name, Integer age, Date birthday) {
  7.     this.name = name;
  8.     this.age = age;
  9.     this.birthday = birthday;
  10.     }
  11. }
（2）配置Account类（使用构造方法注入依赖数据）
  1. <!--使用构造函数的方式：给account中的属性赋值
  2. 要求：
  3. 类中需要提供一个对应参数列表的构造器函数
  5. 涉及的标签：
  6. constructor-arg:
  8. 属性：
  9. name： 执行参数在构造器中的名称
  10. value：它能赋的值是基本数据类型和 String 类型
  11. ref：它能赋的值是其他 bean 类型，也就是说，必须得是在配置文件中配置过的 bean
  12. -->
  13. <bean id="now" class="java.util.Date"></bean>
  14. <bean id="account" class="com.ujiuye.pojo.Account">
  15.     <constructor-arg name="name" value="王达"></constructor-arg>
  16.     <constructor-arg name="age" value="20"></constructor-arg>
  17.     <constructor-arg name="birthday" ref="now"></constructor-arg>
  18. </bean>
（3）构造函数注入测试方法
  1. @Test
  2. public void testDI(){
  3.     ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
  4.     Account account = (Account) applicationContext.getBean("account");
  5.     System.out.println("name:"+account.getName()+" age:"+account.getAge()+"birthday:"+account.getBirthday());
  6.     //打印结果： name:王达 age:20 birthday:Thu Feb 04 13:53:45 CST 2021
  7. }

2、setter注入

（1）修改Account类，添加属性的setter方法
  1. public class Account {
  2.     private String name;
  3.     private Integer age;
  4.     private Date birthday;
  5.  
  6.     public Account() {
  7.     }
  8.  
  9.     public Account(String name, Integer age, Date birthday) {
  10.         this.name = name;
  11.         this.age = age;
  12.         this.birthday = birthday;
  13.     }
  14.  
  15.     public String getName() {
  16.         return name;
  17.     }
  18.  
  19.     public void setName(String name) {
  20.         this.name = name;
  21.     }
  22.  
  23.     public Integer getAge() {
  24.         return age;
  25.     }
  26.  
  27.     public void setAge(Integer age) {
  28.         this.age = age;
  29.     }
  30.  
  31.     public Date getBirthday() {
  32.         return birthday;
  33.     }
  34.  
  35.     public void setBirthday(Date birthday) {
  36.         this.birthday = birthday;
  37.     }
  38.  
  39. }
（2）配置Account类（利用setter方法注入依赖数据）
  1. <!--使用set方法的方式给属性赋值
  2. 涉及的标签： property
  4. 属性：
  5. name：找的是类中set方法后面的部分
  6. ref： 给属性赋值是其他bean类型的
  7. value：给属性赋值是基本数据类型和 string 类型的
  8. 实际开发当中， 此种方式用的比较多，推荐使用
  9. -->
  10.  
  11. <bean id="now" class="java.util.Date"></bean>
  12. <bean id="account" class="com.ujiuye.pojo.Account">
  13.     <property name="name" value="张三丰"></property>
  14.     <property name="age" value="31"></property>
  15.     <property name="birthday" ref="now"></property>
  16. </bean>
（3）setter注入测试方法
  1. @Test
  2. public void testDI(){
  3.     ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
  4.     Account account = (Account) applicationContext.getBean("account");
  5.     System.out.println("name:"+account.getName()+" age:"+account.getAge()+"birthday:"+account.getBirthday());
  6.     //测试结果： name:张三丰 age:31 birthday:Thu Feb 04 14:05:19 CST 2021
  7. }

3、注入集合数据

（1）修改Account类，添加集合属性
给类中的集合成员传值，它用的也是set方法注入的方式，只不过变量的数据类型都是集合。
我们这里介绍注入数组，List,Set,Map,Properties。具体代码如下： 
  1. public class Account {
  2.     //注入数组，List集合，Set集合，Map集合，Properties集合属性
  3.     private String[] myStrs;
  4.     private List<String> myList;
  5.     private Set<String> mySet;
  6.     private Map<String,String> myMap;
  7.     private Properties myProps;
  8.  
  9.     public Account() {
  10.     }
  11.  
  12.     public String[] getMyStrs() {
  13.         return myStrs;
  14.     }
  15.  
  16.     public void setMyStrs(String[] myStrs) {
  17.         this.myStrs = myStrs;
  18.     }
  19.  
  20.     public List<String> getMyList() {
  21.         return myList;
  22.     }
  23.  
  24.     public void setMyList(List<String> myList) {
  25.         this.myList = myList;
  26.     }
  27.  
  28.     public Set<String> getMySet() {
  29.         return mySet;
  30.     }
  31.  
  32.     public void setMySet(Set<String> mySet) {
  33.         this.mySet = mySet;
  34.     }
  35.  
  36.     public Map<String, String> getMyMap() {
  37.         return myMap;
  38.     }
  39.  
  40.     public void setMyMap(Map<String, String> myMap) {
  41.         this.myMap = myMap;
  42.     }
  43.  
  44.     public Properties getMyProps() {
  45.         return myProps;
  46.     }
  47.  
  48.     public void setMyProps(Properties myProps) {
  49.         this.myProps = myProps;
  50.     }
  51.  
  52. }
（2）配置Account类（利用setter注入依赖集合数据）
  1. <!--注入集合类型数据：
  2.     涉及到标签：
  3.     List结构： array list set
  4.     Map结构： map entry props prop
  5. -->
  6.  
  7. <bean id="account" class="com.ujiuye.pojo.Account">
  8. <!--注意：在注入集合数据时，只要是结构相同，标签可以互换-->
  9.  
  10.     <!--注入数组数据-->
  11.     <property name="myStrs">
  12.         <array>
  13.             <value>array-AAA</value>
  14.             <value>array-BBB</value>
  15.             <value>array-CCC</value>
  16.         </array>
  17.     </property>
  18.  
  19.     <!--注入List集合数据-->
  20.     <property name="myList">
  21.         <list>
  22.             <value>list-AAA</value>
  23.             <value>list-BBB</value>
  24.             <value>list-CCC</value>
  25.         </list>
  26.     </property>
  27.  
  28.     <!--注入Set集合数据-->
  29.     <property name="mySet">
  30.         <list>
  31.             <value>set-AAA</value>
  32.             <value>set-BBB</value>
  33.             <value>set-CCC</value>
  34.         </list>
  35.     </property>
  36.  
  37.     <!--注入Map集合-->
  38.     <property name="myMap">
  39.         <map>
  40.             <entry key="map-a" value="AAA"></entry>
  41.             <entry key="map-b">
  42.             <value>BBB</value>
  43.             </entry>
  44.         </map>
  45.     </property>
  46.  
  47.     <!--注入Properties集合-->
  48.     <property name="myProps">
  49.         <props>
  50.             <prop key="pro-a">AAA</prop>
  51.             <prop key="pro-b">BBB</prop>
  52.         </props>
  53.     </property>
  54. </bean>

（3）集合注入测试方法
  1. @Test
  2. public void testDI(){
  3.     ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext("applicationContext.xml");
  4.     Account account = (Account) applicationContext.getBean("account");
  5.     System.out.println("array:"+ Arrays.toString(account.getMyStrs()));
  6.     System.out.println("list:"+account.getMyList());
  7.     System.out.println("set:"+account.getMySet());
  8.     System.out.println("map:"+account.getMyMap());
  9.     System.out.println("props:"+account.getMyProps());
  10. /*
  11. 测试结果：
  12. array:[array-AAA, array-BBB, array-CCC]
  13. list:[list-AAA, list-BBB, list-CCC]
  14. set:[set-AAA, set-BBB, set-CCC]
  15. map:{map-a=AAA, map-b=BBB}
  16. props:{pro-b=BBB, pro-a=AAA}
  17. */
  18. }

五、Spring配置文件模块化

（一）Spring模块化的介绍

        我们现在的配置都集中配在了一个applicationContext.xml文件中，当开发人员过多时， 如果所有bean 都配置到同一个配置文件中，会使这个文件巨大，而且也不方便维护。 针对这个问题，Spring提供了多配置文件的方式，也就是所谓的配置文件模块化。

（二）Spring模块化的配置

1、Spring模块化配置方式一

并列的多个配置文件直接编写多个配置文件，比如beans1.xml，beans2.xml，...，然后在创建ApplicationContext的时候，直接传入多个配置文件。

ApplicationContext act = new ClassPathXmlApplicationContext("beans1.xml","beans2.xml","...");

2、Spring模块化配置方式二

主从配置文件，先配置一个主配置文件，然后在里面导入其他的配置文件。

  1. <import resource="beans1.xml" />
  2. <import resource="beans2.xml" />

注意：

        同一个xml文件中不能出现相同名称的bean，如果出现会报错。‘’

        多个xml文件如果出现相同的名称的bean，不会报错，但是后加载的会覆盖前加载的bean，所以企业开发中尽量保证bean的名称是唯一的。

六、模块设计模式解析

（一）模块化设计模式介绍

模块方法（Template Method）模式的定义：定义一个操作中的算法骨架，而将算法的一些步骤延迟到子类中，使得子类可以不改变该算法结构的情况下重定义该算法的某些特定步骤。它是一种类行为型模式。

模块方法模式的静态结构图：

                                                

 

（二）模板设计模式的应用场景

在多个子类中拥有相同的方法，而且逻辑相同时，可以将这些方法抽出来发到一个模块抽象类中程序主框架相同，细节不同的情况下，也可以使用模块方法。

举例说明：

  • 使用过Servlet的人都清楚，除了要在web.xml做相应的配置外，还需继承一个叫HttpServlet的抽象类。HttpService类提供了一个service()方法，这个方法调用七个do方法中的一个或几个，完成对客户端调用的响应。这些do方法需要由HttpServlet的具体子类提供，因此这是典型的模板方法模式。
  • 持久层对数据库的操作，Spring提供了JdbcTemplate模板对象， 完成CRUD操作。

（三）模板设计模式实现

1、需求：用模块方法模式实现出国留学手续设计程序

分析：出国留学手续一般经过以下流程：索取学校资料，提出入学申请，办理因私出国护照、出境卡和公证，申请签证，体检、订机票、准备行装，抵达目标学校等，其中有些业务对各个学校是一样的，但有些业务因学校不同而不同，所以比较适合用模板方法模式来实现。

在本实例中，我们先定义一个出国留学的抽象类 StudyAbroad，里面包含了一个模板方法 TemplateMethod()，该方法中包含了办理出国留学手续流程中的各个基本方法，其中有些方法的处理由于各国都一样，所以在抽象类中就可以实现，但有些方法的处理各国是不同的，必须在其具体子类（如美国留学类 StudyInAmerica）中实现。如果再增加一个国家，只要增加一个子类就可以了。

                

2、代码实现

抽象类：

  1. //抽象类: 出国留学
  2. public abstract class StudyAbroad {
  3.  
  4.     //定义抽象方法，索取学校资料
  5.     public abstract void LookingForSchool();
  6.  
  7.     //定义抽象方法，定义入学申请
  8.     public abstract void ApplyForEnrol();
  9.  
  10.     //定义入学申请方法：
  11.     public void ApplyForPassport() {
  12.         System.out.println("三.办理因私出国护照、出境卡和公证：");
  13.         System.out.println(" 1）持录取通知书、本人户口簿或身份证向户口所在地公安机关申请办理因私出国护照和出境卡。");
  14.         System.out.println(" 2）办理出生公证书，学历、学位和成绩公证，经历证书，亲属关系公证，经济担保公证。");
  15.     }
  16.  
  17.     //定义申请签证方法
  18.     public void ApplyForVisa() {
  19.         System.out.println("四.申请签证：");
  20.         System.out.println(" 1）准备申请国外境签证所需的各种资料，包括个人学历、成绩单、工作经历的证明；个人及家庭收入、资金和财产证明；家庭成员的关系证明等；");
  21.         System.out.println(" 2）向拟留学国家驻华使(领)馆申请入境签证。申请时需按要求填写有关表格，递交必需的证明材料，缴纳签证。有的国家(比如美国、英国、加拿大等)在申请签证时会要求申请人前往使(领)馆进行面试。");
  22.     }
  23.  
  24.     //体检、订机票、准备行装 方法
  25.     public void ReadyGoAbroad() {
  26.         System.out.println("五.体检、订机票、准备行装：");
  27.         System.out.println(" 1）进行身体检查、免疫检查和接种传染病疫苗；");
  28.         System.out.println(" 2）确定机票时间、航班和转机地点。");
  29.     }
  30.  
  31.     //定义抵达抽象方法
  32.         public abstract void Arriving();
  33.     }

子类

  1. //定义具体的子类，美国留学
  2. public class StudyInAmerica extends StudyAbroad {
  3.  
  4.     //索取资料的具体实现
  5.     @Override
  6.     public void LookingForSchool() {
  7.         System.out.println("一.索取学校以下资料：");
  8.         System.out.println(" 1）对留学意向国家的政治、经济、文化背景和教育体制、学术水平进行较为全面的了解；");
  9.         System.out.println(" 2）全面了解和掌握国外学校的情况，包括历史、学费、学制、专业、师资配备、教学设施、学术地位、学生人数等；");
  10.         System.out.println(" 3）了解该学校的住宿、交通、医疗保险情况如何；");
  11.         System.out.println(" 4）该学校在中国是否有授权代理招生的留学中介公司？");
  12.         System.out.println(" 5）掌握留学签证情况；");
  13.         System.out.println(" 6）该国政府是否允许留学生合法打工？");
  14.         System.out.println(" 8）毕业之后可否移民？");
  15.         System.out.println(" 9）文凭是否受到我国认可？");
  16.     }
  17.  
  18.     //入学申请的具体实现
  19.     @Override
  20.     public void ApplyForEnrol() {
  21.         System.out.println("二.入学申请：");
  22.         System.out.println(" 1）填写报名表；");
  23.         System.out.println(" 2）将报名表、个人学历证明、最近的学习成绩单、推荐信、个人简历、托福或雅思语言考试成绩单等资料寄往所申请的学校；");
  24.         System.out.println(" 3）为了给签证办理留有充裕的时间，建议越早申请越好，一般提前1年就比较从容。");
  25.     }
  26.  
  27.     //抵达的具体实现
  28.     @Override
  29.     public void Arriving() {
  30.         System.out.println("六.抵达目标学校：");
  31.         System.out.println(" 1）安排住宿；");
  32.         System.out.println(" 2）了解校园及周边环境。");
  33.     }
  34. }
  1. public class StudyAbroadProcess {
  2.     public static void main(String[] args) {
  3.         StudyAbroad tm = new StudyInAmerica();
  4.         tm.TemplateMethod();
  5.     }
  6. }

七、Spring整合JDBC实现用户的CRUD

（一）整合思路分析

Spring提供了ioc容器，管理jdbc操作数据库的过程中需要的数据库连接对象，同时Spring提供了整合jdbc操作数据库的工具类JdbcDaoSupport 和模板工具 JdbcTemplate，在JdbcTemplate中提供了大量的操作数据库的方式供用户使用。所以我们只需要获取模板工具类然后调用方法就可以完成Jdbc的操作了。

（二）构建maven工程，添加技术依赖

  1. <dependencies>
  2.     <!--导入spring的context坐标-->
  3.     <dependency>
  4.         <groupId>org.springframework</groupId>
  5.         <artifactId>spring-context</artifactId>
  6.         <version>${spring.version}</version>
  7.     </dependency>
  8.  
  9.     <!--导入Jdbc模块依赖-->
  10.     <dependency>
  11.         <groupId>org.springframework</groupId>
  12.         <artifactId>spring-jdbc</artifactId>
  13.         <version>${spring.version}</version>
  14.     </dependency>
  15.  
  16.     <!--导入Mysql 驱动-->
  17.     <dependency>
  18.         <groupId>mysql</groupId>
  19.         <artifactId>mysql-connector-java</artifactId>
  20.         <version>5.1.47</version>
  21.     </dependency>
  22.  
  23.     <!--导入C3P0连接池-->
  24.     <dependency>
  25.         <groupId>com.mchange</groupId>
  26.         <artifactId>c3p0</artifactId>
  27.         <version>0.9.5.2</version>
  28.     </dependency>
  29.  
  30.     <!--导入junit单元测试-->
  31.     <dependency>
  32.         <groupId>junit</groupId>
  33.         <artifactId>junit</artifactId>
  34.         <version>4.12</version>
  35.         <scope>test</scope>
  36.     </dependency>
  37. </dependencies>

（三）构建数据库表并编写实体类Account

  1. public class Account implements Serializable {
  2.     private Integer id;
  3.     private String name;
  4.     private double money;
  5.  
  6.     public Integer getId() {
  7.         return id;
  8.     }
  9.  
  10.     public void setId(Integer id) {
  11.         this.id = id;
  12.     }
  13.  
  14.     public String getName() {
  15.         return name;
  16.     }
  17.  
  18.     public void setName(String name) {
  19.         this.name = name;
  20.     }
  21.  
  22.     public double getMoney() {
  23.         return money;
  24.     }
  25.  
  26.     public void setMoney(double money) {
  27.         this.money = money;
  28.     }
  29.  
  30.     @Override
  31.     public String toString() {
  32.         return "Account{" +
  33.         "id=" + id +
  34.         ", name='" + name + '\'' +
  35.         ", money=" + money +
  36.         '}';
  37.     }
  38. }

（四）编写持久层代码AccountDao以及实现类AccountDaoImpl

  1. public interface AccountDao {
  2.     public void save(Account account);
  3.     public void delete(Integer id);
  4.     public void update(Account account);
  5.     public Account findById(Integer id);
  6.     public Integer getTotalRecords();
  7.     public List<Account> findAll();
  8. }
  1. public class AccountDaoImpl implements AccountDao {
  2.     private JdbcTemplate jdbcTemplate;
  3.  
  4.     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
  5.         this.jdbcTemplate = jdbcTemplate;
  6.     }
  7.  
  8.     @Override
  9.     public void save(Account account) {
  10.         String sql ="insert into account(name,money) values(?,?)";
  11.         jdbcTemplate.update(sql,account.getName(),account.getMoney());
  12.     }
  13.  
  14.     @Override
  15.     public void delete(Integer id) {
  16.         String sql ="delete from account where id = ? ";
  17.         jdbcTemplate.update(sql,id);
  18.     }
  19.  
  20.     @Override
  21.     public void update(Account account) {
  22.         String sql ="update account set money = ? , name=? where id= ?";
  23.         jdbcTemplate.update(sql,account.getMoney(),account.getName(),account.getId());
  24.     }
  25.  
  26.     @Override
  27.     public Account findById(Integer id) {
  28.         String sql ="select * from account where id = ? ";
  29.         Account account = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<Account>(Account.class),id);
  30.         return account;
  31.     }
  32.  
  33.     @Override
  34.     public Long getTotalRecords() {
  35.         Long count = jdbcTemplate.queryForObject("select count(*) from account",Long.class);
  36.         System.out.println(count);
  37.         return count;
  38.     }
  39.  
  40.     @Override
  41.     public List<Account> findAll() {
  42.         String sql ="select * from account";
  43.         List<Account> accountList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<Account>(Account.class));
  44.         return accountList;
  45.     }
  46. }

（五）编写业务层代码Accountservice以及实现类AccountServiceImpl

  1. public interface AccountService {
  2.     public void save(Account account);
  3.     public void delete(Integer id);
  4.     public void update(Account account);
  5.     public Account findById(Integer id);
  6.     public Long getTotalRecords();
  7.     public List<Account> findAll();
  8. }
  1. public class AccountServiceImpl implements AccountService {
  2.     private AccountDao accountDao;
  3.  
  4.     public void setAccountDao(AccountDao accountDao) {
  5.         this.accountDao = accountDao;
  6.     }
  7.  
  8.     @Override
  9.     public void save(Account account) {
  10.         accountDao.save(account);
  11.     }
  12.   
  13.   @Override
  14.     public void delete(Integer id) {
  15.         accountDao.delete(id);
  16.     }
  17.   
  18.   @Override
  19.     public void update(Account account) {
  20.         accountDao.update(account);
  21.     }
  22.  
  23.    @Override
  24.     public Account findById(Integer id) {
  25.         return accountDao.findById(id);
  26.     }
  27.  
  28.     @Override
  29.     public Long getTotalRecords() {
  30.         return accountDao.getTotalRecords();
  31.     }
  32.  
  33.     @Override
  34.     public List<Account> findAll() {
  35.         return accountDao.findAll();
  36.     }
  37. }

（六）创建并编写配置文件：配置容器管理对象

将数据库的连接信息抽取到外部配置文件中，和spring的配置文件分离开，有利于后期维护

  1. jdbc.driver=com.mysql.jdbc.Driver
  2. jdbc.url=jdbc:mysql://localhost:3306/test
  3. jdbc.username=root
  4. jdbc.password=root
  1. <!--数据源对象-->
  2. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  3.     <property name="driverClass" value="${jdbc.driver}"/>
  4.     <property name="jdbcUrl" value="${jdbc.url}"/>
  5.     <property name="user" value="${jdbc.username}"/>
  6.     <property name="password" value="${jdbc.password}"/>
  7. </bean>
  8.  
  9. <!--配置JdbcTemplate模板对象-->
  10. <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
  11.     <property name="dataSource" ref="dataSource"/>
  12. </bean>
  13.  
  14. <!--配置AccountDaoImpl对象-->
  15. <bean id="accountDao" class="com.ujiuye.dao.impl.AccountDaoImpl">
  16.     <property name="jdbcTemplate" ref="jdbcTemplate"></property>
  17. </bean>
  18.  
  19. <!--配置AccountServiceImpl对象-->
  20. <bean id="accountService" class="com.ujiuye.service.AccountServiceImpl">
  21.     <property name="accountDao" ref="accountDao"></property>
  22. </bean>

（七）测试代码

  1. //测试save方法
  2. @Test
  3. public void testJdbcTemplateSave(){
  4.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  5.     AccountService service = (AccountService) context.getBean("accountService");
  6.     Account account = new Account();
  7.     account.setName("jack");
  8.     account.setMoney(1001D);
  9.     service.save(account);
  10. }
  11.  
  12. //测试update方法
  13. @Test
  14. public void testJdbcTemplateUpdate(){
  15.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  16.     AccountService service = (AccountService) context.getBean("accountService");
  17.     Account account = new Account();
  18.     account.setName("jack2");
  19.     account.setMoney(999D);
  20.     account.setId(1008);
  21.     service.update(account);
  22. }
  23.  
  24. //测试delete方法
  25. @Test
  26. public void testJdbcTemplateDelete(){
  27.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  28.     AccountService service = (AccountService) context.getBean("accountService");
  29.     service.delete(1001);
  30. }
  31.  
  32. //测试唯一性查询findById
  33. @Test
  34. public void testJdbcTemplateFindById(){
  35.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  36.     AccountService service = (AccountService) context.getBean("accountService");
  37.     Account account = service.findById(1001);
  38.     System.out.println(account);
  39. }
  40.  
  41. //测试总记录数
  42. @Test
  43. public void testJdbcTemplateGetTotalRecords(){
  44.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  45.     AccountService service = (AccountService) context.getBean("accountService");
  46.     Long totalRecords = service.getTotalRecords();
  47.     System.out.println("表当中的总记录数为："+totalRecords);
  48. }
  49.  
  50. //测试账户列表
  51. @Test
  52. public void testJdbcTemplateGetAll(){
  53.     ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  54.     AccountService service = (AccountService) context.getBean("accountService");
  55.     List<Account> accountList = service.findAll();
  56.     accountList.forEach((account -> {
  57.     System.out.println(account);
  58.     }));
  59. }

 八、常用注解

（一）创建对象的注解

注解说明
@Component使用在类上用于实例化Bean
@Controller使用在web层类上用于实例化Bean
@Service使用在service层类上用于实例化Bean
@Repository使用在dao层类上用于实例化Bean

注意：

  • 使用注解进行开发时，需要在applicationContext.xml中配置组件扫描，作用是指定哪个包及其子包下的Bean需要进行扫描一便识别使用注解配置的类、字段和方法。
  1. <!--注解的组件扫描-->
  2. <context:component-scan base-package="com.ujiuye"></context:component-scan>

  • 使用@Component或@Repository标识UserDaoImpl需要Spring进行实例化。
  1. //@Component("userDao")
  2. @Repository("userDao")
  3. public class UserDaoImpl implements UserDao {
  4.     @Override
  5.     public void save() {
  6.         System.out.println("save running... ...");
  7.     }
  8. }

  • 使用@Component或Service标识UserServiceImpl需要Spring进行实例化
  1. //@Component("userService")
  2. @Service("userService")
  3. public class UserServiceImpl implements UserService {
  4.     @Override
  5.     public void save() {
  6.         System.out.println("save running... ...");
  7.     }
  8. }

（二）用于注入数据的注解

注解说明
@Value注入普通属性
@Autowired

自动按照类型注入。当使用注解注入属性时，set 方法可以省略。它只能注入其他 bean 类型。当有多个类型匹配时，使用要注入的对象变量名称作为 bean 的id，在 spring 容器查找，找到了也可以注入成功。找不到就报错。

@Qualifier

结合@Autowired一起使用用于根据名称进行依赖注入

@Resource

相当于@Autowired+@Qualifier，按照名称进行注入

  • 使用@Value进行字符串的注入
  1. @Repository("userDao")
  2. public class UserDaoImpl implements UserDao {
  3.     @Value("注入普通数据")
  4.     private String str;
  5.     @Value("${jdbc.driver}")
  6.     private String driver;
  7.     @Override
  8.     public void save() {
  9.         System.out.println(str);
  10.         System.out.println(driver);
  11.         System.out.println("save running... ...");
  12.     }
  13. }

  • 使用Autowired或者@Autowired+@Qulifier或者@Resource进行userDao的注入
  1. //@Component("userService")
  2. @Service("userService")
  3. public class UserServiceImpl implements UserService {
  4.     /*@Autowired
  5.     @Qualifier("userDao")*/
  6.     @Resource(name="userDao")
  7.     private UserDao userDao;
  8.  
  9.     @Override
  10.     public void save() {
  11.         userDao.save();
  12.     }
  13. }

（三）用于改变作用范围的注解

注解说明
@Scope标注Bean的作用范围，scope取值singleton prototype request session globalsession

使用@Scope标注Bean的范围

  1. //@Scope("prototype")
  2. @Scope("singleton")
  3. public class UserDaoImpl implements UserDao {
  4.     //此处省略代码
  5. }

九、基于注解的IOC案例

（一）构建工程，添加依赖

  1. <dependencies>
  2.     <!--导入spring的context坐标-->
  3.     <dependency>
  4.         <groupId>org.springframework</groupId>
  5.         <artifactId>spring-context</artifactId>
  6.         <version>${spring.version}</version>
  7.     </dependency>
  8.  
  9.     <!--导入Jdbc模块依赖-->
  10.     <dependency>
  11.         <groupId>org.springframework</groupId>
  12.         <artifactId>spring-jdbc</artifactId>
  13.         <version>${spring.version}</version>
  14.     </dependency>
  15.  
  16.     <!--导入Mysql 驱动-->
  17.     <dependency>
  18.         <groupId>mysql</groupId>
  19.         <artifactId>mysql-connector-java</artifactId>
  20.         <version>5.1.47</version>
  21.     </dependency>
  22.  
  23.     <!--导入C3P0连接池-->
  24.     <dependency>
  25.         <groupId>com.mchange</groupId>
  26.         <artifactId>c3p0</artifactId>
  27.         <version>0.9.5.2</version>
  28.     </dependency>
  29.  
  30.     <!--导入junit单元测试-->
  31.     <dependency>
  32.         <groupId>junit</groupId>
  33.         <artifactId>junit</artifactId>
  34.         <version>4.12</version>
  35.         <scope>test</scope>
  36.     </dependency>
  37. </dependencies>

（二）使用注解配置

  1. @Repository(value = "userDao")
  2. public class UserDaoImpl implements UserDao {
  3.  
  4.     @Autowired
  5.     private JdbcTemplate jdbcTemplate;
  6.  
  7.     @Override
  8.     public void save(User user) {
  9.         String sql ="insert into user (name,birthday) values(?,?)";
  10.         jdbcTemplate.update(sql,user.getName(),user.getBirthday());
  11.     }
  12. }
  1. @Service("userService")
  2. public class UserServiceImpl implements UserService {
  3.  
  4.     @Autowired
  5.     private UserDao userDao ;
  6.  
  7.     @Override
  8.     public void saveService(User user) {
  9.         userDao.save(user);
  10.     }
  11. }

（三）创建配置文件并开启对注解的支持

  1. <context:component-scan base-package="com.offcn"></context:component-scan>
  2.     
  3. <!--配置数据源-->
  4. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  5.     <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
  6.     <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test">
  7. </property>
  8.     <property name="user" value="root"></property>
  9.     <property name="password" value="root"></property>
  10. </bean>
  11. <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
  12.     <constructor-arg name="dataSource" ref="dataSource"></constructor-arg>
  13. </bean>

（四）编写测试代码

  1. //IOC 注解版本的案例：
  2. @Test
  3. public void test1(){
  4.     ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  5.     UserService userService = (UserService) context.getBean("userService");
  6.     User user = new User();
  7.     user.setName("admin");
  8.     user.setBirthday(new Date());
  9.     userService.saveService(user);
  10. }

十、纯注解配置

（一）新注解说明

注解说明
@Configuration用于指定当前类是一个Spring配置类，当创建容器时会从该类上加载注解
@ComponentScan用于指定Spring在初始化容器时要扫描的包。作用和在Springdexml配置文件中的<context：component-scan base-package="com.offcn"/>一样
@Bean使用在方法上，标注将该方法的返回值存储到Spring容器中
@PropertySource用于加载xxx.properties文件中的配置
@Import用于导入其他配置类
  • @Configuration，@ComponentScan，@Import
  1. @Configuration //指定当前类是一个配置类，取代applicationContext.xml配置文件
  2. @ComponentScan("com.offcn") //指定Spring在初始化容器时要扫描的包
  3. @Import({xxx.class}) //导入其他的配置类
  4. public class SpringConfiguration {
  5.     ...
  6. }
  • @PropertySource，@Value
  1. @PropertySource("classpath:dbConfig.properties") //当前类中引入dbConfig.properties文件
  2. public class DataSourceConfiguration {
  3.     @Value("${jdbc.driver}")
  4.     private String driver;
  5.  
  6.     @Value("${jdbc.url}")
  7.     private String url;
  8.  
  9.     @Value("${jdbc.username}")
  10.     private String username;
  11.  
  12.     @Value("${jdbc.password}")
  13.     private String password;
  14. }

  • @Bean
  1. @Bean(name="dataSource") //将方法的返回值存入到IOC容器当中
  2. public DataSource getDataSource() throws Exception {
  3.     ComboPooledDataSource dataSource = new ComboPooledDataSource();
  4.     dataSource.setDriverClass(driver);
  5.     dataSource.setJdbcUrl(url);
  6.     dataSource.setUser(username);
  7.     dataSource.setPassword(password);
  8.     return dataSource;
  9. }

（二）通过注解获取容器

  1. public void AnnotationTest (){
  2.     //使用AnnotationConfigApplicationContext获得ioc容器对象
  3.     ApplicationContext context= new AnnotationConfigApplicationContext(SpringConfig.class);
  4.     Object obj = context.getBean("...");
  5. }

十一、Spring整合Junit

（一）IOC测试类中的问题和解决思路

在测试类中，每个测试方法都有一下两行代码：

  1. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
  2. UserService userService = (UserService) context.getBean("userService");

这两行代码的作用是获取容器，如果不写的话，直接会提示空指针异常。所以又不能轻易删掉。

（二）整合Junit配置步骤

1、添加技术依赖

  1. <properties>
  2. <spring.version>5.2.5.RELEASE</spring.version>
  3. </properties>
  4.  
  5. <!--此处需要注意的是，spring5 及以上版本要求 junit 的版本必须是 4.12 及以上-->
  6. <dependency>
  7.     <groupId>junit</groupId>
  8.     <artifactId>junit</artifactId>
  9.     <version>4.12</version>
  10.     <scope>test</scope>
  11. </dependency>
  12.  
  13. <!--导入Spring整合Junit的依赖-->
  14. <dependency>
  15.     <groupId>org.springframework</groupId>
  16.     <artifactId>spring-test</artifactId>
  17.     <version>${spring.version}</version>
  18. </dependency>
  19.  
  20. <!--导入spring的context依赖-->
  21. <dependency>
  22.     <groupId>org.springframework</groupId>
  23.     <artifactId>spring-context</artifactId>
  24.     <version>${spring.version}</version>
  25. </dependency>

2、使用@RunWith注解替换原有运行器

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2.     public class SpringJunitTest {
  3. }

3、使用@ContextConfiguration 指定 Spring 配置文件的位置 

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. //加载spring核心配置文件
  3. //@ContextConfiguration(value = {"classpath:applicationContext.xml"})
  4. //加载spring核心配置类
  5. @ContextConfiguration(classes = {SpringConfiguration.class})
  6. public class SpringJunitTest {
  7. }

4、使用@Autowired 给测试类中的变量注入数据

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @ContextConfiguration(classes = {SpringConfiguration.class})
  3. public class SpringJunitTest {
  4.     @Autowired
  5.     private ApplicationContext context;
  6.  
  7.     @Test
  8.     public void test(){
  9.         ...
  10.     }
  11. }

十二、Spring整合DButils实现转账业务

（一）添加转账方法，并演示事务问题

1、转账Account表以及对应的实体bean

  1. public class Account implements Serializable {
  2.     private Integer id;
  3.     private String name;
  4.     private double money;
  5.  
  6.     public Integer getId() {
  7.         return id;
  8.     }
  9.  
  10.     public void setId(Integer id) {
  11.         this.id = id;
  12.     }
  13.  
  14.     public String getName() {
  15.         return name;
  16.     }
  17.  
  18.     public void setName(String name) {
  19.         this.name = name;
  20.     }
  21.  
  22.     public double getMoney() {
  23.         return money;
  24.     }
  25.  
  26.     public void setMoney(double money) {
  27.         this.money = money;
  28.     }
  29.  
  30.     @Override
  31.     public String toString() {
  32.         return "Account{" +
  33.         "id=" + id +
  34.         ", name='" + name + '\'' +
  35.         ", money=" + money +
  36.         '}';
  37.     }
  38. }

2、引入DBUtils依赖坐标

  1. <!--引入QueryRunner-->
  2. <dependency>
  3.     <groupId>commons-dbutils</groupId>
  4.     <artifactId>commons-dbutils</artifactId>
  5.     <version>1.7</version>
  6. </dependency>

3、创建Account接口和对应实现类

  1. public interface AccountDao {
  2.     public Account findByName(String name);
  3.     public void update(Account account);
  4. }
  1. public class AccountDaoImpl implements AccountDao {
  2.     private QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());
  3.    
  4.     @Override
  5.     public Account findByName(String name) {
  6.  
  7.     try {
  8.         String sql ="select *from account where name =? ";
  9.         Account account = queryRunner.query(sql, new BeanHandler<> (Account.class), name);
  10.         return account;
  11.     } catch (SQLException throwables) {
  12.         throwables.printStackTrace();
  13.     }
  14.     return null;
  15.     }
  16.  
  17.     @Override
  18.     public void update(Account account) {
  19.         try {
  20.             String sql ="update account set money =? where name =? ";
  21.             queryRunner.update(sql, account.getMoney(), account.getName());
  22.         } catch (SQLException throwables) {
  23.             throwables.printStackTrace();
  24.         }
  25.     }
  26. }

4、创建AccountService接口和实现类

  1. public interface AccountService {
  2. /**
  3. * 定义业务方法， 实现转账
  4. * @param sourceAccountName 来源账户
  5. * @param targetAccountName 目标账户
  6. * @param money 转账金额
  7. */
  8.     public void transfer(String sourceAccountName,String targetAccountName,double money);
  9. }
  1. public class AccountServiceImpl implements AccountService {
  2.     //依赖dao层
  3.     private AccountDao accountDao = new AccountDaoImpl();
  4.  
  5.     @Override
  6.     public void transfer(String sourceAccountName, String targetAccountName, double money) {
  7.         //查询来源账户和目标账户
  8.         Account sAccount = accountDao.findByName(sourceAccountName);
  9.         Account tAccount = accountDao.findByName(targetAccountName);
  10.  
  11.         //来源账户减钱，目标账户加钱
  12.         sAccount.setMoney(sAccount.getMoney()-money);
  13.         tAccount.setMoney(tAccount.getMoney()+money);
  14.  
  15.         //持久化到数据库
  16.         accountDao.update(sAccount);
  17.         //模拟异常发生
  18.         int i=1/0;
  19.         accountDao.update(tAccount);
  20.     }
  21. }

5、测试转账业务

  1. @Test
  2. public void test1(){
  3.     //获得业务层对象：
  4.     AccountService service = new AccountServiceImpl();
  5.     service.transfer("aaa","bbb",100D);
  6. }

（二）编写ConnectionUtils工具类管理数据库连接

  1. public class ConnectionUtils {
  2.  
  3.     private ThreadLocal<Connection> tl = new ThreadLocal<Connection>();
  4.     private DataSource dataSource;
  5.  
  6.     public void setDataSource(DataSource dataSource) {
  7.         this.dataSource = dataSource;
  8.     }
  9.  
  10.     /**
  11.     * 获取当前线程上的连接
  12.     * @return
  13.     */
  14.     public Connection getThreadConnection() {
  15.         try{
  16.             //1.先从ThreadLocal上获取
  17.             Connection connection = tl.get();
  18.             //2.判断当前线程上是否有连接
  19.             if (connection == null) {
  20.                 //3.从数据源中获取一个连接，并且存入ThreadLocal中
  21.                 connection = dataSource.getConnection();
  22.                 tl.set(connection);
  23.             }
  24.             //4.返回当前线程上的连接
  25.             return connection;
  26.         }catch (Exception e){
  27.             throw new RuntimeException(e);
  28.         }
  29.     }
  30.  
  31.     /**
  32.     * 把连接和线程解绑
  33.     */
  34.     public void removeConnection(){
  35.         tl.remove();
  36.     }

（三）编写事务管理工具类

  1. /**
  2. * 和事务管理相关的工具类，它包含了，开启事务，提交事务，回滚事务和释放连接
  3. */
  4. public class TransactionManager {
  5.     private ConnectionUtils connectionUtils;
  6.  
  7.     public void setConnectionUtils(ConnectionUtils connectionUtils) {
  8.         this.connectionUtils = connectionUtils;
  9.     }
  10.  
  11.     /**
  12.     * 开启事务
  13.     */
  14.     public void beginTransaction(){
  15.         try {
  16.             connectionUtils.getThreadConnection().setAutoCommit(false);
  17.         }catch (Exception e){
  18.             e.printStackTrace();
  19.         }
  20.     }
  21.  
  22.     /**
  23.     * 提交事务
  24.     */
  25.     public void commit(){
  26.         try {
  27.             connectionUtils.getThreadConnection().commit();
  28.         }catch (Exception e){
  29.             e.printStackTrace();
  30.         }
  31.     }
  32.  
  33.     /**
  34.     * 回滚事务
  35.     */
  36.     public void rollback(){
  37.         try {
  38.             connectionUtils.getThreadConnection().rollback();
  39.         }catch (Exception e){
  40.             e.printStackTrace();
  41.         }
  42.     }
  43.  
  44.     /**
  45.     * 释放连接
  46.     */
  47.     public void release(){
  48.         try {
  49.             connectionUtils.removeConnection();
  50.             connectionUtils.getThreadConnection().close();//还回连接池中
  51.         }catch (Exception e){
  52.             e.printStackTrace();
  53.         }
  54.     }
  55. }

（四）编写业务层和持久层控制代码并配置Spring的IOC

  1. public class AccountDaoImpl implements AccountDao {
  2.  
  3.     private QueryRunner queryRunner ;
  4.     private ConnectionUtils connectionUtils;
  5.  
  6.     public void setQueryRunner(QueryRunner queryRunner) {
  7.         this.queryRunner = queryRunner;
  8.     }
  9.  
  10.     public void setConnectionUtils(ConnectionUtils connectionUtils) {
  11.         this.connectionUtils = connectionUtils;
  12.     }
  13.  
  14.     @Override
  15.     public Account findByName(String name) {
  16.         try {
  17.             String sql ="select * from account where name =? ";
  18.             Account account = queryRunner.query(connectionUtils.getThreadConnection(), sql,new BeanHandler<Account>(Account.class), name);
  19.             return account;
  20.         } catch (SQLException throwables) {
  21.             throwables.printStackTrace();
  22.         }
  23.         return null;
  24.     }
  25.  
  26.     @Override
  27.     public void update(Account account) {
  28.         try {
  29.             String sql ="update account set money =? where name =? ";
  30.             queryRunner.update(connectionUtils.getThreadConnection(),sql,account.getMoney(),account.getName());
  31.         } catch (SQLException throwables) {
  32.             throwables.printStackTrace();
  33.         }
  34.     }
  35. }
  1. public class AccountServiceImpl implements AccountService {
  2.     //依赖dao层
  3.     private AccountDao accountDao ;
  4.     private TransactionManager txManager;
  5.   
  6.     public AccountDao getAccountDao() {
  7.         return accountDao;
  8.     }
  9.  
  10.     public void setAccountDao(AccountDao accountDao) {
  11.         this.accountDao = accountDao;
  12.     }
  13.  
  14.     public TransactionManager getTxManager() {
  15.         return txManager;
  16.     }
  17.  
  18.     public void setTxManager(TransactionManager txManager) {
  19.         this.txManager = txManager;
  20.     }
  21.  
  22.     @Override
  23.     public void transfer(String sourceAccountName, String targetAccountName,double money) {
  24.             try {
  25.                 //开启事务：
  26.                 txManager.beginTransaction();
  27.                 //查询来源账户和目标账户
  28.                 Account sAccount = accountDao.findByName(sourceAccountName);
  29.                 Account tAccount = accountDao.findByName(targetAccountName);
  30.                 //来源账户减钱，目标账户加钱
  31.                 sAccount.setMoney(sAccount.getMoney()-money);
  32.                 tAccount.setMoney(tAccount.getMoney()+money);
  33.                 //持久化到数据库
  34.                 accountDao.update(sAccount);
  35.                 //模拟异常发生
  36.                 int i=1/0;
  37.                 accountDao.update(tAccount);
  38.             } catch (Exception exception){
  39.                 //事务回滚
  40.                 txManager.rollback();
  41.                 exception.printStackTrace();
  42.             } finally {
  43.                 //释放资源
  44.                 txManager.release();
  45.             }
  46.         }
  47. }
  1. <!-- 配置数据源 -->
  2. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  3.     <!--连接数据库的必备信息-->
  4.     <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
  5.     <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test">
  6. </property>
  7.     <property name="user" value="root"></property>
  8.     <property name="password" value="root"></property>
  9. </bean>
  10.  
  11. <!-- 配置Connection的工具类 ConnectionUtils -->
  12. <bean id="connectionUtils" class="com.offcn.utils.ConnectionUtils">
  13.     <!-- 注入数据源-->
  14.     <property name="dataSource" ref="dataSource"></property>
  15. </bean>
  16.  
  17. <!-- 配置事务管理器-->
  18. <bean id="txManager" class="com.offcn.utils.TransactionManager">
  19.     <!-- 注入ConnectionUtils -->
  20.     <property name="connectionUtils" ref="connectionUtils"></property>
  21. </bean>
  22.  
  23. <!--配置QueryRunner-->
  24. <bean id="queryRunner" class="org.apache.commons.dbutils.QueryRunner"scope="prototype"></bean>
  25.  
  26. <!--配置Dao对象-->
  27. <bean id="accountDao" class="com.offcn.dao.impl.AccountDaoImpl">
  28.  
  29.     <!-- 注入QueryRunner -->
  30.     <property name="queryRunner" ref="queryRunner"></property>
  31.     
  32.     <!-- 注入ConnectionUtils -->
  33.     <property name="connectionUtils" ref="connectionUtils"></property>
  34. </bean>
  35.  
  36. <!-- 配置Service层对象 -->
  37. <bean id="accountService" class="com.offcn.service.impl.AccountServiceImpl">
  38.  
  39.     <!-- 注入dao -->
  40.     <property name="accountDao" ref="accountDao"></property>
  41.  
  42.     <!--注入txManager-->
  43.     <property name="txManager" ref="txManager"></property>
  44. </bean>

（五）测试转账

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @ContextConfiguration(locations = "classpath:applicationContext.xml")
  3. public class TestAccountTransfer {
  4.     @Autowired
  5.     private AccountService accountService;
  6.     @Test
  7.     public void test1(){
  8.         accountService.transfer("aaa","bbb",100);
  9.     }
  10. }

（六）转账业务案例中存在的问题

（七）使用动态代理实现事务控制

1、创建代理工具类

  1. /**
  2. * 用于创建客户业务层对象工厂（当然也可以创建其他业务层对象，只不过我们此处不做那么繁琐）
  3. */
  4. public class BeanFactory {
  5.     private AccountService accountService;
  6.     private TransactionManager txManager;
  7.  
  8.     public void setAccountService(AccountService accountService) {
  9.         this.accountService = accountService;
  10.     }
  11.  
  12.     public void setTxManager(TransactionManager txManager) {
  13.         this.txManager = txManager;
  14.     }
  15.  
  16.     /**
  17.     * 获取Service代理对象
  18.     * @return
  19.     */
  20.     public AccountService getAccountService() {
  21.         return (AccountService)
  22.         Proxy.newProxyInstance(accountService.getClass().getClassLoader(),accountService.getClass().getInterfaces(),new InvocationHandler() {
  23.             /**
  24.             * 添加事务的支持
  25.             * @param proxy
  26.             * @param method 执行目标方法被封装到Method当中
  27.             * @param args 执行目标方法的参数
  28.             * @return 执行目标方法的返回值
  29.             * @throws Throwable
  30.             */
  31.             @Override
  32.             public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
  33.                 Object returntValue = null;
  34.                 try {
  35.                     //1.开启事务
  36.                     txManager.beginTransaction();
  37.                     //2.执行操作
  38.                     returntValue = method.invoke(accountService, args);
  39.                     //3.提交事务
  40.                     txManager.commit();
  41.                     //4.返回结果
  42.                     return returntValue;
  43.                 } catch (Exception e) {
  44.                     //5.回滚操作
  45.                     txManager.rollback();
  46.                     throw new RuntimeException(e);
  47.                 } finally {
  48.                     //6.释放连接
  49.                     txManager.release();
  50.                 }
  51.             }
  52.         });
  53.     }
  54. }

2、配置并测试动态代理转账业务

配置静态工厂，生产实例bean

  1. <!--配置beanfactory-->
  2. <bean id="beanFactory" class="com.offcn.factory.BeanFactory">
  3.     <!-- 注入service -->
  4.     <property name="accountService" ref="accountService"></property>
  5.     <!-- 注入事务管理器 -->
  6.     <property name="txManager" ref="txManager"></property>
  7. </bean>
  8. <!--配置代理的service-->
  9. <bean id="proxyAccountService" factory-bean="beanFactory" factorymethod="getAccountService">
  10. </bean>

业务层代码的修改：把和事务相关的代码去掉

  1. @Override
  2. public void transfer(String sourceAccountName, String targetAccountName, double money) {
  3.     Account sAccount = accountDao.findByName(sourceAccountName);
  4.     Account tAccount = accountDao.findByName(targetAccountName);
  5.   
  6.   //来源账户减钱，目标账户加钱
  7.     sAccount.setMoney(sAccount.getMoney()-money);
  8.     tAccount.setMoney(tAccount.getMoney()+money);
  9.    
  10.  //持久化到数据库
  11.     accountDao.update(sAccount);
  12.     //模拟异常发生
  13.     //int i=1/0;
  14.     accountDao.update(tAccount);
  15. }

测试代码：

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @ContextConfiguration(locations = "classpath:applicationContext.xml")
  3. public class TestAccountTransfer {
  4.  
  5.     @Autowired
  6.     @Qualifier("proxyAccountService")
  7.     private AccountService accountProxyService;
  8.  
  9.     @Test
  10.     public void testAccountProxy(){
  11.         accountProxyService.transfer("aaa","bbb",100D);
  12.     }
  13. }

总结：使用动态代理改造之后，业务层代码已经和事务相关代码进行了分离，并且保证了事务的一致性。

十三、SpringAOP机制详解

 （一）AOP概述

1、什么是AOP

AOP为Aspect Oriented Programming的缩写，意思为面向切面编程，是通过预编译方式和运行期动态代理实现程序功能的统一维护的一种技术。

2、AOP编程思想

AOP面向切面编程是一种编程思想，是OOP的延续，是软件开发中的一个热点，也是Spring框架中的一个重要内容，是函数式编程的一种衍生范型。利用AOP可以对业务逻辑的各个部分进行隔离，从而使得业务逻辑各个部分之间的耦合度降低，提高程序的可重用性，同时提高了开发的效率。

3、Spring中的常用术语

  • Joinpoint（连接点）：所谓连接点是指那些被拦截到的点。在Spring中，这些点指的是方法，因为Spring只支持方法类型的连接点。
  • Pointcut（切入点）：所谓切入点是指我们要对哪些Joinpoint进行拦截的定义。
  • Advice（通知/增强）：通知是指拦截到Joinpoint之后所要做的事情就是通知。通知的类型：前置通知，后置通知，异常通知，最终通知，环绕通知。
  • Introduction（引介）：引介是一种特殊的通知在不修改类代码的前提下，Introduction可以在运行期为类动态地添加一些方法。
  • Target（目标对象）：代理的目标对象。
  • Proxy（代理）：一个类被AOP织入增强后，就产生一个结果代理类。
  • Weaving（织入）：是指把增强应用到目标对象来创建新的代理对象的过程。Spring采用动态代理织入，而Aspect采用编译期织入和类装载期织入。
  • Aspect（切面）：是切入点和通知（引介）的结合。

4、AOP编程底层的实现机制

（1）JDK动态代理

只提供接口的代理，不支持类的代理。JDK动态代理通过反射来接受被代理的类，并且要求被代理的类必须实现一个接口。JDK动态代理的核心是invocationHandler接口和Proxy类

（2）CGLB动态代理

通过继承的方式来实现动态代理，因此如果某个类被标记为final，那么他是无法使用CGLB做动态代理。

5、AOP的作用及优势

作用：在程序运行期间，在不修改源码的情况下对方法进行功能增强。

优势：减少重复代码，提高开发效率，并且便于维护。

（二）Spring基于XML的AOP配置

1、环境搭建

（1）添加依赖 
  1. <properties>
  2.     <spring.version>5.2.5.RELEASE</spring.version>
  3. </properties>
  4.  
  5. <dependencies>
  6.     <dependency>
  7.         <groupId>org.springframework</groupId>
  8.         <artifactId>spring-context</artifactId>
  9.         <version>${spring.version}</version>
  10.     </dependency>
  11.  
  12.     <dependency>
  13.         <groupId>org.aspectj</groupId>
  14.         <artifactId>aspectjweaver</artifactId>
  15.         <version>1.8.7</version>
  16.     </dependency>
  17. </dependencies>
（2）添加代码
准备实体类
  1. public class Account implements Serializable {
  2.     private Integer id;
  3.     private String name;
  4.     private double money;
  5.  
  6.     public Integer getId() {
  7.         return id;
  8.     }
  9.  
  10.     public void setId(Integer id) {
  11.         this.id = id;
  12.     }
  13.  
  14.     public String getName() {
  15.         return name;
  16.     }
  17.  
  18.     public void setName(String name) {
  19.         this.name = name;
  20.     }
  21.  
  22.     public double getMoney() {
  23.         return money;
  24.     }
  25.  
  26.     public void setMoney(double money) {
  27.         this.money = money;
  28.     }
  29.  
  30.     @Override
  31.     public String toString() {
  32.         return "Account{" +
  33.             "id=" + id +
  34.             ", name='" + name + '\'' +
  35.             ", money=" + money +
  36.             '}';
  37.     }
  38. }
创建AccountDao接口以及实现类
  1. public interface AccountDao {
  2.     public Account findByName(String name);
  3.     public void update(Account account);
  4. }
  1. public class AccountDaoImpl implements AccountDao {
  2.     private QueryRunner queryRunner = new QueryRunner(new ComboPooledDataSource());
  3.  
  4.     @Override
  5.     public Account findByName(String name) {
  6.         try {
  7.             String sql ="select *from account where name =? ";
  8.             Account account = queryRunner.query(sql, new BeanHandler<>(Account.class), name);
  9.             return account;
  10.         } catch (SQLException throwables) {
  11.             throwables.printStackTrace();
  12.         }
  13.         return null;
  14.     }
  15.  
  16.     @Override
  17.     public void update(Account account) {
  18.         try {
  19.             String sql ="update account set money =? where name =? ";
  20.             queryRunner.update(sql, account.getMoney(), account.getName());
  21.         } catch (SQLException throwables) {
  22.             throwables.printStackTrace();
  23.         }
  24.     }
  25. }
创建AccountService接口以及实现类
  1. public interface AccountService {
  2. /**
  3. * 定义业务方法， 实现转账
  4. * @param sourceAccountName 来源账户
  5. * @param targetAccountName 目标账户
  6. * @param money 转账金额
  7. */
  8. public void transfer(String sourceAccountName,String targetAccountName,double money);
  9. }
  1. public class AccountServiceImpl implements AccountService {
  2.  
  3.     //依赖dao层
  4.     private AccountDao accountDao = new AccountDaoImpl();
  5.  
  6.     @Override
  7.     public void transfer(String sourceAccountName, String targetAccountName,double money) {
  8.         //查询来源账户和目标账户
  9.         Account sAccount = accountDao.findByName(sourceAccountName);
  10.         Account tAccount = accountDao.findByName(targetAccountName);
  11.        
  12.         //来源账户减钱，目标账户加钱
  13.         sAccount.setMoney(sAccount.getMoney()-money);
  14.         tAccount.setMoney(tAccount.getMoney()+money);
  15.  
  16.         //持久化到数据库
  17.         accountDao.update(sAccount);
  18.         //模拟异常发生
  19.         int i=1/0;
  20.         accountDao.update(tAccount);
  21.     }
  22. }
（3）创建配置文件并导入约束
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.     xmlns:aop="http://www.springframework.org/schema/aop"
  5.     xsi:schemaLocation="http://www.springframework.org/schema/beans
  6.     http://www.springframework.org/schema/beans/spring-beans.xsd
  7.     http://www.springframework.org/schema/aop
  8.     http://www.springframework.org/schema/aop/spring-aop.xsd">
  9. </beans>
（4）配置Spring的IOC
  1. <!-- 配置数据源 -->
  2. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  3.     <!--连接数据库的必备信息-->
  4.     <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
  5.     <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test">
  6. </property>
  7.     <property name="user" value="root"></property>
  8.     <property name="password" value="root"></property>
  9. </bean>
  10.  
  11. <!-- 配置Connection的工具类 ConnectionUtils -->
  12. <bean id="connectionUtils" class="com.offcn.utils.ConnectionUtils">
  13.     <!-- 注入数据源-->
  14.     <property name="dataSource" ref="dataSource"></property>
  15. </bean>
  16.  
  17. <!--配置queryRunner-->
  18. <bean id="queryRunner" class="org.apache.commons.dbutils.QueryRunner"></bean>
  19.  
  20. <!--配置accountDao-->
  21. <bean id="accountDao" class="com.offcn.dao.impl.AccountDaoImpl">
  22.     <property name="queryRunner" ref="queryRunner"></property>
  23.     <property name="connectionUtils" ref="connectionUtils"></property>
  24. </bean>
  25.  
  26. <!--配置accountService-->
  27. <bean id="accountService" class="com.offcn.service.impl.AccountServiceImpl">
  28.     <property name="accountDao" ref="accountDao"></property>
  29. </bean>
（5）抽取公共代码制作成通知
  1. /**
  2. * 和事务管理相关的工具类，它包含了，开启事务，提交事务，回滚事务和释放连接
  3. */
  4. public class TransactionManager {
  5.     private ConnectionUtils connectionUtils;
  6.  
  7.     public void setConnectionUtils(ConnectionUtils connectionUtils) {
  8.         this.connectionUtils = connectionUtils;
  9.     }
  10.  
  11.     /**
  12.     * 开启事务
  13.     */
  14.     public void beginTransaction(){
  15.         try {
  16.             connectionUtils.getThreadConnection().setAutoCommit(false);
  17.         }catch (Exception e){
  18.             e.printStackTrace();
  19.         }
  20.     }
  21.  
  22.     /**
  23.     * 提交事务
  24.     */
  25.     public void commit(){
  26.         try {
  27.             connectionUtils.getThreadConnection().commit();
  28.         }catch (Exception e){
  29.             e.printStackTrace();
  30.         }
  31.     }
  32.  
  33.     /**
  34.     * 回滚事务
  35.     */
  36.     public void rollback(){
  37.         try {
  38.             connectionUtils.getThreadConnection().rollback();
  39.         }catch (Exception e){
  40.             e.printStackTrace();
  41.         }
  42.     }
  43.  
  44.     /**
  45.     * 释放连接
  46.     */
  47.     public void release(){
  48.         try {
  49.             connectionUtils.removeConnection();
  50.             connectionUtils.getThreadConnection().close();//还回连接池中
  51.         }catch (Exception e){
  52.             e.printStackTrace();
  53.         }
  54.     }
  55. }

2、AOP配置步骤

（1）配置bean标签
  1. <!--配置通知：txManager-->
  2. <bean id="txManager" class="com.offcn.utils.TransactionManager">
  3.     <property name="connectionUtils" ref="connectionUtils"></property>
  4. </bean>
（2）使用aop：config 声明AOP配置

aop:config:
    作用： 开始声明aop配置

  1. <aop:config>
  2.     <!-- 配置的代码都写在此处 -->
  3. </aop:config>
（3）使用aop：aspect 配置切面

aop：aspect
        作用： 用于配置切面
        属性：id ：给切面提供一个唯一标识。
                   ref：引用配置好的通知类 bean 的 id。

  1. <aop:aspect id="tdAdvice" ref="txManager">
  2.     <!--配置通知的类型要写在此处-->
  3. </aop:aspect>
（4）使用aop：pointcut配置切入点表达式

aop:pointcut

        作用： 用于配置切入点表达式。就是指定对哪些类的哪些方法进行增强。

        属性： expression：用于定义切入点表达式。

                    id：用于给切入点表达式提供一个唯一标识

  1. <aop:pointcut id="point1" expression="execution( public void com.offcn.service.impl.AccountServiceImpl.transfer(java.lang.String,java.lang.St
  2. ring,java.lang.Double))"/>

（5）使用aop：xxx配置对应的通知类型
  • aop：before

        作用：用于指定通知类中的增强方法名称

        属性：method：用于指定通知类中的增强方法名称

                  ponitcut-ref：用于指定切入点的表达式的引用

                  poinitcut：用于指定切入点表达式

        执行时间点：切入点方法执行之前执行

<aop:before method="beginTransaction" pointcut-ref="point1"></aop:before>

  • aop：after-returning

        作用：用于配置后置通知

        属性：method：指定通知中方法的名称

                   pointct：定义切入点表达式

                   pointcut-ref：指定切入点表达式的引用

        执行时间点：切入点方法正常执行之后。它和异常通知只能有一个执行。

<aop:after-returning method="commit" pointcut-ref="point1"/>
  • aop：after-throwing

        作用：用于配置异常通知

        属性：method：指定通知中方法的名称

                   pointct：定义切入点表达式

                   pointcut-ref：指定切入点表达式的引用

        执行时间点：切入点方法执行产生异常后执行。它和后置通知只能执行一个。

<aop:after-throwing method="rollback" pointcut-ref="point1"/>

  • aop：after

        作用：用于配置最终通知

        属性：method：指定通知中方法的名称

                   pointct：定义切入点表达式

                   pointcut-ref：指定切入点表达式的引用

        执行时间点：无论切入点方法执行时是否有异常，它都会在其后面执行。

<aop:after method="release" pointcut-ref="point1"/>

3、切入点表达式说明

切入点表达式的语法

execution([修饰符] 返回值类型 包名.类名.方法名(参数))

  • 访问修饰符可以省略
  • 返回值类型、包名、类名、方法名可以使用*代表任意
  • 包名与类名之间一个点。代表当前包下的类，两个点...表示当前包及其子包下的类
  • 参数列表可以使用两个点...表示任意个数，任意类型的参数列表

4、环绕通知配置事务管理

在TransactionManager类当中添加方法

  1. /**
  2.     * 环绕通知:
  3.     * spring 框架为我们提供了一个接口：ProceedingJoinPoint，它可以作为环绕通知的方法参
  4. 数。
  5.     * 在环绕通知执行时，spring 框架会为我们提供该接口的实现类对象，我们直接使用就行。
  6.     * @param pjp
  7.     * @return
  8. */
  9. public Object transactionAround(ProceedingJoinPoint pjp) {
  10.     //定义返回值
  11.     Object returnValue = null;
  12.     try {
  13.         //获取方法执行所需的参数
  14.         Object[] args = pjp.getArgs();
  15.         //前置通知：开启事务
  16.         beginTransaction();
  17.         //执行方法
  18.         returnValue = pjp.proceed(args);
  19.         //后置通知：提交事务
  20.         commit();
  21.     }catch(Throwable e) {
  22.         //异常通知：回滚事务
  23.         rollback();
  24.         e.printStackTrace();
  25.     }finally {
  26.         //最终通知：释放资源
  27.         release();
  28.     }
  29.     return returnValue;
  30. }

aop：around：

        作用：用于配置环绕通知

        属性：method：指定通知中方法的名称

                   pointct：定义切入点表达式

                   pointcut-ref：指定切入点表达式的引用

        说明：它是 spring 框架为我们提供的一种可以在代码中手动控制增强代码什么时候执行的方式。

        注意：通常情况下，环绕通知都是独立使用的。

  1. <aop:config>
  2.     <aop:aspect id="tdAdvice" ref="txManager">
  3.         <aop:pointcut id="point1" expression="execution(*com.offcn.service.impl.*.*(..))"/>
  4.         <!-- 配置环绕通知 -->
  5.         <aop:around method="transactionAround" pointcut-ref="point1"/>
  6.     </aop:aspect>
  7. </aop:config>

（三）Spring基于注解的AOP配置

1、环境搭建

（1）构建maven工程添加AOP注解的相关依赖
  1. <properties>
  2.     <spring.version>5.2.5.RELEASE</spring.version>
  3. </properties>
  4.  
  5. <dependencies>
  6.     <dependency>
  7.         <groupId>org.springframework</groupId>
  8.         <artifactId>spring-context</artifactId>
  9.         <version>${spring.version}</version>
  10.     </dependency>
  11.  
  12.     <dependency>
  13.         <groupId>org.aspectj</groupId>
  14.         <artifactId>aspectjweaver</artifactId>
  15.         <version>1.8.7</version>
  16.     </dependency>
  17. </dependencies>

（2）导入代码

沿用上一章节资源

copy Account AccountDao AccountDaoImpl AccountService AccountServiceImpl

（3）在配置文件中导入context的名称空间且配置
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.     xmlns:aop="http://www.springframework.org/schema/aop"
  4.     xmlns:context="http://www.springframework.org/schema/context"
  5.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  6.     xsi:schemaLocation="http://www.springframework.org/schema/beans
  7.     http://www.springframework.org/schema/beans/spring-beans.xsd
  8.     http://www.springframework.org/schema/aop
  9.     http://www.springframework.org/schema/aop/spring-aop.xsd
  10.     http://www.springframework.org/schema/context
  11.     http://www.springframework.org/schema/context/spring-context.xsd">
  12. </beans>

（4）资源使用注解配置
  1. <!-- 配置数据源 -->
  2. <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  3.     <!--连接数据库的必备信息-->
  4.     <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
  5.     <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test">
  6. </property>
  7.     <property name="user" value="root"></property>
  8.     <property name="password" value="root"></property>
  9. </bean>
  10.  
  11. <!--配置queryRunner-->
  12.     <bean id="queryRunner" class="org.apache.commons.dbutils.QueryRunner">
  13. </bean>

（5）在配置文件中指定spring要扫描的包
  1. <!-- 告知 spring，在创建容器时要扫描的包 -->
  2. <context:component-scan base-package="com.offcn"></context:component-scan>

2、配置步骤

（1）通知类使用注解配置
  1. /**
  2. * 和事务管理相关的工具类，它包含了，开启事务，提交事务，回滚事务和释放连接
  3. */
  4. @Component("txManager")
  5. public class TransactionManager {
  6.     @Autowired
  7.     private ConnectionUtils connectionUtils;
  8. }
（2）通知类使用@Aspect注解声明为切面
  1. /**
  2. * 和事务管理相关的工具类，它包含了，开启事务，提交事务，回滚事务和释放连接
  3. */
  4. @Component("txManager")
  5. @Aspect //表明当前类是一个切面类
  6. public class TransactionManager {
  7.     @Autowired
  8.     private ConnectionUtils connectionUtils;
  9. }
（3）增强方法上使用注解配置通知
  • @Before

        作用：把当前方法看成是前置通知

        属性：value：用于指定切入点表达式，还可以指定切入点表达式的引用。

  1. //开启事务
  2. @Before("execution(* com.offcn.service.impl.*.*(..)))")
  3. public void beginTransaction(){
  4.     try {
  5.         System.out.println("before..........................");
  6.         connectionUtils.getThreadConnection().setAutoCommit(false);
  7.     }catch (Exception e){
  8.         e.printStackTrace();
  9.     }
  10. }

  • @AfterReturning

        作用：把当前方法看成是后置通知。

        属性：value：用于指定切入点表达式，还可以指定切入点表达式的引用

  1. // 提交事务
  2. @AfterReturning("execution(* com.offcn.service.impl.*.*(..)))")
  3. public void commit(){
  4.     try {
  5.         connectionUtils.getThreadConnection().commit();
  6.     }catch (Exception e){
  7.         e.printStackTrace();
  8.     }
  9. }

  • @AfterThrowing

        作用：把当前方法看成是异常通知。

        属性：value：用于指定切入点表达式，还可以指定切入点表达式的引用

  1. //回滚事务
  2. @AfterThrowing("execution(* com.offcn.service.impl.*.*(..)))")
  3. public void rollback(){
  4.     try {
  5.         connectionUtils.getThreadConnection().rollback();
  6.     }catch (Exception e){
  7.         e.printStackTrace();
  8.     }
  9. }

  • @After

        作用：把当前方法看成是最终通知。

        属性：value：用于指定切入点表达式，还可以指定切入点表达式的引用 。

  1. //释放连接
  2. @After("execution(* com.offcn.service.impl.*.*(..)))")
  3. public void release(){
  4.     try {
  5.         connectionUtils.removeConnection();
  6.         connectionUtils.getThreadConnection().close();//还回连接池中
  7.     }catch (Exception e){
  8.         e.printStackTrace();
  9.     }
  10. }

（4）开启Spring对注解AOP的支持
  1. <!-- 开启 spring 对注解 AOP 的支持 -->
  2. <aop:aspectj-autoproxy/>
（5）环绕通知注解配置

@Around

作用：把当前方法看成是环绕通知。

属性：value：用于指定切入点表达式，还可以指定切入点表达式的引用。

  1. // 环绕通知:
  2. @Around("execution(*com.offcn.service.impl.*.*(..))")
  3. public Object transactionAround(ProceedingJoinPoint pjp) {
  4.  
  5.     //定义返回值
  6.     Object returnValue = null;
  7.     try {
  8.         //获取方法执行所需的参数
  9.         Object[] args = pjp.getArgs();
  10.         //前置通知：开启事务
  11.         beginTransaction();
  12.         //执行方法
  13.         returnValue = pjp.proceed(args);
  14.         //后置通知：提交事务
  15.         commit();
  16.     }catch(Throwable e) {
  17.         //异常通知：回滚事务
  18.         rollback();
  19.         e.printStackTrace();
  20.     }finally {
  21.         //最终通知：释放资源
  22.         release();
  23.     }
  24.     return returnValue;
  25. }
（6）切入点表达式注解
  1. @Pointcut("execution(* com.offcn.service.impl.*.*(..))")
  2. private void point1() {}
  3.  
  4. // 环绕通知:
  5. @Around("point1()")///注意：千万别忘了写括号
  6. public Object transactionAround(ProceedingJoinPoint pjp) {
  7.     //定义返回值
  8.     Object returnValue = null;
  9.     try {
  10.         //获取方法执行所需的参数
  11.         Object[] args = pjp.getArgs();
  12.         //前置通知：开启事务
  13.         beginTransaction();
  14.         //执行方法
  15.         returnValue = pjp.proceed(args);
  16.         //后置通知：提交事务
  17.         commit();
  18.     }catch(Throwable e) {
  19.         //异常通知：回滚事务
  20.         rollback();
  21.         e.printStackTrace();
  22.     }finally {
  23.         //最终通知：释放资源
  24.         release();
  25.     }
  26.     return returnValue;
  27. }

十四、Spring事务详解

（一）Spring基于XML的事务配置

1、环境搭建

（1）构建工程，添加依赖
  1. <properties>
  2.     <spring.version>5.2.5.RELEASE</spring.version>
  3. </properties>
  4.  
  5. <dependencies>
  6.     <!--导入junit单元测试-->
  7.     <dependency>
  8.         <groupId>junit</groupId>
  9.         <artifactId>junit</artifactId>
  10.         <version>4.12</version>
  11.         <scope>test</scope>
  12.     </dependency>
  13.  
  14.     <!--导入spring的context坐标-->
  15.     <dependency>
  16.         <groupId>org.springframework</groupId>
  17.         <artifactId>spring-context</artifactId>
  18.         <version>${spring.version}</version>
  19.     </dependency>
  20.  
  21.     <dependency>
  22.         <groupId>org.springframework</groupId>
  23.         <artifactId>spring-test</artifactId>
  24.         <version>${spring.version}</version>
  25.     </dependency>
  26.  
  27.     <!--导入Jdbc模块依赖-->
  28.     <dependency>
  29.         <groupId>org.springframework</groupId>
  30.         <artifactId>spring-jdbc</artifactId>
  31.         <version>${spring.version}</version>
  32.     </dependency>
  33.  
  34.     <!--导入Mysql 驱动-->
  35.     <dependency>
  36.         <groupId>mysql</groupId>
  37.         <artifactId>mysql-connector-java</artifactId>
  38.         <version>5.1.47</version>
  39.     </dependency>
  40.  
  41.     <!--导入C3P0连接池-->
  42.     <dependency>
  43.         <groupId>com.mchange</groupId>
  44.         <artifactId>c3p0</artifactId>
  45.         <version>0.9.5.2</version>
  46.     </dependency>
  47.  
  48.     <!--aop-->
  49.     <dependency>
  50.         <groupId>org.aspectj</groupId>
  51.         <artifactId>aspectjweaver</artifactId>
  52.         <version>1.8.7</version>
  53.     </dependency>
  54. </dependencies>

（2）创建Spring的配置文件，导入约束
  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xmlns:context="http://www.springframework.org/schema/context"
  4.     xmlns:aop="http://www.springframework.org/schema/aop"
  5.     xmlns:tx="http://www.springframework.org/schema/tx"
  6.     xsi:schemaLocation="
  7.     http://www.springframework.org/schema/context
  8.     http://www.springframework.org/schema/context/spring-context.xsd
  9.     http://www.springframework.org/schema/aop
  10.     http://www.springframework.org/schema/aop/spring-aop.xsd
  11.     http://www.springframework.org/schema/tx
  12.     http://www.springframework.org/schema/tx/spring-tx.xsd
  13.     http://www.springframework.org/schema/beans
  14.     http://www.springframework.org/schema/beans/spring-beans.xsd">
  15.  
  16.     <!-- 告知 spring，在创建容器时要扫描的包 -->
  17.     <context:component-scan base-package="com.offcn"></context:component-scan>
  18.  
  19.     <!-- 配置数据源 -->
  20.     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  21.  
  22.     <!--连接数据库的必备信息-->
  23.     <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
  24.     <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test">
  25. </property>
  26.     <property name="user" value="root"></property>
  27.     <property name="password" value="root"></property>
  28. </bean>
  29.  
  30.     <!--JdbcTemplate-->
  31.     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
  32.         <property name="dataSource" ref="dataSource"></property>
  33.     </bean>
  34. </beans>

（3）沿用转账业务

copy Account AccountDao AccountDaoImpl AccontService AccountServiceImpl 代码：

注意： AccountDaoImpl 具体使用使用Spring提供的JdbcTemplate模板对象实现 
  1. @Repository("accountDao")
  2. public class AccountDaoImpl implements AccountDao {
  3.  
  4.     @Autowired
  5.     private JdbcTemplate jdbcTemplate;
  6.  
  7.     @Override
  8.     public Account findByName(String name) {
  9.         String sql ="select * from account where name =? ";
  10.         Account account = this.jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<>(Account.class), name);
  11.     return account;
  12.     }
  13.  
  14.     @Override
  15.     public void update(Account account) {
  16.         String sql ="update account set money =? where name =? ";
  17.         this.jdbcTemplate.update(sql, account.getMoney(), account.getName());
  18.     }
  19. }

2、事务管理配置步骤

（1）配置事务管理器
  1. <!--平台事务管理器-->
  2. <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  3.     <property name="dataSource" ref="dataSource"></property>
  4. </bean>
（2）配置事务的通知引用事务管理器
  1. <!--事务的配置-->
  2. <tx:advice id="txAdvice" transaction-manager="transactionManager">
  3. </tx:advice>

（3）配置事务的属性
  1. <!--
  2.     指定方法名称：是业务核心方法
  3.         read-only：是否是只读事务。默认 false，不只读。
  4.         isolation：指定事务的隔离级别。默认值是使用数据库的默认隔离级别。
  5.         propagation：指定事务的传播行为。
  6.         timeout：指定超时时间。默认值为：-1。永不超时。
  7.         rollback-for：用于指定一个异常，当执行产生该异常时，事务回滚。产生其他异常，事务不回滚。
  8.         没有默认值，任何异常都回滚。
  9.         no-rollback-for：用于指定一个异常，当产生该异常时，事务不回滚，产生其他异常时，事务回滚。没有默认值，任何异常都回滚。
  10. -->
  11. <tx:attributes>
  12.     <tx:method name="*"/>
  13. </tx:attributes>

（4）配置AOP切入点表达式
  1. <!--事务的aop增强-->
  2. <aop:config>
  3.     <aop:pointcut id="myPointcut" expression="execution(*com.offcn.service.impl.*.*(..))"/>
  4. </aop:config>

（5）配置切入点表达式和事务通知的对应关系
  1. <!--在aop：config标签内部：建立事务的通知和切入点表达式的关系-->
  2. <aop:advisor advice-ref="txAdvice" pointcut-ref="myPointcut"></aop:advisor>

（二）Spring基于注解的事务配置

1、环境搭建

（1）构建maven工程，添加相关依赖
  1. <properties>
  2.     <spring.version>5.2.5.RELEASE</spring.version>
  3. </properties>
  4.  
  5. <dependencies>
  6.     <!--导入junit单元测试-->
  7.     <dependency>
  8.         <groupId>junit</groupId>
  9.         <artifactId>junit</artifactId>
  10.         <version>4.12</version>
  11.         <scope>test</scope>
  12.     </dependency>
  13.  
  14.     <!--导入spring的context坐标-->
  15.     <dependency>
  16.         <groupId>org.springframework</groupId>
  17.         <artifactId>spring-context</artifactId>
  18.         <version>${spring.version}</version>
  19.     </dependency>
  20.  
  21.     <dependency>
  22.         <groupId>org.springframework</groupId>
  23.         <artifactId>spring-test</artifactId>
  24.         <version>${spring.version}</version>
  25.     </dependency>
  26.  
  27.     <!--导入Jdbc模块依赖-->
  28.     <dependency>
  29.         <groupId>org.springframework</groupId>
  30.         <artifactId>spring-jdbc</artifactId>
  31.         <version>${spring.version}</version>
  32.     </dependency>
  33.  
  34.     <!--导入Mysql 驱动-->
  35.     <dependency>
  36.         <groupId>mysql</groupId>
  37.         <artifactId>mysql-connector-java</artifactId>
  38.         <version>5.1.47</version>
  39.     </dependency>
  40.  
  41.     <!--导入C3P0连接池-->
  42.     <dependency>
  43.         <groupId>com.mchange</groupId>
  44.         <artifactId>c3p0</artifactId>
  45.         <version>0.9.5.2</version>
  46.     </dependency>
  47.  
  48.     <!--aop-->
  49.     <dependency>
  50.         <groupId>org.aspectj</groupId>
  51.         <artifactId>aspectjweaver</artifactId>
  52.         <version>1.8.7</version>
  53.     </dependency>
  54. </dependencies>

（2）创建Spring配置文件
  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xmlns:context="http://www.springframework.org/schema/context"
  4.     xmlns:aop="http://www.springframework.org/schema/aop"
  5.     xmlns:tx="http://www.springframework.org/schema/tx"
  6.     xsi:schemaLocation="
  7.      http://www.springframework.org/schema/context
  8.      http://www.springframework.org/schema/context/spring-context.xsd
  9.      http://www.springframework.org/schema/aop
  10.      http://www.springframework.org/schema/aop/spring-aop.xsd
  11.      http://www.springframework.org/schema/tx
  12.      http://www.springframework.org/schema/tx/spring-tx.xsd
  13.      http://www.springframework.org/schema/beans
  14.      http://www.springframework.org/schema/beans/spring-beans.xsd">
  15.  
  16.     <!-- 告知 spring，在创建容器时要扫描的包 -->
  17.     <context:component-scan base-package="com.offcn"></context:component-scan>
  18.  
  19.     <!-- 配置数据源 -->
  20.     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  21.         <!--连接数据库的必备信息-->
  22.         <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
  23.         <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test">
  24. </property>
  25.         <property name="user" value="root"></property>
  26.         <property name="password" value="root"></property>
  27.     </bean>
  28.     <!--JdbcTemplate-->
  29.     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
  30.         <property name="dataSource" ref="dataSource"></property>
  31.     </bean>
  32. </beans>

（3）沿用转账业务的代码：dao实现类和service实现类采用注解的形式，添加到容
器中管理

copy Account AccountDao AccountImpl AccountService AccountServiceImpl 到工程当中复用

2、事务管理配置步骤

（1）配置事务管理器并注入数据源
  1. <!-- 配置事务管理器 -->
  2. <bean id="transactionManager"class="org.springframework.jdbc.datasource.DataSourceTran
  3. sactionManager">
  4.     <property name="dataSource" ref="dataSource"></property>
  5. </bean>

（2）在业务层使用@Transactional注解
  1. /**
  2. 该注解的属性和 xml 中的属性含义一致。该注解可以出现在接口上，类上和方法上。
  3. 出现接口上，表示该接口的所有实现类都有事务支持。
  4. 出现在类上，表示类中所有方法有事务支持
  5. 出现在方法上，表示方法有事务支持。
  6. 以上三个位置的优先级：方法>类>接口
  7. */
  8.  
  9. @Service("accountService")
  10. @Transactional(readOnly = true,propagation = Propagation.SUPPORTS)
  11. public class AccountServiceImpl implements AccountService {
  12.     //依赖dao层
  13.     @Autowired
  14.     private AccountDao accountDao ;
  15.  
  16.     @Transactional(readOnly = false,propagation = Propagation.REQUIRED)
  17.     @Override
  18.     public void transfer(String sourceAccountName, String targetAccountName,Double money) {
  19.         Account sAccount = accountDao.findByName(sourceAccountName);
  20.         Account tAccount = accountDao.findByName(targetAccountName);
  21.         //来源账户减钱，目标账户加钱
  22.         sAccount.setMoney(sAccount.getMoney()-money);
  23.         tAccount.setMoney(tAccount.getMoney()+money);
  24.         //持久化到数据库
  25.         accountDao.update(sAccount);
  26.         //模拟异常发生
  27.         //int i=1/0;
  28.         accountDao.update(tAccount);
  29.     }
  30. }

（3）配置文件中开启Spring对注解事务的支持
  1. <!-- 开启 spring 对注解事务的支持 -->
  2. <tx:annotation-driven transaction-manager="transactionManager"/>

十五、Spring整合Mybatis实现用户的CRUD

（一）整理思路分析

Mybatis框架是一个持久层ORM框架，而Spring则是一个综合性一站式框架。所以整合是Mybatis往Spring上整合。就是让Spring框架接管Mybatis的组件。

Mybatis 单独运行时，数据源的管理，事务的管理， SqlSessionFactory 以及接口的实现类都是 Mybatis管理的，整合后以上组件交给Spring 管理。

（二）构建maven工程，添加依赖

  1. <properties>
  2.     <spring.version>5.2.5.RELEASE</spring.version>
  3. </properties>
  4.  
  5. <dependencies>
  6.  
  7.     <!--导入junit单元测试-->
  8.     <dependency>
  9.         <groupId>junit</groupId>
  10.         <artifactId>junit</artifactId>
  11.         <version>4.12</version>
  12.         <scope>test</scope>
  13.     </dependency>
  14.  
  15.     <!--导入spring的context坐标-->
  16.     <dependency>
  17.         <groupId>org.springframework</groupId>
  18.         <artifactId>spring-context</artifactId>
  19.         <version>${spring.version}</version>
  20.     </dependency>
  21.  
  22.     <dependency>
  23.         <groupId>org.springframework</groupId>
  24.         <artifactId>spring-test</artifactId>
  25.         <version>${spring.version}</version>
  26.     </dependency>
  27.  
  28.     <!--导入Jdbc模块依赖-->
  29.     <dependency>
  30.         <groupId>org.springframework</groupId>
  31.         <artifactId>spring-jdbc</artifactId>
  32.         <version>${spring.version}</version>
  33.     </dependency>
  34.  
  35.     <!--导入Mysql 驱动-->
  36.     <dependency>
  37.         <groupId>mysql</groupId>
  38.         <artifactId>mysql-connector-java</artifactId>
  39.         <version>5.1.47</version>
  40.     </dependency>
  41.  
  42.     <!--导入C3P0连接池-->
  43.     <dependency>
  44.         <groupId>com.mchange</groupId>
  45.         <artifactId>c3p0</artifactId>
  46.         <version>0.9.5.2</version>
  47.     </dependency>
  48.  
  49.     <!--aop-->
  50.     <dependency>
  51.         <groupId>org.aspectj</groupId>
  52.         <artifactId>aspectjweaver</artifactId>
  53.         <version>1.8.7</version>
  54.     </dependency>
  55.  
  56.     <!--mybatis-Spring适配包 -->
  57.     <dependency>
  58.         <groupId>org.mybatis</groupId>
  59.         <artifactId>mybatis-spring</artifactId>
  60.         <version>2.0.0</version>
  61.     </dependency>
  62.  
  63.     <!-- mybatis orm框架 -->
  64.     <dependency>
  65.         <groupId>org.mybatis</groupId>
  66.         <artifactId>mybatis</artifactId>
  67.         <version>3.4.6</version>
  68.         </dependency>
  69.     </dependencies>

（三）构建数据库表并创建实体类

  1. create table User(
  2. id int primary key auto_increment,
  3. name varchar(32) not null,
  4. address varchar(32) not null,
  5. birthday date
  6. );
  1. public class User implements Serializable {
  2.     private Integer id;
  3.     private String name;
  4.     private String address;
  5.     private Date birthday;
  6.  
  7.     public Integer getId() {
  8.         return id;
  9.     }
  10.  
  11.     public void setId(Integer id) {
  12.         this.id = id;
  13.     }
  14.  
  15.     public String getName() {
  16.         return name;
  17.     }
  18.  
  19.     public void setName(String name) {
  20.         this.name = name;
  21.     }
  22.  
  23.     public String getAddress() {
  24.         return address;
  25.     }
  26.  
  27.     public void setAddress(String address) {
  28.         this.address = address;
  29.     }
  30.  
  31.     public Date getBirthday() {
  32.         return birthday;
  33.     }
  34.  
  35.     public void setBirthday(Date birthday) {
  36.         this.birthday = birthday;
  37.     }
  38.  
  39.     @Override
  40.     public String toString() {
  41.         return "User{" +
  42.         "id=" + id +
  43.         ", name='" + name + '\'' +
  44.         ", address='" + address + '\'' +
  45.         ", birthday=" + birthday +
  46.         '}';
  47.     }
  48. }

（四）编写dao层的接口UserMapper

  1. public interface UserMapper {
  2.     int insert(User user);
  3.     int update(User user);
  4.     int delete(Integer id);
  5.     User findById(Integer id);
  6.     List<User> findAll();
  7. }

（五）构建mapper接口对应的sql配置文件

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3.     PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4.     "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <mapper namespace="com.offcn.mapper.UserMapper">
  6.     <resultMap id="BaseResultMap" type="com.offcn.pojo.User">
  7.         <id column="id" jdbcType="INTEGER" property="id" />
  8.         <result column="name" jdbcType="VARCHAR" property="name" />
  9.         <result column="address" jdbcType="VARCHAR" property="address" />
  10.         <result column="birthday" jdbcType="DATE" property="birthday" />
  11.     </resultMap>
  12.  
  13.     <insert id="insert" parameterType="com.offcn.pojo.User">
  14.         insert into user (name, birthday, address)
  15.         values (#{name}, #{birthday},#{address})
  16.     </insert>
  17.  
  18.     <update id="update">
  19.         update user
  20.         set
  21.         name= #{name},
  22.         birthday=#{birthday},
  23.         address = #{address}
  24.         where id=#{id}
  25.     </update>
  26.  
  27.     <delete id="delete">
  28.         delete from user
  29.         where id =#{id}
  30.     </delete>
  31.  
  32.     <select id="findById" resultMap="BaseResultMap">
  33.         select * from user where id=#{id}
  34.     </select>
  35.  
  36.     <select id="findAll" resultMap="BaseResultMap">
  37.         select * from user
  38.     </select>
  39. </mapper>

（六）构建服务层接口UserService

  1. public interface UserService {
  2.     int insert(User user);
  3.     int update(User user);
  4.     int delete(Integer id);
  5.     User findById(Integer id);
  6.     List<User> findAll();
  7. }

（七）构建服务层实现类UserServiceImpl

  1. @Service
  2. public class UserServiceImpl implements UserService {
  3.  
  4.     @Autowired
  5.     private UserMapper userMapper;
  6.  
  7.     @Override
  8.     public int insert(User user) {
  9.         int num = userMapper.insert(user);
  10.         return num;
  11.     }
  12.  
  13.     @Override
  14.     public int update(User user) {
  15.         int num = userMapper.update(user);
  16.         return num;
  17.     }
  18.  
  19.     @Override
  20.     public int delete(Integer id) {
  21.         int num = userMapper.delete(id);
  22.         return num;
  23.     }
  24.  
  25.     @Override
  26.     public User findById(Integer id) {
  27.         User user = userMapper.findById(id);
  28.         return user;
  29.     }
  30.  
  31.     @Override
  32.     public List<User> findAll() {
  33.         List<User> userList = userMapper.findAll();
  34.         return userList;
  35.     }
  36. }

（八）构建配置文件

  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xmlns:aop="http://www.springframework.org/schema/aop"
  4.     xmlns:tx="http://www.springframework.org/schema/tx"
  5.     xmlns:context="http://www.springframework.org/schema/context"
  6.     xsi:schemaLocation="http://www.springframework.org/schema/beans
  7.     https://www.springframework.org/schema/beans/spring-beans.xsd
  8.     http://www.springframework.org/schema/tx
  9.     http://www.springframework.org/schema/tx/spring-tx.xsd
  10.     http://www.springframework.org/schema/aop
  11.     http://www.springframework.org/schema/aop/spring-aop.xsd
  12.     http://www.springframework.org/schema/context
  13.     http://www.springframework.org/schema/context/spring-context.xsd">
  14.  
  15.     <!--开启包扫描-->
  16.     <context:component-scan base-package="com.offcn"> </context:component-scan>
  17.  
  18.     <!-- 配置数据源 -->
  19.     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  20.  
  21.         <!--连接数据库的必备信息-->
  22.         <property name="driverClass" value="com.mysql.jdbc.Driver"></property>
  23.         <property name="jdbcUrl" value="jdbc:mysql://localhost:3306/test">
  24. </property>
  25.         <property name="user" value="root"></property>
  26.         <property name="password" value="root"></property>
  27.     </bean>
  28.  
  29.     <!--Mybatis 核心对象： 工厂对象-->
  30.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  31.  
  32.         <!--工厂创建必须注入一个数据源-->
  33.         <property name="dataSource" ref="dataSource"/>
  34.  
  35.         <!--指定mapper文件位置-->
  36.         <property name="mapperLocations" value="classpath:com/offcn/mapper/*Mapper.xml"></property>
  37.  
  38.         <!--引入Mybatis的核心配置文件：如果Mybaits的核心配置要保留，需要再此处配置：-->
  39.         <property name="configLocation" value="classpath:SqlMapConfig.xml"/>
  40.  
  41.         <!--别名配置-->
  42.         <property name="typeAliasesPackage" value="com/offcn/pojo"/>
  43.         <!--进行分页插件的配置-->
  44.         <property name="plugins">
  45.             <array>
  46.                 <bean class="com.github.pagehelper.PageInterceptor">
  47.                     <property name="properties">
  48.                         <value>
  49.                             helperDialect=MySQL
  50.                             reasonable=true
  51.                             supportMethodsArguments=true
  52.                             params=count=countSql
  53.                             autoRuntimeDialect=true
  54.                         </value>
  55.                     </property>
  56.                 </bean>
  57.             </array>
  58.         </property>
  59.     </bean>
  60.  
  61.     <!--配置接口的扫描-->
  62.     <bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
  63.         <!--指定了包： 能够将包下的接口生成实现类： -->
  64.         <property name="basePackage" value="com.offcn.mapper"></property>
  65.     </bean>
  66.  
  67.     <!--配置平台管理器-->
  68.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  69.  
  70.         <!--注入数据源-->
  71.         <property name="dataSource" ref="dataSource"/>
  72.     </bean>
  73.     <tx:annotation-driven transaction-manager="transactionManager"/>
  74. </beans>

（九）测试代码

  1. @RunWith(SpringJUnit4ClassRunner.class)
  2. @ContextConfiguration(locations = "classpath:applicationContext.xml")
  3. public class TestAccountTransfer {
  4.  
  5.     @Autowired
  6.     private UserService userService;
  7.  
  8.     //save
  9.     @Test
  10.     public void testInsert(){
  11.         User user = new User();
  12.         user.setName("admin");
  13.         user.setAddress("china");
  14.         user.setBirthday(new Date());
  15.         int num = userService.insert(user);
  16.         System.out.println("num:"+num);
  17.     }
  18.  
  19.     //update
  20.     @Test
  21.     public void testUpdate(){
  22.         User user = new User();
  23.         user.setName("marry");
  24.         user.setAddress("America");
  25.         user.setBirthday(new Date());
  26.         user.setId(1);
  27.         int num = userService.update(user);
  28.         System.out.println("num:"+num);
  29.     }
  30.  
  31.     //delete:
  32.     @Test
  33.     public void testDelete(){
  34.         int num = userService.delete(1);
  35.         System.out.println("num:"+num);
  36.     }
  37.  
  38.     //findById
  39.     @Test
  40.     public void testFindById(){
  41.         User user = userService.findById(2);
  42.         System.out.println("user:"+user);
  43.     }
  44.  
  45.     //findAll
  46.     @Test
  47.     public void testFindByAll(){
  48.         List<User> userList = userService.findAll();
  49.         System.out.println("userList:"+userList);
  50.     }
  51. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/小丑西瓜9/article/detail/86265
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号