十三：java web（5）-- Spring数据持久层

Spring 数据持久层

1. Spring 与 JDBC

1.1 使用 Spring 管理数据库连接

1.1.2 Apache Commons DBCP 基于配置文件xml 使用

1.1.3 Apache Commons DBCP 基于配置类使用

1.1.4 HikariCP 基于配置文件xml 使用推荐使用 Spring Boot 默认连接池

1.1.5 HikariCP 基于配置类使用

1.2 JdbcTemplate 的使用

1.2.1 DataSource 注入到 JdbcTemplate 基于xml方式

1.2.2 DataSource 注入到 JdbcTemplate 基于配置类方式

1.2.3 JdbcTemplate 基本操作感觉了解就好

1.3 总结：

2. Spring 与 ORM 框架

2.1 ORM框架是什么

2.2 集成 MyBatis

基于xml 配置的方式前提是你连接池可以连接上你数据库

2.2.1 引入pom.xml

2.2.2 编写配置文件 applicationContext.xml

2.2.3 编写实体类

2.2.4 编写mapper接口

2.2.5 编写mapper.xml

2.2.6 在使用的类注入mapper类

2.2.7 主函数调用

3. 事务管理

3.1 事务管理的基础概念

3.2 声明式事务管理（@Transactional）

3.3 编程式事务管理

Spring 数据持久层

1. Spring 与 JDBC

1.1 使用 Spring 管理数据库连接

1.1.1 Spring 提供了数据源（DataSource）的管理方式，通过将数据库连接池配置为一个 Spring Bean，Spring 可以帮助我们管理连接的创建与销毁。常用的数据源有：
- DriverManagerDataSource：仅适用于测试环境，因为它不使用连接池。
- Apache Commons DBCP：提供了基本的连接池功能。
- HikariCP：高性能的连接池管理器。

1.1.2 Apache Commons DBCP 基于配置文件xml 使用

pom.xml

        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-dbcp2</artifactId>
            <version>2.9.0</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.33</version>
        </dependency>

配置文件 applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 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 https://www.springframework.org/schema/aop/spring-aop.xsd">

    <!--    applicationContext.xml 是 Spring 框架中的配置文件，
    通常用于定义 Spring IoC（控制反转）容器中的 Bean 配置和管理。
    这个文件主要用于将 Spring 的配置项和组件描述清楚，
    告知 Spring 容器如何实例化、配置和管理应用程序中的各种对象（Bean）。
    它是 Spring 配置的传统方式之一（除了注解和 Java 配置类）。-->

    <bean id="dataSource" class="org.apache.commons.dbcp2.BasicDataSource">
        <!-- 数据库驱动类 -->
        <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />

        <!-- 数据库连接 URL -->
        <property name="url" value="jdbc:mysql://localhost:3306/lirui" />

        <!-- 数据库用户名 -->
        <property name="username" value="root" />

        <!-- 数据库密码 -->
        <property name="password" value="root" />
        <!-- 可选的连接池参数 -->
        <!-- 初始连接数 -->
        <property name="initialSize" value="5" />
        <!-- 最大连接数 -->
        <property name="maxTotal" value="20" />
        <!-- 最小空闲连接数 -->
        <property name="minIdle" value="5" />
        <!-- 最大空闲连接数 -->
        <property name="maxIdle" value="10" />
        <!-- 最大等待时间（毫秒），连接池用尽时的等待时长 -->
        <property name="maxWaitMillis" value="10000" />
    </bean>

    <!-- 配置 Engine Bean，带参数构造函数 -->
    <bean id="engine" class="com.lirui.car.Engine">
        <constructor-arg value="V8" />
    </bean>

    <!-- 配置 GPS Bean -->
    <bean id="gps" class="com.lirui.car.GPSImpl" />

    <!-- 配置 Radio Bean -->
    <bean id="radio" class="com.lirui.car.RadioImpl" />

    <!-- 配置 Car Bean，使用 setter 注入 -->
    <bean id="car" class="com.lirui.car.Car">
        <property name="engine" ref="engine" />
        <property name="gps" ref="gps" />
        <property name="radio" ref="radio" />
        <property name="dataSource" ref="dataSource" />
    </bean>


</beans>

调用

package com.lirui.car;


import org.springframework.beans.factory.annotation.Autowired;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;


public class Car {
    private Engine engine;
    private GPS gps;
    private Radio radio;
    private DataSource dataSource;


    // Setters for dependency injection
    public void setEngine(Engine engine) {
        this.engine = engine;
    }

    public void setGps(GPS gps) {
        this.gps = gps;
    }

    public void setRadio(Radio radio) {
        this.radio = radio;
    }

    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
    }

    public void drive() {
        // 使用 DataSource 获取数据库连接并执行查询
        String sql = "SELECT id, ui_path, menu_type FROM t_sys_resource";
        try (Connection connection = dataSource.getConnection();
             PreparedStatement statement = connection.prepareStatement(sql);
             ResultSet resultSet = statement.executeQuery()) {

            // 遍历查询结果
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("ui_path");
                String email = resultSet.getString("menu_type");

                System.out.println("ID: " + id + ", ui_path: " + name + ", menu_type: " + email);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        System.out.println("引擎"+engine.getType() );
        gps.navigate();
        radio.playMusic();
    }
}

主函数

    public static void main(String[] args) {
        // 加载 Spring 配置文件
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");

        // 获取 userService Bean
        Car car = context.getBean("car", Car.class);

        // 调用方法
        car.drive();
    }

1.1.3 Apache Commons DBCP 基于配置类使用

pom.xml

        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-dbcp2</artifactId>
            <version>2.9.0</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.33</version>
        </dependency>

application.properties

db.url=jdbc:mysql://localhost:3306/lirui
db.username=root
db.password=root
db.driverClassName=com.mysql.cj.jdbc.Driver

config配置文件

package com.lirui.carconfig;


import org.apache.commons.dbcp2.BasicDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.*;

import javax.sql.DataSource;

@Configuration
@ComponentScan(basePackages = "com.lirui.carconfig")
@PropertySource("classpath:application.properties")
@EnableAspectJAutoProxy
public class AppConfig {

    @Value("${db.url}")
    private String dbUrl;

    @Value("${db.username}")
    private String dbUsername;

    @Value("${db.password}")
    private String dbPassword;

    @Value("${db.driverClassName}")
    private String driverClassName;

    @Bean
    public DataSource dataSource() {
        BasicDataSource dataSource = new BasicDataSource();
        dataSource.setDriverClassName(driverClassName);
        dataSource.setUrl(dbUrl);
        dataSource.setUsername(dbUsername);
        dataSource.setPassword(dbPassword);

        dataSource.setInitialSize(5);
        dataSource.setMaxTotal(20);
        dataSource.setMinIdle(5);
        dataSource.setMaxIdle(10);
        dataSource.setMaxWaitMillis(10000);

        return dataSource;
    }

    @Bean
    public Engine engine() {
        return new Engine("V8");
    }

    @Bean
    public GPS gps() {
        return new GPSImpl();
    }

    @Bean
    public Radio radio() {
        return new RadioImpl();
    }

    @Bean
    public Car car() {
        Car car = new Car();
        car.setEngine(engine());
        car.setGps(gps());
        car.setRadio(radio());
        car.setDataSource(dataSource());
        return car;
    }
}

调用

package com.lirui.carconfig;


import org.springframework.beans.factory.annotation.Autowired;

import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;


public class Car {
    private Engine engine;
    private GPS gps;
    private Radio radio;
    private DataSource dataSource;


    public void setEngine(Engine engine) {
        this.engine = engine;
    }

    public void setGps(GPS gps) {
        this.gps = gps;
    }

    public void setRadio(Radio radio) {
        this.radio = radio;
    }

    public void setDataSource(DataSource dataSource) {
        this.dataSource = dataSource;
    }


    public void drive() {
        // 使用 DataSource 获取数据库连接并执行查询
        String sql = "SELECT id, ui_path, menu_type FROM t_sys_resource";
        try (Connection connection = dataSource.getConnection();
             PreparedStatement statement = connection.prepareStatement(sql);
             ResultSet resultSet = statement.executeQuery()) {

            // 遍历查询结果
            while (resultSet.next()) {
                int id = resultSet.getInt("id");
                String name = resultSet.getString("ui_path");
                String email = resultSet.getString("menu_type");

                System.out.println("ID: " + id + ", ui_path: " + name + ", menu_type: " + email);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        System.out.println("引擎" + engine.getType());
        gps.navigate();
        radio.playMusic();
    }
}

主函数

package com.lirui.carconfig;

import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Main {

    public static void main(String[] args) {
        // 使用 Java 配置类来初始化 Spring 容器
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);

    // 获取 Car 实例，依赖项会自动注入
        Car car = context.getBean(Car.class);
        car.drive();

        context.close();
    }
}