Spring5 (G笔记)

目录

大纲

1、Spring 框架概述
2、IOC 容器
(1)IOC 底层原理
(2)IOC 接口(BeanFactory) 
(3)IOC 操作 Bean 管理(基于 xml) 
(4)IOC 操作 Bean 管理(基于注解)
3、Aop
4、JdbcTemplate
5、事务管理
6、Spring5 新特性

Spring 5 框架概述

1 、Spring是轻量级的开源的JavaEE框架

2 、Spring可以解决企业应用开发的复杂性

3 、Spring有两个核心部分:IOC和Aop
( 1 )IOC:控制反转,把创建对象过程交给Spring进行管理
( 2 )Aop:面向切面,不修改源代码进行功能增强

4 、Spring特点
( 1 )方便解耦,简化开发
( 2 )Aop编程支持
( 3 )方便程序测试
( 4 )方便和其他框架进行整合
( 5 )方便进行事务操作
( 6 )降低API开发难度

5 、现在课程中,选取Spring版本 5.x

Spring5 入门案例

1 、下载 Spring
( 1 )使用Spring最新稳定版本 5.2.

( 2 )下载地址
https://repo.spring.io/release/org/springframework/spring/

2 、打开 idea 工具,创建普通 Java 工程

3 、导入 Spring5 相关 jar

4 、创建普通类,在这个类创建普通方法

public class User {
      public void add() {
      System.out.println("add......");
      }
}

5 、创建Spring配置文件,在配置文件配置创建的对象
( 1 )Spring配置文件使用xml格式 (选择Spring config)

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
[http://www.springframework.org/schema/beans/spring-beans.xsd">](http://www.springframework.org/schema/beans/spring-beans.xsd">)
    <!--配置User对象创建-->
    <bean id="user" class="com.yu.spring5.User"></bean>
</beans>

6 、进行测试代码编写

    @Test
    public void testAdd(){
        //1 加载spring配置文件
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        //2 获取配置创建的对象
        User user = context.getBean("user", User.class);

        System.out.println(user);
        user.add();
    }

IOC (概念和原理)

1 、什么是IOC
( 1 )控制反转,把对象创建和对象之间的调用过程,交给Spring进行管理
( 2 )使用IOC目的:为了耦合度降低
( 3 )做入门案例就是IOC实现

2 、IOC底层原理
( 1 )xml解析、工厂模式、反射

3 、画图讲解IOC底层原理

IOC ( BeanFactory 接口)

1 、IOC思想基于IOC容器完成,IOC容器底层就是对象工厂

2 、Spring提供IOC容器实现两种方式:(两个接口)
( 1 )BeanFactory:IOC容器基本实现,是Spring内部的使用接口,不提供开发人员进行使用

  • 加载配置文件时候不会创建对象,在获取对象(使用)才去创建对象

( 2 )ApplicationContext:BeanFactory接口的子接口,提供更多更强大的功能,一般由开发人
员进行使用

  • 加载配置文件时候就会把在配置文件对象进行创建

3 、ApplicationContext接口有实现类

IOC 操作 Bean 管理(概念)

1 、什么是 Bean 管理
( 0 )Bean管理指的是两个操作
( 1 )Spring创建对象
( 2 )Spirng注入属性

2 、Bean管理操作有两种方式
( 1 )基于xml配置文件方式实现
( 2 )基于注解方式实现

IOC 操作 Bean 管理(基于 xml 方式)

1 、基于 xml 方式创建对象

    <!--配置User对象创建-->
    <bean id="user" class="com.yu.spring5.User"></bean>

( 1 )在spring配置文件中,使用bean标签,标签里面添加对应属性,就可以实现对象创建
( 2 )在bean标签有很多属性,介绍常用的属性

  • id属性:唯一标识
  • class属性:类全路径(包类路径)
  • name属性(不常用):和id类似,可以有特殊符号
    ( 3 )创建对象时候,默认也是执行无参数构造方法完成对象创建

2 、基于 xml 方式注入属性

DI :依赖注入,就是注入属性

2.1 、第一种注入方式:使用 set 方法进行注入

( 1 )创建类,定义属性和对应的set方法

/**
* 演示使用set方法进行注入属性
*/
public class Book {
//创建属性
private String bname;
private String bauthor;
//创建属性对应的set方法
public void setBname(String bname) {
this.bname = bname;
}
public void setBauthor(String bauthor) {
this.bauthor = bauthor;
}
}

( 2 )在spring配置文件配置对象创建,配置属性注入

<!-- 2 set方法注入属性-->
<bean id="book" class="com.yu.spring5.Book">
<!--使用property完成属性注入
name:类里面属性名称
value:向属性注入的值
-->
<property name="bname" value="易筋经"></property>
<property name="bauthor" value="达摩老祖"></property>
</bean>
2.2 、第二种注入方式:使用有参数构造进行注入

( 1 )创建类,定义属性,创建属性对应有参数构造方法

/**
* 使用有参数构造注入
*/

public class Orders {
//属性
private String oname;
private String address;
//有参数构造
public Orders(String oname,String address) {
this.oname = oname;
this.address = address;
}
}

( 2 )在spring配置文件中进行配置

<!-- 3 有参数构造注入属性-->
<bean id="orders" class="com.yu.spring5.Orders">
<constructor-arg name="oname" value="电脑"></constructor-arg>
<constructor-arg name="address" value="China"></constructor-arg>
</bean>

除了使用name外,还可以使用索引index,如

<constructor-arg index="0" value="电脑"></constructor-arg>

0表示有参构造的第0个参数

3p 名称空间注入(了解)

只能用于set方法注入
( 1 )使用p名称空间注入,可以简化基于xml配置方式
第一步 添加p名称空间在配置文件中

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

第二步 进行属性注入,在bean标签里面进行操作

<!--2 set方法注入属性-->
<bean id="book" class="com.yu.spring5.Book" p:bname="九阳神功"p:bauthor="无名氏"></bean>

IOC 操作 Bean 管理( xml 注入其他类型属性)

1 、字面量(null和特殊符号)

( 1 )null值

        <!--null值-->
        <property name="address">
            <null/>
        </property>

( 2 )属性值包含特殊符号

        <!--属性值包含特殊符号
            方法1 把<>进行转义 &lt; &gt;
            方法2 把带特殊符号内容写到CDATA
        -->
        <property name="address" >
            <value><![CDATA[<<上海>>]]></value>
        </property>

2 、注入属性 - 外部 bean

( 1 )创建两个类 service类和dao类
( 2 )在service调用dao里面的方法
( 3 )在spring配置文件中进行配置

public class UserService {
    //创建UserDao类型属性,生成set方法
    private UserDao userDao;

    public void setUserDao(UserDao userDao) {
        this.userDao = userDao;
    }

    public void add(){

        System.out.println("UserService add ~~~~~~~");
//        //原始方式创建UserDao对象
//        UserDao userDao = new UserDaoImpl();
        userDao.update();
    }
}

UserDao略

    <!--1 service和dao对象创建-->
    <bean id="userService" class="com.yu.spring5.service.UserService">
        <!--注入userDao对象
            name属性:类里面属性名称
            ref属性:创建userDao对象bean标签id值
        -->
        <property name="userDao" ref="userDaoImpl"></property>
    </bean>

    <bean id="userDaoImpl" class="com.yu.spring5.dao.UserDaoImpl"></bean>

3 、注入属性 - 内部 bean

( 1 )一对多关系:部门和员工
一个部门有多个员工,一个员工属于一个部门
部门是一,员工是多
( 2 )在实体类之间表示一对多关系,员工表示所属部门,使用对象类型属性进行表示

//部门类
public class Dept {
    private String dname;
    public void setDname(String dname) {
      this.dname = dname;
    }
}
//员工类
public class Emp {
      private String ename;
      private String gender;
      //员工属于某一个部门,使用对象形式表示
      private Dept dept;
      public void setDept(Dept dept) {
           this.dept = dept;
      }
      public void setEname(String ename) {
          this.ename = ename;
      }
      public void setGender(String gender) {
          this.gender = gender;
      }
}

( 3 )在spring配置文件中进行配置

    <!--内部bean-->
    <bean id="emp" class="com.yu.spring5.bean.Emp">
        <!--设置两个普通属性-->
        <property name="ename" value="lucy"></property>
        <property name="gender" value="女"></property>
        <!--设置对象类型属性-->
        <property name="dept">
            <bean id="dept" class="com.yu.spring5.bean.Dept">
                <property name="dname" value="安保部"></property>
            </bean>
        </property>
    </bean>

4 、注入属性 - 级联赋值

( 1 )第一种写法
    <!--级联赋值-->
    <bean id="emp" class="com.yu.spring5.bean.Emp">
        <!--设置两个普通属性-->
        <property name="ename" value="lucy"></property>
        <property name="gender" value="女"></property>
        <!--级联赋值-->
        <property name="dept" ref="dept">
        </property>
    </bean>

    <bean id="dept" class="com.yu.spring5.bean.Dept">
        <property name="dname" value="财务部"></property>
    </bean>
( 2 )第二种写法

注意: 这种方法需要Emp中有dept的get方法

    <!--级联赋值-->
    <bean id="emp" class="com.yu.spring5.bean.Emp">
        <!--设置两个普通属性-->
        <property name="ename" value="lucy"></property>
        <property name="gender" value="女"></property>
        <!--级联赋值-->
        <property name="dept" ref="dept"></property>
        <property name="dept.dname" value="技术部"></property>

    </bean>

    <bean id="dept" class="com.yu.spring5.bean.Dept">
    </bean>

IOC 操作 Bean 管理( xml 注入集合属性)

1 、注入数组类型属性 2 、注入 List 集合类型属性 3 、注入 Map 集合类型属性

( 1 )创建类,定义数组、list、map、set类型属性,生成对应set方法

public class Stu {
//1 数组类型属性
private String[] courses;
//2 list集合类型属性
private List<String> list;
//3 map集合类型属性
private Map<String,String> maps;
//4 set集合类型属性
private Set<String> sets;

public void setSets(Set<String> sets) {
this.sets = sets;
}
public void setCourses(String[] courses) {
this.courses = courses;
}
public void setList(List<String> list) {
this.list = list;
}
public void setMaps(Map<String, String> maps) {
this.maps = maps;
}
}

( 2 )在spring配置文件进行配置

    <!-- 集合类型属性注入-->
    <bean id="stu" class="com.yu.spring5.collectionType.Stu">
        <!--数组类型属性注入-->
        <property name="cources">
            <array>
                <value>java</value>
                <value>数据库</value>
            </array>
        </property>
        <!--List类型属性注入-->
        <property name="list">
            <list>
                <value>张三</value>
                <value>小三</value>
            </list>
        </property>
        <!--map类型属性注入-->
        <property name="maps">
            <map>
                <entry key="JAVA" value="java"></entry>
                <entry key="REDIS" value="redis"></entry>
            </map>
        </property>
        <!--set类型属性注入-->
        <property name="sets">
            <set>
                <value>李四</value>
                <value>小四</value>
            </set>
        </property>
    </bean>

4 、在集合里面设置对象类型值

public class Stu {
    //学生所学多门课程
    private List<Course> coursesList;

    public void setCoursesList(List<Course> coursesList) {
        this.coursesList = coursesList;
    }
}
//课程类
public class Course {
    private String cname;//课程名称

    public void setCname(String cname) {
        this.cname = cname;
    }
}
    <!-- 集合类型属性注入-->
    <bean id="stu" class="com.yu.spring5.collectionType.Stu">
        <!--注入list集合类型,值是对象-->
        <property name="coursesList">
            <list>
                <ref bean="course1"></ref>
                <ref bean="course2"></ref>
            </list>
        </property>
    </bean>


    <!--创建多个course对象-->
    <bean id="course1" class="com.yu.spring5.collectionType.Course">
        <property name="cname" value="Spring"></property>
    </bean>
    <bean id="course2" class="com.yu.spring5.collectionType.Course">
        <property name="cname" value="SpringBoot"></property>
    </bean>

5 、把集合注入部分提取出来

( 1 )在spring配置文件中引入名称空间 util

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:util="http://www.springframework.org/schema/util"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">

( 2 )使用util标签完成list集合注入提取

    <!-- 1 提取list集合类型属性注入-->
    <util:list id="bookList">
        <value>易筋经</value>
        <value>九阴真经</value>
        <value>九阳神功</value>
    </util:list>
    <!--2 提取list集合类型属性注入使用-->
    <bean id="book" class="com.yu.spring5.collectionType.Book">
        <property name="list" ref="bookList"></property>
    </bean>

IOC 操作 Bean 管理( FactoryBean )

1Spring 有两种类型 bean ,一种普通 bean ,另外一种工厂 beanFactoryBean

2 、普通 bean :在配置文件中定义 bean 类型就是返回类型

3 、工厂 bean :在配置文件定义 bean 类型可以和返回类型不一样
第一步 创建类,让这个类作为工厂bean,实现接口 FactoryBean
第二步 实现接口里面的方法,在实现的方法中定义返回的bean类型

public class MyBean implements FactoryBean<Course> {
//定义返回bean
@Override
public Course getObject() throws Exception {
    Course course = new Course();
    course.setCname("abc");
    return course;
}
@Override
public Class<?> getObjectType() {
    return null;
}
@Override
public boolean isSingleton() {
    return false;
}
}
<bean id="myBean" class="com.yu.spring5.factoryBean.MyBean">
</bean>
    @Test
    public void testCollectionTest3(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean3.xml");
        Course course = context.getBean("myBean", Course.class);

        System.out.println(course);
    }

IOC 操作 Bean 管理( bean 作用域)

1 、在 Spring 里面,设置创建 bean 实例是单实例还是多实例

单实例:确保一个类只有一个实例,自行提供这个实例并向整个系统提供这个实例。

2 、在 Spring 里面,默认情况下, bean 是单实例对象

3 、如何设置单实例还是多实例
( 1 )在spring配置文件bean标签里面有属性(scope)用于设置单实例还是多实例
( 2 )scope属性值
第一个值 默认值,singleton,表示是单实例对象
第二个值 prototype,表示是多实例对象

( 3 )singleton和prototype区别
第一 singleton单实例,prototype多实例
第二 设置scope值是singleton时候,加载spring配置文件时候就会创建单实例对象
设置scope值是prototype时候,不是在加载spring配置文件时候创建对象,而是在调用
getBean方法时候创建多实例对象
scope还有两个不常用的参数:request,session

IOC 操作 Bean 管理( bean 生命周期)

1 、生命周期
( 1 )从对象创建到对象销毁的过程

2bean 生命周期
( 1 )通过构造器创建bean实例(无参数构造)
( 2 )为bean的属性设置值和对其他bean引用(调用set方法)
( 3 )调用bean的初始化的方法(需要进行配置初始化的方法)
( 4 )bean可以使用了(对象获取到了)
( 5 )当容器关闭时候,调用bean的销毁的方法(需要进行配置销毁的方法)

3 、演示 bean 生命周期

public class Orders {
    private String oname;
    //无参数构造
    public Orders() {
        System.out.println("第一步,执行无参构造创建bean实例");
    }

    public void setOname(String oname) {
        this.oname = oname;
        System.out.println("第二步,调用set方法设置属性值");
    }
    //创建执行的初始化的方法
    public void initMethod(){
        System.out.println("第三步,执行初始化的方法");
    }
    //创建执行的销毁的方法
    public void destroyMethod(){
        System.out.println("第五步,执行销毁的方法");
    }
}
    <bean id="oders" class="com.yu.spring5.bean.Orders" init-method="initMethod" destroy-method="destroyMethod">
        <property name="oname" value="手机"></property>
    </bean>
    @Test
    public void testBean3(){
//        ApplicationContext context =
//                new ClassPathXmlApplicationContext("bean4.xml");
        ClassPathXmlApplicationContext context =
                new ClassPathXmlApplicationContext("bean4.xml");
        Orders oders = context.getBean("oders", Orders.class);
        System.out.println("第四步 获取创建bean实例对象");
        System.out.println(oders);
        //手动让bean实例销毁
        context.close();

    }

4 、 更完整:加上bean 的后置处理器, bean 生命周期有七步
( 1 )通过构造器创建bean实例(无参数构造)
( 2 )为bean的属性设置值和对其他bean引用(调用set方法)
( 3 )把bean实例传递bean后置处理器的方法postProcessBeforeInitialization

( 4 )调用bean的初始化的方法(需要进行配置初始化的方法)

5 )把 bean 实例传递 bean 后置处理器的方法 postProcessAfterInitialization
( 6 )bean可以使用了(对象获取到了)
( 7 )当容器关闭时候,调用bean的销毁的方法(需要进行配置销毁的方法)

5 、演示添加后置处理器效果
( 1 )创建类,实现接口BeanPostProcessor,创建后置处理器

public class MyBeanPost implements BeanPostProcessor{
    @Override
    public java.lang.Object postProcessBeforeInitialization(java.lang.Object bean, java.lang.String beanName) throws org.springframework.beans.BeansException {
        /* compiled code */
        System.out.println("在初始化之前执行的方法");
        return bean;
    }

    @Override
    public java.lang.Object postProcessAfterInitialization(java.lang.Object bean, java.lang.String beanName) throws org.springframework.beans.BeansException {
        /* compiled code */
        System.out.println("在初始化之后执行的方法");
        return bean;
    }
    <!--配置后置处理器-->
    <bean id="myBeanPost" class="com.yu.spring5.bean.MyBeanPost"></bean>

IOC 操作 Bean 管理( xml 自动装配)

1 、什么是自动装配
( 1 )根据指定装配规则(属性名称或者属性类型),Spring自动将匹配的属性值进行注入

2 、演示自动装配过程
( 1 )根据属性名称自动注入

    <!--实现自动装配
        bean标签属性autowire,配置自动装配
        autowire属性常用两个值:
            byName根据属性名注入  注入bean的id值和类属性名称
            byType根据属性类型注入
    -->
    <bean id="emp" class="com.yu.spring5.autowire.Emp" autowire="byName" >
        <!--<property name="dept" ref="dept"></property>-->
    </bean>

    <bean id="dept" class="com.yu.spring5.autowire.Dept" >
    </bean>

( 2 )根据属性类型自动注入

    <bean id="emp" class="com.yu.spring5.autowire.Emp" autowire="byType" >
        <!--<property name="dept" ref="dept"></property>-->
    </bean>

    <bean id="dept" class="com.yu.spring5.autowire.Dept" >
    </bean>

IOC 操作 Bean 管理 ( 外部属性文件 )

1 、直接配置数据库信息

( 1 )配置德鲁伊连接池
( 2 )引入德鲁伊连接池依赖jar包 druid-1.1.9.jar

    <!--直接配置连接池-->
    <!-- DruidDataSource dataSource = new DruidDataSource(); -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="com.mysql.jdbc.Driver"></property>
        <property name="url" value="jdbc:mysql://localhost:3306/userDb"></property>
        <property name="username" value="root"></property>
        <property name="password" value="root"></property>
    </bean>

2 、引入外部属性文件配置数据库连接池

( 1 )创建外部属性文件,properties格式文件,写数据库信息

prop.driverClass=com.mysql.jdbc.Driver
prop.url=jdbc:mysql://localhost:3306/userDb
prop.userName=root
prop.password=root

( 2 )把外部properties属性文件引入到spring配置文件中

  • 引入context名称空间
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:util="http://www.springframework.org/schema/util"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

⚫ 在spring配置文件使用标签引入外部属性文件

    <!--引入外部属性文件-->
    <context:property-placeholder location="classpath:jdbc.properties"/>

    <!--配置连接池-->
    <!-- DruidDataSource dataSource = new DruidDataSource(); -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
        <property name="driverClassName" value="${prop.driverClass}"></property>
        <property name="url" value="${prop.url}"></property>
        <property name="username" value="${prop.userName}"></property>
        <property name="password" value="${prop.password}"></property>
    </bean>

IOC 操作 Bean 管理 ( 基于注解方式 )

1 、什么是注解

( 1 )注解是代码特殊标记,格式:@注解名称(属性名称=属性值, 属性名称=属性值..)
( 2 )使用注解,注解作用在类上面,方法上面,属性上面
( 3 )使用注解目的:简化xml配置

2Spring 针对 Bean 管理中创建对象提供注解

( 1 )@Component 普通组件
( 2 )@Service 用于业务逻辑(Service)层
( 3 )@Controller 用于Web层
( 4 )@Repository 用于Dao层

  • 上面四个注解功能是一样的,都可以用来创建bean实例

3 、基于注解方式实现对象创建

第一步 引入依赖
spring-aop-5.2.6.RELEASE.jar
第二步 开启组件扫描
在bean1中添加

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <!--开启组件扫描
        1 如果扫描多个包,多个包使用逗号隔开
        2 扫描包上层目录也可以实现扫描多个包
    -->
    <context:component-scan base-package="com.yu"></context:component-scan>
</beans>

第三步 创建类,在类上面添加创建对象注解

//在注解里面value属性值可以省略不写
//若不写,默认是类名称,首字母小写
//UserService --》userService

@Component(value = "userService")//<bean id="userService" class=".."/>
public class UserService {
    public void add(){
        System.out.println("service add·····");
    }
}

4 、开启组件扫描细节配置

    <!--示例1
        use-default-filters="false" 表示现在不使用默认filter,自己配置filter
        context:include-filter, 设置扫描哪些内容(带Controller注解的)
    -->
    <context:component-scan base-package="com.yu" use-default-filters="false">
        <context:include-filter type="annotation"
                                expression="org.springframework.stereotype.Controller"/>
    </context:component-scan>
    
    <!--示例2
        context:exclude-filter: 设置哪些内容不进行扫描
    -->
    <context:component-scan base-package="com.yu">
        <context:exclude-filter type="annotation"
                                expression="org.springframework.stereotype.Controller"/>
    </context:component-scan>

5 、基于注解方式实现属性注入

前三个都是针对对象类型
( 1 )@Autowired:根据属性类型进行自动装配
第一步 把service和dao对象创建,在service和dao类添加创建对象注解
第二步 在service注入dao对象,在service类添加dao类型属性,在属性上面使用注解,不需要set方法
UserDao

@Repository
public class UserDaoImpl implements UserDao {

    @Override
    public void add() {
        System.out.println("dao add````");
    }
}

UserService

@Service
public class UserService {
    //定义dao类型属性
    //不需要set方法
    //添加注入属性注解
    @Autowired
    private UserDao userDao;

    public void add(){
        System.out.println("service add·····");
        userDao.add();
    }
}

( 2 )@Qualifier:根据名称进行注入
这个@Qualifier注解的使用,和上面@Autowired一起使用

@Repository(value = "userDaoImpl1")
public class UserDaoImpl implements UserDao {

    @Override
    public void add() {
        System.out.println("dao add````");
    }
}
@Service
public class UserService {
    //定义dao类型属性
    //不需要set方法
    //添加注入属性注解
    @Autowired
    @Qualifier(value = "userDaoImpl1")//根据名称进行注入
    private UserDao userDao;

    public void add(){
        System.out.println("service add·····");
        userDao.add();
    }
}

( 3 )@Resource:可以根据类型注入,可以根据名称注入

import javax.annotation.Resource;


//@Resource //根据类型进行注入
@Resource(name = "userDaoImpl1") //根据名称进行注入
private UserDao userDao;

( 4 )@Value:注入普通类型属性

@Value(value = "abc")
private String name;

6 、完全注解开发(用配置类替代xml配置文件,详细可见SpringBoot)

( 1 )创建配置类,替代xml配置文件
config.SpringConfig

@Configuration //作为配置类,替代xml配置文件
@ComponentScan(basePackages = {"com.yu"})
public class SpringConfig {

}

这样就可以替代bean1.xml
( 2 )编写测试类

    @Test
    public void testService(){
        ApplicationContext context =
                new AnnotationConfigApplicationContext(SpringConfig.class);
        UserService userService = context.getBean("userService", UserService.class);
        System.out.println(userService);
        userService.add();
    }

AOP (概念)

1 、什么是 AOP
( 1 )面向切面编程(方面),利用AOP可以对业务逻辑的各个部分进行隔离,从而使得
业务逻辑各部分之间的耦合度降低,提高程序的可重用性,同时提高了开发的效率。

( 2 )通俗描述:不通过修改源代码方式,在主干功能里面添加新功能

( 3 )使用登录例子说明AOP

AOP (底层原理)

1AOP 底层使用动态代理
( 1 )有两种情况动态代理
第一种 有接口情况,使用 JDK 动态代理
⚫ 创建接口实现类代理对象,增强类的方法

第二种 没有接口情况,使用 CGLIB 动态代理
⚫ 创建子类的代理对象,增强类的方法

AOP ( JDK 动态代理)

1 、使用JDK动态代理,使用Proxy类里面的方法创建代理对象

( 1 )调用newProxyInstance方法

方法有三个参数:
第一参数,类加载器
第二参数,增强方法所在的类,这个类实现的接口,支持多个接口
第三参数,实现这个接口InvocationHandler,创建代理对象,写增强的部分

2 、编写 JDK 动态代理代码
( 1 )创建接口,定义方法

package com.yu.spring5;

public interface UserDao {
    public int add(int a,int b);
    public String update(String id);
}

( 2 )创建接口实现类,实现方法

package com.yu.spring5;

public class UserDaoImpl implements UserDao {
    @Override
    public int add(int a, int b) {
        System.out.println("add方法执行了。。。");
        return a+b;
    }

    @Override
    public String update(String id) {
        System.out.println("update方法执行了。。。");
        return id;
    }
}

( 3 )使用Proxy类创建接口代理对象

package com.yu.spring5;

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.Arrays;

public class JDKProxy {
    public static void main(String[] args){
        //创建接口实现类代理对象
        Class[] interfaces = {UserDao.class};
//        Proxy.newProxyInstance(JDKProxy.class.getClassLoader(), interfaces, new InvocationHandler() {
//            @Override
//            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
//                return null;
//            }
//        });
        UserDaoImpl userDao = new UserDaoImpl();
        UserDao dao = (UserDao) Proxy.newProxyInstance(JDKProxy.class.getClassLoader(), interfaces, new UserDaoProxy(userDao));
        int result = dao.add(1, 2);
        System.out.println("result:"+result);
    }
}
//创建代理对象代码
class UserDaoProxy implements InvocationHandler{
    //1 把创建的是谁的代理对象,的谁传递过来
    //有参构造传递
    private Object obj;
    public UserDaoProxy(Object obj){
        this.obj=obj;
    }

    //增强的逻辑
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        //方法之前
        System.out.println("方法之前执行..."+method.getName()+":传递的参数..."+ Arrays.toString(args));
        //被增强的方法执行
        Object res = method.invoke(obj, args);
        //方法之后
        System.out.println("方法执行之后..."+obj);

        return res;
    }
}

AOP (术语)

1 、连接点

2 、切入点

3 、通知(增强)

4 、切面

AOP 操作(准备工作)

1Spring 框架一般都是基于 AspectJ 实现 AOP 操作
( 1 )AspectJ不是Spring组成部分,独立AOP框架,一般把AspectJ和Spirng框架一起使
用,进行AOP操作

2 、基于 AspectJ 实现 AOP 操作
( 1 )基于xml配置文件实现
( 2 )基于注解方式实现(使用)

3 、在项目工程里面引入 AOP 相关依赖

spring-aspects-5.2.6.RELEASE.jar

4 、切入点表达式
( 1 )切入点表达式作用:知道对哪个类里面的哪个方法进行增强
( 2 )语法结构: execution([权限修饰符] [返回类型] [类全路径] 方法名称 )

举例 1 :对com.yu.dao.BookDao类里面的add进行增强
//* 任意修饰符 [返回类型]可以省略
execution(* com.yu.dao.BookDao.add(..))

举例 2 :对com.yu.dao.BookDao类里面的所有的方法进行增强
execution(* com.yu.dao.BookDao.* (..))

举例 3 :对com.yu.dao包里面所有类,类里面所有方法进行增强
execution(* com.yu.dao.. (..))

AOP 操作( AspectJ 注解实现)(推荐)

1 、创建类,在类里面定义方法

package com.yu.spring5.aopanno;

import org.springframework.stereotype.Component;

//被增强的类
@Component
public class User {
    public void add(){
        System.out.println("add.....");
    }
}

2 、创建增强类(编写增强逻辑)
( 1 )在增强类里面,创建方法,让不同方法代表不同通知类型

package com.yu.spring5.aopanno;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

//增强的类
@Component
@Aspect//生成代理对象
public class UserProxy {
    //前置通知
    //@Before注解表示作为前置通知
    @Before(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void before(){
        System.out.println("before,.......");
    }
    //最终通知
    @After(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void after(){
        System.out.println("After,.......");
    }
    //后置通知(返回通知)
    //After是在方法之后执行,AfterReturning是返回值之后执行
    @AfterReturning(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void afterReturning(){
        System.out.println("AfterReturning,.......");
    }
    //异常通知
    @AfterThrowing(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void afterThrowing(){
        System.out.println("AfterThrowing,.......");
    }
    //环绕通知
    @Around(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
        System.out.println("环绕之前,.......");
        //被增强的方法执行
        proceedingJoinPoint.proceed();
        System.out.println("环绕之后,.......");
    }
}


3 、进行通知的配置
( 1 )在spring配置文件中,开启注解扫描
bean1.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
    <!--开启注解扫描-->
    <context:component-scan base-package="com.yu.spring5.aopanno"></context:component-scan>

    <!--开启Aspect生成代理对象-->
    <aop:aspectj-autoproxy></aop:aspectj-autoproxy>
</beans>

( 2 )使用注解创建User和UserProxy对象

( 3 )在增强类上面添加注解 @Aspect

//增强的类

@Component
@Aspect //生成代理对象
public class UserProxy {

( 4 )在spring配置文件中开启生成代理对象

<!-- 开启Aspect生成代理对象-->
<aop:aspectj-autoproxy></aop:aspectj-autoproxy>

4 、配置不同类型的通知
( 1 )在增强类的里面,在作为通知方法上面添加通知类型注解,使用切入点表达式配置


( 2 )测试

package com.yu.spring5.test;

import com.yu.spring5.aopanno.User;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class TestAop {
    @Test
    public void testAopAnno(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        User user = context.getBean("user", User.class);
        user.add();
    }
}

5 、相同的切入点抽取

    //相同切入点抽取
    @Pointcut(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void pointdemo(){

    }
    //前置通知
    //@Before注解表示作为前置通知
    @Before(value = "pointdemo()")
    public void before(){
        System.out.println("before,.......");
    }

6 、有多个增强类多同一个方法进行增强,设置增强类优先级
( 1 )在增强类上面添加注解 @Order(数字类型值),数字类型值越小优先级越高

@Component
@Aspect
@Order(1)
public class PersonProxy {
    //后置通知
    @Before(value = "execution(* com.yu.spring5.aopanno.User.add())")
    public void personBefore(){
        System.out.println("personBefore~~~~~");
    }
}

7 、完全使用注解开发
创建配置类,不需要创建xml配置文件
创建class: config.ConfigAop

package com.yu.spring5.config;

import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.EnableAspectJAutoProxy;

@Configuration
@ComponentScan(basePackages = {"com.yu"})
@EnableAspectJAutoProxy(proxyTargetClass = true)
public class ConfigAop {
}

测试

    @Test
    public void testAopAnno(){
        ApplicationContext context =
                new AnnotationConfigApplicationContext(ConfigAop.class);
        User user = context.getBean("user", User.class);
        user.add();
    }

AOP 操作( AspectJ 配置文件实现)()

1 、创建两个类,增强类和被增强类,创建方法

public class Book {
    public void buy(){
        System.out.println("buy......");
    }
}
public class BookProxy {
    public void before111(){
        System.out.println("before////");
    }
}

2 、在 spring 配置文件中创建两个类对象

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd">
    <!--创建对象-->
    <bean id="book" class="com.yu.spring5.aopxml.Book"></bean>
    <bean id="bookProxy" class="com.yu.spring5.aopxml.BookProxy"></bean>

    <!--配置aop增强-->
    <aop:config>
        <!--切入点-->
        <aop:pointcut id="p" expression="execution(* com.yu.spring5.aopxml.Book.buy())"></aop:pointcut>    
        <!--配置切面-->
        <aop:aspect ref="bookProxy">
            <!--增强作用在具体的方法上-->
            <aop:before method="before111" pointcut-ref="p"/>
        </aop:aspect>
        
    </aop:config>
    

</beans>

3 、在 spring 配置文件中配置切入点


JdbcTemplate( 概念和准备 )

1 、什么是 JdbcTemplate
( 1 )Spring框架对JDBC进行封装,使用JdbcTemplate方便实现对数据库操作

2 、准备工作
( 1 )引入相关jar包

( 2 )在spring配置文件bean1.xml配置数据库连接池

    <!-- 数据库连接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close">
        <property name="url" value="jdbc:mysql:///user_db" />
        <property name="username" value="root" />
        <property name="password" value="root" />
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    </bean>

( 3 )bean1.xml中配置JdbcTemplate对象,注入DataSource

    <!--JdbcTemplate对象-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入dataSource-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

( 4 )创建service类,创建dao类,在dao注入jdbcTemplate对象

  • 配置文件bean1.xml
<!-- 组件扫描 -->
<context:component-scan base-package="com.atguigu"></context:component-scan>

创建类:
⚫ Service

package com.yu.spring5.service;

import com.yu.spring5.dao.BookDao;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class BookService {
    //注入dao
    @Autowired
    public BookDao bookDao;

}

⚫ Dao

package com.yu.spring5.dao;

public interface BookDao {
}

package com.yu.spring5.dao;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository
public class BookDapImpl implements BookDao{
    //注入JdbcTemplate
    @Autowired
     private JdbcTemplate jdbcTemplate;
}

JdbcTemplate 操作数据库(添加)

1 、对应数据库创建实体类

package com.yu.spring5.entity;

public class Book{
    private String userId;
    private String username;
    private String ustatus;
//get和set略
}

2 、编写 servicedao
BookService

    //添加方法
    public void addBook(Book book){
        bookDao.add(book);
    }

BookDao

    //添加方法
    void add(Book book);

( 1 )在dao进行数据库添加操作
( 2 )调用JdbcTemplate对象里面update方法实现添加操作

⚫ 有两个参数
⚫ 第一个参数:sql语句
⚫ 第二个参数:可变参数,设置sql语句值

BookDaoImpl

@Repository
public class BookDapImpl implements BookDao{
    //注入JdbcTemplate
    @Autowired
     private JdbcTemplate jdbcTemplate;

    @Override
    public void add(Book book) {
        //1 创建sql语句
        String sql = "insert into t_book values(?,?,?)";
        //2 调用方法实现
        Object[] args = {book.getUserId(), book.getUsername(), book.getUstatus()};
        int update = jdbcTemplate.update(sql,args);
        System.out.println(update);
    }
}

3 、测试类

public class TestBook {
    @Test
    public void testJdbcTemplate(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        BookService bookService = context.getBean("bookService", BookService.class);

        Book book = new Book();
        book.setUserId("1");
        book.setUsername("Java");
        book.setUstatus("a");
        bookService.addBook(book);

    }
}

JdbcTemplate 操作数据库(修改和删除)

1 、修改

    @Override
    public void update(Book book) {
        String sql = "update t_book set username=?,ustatus=? where user_id=?";
        Object[] args = {book.getUsername(), book.getUstatus(), book.getUserId()};
        int update = jdbcTemplate.update(sql, args);
        System.out.println(update);
    }

2 、删除

    @Override
    public void delete(int id) {
        String sql ="delete from t_book where user_id=?";
        int update = jdbcTemplate.update(sql, id);
        System.out.println(update);
    }

JdbcTemplate 操作数据库(查询返回某个值)

1 、查询表里面有多少条记录,返回是某个值
2 、使用 JdbcTemplate 实现查询返回某个值代码

⚫ 有两个参数
⚫ 第一个参数:sql语句
⚫ 第二个参数:返回类型Class

    @Override
    public int selectCount(){
        String sql = "select count(*) from t_book";
        Integer count = jdbcTemplate.queryForObject(sql, Integer.class);
        return count;
    }

测试

        //查询表记录数
        System.out.println(bookService.findCount());

JdbcTemplate 操作数据库(查询返回对象)

1 、场景:查询图书详情
2JdbcTemplate 实现查询返回对象


⚫ 有三个参数
⚫ 第一个参数:sql语句
⚫ 第二个参数:RowMapper 是接口,针对返回不同类型数据,使用这个接口里面实现类完成
数据封装
⚫ 第三个参数:sql语句值

    @Override
    public Book findBookInfo(String id){
        String sql = "select * from t_book where user_id = ?";
        Book book1 = jdbcTemplate.queryForObject(sql, new BeanPropertyRowMapper<Book>(Book.class), id);
        return book1;
    }

JdbcTemplate 操作数据库(查询返回集合)

1 、场景:查询图书列表分页 ...

2 、调用 JdbcTemplate 方法实现查询返回集合

⚫ 有三个参数
⚫ 第一个参数:sql语句
⚫ 第二个参数:RowMapper 是接口,针对返回不同类型数据,使用这个接口里面实现类完成数据封装
⚫ 第三个参数:sql语句值

    //查询返回集合
    @Override
    public List<Book> findAllBook() {
        String sql = "select * from t_book";
        List<Book> bookList = jdbcTemplate.query(sql, new BeanPropertyRowMapper<Book>(Book.class));
        return bookList;
    }

测试

        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean1.xml");
        BookService bookService = context.getBean("bookService", BookService.class);
        List<Book> all = bookService.findAll();
        System.out.println(all);

JdbcTemplate 操作数据库(批量操作)

1 、批量操作:操作表里面多条记录

2JdbcTemplate 实现批量添加操作

⚫ 有两个参数
⚫ 第一个参数:sql语句
⚫ 第二个参数:List集合,添加多条记录数据

    //批量添加
    @Override
    public void batchAddBook(List<Object[]> batchArgs) {
        String sql = "insert into t_book values(?,?,?)";
        int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
        System.out.println(Arrays.toString(ints));
    }

批量添加测试

        //批量添加 测试
        List<Object[]> batchArgs = new ArrayList<>();
        Object[] o1 ={"5","java","b"};
        Object[] o2 ={"6","c++","c"};
        Object[] o3 ={"7","mysql","d"};
        batchArgs.add(o1);
        batchArgs.add(o2);
        batchArgs.add(o3);
       
        bookService.batchAdd(batchArgs);

3JdbcTemplate 实现批量修改操作

    @Override
    public void batchUpdateBook(List<Object[]> batchArgs) {
        String sql = "update t_book set username = ?,ustatus=? where user_id = ?";
        int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
        System.out.println(Arrays.toString(ints));
    }
        //批量修改 测试
        List<Object[]> batchArgs = new ArrayList<>();
        Object[] o1 ={"javaBatch","bBatch","5"};
        Object[] o2 ={"c++Batch","cBatch","6"};
        Object[] o3 ={"mysqlBatch","dBatch","7",};
        batchArgs.add(o1);
        batchArgs.add(o2);
        batchArgs.add(o3);

        bookService.batchUpdate(batchArgs);

4JdbcTemplate 实现批量删除操作

    @Override
    public void batchDeleteBook(List<Object[]> batchArgs) {
        String sql ="delete from t_book where user_id = ?";
        int[] ints = jdbcTemplate.batchUpdate(sql, batchArgs);
        System.out.println(Arrays.toString(ints));
    }
        //批量删除 测试
        List<Object[]> batchArgs = new ArrayList<>();
        Object[] o1 = {"6"};
        Object[] o2 = {"7"};
        batchArgs.add(o1);
        batchArgs.add(o2);

        bookService.batchDelete(batchArgs);

事务操作(事务概念)

1 、什么事务
( 1 )事务是数据库操作最基本单元,逻辑上一组操作,要么都成功,如果有一个失败所有操
作都失败
( 2 )典型场景:银行转账

  • lucy 转账 100 元 给mary
  • lucy少 100 ,mary多 100

2 、事务四个特性( ACID
( 1 )原子性
( 2 )一致性
( 3 )隔离性
( 4 )持久性

事务操作(搭建事务操作环境)

1 、创建数据库表,添加记录

2 、创建 service ,搭建 dao ,完成对象创建和注入关系
( 1 )service注入dao,在dao注入JdbcTemplate,在JdbcTemplate注入DataSource

@Service
public class UserService {
    //注入dao
    @Autowired
    private UserDao userDao;

    //转账
    public void accountMoney(){
        
        userDao.addMoney();
        int i = 10/0;
        userDao.reduceMoney();
    }
}

3 、在 dao 创建两个方法:多钱和少钱的方法,在 service 创建方法(转账的方法)

@Repository
public class UserDaoImpl implements UserDao{
    @Autowired
    private JdbcTemplate jdbcTemplate;
    //lucy 转账100给mary
    @Override
    public void addMoney() {
        String sql = "update account set money = money-? where username = ?";
        jdbcTemplate.update(sql,100,"lucy");
    }

    @Override
    public void reduceMoney() {
        String sql = "update account set money = money+? where username = ?";
        jdbcTemplate.update(sql,100,"mary");
    }

}

4 、上面代码,如果正常执行没有问题的,但是如果代码执行过程中出现异常,有问题

( 1 )上面问题如何解决呢?

  • 使用事务进行解决

( 2 )事务操作过程

事务操作( Spring 事务管理介绍)

1 、事务添加到 JavaEE 三层结构里面 Service 层(业务逻辑层)

2 、在 Spring 进行事务管理操作
1 )有两种方式:编程式事务管理和声明式事务管理(使用)

3 、声明式事务管理
1 )基于注解方式(使用)
( 2 )基于xml配置文件方式

4 、在 Spring 进行声明式事务管理,底层使用 AOP 原理

5Spring 事务管理 API
( 1 )提供一个接口,代表事务管理器,这个接口针对不同的框架提供不同的实现类

事务操作(注解声明式事务管理)

1 、在 spring 配置文件配置事务管理器

<!--创建事务管理器-->
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!--注入数据源-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

2 、在 spring 配置文件,开启事务注解
( 1 )在spring配置文件引入名称空间 tx

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
                             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">

( 2 )开启事务注解

    <!--开启事务注解-->
    <tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>

3 、在 service 类上面(或者 service 类里面方法上面)添加事务注解
( 1 )@Transactional,这个注解添加到类上面,也可以添加方法上面
( 2 )如果把这个注解添加类上面,这个类里面所有的方法都添加事务
( 3 )如果把这个注解添加方法上面,为这个方法添加事务

@Service
@Transactional
public class UserService {

事务操作(注解声明式事务管理参数配置)

1 、在 service 类上面添加注解 @Transactional ,在这个注解里面可以配置事务相关参数

2propagation :事务传播行为

1 )多事务方法直接进行调用,这个过程中事务 是如何进行管理的

@Service
@Transactional( propagation = Propagation.REQUIRED)
public class UserService {

3ioslation :事务隔离级别

( 1 )事务有特性成为隔离性,多事务操作之间不会产生影响。不考虑隔离性产生很多问题
( 2 )有三个读问题:脏读、不可重复读、虚(幻)读
( 3 )脏读:一个未提交事务读取到另一个未提交事务的数据

( 4 )不可重复读:一个未提交事务读取到另一提交事务修改数据

( 5 )虚读:一个未提交事务读取到另一提交事务添加数据

( 6 )解决:通过设置事务隔离级别,解决读问题


mysql默认是REPEATABLE_READ

@Service
@Transactional(isolation = Isolation.REPEATABLE_READ)
public class UserService {

4timeout :超时时间

( 1 )事务需要在一定时间内进行提交,如果不提交进行回滚
( 2 )默认值是 - 1 ,设置时间以秒单位进行计算

5readOnly :是否只读

( 1 )读:查询操作,写:添加修改删除操作
( 2 )readOnly默认值false,表示可以查询,可以添加修改删除操作
( 3 )设置readOnly值是true,设置成true之后,只能查询

6rollbackFor :回滚

( 1 )设置出现哪些异常进行事务回滚

@Service
@Transactional(rollbackFor = Exception.class)
public class UserService {

7noRollbackFor :不回滚

( 1 )设置出现哪些异常不进行事务回滚

事务操作( XML 声明式事务管理)

1 、在 spring 配置文件中进行配置

第一步 配置事务管理器
第二步 配置通知
第三步 配置切入点和切面

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xmlns:tx="http://www.springframework.org/schema/tx"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
                            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
                            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd
                             http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd">
    <!--组件扫描    -->
    <context:component-scan base-package="com.yu"></context:component-scan>
    <!-- 数据库连接池 -->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
          destroy-method="close">
        <property name="url" value="jdbc:mysql:///user_db" />
        <property name="username" value="root" />
        <property name="password" value="root" />
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
    </bean>
    <!--JdbcTemplate对象-->
    <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <!--注入dataSource-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!--1 创建事务管理器-->
    <bean id="transactionManager"
        class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <!--注入数据源-->
        <property name="dataSource" ref="dataSource"></property>
    </bean>
    <!--2 配置通知-->
    <tx:advice id="txadvice">
        <!--配置事务参数-->
        <tx:attributes>
            <!--指定哪种规则的方法上面添加事务-->
            <tx:method name="accountMoney" propagation="REQUIRED"/>
            <!--<tx:method name="account*"/>-->
        </tx:attributes>
    </tx:advice>
    <!--3 配置切入点和切面-->
    <aop:config>
        <!--配置切入点-->
        <aop:pointcut id="pt" expression="execution(* com.yu.spring5.service.UserService.*(..))"/>
        <!--配置切面-->
        <aop:advisor advice-ref="txadvice" pointcut-ref="pt"></aop:advisor>
    </aop:config>
</beans>

测试

public class TestBook {
    @Test
    public void testAccount(){
        ApplicationContext context =
                new ClassPathXmlApplicationContext("bean2.xml");
        UserService userService = context.getBean("userService", UserService.class);
        userService.accountMoney();
    }
}

事务操作(完全注解声明式事务管理)

1 、创建配置类,使用配置类替代 xml 配置文件
在spring5下新建config.TxConfig

package com.yu.spring5.config;

import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;

@Configuration//配置类
@ComponentScan(basePackages = "com.yu")//组件扫描
@EnableTransactionManagement//开启事务
public class TxConfig {
    //创建数据库连接池
    @Bean
    public DruidDataSource getDruidDataSource(){
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setDriverClassName("com.mysql.jdbc.Driver");
        dataSource.setUrl("jdbc:mysql:///user_db");
        dataSource.setUsername("root");
        dataSource.setPassword("root");

        return dataSource;
    }
    //创建JdbcTemplate对象
    @Bean
    public JdbcTemplate getJdbcTemplate(DataSource dataSource){
        //到ioc容器中根据类型找到dataSource
        JdbcTemplate jdbcTemplate = new JdbcTemplate();
        //注入dataSource
        jdbcTemplate.setDataSource(dataSource);

        return jdbcTemplate;
    }
    //创建事务管理器
    @Bean
    public DataSourceTransactionManager getDataSourceTransactionManager(DataSource dataSource){
        DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
        transactionManager.setDataSource(dataSource);
        return transactionManager;
    }

}

测试

    @Test
    public void testAccount2(){
        ApplicationContext context =
                new AnnotationConfigApplicationContext(TxConfig.class);
        UserService userService = context.getBean("userService", UserService.class);
        userService.accountMoney();
    }

Spring5 框架新功能

1 、整个 Spring5 框架的代码基于 Java8 ,运行时兼容 JDK9 ,许多不建议使用的类和方法在代码库中删除

2 、Spring 5.0框架自带了通用的日志封装Log4j2

( 1 )Spring5已经移除Log4jConfigListener,官方建议使用Log4j2
( 2 )Spring5框架整合Log4j2
第一步 引入jar包

第二步 在src下创建log4j2.xml配置文件

<?xml version="1.0" encoding="UTF-8"?>
<!--日志级别以及优先级排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
<!--Configuration后面的status用于设置log4j2自身内部的信息输出,可以不设置,当设置成trace时,可以看到log4j2内部各种详细输出-->
<configuration status="INFO">
    <!--先定义所有的appender-->
    <appenders>
        <!--输出日志信息到控制台-->
        <console name="Console" target="SYSTEM_OUT">
            <!--控制日志输出的格式-->
            <PatternLayout pattern="%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>
        </console>
    </appenders>
    <!--然后定义logger,只有定义了logger并引入的appender,appender才会生效-->
    <!--root:用于指定项目的根日志,如果没有单独指定Logger,则会使用root作为默认的日志输出-->
    <loggers>
        <root level="info">
            <appender-ref ref="Console"/>
        </root>
    </loggers>
</configuration>

手动日志输出

package com.yu.spring5.test;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class UserLog {
    private static final Logger log = LoggerFactory.getLogger(UserLog.class);

    public static void main(String[] args){
        log.info("hello log4j2");
        log.warn("hello log4j2");
    }
}

3Spring5 框架核心容器支持 @Nullable 注解

( 1 )@Nullable注解可以使用在方法上面,属性上面,参数上面,表示方法返回可以为空,属性值可以
为空,参数值可以为空

( 2 )注解用在方法上面,方法返回值可以为空

( 3 )注解使用在方法参数里面,方法参数可以为空

( 4 )注解使用在属性上面,属性值可以为空

4Spring5 核心容器支持函数式风格 GenericApplicationContext

JAVA8中的Lambda理解使用
在Java中如何使用lambda表达式中的Supplier 接口?

    //函数式风格创建对象,交给spring进行管理
    @Test
    public void testGenericApplicationContext(){
        // 1 创建GenericApplicationContext对象
        GenericApplicationContext context = new GenericApplicationContext();
        //2 调用context的方法对象注册
        context.refresh();
        context.registerBean("user1",User.class,() -> new User());
        //3 获取在spring注册的对象
//        User user = (User) context.getBean("com.yu.spring5.test.User");
        User user = (User) context.getBean("user1");
        System.out.println(user);
    }

5Spring5 支持整合 JUnit5

( 1 )整合JUnit4
第一步 引入Spring相关针对测试依赖
spring-test-5.2.6.RELEASE.jar
第二步 创建测试类,使用注解方式完成

package com.yu.spring5.test;

import com.yu.spring5.service.UserService;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

@RunWith(SpringJUnit4ClassRunner.class)//单元测试框架
@ContextConfiguration("classpath:bean1.xml")//加载配置文件
public class JTest4 {

    @Autowired
    private UserService userService;

    @Test
    public void test1(){
        userService.accountMoney();
    }
}

( 2 )Spring5整合JUnit5
第一步 引入JUnit5的jar包

第二步 创建测试类,使用注解完成

package com.yu.spring5.test;

import com.yu.spring5.service.UserService;

import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit.jupiter.SpringExtension;


@ExtendWith(SpringExtension.class)
@ContextConfiguration("classpath:bean1.xml")//加载配置文件
public class JTest5 {

    @Autowired
    private UserService userService;

    @Test
    public void test1(){
        userService.accountMoney();
    }
}

( 3 )使用一个复合注解替代上面两个注解完成整合

@SpringJUnitConfig(locations = "classpath:bean1.xml")
public class JTest5 {

    @Autowired
    private UserService userService;

    @Test
    public void test1(){
        userService.accountMoney();
    }
}

Spring5 框架新功能( Webflux )

1SpringWebflux 介绍

( 1 )是Spring5添加新的模块,用于web开发的,功能和SpringMVC类似的,Webflux使用
当前一种比较流程响应式编程出现的框架。

( 2 )使用传统web框架,比如SpringMVC,这些基于Servlet容器,Webflux是一种异步非阻
塞的框架,异步非阻塞的框架在Servlet3.1以后才支持,核心是基于Reactor的相关API实现
的。

( 3 )解释什么是异步非阻塞

  • 异步和同步
  • 非阻塞和阻塞
    ** 上面都是针对对象不一样

****** 异步和同步针对调用者,调用者发送请求,如果等着对方回应之后才去做其他事情就是同
步,如果发送请求之后不等着对方回应就去做其他事情就是异步

** 阻塞和非阻塞针对被调用者,被调用者受到请求之后,做完请求任务之后才给出反馈就是阻
塞,受到请求之后马上给出反馈然后再去做事情就是非阻塞

( 4 )Webflux特点:
第一 非阻塞式:在有限资源下,提高系统吞吐量和伸缩性,以Reactor为基础实现响应式编程
第二 函数式编程:Spring5框架基于java8,Webflux使用Java8函数式编程方式实现路由请求

( 5 )比较SpringMVC

第一 两个框架都可以使用注解方式,都运行在Tomet等容器中

第二 SpringMVC采用命令式编程,Webflux采用异步响应式编程

2 、响应式编程( Java 实现)

( 1 )什么是响应式编程
响应式编程是一种面向数据流和变化传播的编程范式。这意味着可以在编程语言中很方便
地表达静态或动态的数据流,而相关的计算模型会自动将变化的值通过数据流进行传播。
电子表格程序就是响应式编程的一个例子。单元格可以包含字面值或类似"=B1+C1"的公
式,而包含公式的单元格的值会依据其他单元格的值的变化而变化。

( 2 )Java8及其之前版本

  • 提供的观察者模式两个类Observer和Observable
public class ObserverDemo extends Observable {

public static void main(String[] args) {
ObserverDemo observer = new ObserverDemo();
//添加观察者
observer.addObserver((o,arg)->{
System.out.println("发生变化");
});
observer.addObserver((o,arg)->{
System.out.println("手动被观察者通知,准备改变");
});
observer.setChanged(); //数据变化
observer.notifyObservers(); //通知
}
}

3 、响应式编程( Reactor 实现)

1 )响应式编程操作中, Reactor 是满足 Reactive 规范框架
2Reactor 有两个核心类, MonoFlux ,这两个类实现接口 Publisher ,提供丰富操作
符。 Flux 对象实现发布者,返回 N 个元素; Mono 实现发布者,返回 0 或者 1 个元素
( 3 )Flux和Mono都是数据流的发布者,使用Flux和Mono都可以发出三种数据信号:
元素值,错误信号,完成信号,错误信号和完成信号都代表终止信号,终止信号用于告诉
订阅者数据流结束了,错误信号终止数据流同时把错误信息传递给订阅者

4 )代码演示 FluxMono

第一步 引入依赖

## <dependency>

## <groupId>io.projectreactor</groupId>

## <artifactId>reactor-core</artifactId>

## <version>3.1.5.RELEASE</version>

## </dependency>

第二步 编程代码

public static void main(String[] args) {
//just方法直接声明
Flux.just( 1 , 2 , 3 , 4 );
Mono.just( 1 );
//其他的方法
Integer[] array = { 1 , 2 , 3 , 4 };
Flux.fromArray(array);

List<Integer> list = Arrays.asList(array);
Flux.fromIterable(list);

Stream<Integer> stream = list.stream();
Flux.fromStream(stream);
}

( 5 )三种信号特点

  • 错误信号和完成信号都是终止信号,不能共存的
  • 如果没有发送任何元素值,而是直接发送错误或者完成信号,表示是空数据流
  • 如果没有错误信号,没有完成信号,表示是无限数据流

( 6 )调用just或者其他方法只是声明数据流,数据流并没有发出,只有进行订阅之后才会触
发数据流,不订阅什么都不会发生的

7 )操作符
***** 对数据流进行一道道操作,成为操作符,比如工厂流水线
第一 map 元素映射为新元素

第二 flatMap 元素映射为流
⚫ 把每个元素转换流,把转换之后多个流合并大的流

4SpringWebflux 执行流程和核心 API

SpringWebflux基于Reactor,默认使用容器是Netty,Netty是高性能的NIO框架,异步非阻
塞的框架
( 1 )Netty

  • BIO

NIO

( 2 )SpringWebflux执行过程和SpringMVC相似的

  • SpringWebflux核心控制器 DispatchHandler,实现接口WebHandler
  • 接口WebHandler有一个方法

( 3 )SpringWebflux里面DispatcherHandler,负责请求的处理

  • HandlerMapping:请求查询到处理的方法
  • HandlerAdapter:真正负责请求处理
  • HandlerResultHandler:响应结果处理

( 4 )SpringWebflux实现函数式编程,两个接口:RouterFunction(路由处理)
和HandlerFunction(处理函数)

5SpringWebflux (基于注解编程模型)

SpringWebflux实现方式有两种:注解编程模型和函数式编程模型
使用注解编程模型方式,和之前SpringMVC使用相似的,只需要把相关依赖配置到项目中,
SpringBoot自动配置相关运行容器,默认情况下使用Netty服务器

第一步 创建SpringBoot工程,引入Webflux依赖

第二步 配置启动端口号

第三步 创建包和相关类
⚫ 实体类

⚫ 创建接口定义操作的方法

//用户操作接口
public interface UserService {
//根据id查询用户
Mono<User> getUserById(int id);
//查询所有用户
Flux<User> getAllUser();
//添加用户
Mono<Void> saveUserInfo(Mono<User> user);
}

⚫ 接口实现类

public class UserServiceImpl implements UserService {
//创建map集合存储数据
private final Map<Integer,User> users = new HashMap<>();
public UserServiceImpl() {
this.users.put( 1 ,new User("lucy","nan", 20 ));
this.users.put( 2 ,new User("mary","nv", 30 ));
this.users.put( 3 ,new User("jack","nv", 50 ));
}
//根据id查询
@Override
public Mono<User> getUserById(int id) {
return Mono.justOrEmpty(this.users.get(id));
}
//查询多个用户
@Override
public Flux<User> getAllUser() {
return Flux.fromIterable(this.users.values());
}


//添加用户
@Override
public Mono<Void> saveUserInfo(Mono<User> userMono) {
return userMono.doOnNext(person -> {
//向map集合里面放值
int id = users.size()+ 1 ;
users.put(id,person);
}).thenEmpty(Mono.empty());
}
}

⚫ 创建controller

@RestController
public class UserController {
//注入service
@Autowired
private UserService userService;
//id查询
@GetMapping("/user/{id}")
public Mono<User> geetUserId(@PathVariable int id) {
return userService.getUserById(id);
}
//查询所有
@GetMapping("/user")
public Flux<User> getUsers() {
return userService.getAllUser();
}
//添加
@PostMapping("/saveuser")
public Mono<Void> saveUser(@RequestBody User user) {
Mono<User> userMono = Mono.just(user);
return userService.saveUserInfo(userMono);
}
}

⚫ 说明
SpringMVC方式实现,同步阻塞的方式,基于SpringMVC+Servlet+Tomcat
SpringWebflux方式实现,异步非阻塞 方式,基于SpringWebflux+Reactor+Netty

6SpringWebflux (基于函数式编程模型)

( 1 )在使用函数式编程模型操作时候,需要自己初始化服务器
( 2 )基于函数式编程模型时候,有两个核心接口:RouterFunction(实现路由功能,请求转发
给对应的handler)和HandlerFunction(处理请求生成响应的函数)。核心任务定义两个函数
式接口的实现并且启动需要的服务器。
( 3 )SpringWebflux 请 求 和 响 应 不 再 是 ServletRequest 和 ServletResponse,而是
ServerRequest和ServerResponse

第一步 把注解编程模型工程复制一份 ,保留entity和service内容
第二步 创建Handler(具体实现方法)

public class UserHandler {
private final UserService userService;
public UserHandler(UserService userService) {


this.userService = userService;
}
//根据id查询
public Mono<ServerResponse> getUserById(ServerRequest request) {
//获取id值
int userId = Integer.valueOf(request.pathVariable("id"));
//空值处理
Mono<ServerResponse> notFound = ServerResponse.notFound().build();
//调用service方法得到数据
Mono<User> userMono = this.userService.getUserById(userId);
//把userMono进行转换返回
//使用Reactor操作符flatMap
return
userMono
.flatMap(person ->
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON)
.body(fromObject(person)))
.switchIfEmpty(notFound);
}
//查询所有
public Mono<ServerResponse> getAllUsers() {
//调用service得到结果
Flux<User> users = this.userService.getAllUser();
return
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(users,User.cl
ass);
}
//添加
public Mono<ServerResponse> saveUser(ServerRequest request) {
//得到user对象
Mono<User> userMono = request.bodyToMono(User.class);
return
ServerResponse.ok().build(this.userService.saveUserInfo(userMono));
}

}

第三步 初始化服务器,编写Router
⚫ 创建路由的方法

//1 创建Router路由
public RouterFunction<ServerResponse> routingFunction() {
//创建hanler对象
UserService userService = new UserServiceImpl();
UserHandler handler = new UserHandler(userService);
//设置路由
return RouterFunctions.route(

GET("/users/{id}").and(accept(APPLICATION_JSON)),handler::getUserById)
.andRoute(GET("/users").and(accept(APPLICATION_JSON)),handler::get
AllUsers);
}

⚫ 创建服务器完成适配

//2 创建服务器完成适配
public void createReactorServer() {
//路由和handler适配
RouterFunction<ServerResponse> route = routingFunction();
HttpHandler httpHandler = toHttpHandler(route);
ReactorHttpHandlerAdapter adapter = new
ReactorHttpHandlerAdapter(httpHandler);
//创建服务器
HttpServer httpServer = HttpServer.create();
httpServer.handle(adapter).bindNow();
}

⚫ 最终调用

public static void main(String[] args) throws Exception{
Server server = new Server();
server.createReactorServer();
System.out.println("enter to exit");
System.in.read();
}

( 4 )使用WebClient调用

public class Client {
public static void main(String[] args) {
//调用服务器地址
WebClient webClient = WebClient.create("http://127.0.0.1:5794");
//根据id查询
String id = "1";
User userresult = webClient.get().uri("/users/{id}", id)
.accept(MediaType.APPLICATION_JSON).retrieve().bodyToMono(User
.class)
.block();
System.out.println(userresult.getName());

//查询所有
Flux<User> results = webClient.get().uri("/users")
.accept(MediaType.APPLICATION_JSON).retrieve().bodyToFlux(User
.class);
results.map(stu -> stu.getName())
.buffer().doOnNext(System.out::println).blockFirst();
}
}

课程总结

1Spring 框架概述
( 1 )轻量级开源JavaEE框架,为了解决企业复杂性,两个核心组成:IOC 和AOP
( 2 )Spring5.2.6版本

2IOC 容器

( 1 )IOC底层原理(工厂、反射等)
( 2 )IOC接口(BeanFactory)
( 3 )IOC操作Bean管理(基于xml)
( 4 )IOC操作Bean管理(基于注解)

3Aop
( 1 )AOP底层原理:动态代理,有接口(JDK动态代理),没有接口(CGLIB动态代理)
( 2 )术语:切入点、增强(通知)、切面
( 3 )基于AspectJ实现AOP操作

4JdbcTemplate

( 1 )使用JdbcTemplate实现数据库curd操作
( 2 )使用JdbcTemplate实现数据库批量操作

5 、事务管理
( 1 )事务概念
( 2 )重要概念(传播行为和隔离级别)
( 3 )基于注解实现声明式事务管理
( 4 )完全注解方式实现声明式事务管理

6Spring5 新功能
( 1 )整合日志框架
( 2 )@Nullable注解
( 3 )函数式注册对象
( 4 )整合JUnit5单元测试框架
( 5 )SpringWebflux使用

原文地址:https://www.cnblogs.com/xingkongcanghai/p/15009792.html