SpringBoot中Mybatis+Druid數(shù)據(jù)訪問過程是怎樣的

本篇內(nèi)容主要講解“SpringBoot中Mybatis+Druid數(shù)據(jù)訪問過程是怎樣的”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學(xué)習(xí)“SpringBoot中Mybatis+Druid數(shù)據(jù)訪問過程是怎樣的”吧!

1、簡介

對于數(shù)據(jù)訪問層，無論是SQL(關(guān)系型數(shù)據(jù)庫) 還是NOSQL(非關(guān)系型數(shù)據(jù)庫)，SpringBoot 底層都是采用 SpringData 的方式進行統(tǒng)一處理。

Spring Boot 底層都是采用 SpringData 的方式進行統(tǒng)一處理各種數(shù)據(jù)庫，SpringData也是Spring中與SpringBoot、SpringCloud 等齊名的知名項目。

SpingData 官網(wǎng)：https://spring.io/projects

數(shù)據(jù)庫相關(guān)的啟動器 ： 可以參考官方文檔：https://docs.spring.io/springboot/docs/2.1.7.RELEASE/reference/htmlsingle/#using-boot-starter

2、JDBC

新建一個項目測試：springboot-data; 引入相應(yīng)的模塊！基礎(chǔ)模塊

項目建好之后，發(fā)現(xiàn)自動幫我們導(dǎo)入了如下的啟動器：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>

實現(xiàn)數(shù)據(jù)庫的訪問

1. 先連接上數(shù)據(jù)庫 ， 直接使用IDEA連接即可【操作】

2. SpringBoot中，我們只需要簡單的配置就可以實現(xiàn)數(shù)據(jù)庫的連接了；

我們使用yaml的配置文件進行操作！

spring:
  datasource:
    username: root
    password: 123456
    #?serverTimezone=UTC解決時區(qū)的報錯
    url: jdbc:mysql://localhost:3306/mybatis?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8

配置完這一些東西后，就可以直接去使用了，因為SpringBoot已經(jīng)默認幫我們進行了自動配置；我們?nèi)y試類測試一下

package com.kk;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

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

@SpringBootTest
class Springboot04DataApplicationTests {

    @Autowired
    DataSource dataSource;
    @Test
    void contextLoads() throws SQLException {
        //查看默認的數(shù)據(jù)源 class com.zaxxer.hikari.HikariDataSource   dbcp
        System.out.println(dataSource.getClass());
        //獲得數(shù)據(jù)庫連接
        Connection connection = dataSource.getConnection();
        System.out.println(connection);
        connection.close();


    }

}

在運行的時候可能會遇到的Bug

SpringBoot 中 Invalid character found in the request target 異常

在啟動類中添加

@Bean
public ConfigurableServletWebServerFactory webServerFactory() {
    TomcatServletWebServerFactory factory = new TomcatServletWebServerFactory();
    factory.addConnectorCustomizers(new TomcatConnectorCustomizer() {
        @Override
        public void customize(Connector connector) {
            connector.setProperty("relaxedQueryChars", "|{}[]");
        }
    });
    return factory;
}

輸出結(jié)果：

可以看到它默認給我們配置的數(shù)據(jù)源為 : class com.zaxxer.hikari.HikariDataSource ， 我們并沒有手動配置

全局搜索一下，找到數(shù)據(jù)源的所有自動配置都在 ：DataSourceProperties 文件下；這里自動配置的原理以及能配置哪些屬性？

1. Spring Boot 2.1.7 默認使用 com.zaxxer.hikari.HikariDataSource 數(shù)據(jù)源，

2. 而以前版本，如 Spring Boot 1.5 默認使用 org.apache.tomcat.jdbc.pool.DataSource 作為數(shù)據(jù)源；

HikariDataSource 號稱 Java WEB 當前速度最快的數(shù)據(jù)源，相比于傳統(tǒng)的 C3P0 、DBCP、Tomcat jdbc 等連接池更加優(yōu)秀；

有了數(shù)據(jù)庫連接，顯然就可以 CRUD 操作數(shù)據(jù)庫了。

3、CRUD操作

1、有了數(shù)據(jù)源(com.zaxxer.hikari.HikariDataSource)，可以拿到數(shù)據(jù)庫連接(java.sql.Connection)，有了連接，就可以使用連接和原生的 JDBC 語句來操作數(shù)據(jù)庫

2、即使不使用第三方第數(shù)據(jù)庫操作框架，如 MyBatis等，Spring 本身也對原生的JDBC 做了輕量級的封裝，即 org.springframework.jdbc.core.JdbcTemplate。

3、數(shù)據(jù)庫操作的所有 CRUD 方法都在 JdbcTemplate 中。

4、Spring Boot 不僅提供了默認的數(shù)據(jù)源，同時默認已經(jīng)配置好了 JdbcTemplate 放在了容器中，程序員只需自己注入即可使用

5、JdbcTemplate 的自動配置原理是依賴 org.springframework.boot.autoconfigure.jdbc 包下的 org.springframework.boot.autoconfigure.jdbc.JdbcTemplateAutoConfiguration 類

JdbcTemplate主要提供以下幾類方法：

1. execute方法：可以用于執(zhí)行任何SQL語句，一般用于執(zhí)行DDL語句；

2. update方法及batchUpdate方法：update方法用于執(zhí)行新增、修改、刪除等語句；batchUpdate方法用于執(zhí)行批處理相關(guān)語句；

3. query方法及queryForxxx方法：用于執(zhí)行查詢相關(guān)語句；

4. call方法：用于執(zhí)行存儲過程、函數(shù)相關(guān)語句。

測試：

package com.kk.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;
import java.util.Map;

@RestController
public class JDBCController {
    
    //JdbcTemplate 是 core 包的核心類，用于簡化 JDBC操作，還能避免一些常見的錯誤，如忘記關(guān)閉數(shù)據(jù)庫連接
    //Spring Boot 默認提供了數(shù)據(jù)源，默認提供了 org.springframework.jdbc.core.JdbcTemplate
    //JdbcTemplate 中會自己注入數(shù)據(jù)源，使用起來也不用再自己來關(guān)閉數(shù)據(jù)庫連接
    @Autowired
    JdbcTemplate jdbcTemplate;
    
   	//查詢數(shù)據(jù)庫的所有信息
    //沒有實體類，數(shù)據(jù)庫中的東西怎么獲取? Map
   	//List 中的1個 Map 對應(yīng)數(shù)據(jù)庫的 1行數(shù)據(jù)
    //Map 中的 key 對應(yīng)數(shù)據(jù)庫的字段名，value 對應(yīng)數(shù)據(jù)庫的字段值
    @GetMapping("/userList")
    public List<Map<String ,Object>> userList(){
        String sql="select * from user";
        List<Map<String, Object>> list_maps = jdbcTemplate.queryForList(sql);
        return list_maps;
    }

    @GetMapping("/addUser")
    public String addUser(){
        String sql="insert into mybatis.user(id,name,pwd) values(2,'dabai','123456')";
       jdbcTemplate.update(sql);
        return "update-ok";
    }

    @GetMapping("/updateUser/{id}")
    public String updateUser(@PathVariable("id") int id){
        String sql="update mybatis.user set name=?,pwd=? where id="+id;
        //封裝
        Object[] objects = new Object[2];
        objects[0]="xiaobai";
        objects[1]="9999999";
        jdbcTemplate.update(sql,objects);
        return "updateUser-ok";
    }

    @GetMapping("/deleteUser/{id}")
    public String deleteUser(@PathVariable("id") int id){
        String sql="delete from mybatis.user where id=?";
        jdbcTemplate.update(sql,id);
        return "deleteUser-ok";
    }
}

測試成功！

原理探究 ：

org.springframework.boot.autoconfigure.jdbc.DataSourceConfiguration 數(shù)據(jù)源配置類作用 ：根據(jù)邏輯判斷之后，添加數(shù)據(jù)源；

SpringBoot默認支持以下數(shù)據(jù)源：

• com.zaxxer.hikari.HikariDataSource （Spring Boot 2.0 以上，默認使用此數(shù)據(jù)源）

• org.apache.tomcat.jdbc.pool.DataSource

• org.apache.commons.dbcp2.BasicDataSource

可以使用 spring.datasource.type 指定自定義的數(shù)據(jù)源類型，值為要使用的連接池實現(xiàn)的完全限定名。默認情況下，它是從類路徑自動檢測的。

	 @Configuration
    @ConditionalOnMissingBean({DataSource.class})
    @ConditionalOnProperty(
        name = {"spring.datasource.type"}
    )
    static class Generic {
        Generic() {
        }

        @Bean
        public DataSource dataSource(DataSourceProperties properties) {
            return properties.initializeDataSourceBuilder().build();
        }
    }

4、自定義數(shù)據(jù)源 DruidDataSource

DRUID 簡介

• Druid 是阿里巴巴開源平臺上一個數(shù)據(jù)庫連接池實現(xiàn)，結(jié)合了 C3P0、DBCP、PROXOOL 等 DB 池的優(yōu)點，同時 加入了日志監(jiān)控。

• Druid 可以很好的監(jiān)控 DB 池連接和 SQL 的執(zhí)行情況，天生就是針對監(jiān)控而生的 DB 連接池。

• Spring Boot 2.0 以上默認使用 Hikari 數(shù)據(jù)源，可以說 Hikari 與 Driud 都是當前 Java Web 上最優(yōu)秀的數(shù)據(jù)源，我們 來重點介紹 Spring Boot 如何集成 Druid 數(shù)據(jù)源，如何實現(xiàn)數(shù)據(jù)庫監(jiān)控。

*com.alibaba.druid.pool.DruidDataSource 基本配置參數(shù)如下：*

引入數(shù)據(jù)源

<!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.6</version>
</dependency>

查看項目依賴，導(dǎo)入成功！

切換數(shù)據(jù)源；

之前已經(jīng)說過 Spring Boot 2.0 以上默認使用 com.zaxxer.hikari.HikariDataSource 數(shù)據(jù)源，可以通過 spring.datasource.type 指定數(shù)據(jù)源。

type: com.alibaba.druid.pool.DruidDataSource

設(shè)置數(shù)據(jù)源連接初始化大小、最大連接數(shù)、等待時間、最小連接數(shù) 等設(shè)置項；

#Spring Boot 默認是不注入這些屬性值的，需要自己綁定
#druid 數(shù)據(jù)源專有配置
initialSize: 5
minIdle: 5
maxActive: 20
maxWait: 60000
timeBetweenEvictionRunsMillis: 60000
minEvictableIdleTimeMillis: 300000
validationQuery: SELECT 1 FROM DUAL
testWhileIdle: true
testOnBorrow: false
testOnReturn: false
poolPreparedStatements: true
#配置監(jiān)控統(tǒng)計攔截的filters，stat:監(jiān)控統(tǒng)計、log4j：日志記錄、wall：防御sql注入
#如果允許時報錯  java.lang.ClassNotFoundException: org.apache.log4j.Priority
#則導(dǎo)入 log4j 依賴即可，Maven 地址： https://mvnrepository.com/artifact/log4j/log4j
filters: stat,wall,log4j
maxPoolPreparedStatementPerConnectionSize: 20
useGlobalDataSourceStat: true
connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=500

log4****日志依賴

<!-- https://mvnrepository.com/artifact/log4j/log4j -->
<dependency>
    <groupId>log4j</groupId>
    <artifactId>log4j</artifactId>
    <version>1.2.17</version>
</dependency>

測試

public class SpringbootDemoDataApplicationTests {

    //注入數(shù)據(jù)源
    @Autowired
    DataSource dataSource;

    @Test
    public void contextLoads() throws SQLException {
        //看一下默認數(shù)據(jù)源
        System.out.println(dataSource.getClass());
        //獲得連接
        Connection connection =   dataSource.getConnection();
        System.out.println(connection);

        DruidDataSource druidDataSource = (DruidDataSource) dataSource;
        System.out.println("druidDataSource 數(shù)據(jù)源最大連接數(shù)：" + druidDataSource.getMaxActive());
        System.out.println("druidDataSource 數(shù)據(jù)源初始化連接數(shù)：" + druidDataSource.getInitialSize());

        //關(guān)閉連接
        connection.close();
    }

}

測試成功！

1、配置 Druid 數(shù)據(jù)源監(jiān)控

Druid 數(shù)據(jù)源具有監(jiān)控的功能，并提供了一個web界面方便用戶查看，類似安裝路由器 時，它也提供了一個默認的 web 頁面。

所以第一步需要設(shè)置 Druid 的后臺管理頁面，比如登錄賬號、密碼等配置后臺管理；

package com.kk.config;

import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.servlet.Filter;
import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;

@Configuration
public class DruidConfig {

    @ConfigurationProperties(prefix = "spring.datasource")  //關(guān)聯(lián)application.yaml中的spring.datasource
    @Bean
    public DataSource druidDataSource(){
        return new DruidDataSource();
    }

    //配置 Druid 監(jiān)控管理后臺的Servlet；
    //內(nèi)置 Servler 容器時沒有web.xml文件，所以使用 Spring Boot 的注冊 Servlet 方式
    @Bean
    public ServletRegistrationBean statViewServlet() {
        ServletRegistrationBean bean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");

        Map<String, String> initParams = new HashMap<>();
        initParams.put("loginUsername", "admin"); //后臺管理界面的登錄賬號
        initParams.put("loginPassword", "123456"); //后臺管理界面的登錄密碼

        //后臺允許誰可以訪問
        //initParams.put("allow", "localhost")：表示只有本機可以訪問
        //initParams.put("allow", "")：為空或者為null時，表示允許所有訪問
        initParams.put("allow", "");
        //deny：Druid 后臺拒絕誰訪問
        //initParams.put("kuangshen", "192.168.1.20");表示禁止此ip訪問

        //設(shè)置初始化參數(shù)
        bean.setInitParameters(initParams);
        return bean;
        //這些參數(shù)可以在 com.alibaba.druid.support.http.StatViewServlet 的父類 com.alibaba.druid.support.http.ResourceServlet 中找到
    }



    //filter
    @Bean
    public FilterRegistrationBean webStatFilter(){
        FilterRegistrationBean<Filter> bean = new FilterRegistrationBean<>();
        bean.setFilter(new WebStatFilter());

        //可以過濾哪些請求？
        HashMap<String, String> initParameters = new HashMap<>();
        //這些東西不進行統(tǒng)計
        initParameters.put("exclusions","*.js,*.css,/druid/*");


        bean.setInitParameters(initParameters);
        return bean;
    }
}

測試訪問！ http://localhost:8080/druid/login.html

2、配置 Druid web 監(jiān)控 filter

這個過濾器的作用就是統(tǒng)計 web 應(yīng)用請求中所有的數(shù)據(jù)庫信息，比如 發(fā)出的 sql 語句，sql 執(zhí)行的時間、請求次數(shù)、請求的 url 地址、以及seesion 監(jiān)控、數(shù)據(jù)庫表的訪問次數(shù) 等等。

//filter
@Bean
public FilterRegistrationBean webStatFilter(){
    FilterRegistrationBean<Filter> bean = new FilterRegistrationBean<>();
    bean.setFilter(new WebStatFilter());

    //可以過濾哪些請求？
    HashMap<String, String> initParameters = new HashMap<>();
    //這些東西不進行統(tǒng)計
    initParameters.put("exclusions","*.js,*.css,/druid/*");


    bean.setInitParameters(initParameters);
    return bean;
}

執(zhí)行sql

執(zhí)行sql之后會有記錄

5、SpringBoot 整合mybatis

1. 導(dǎo)入mybatis所需要的依賴

<!-- https://mvnrepository.com/artifact/org.mybatis.spring.boot/mybatis-spring-boot-starter -->
<dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>2.2.0</version>
</dependency>

2.配置數(shù)據(jù)庫連接信息

# 數(shù)據(jù)庫驅(qū)動：
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
# 數(shù)據(jù)源名稱
spring.datasource.name=defaultDataSource
# 數(shù)據(jù)庫連接地址
spring.datasource.url=jdbc:mysql://localhost:3306/mybatis?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC
# 數(shù)據(jù)庫用戶名&密碼：
spring.datasource.username=root
spring.datasource.password=123456

測試一下連接是否成功！

package com.kk;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import javax.sql.DataSource;
import java.sql.SQLException;

@SpringBootTest
class Springboot05MybatisApplicationTests {

    @Autowired
    DataSource dataSource;
    @Test
    void contextLoads() throws SQLException {
        System.out.println(dataSource.getClass());
        System.out.println(dataSource.getConnection());
    }

}

測試成功！

3，創(chuàng)建實體類

package com.kk;

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import javax.sql.DataSource;
import java.sql.SQLException;

@SpringBootTest
class Springboot05MybatisApplicationTests {

    @Autowired
    DataSource dataSource;
    @Test
    void contextLoads() throws SQLException {
        System.out.println(dataSource.getClass());
        System.out.println(dataSource.getConnection());
    }

}

4.配置Mapper接口類

package com.kk.mapper;

import com.kk.pojo.User;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;

import java.util.List;

//這個注解表示 這是一個mybatis 的mapper類
@Mapper  //controller層
@Repository  //spring
public interface UserMapper {


    List<User> queryUserList();

    User queryUserById(int id);

    int addUser(User user);

    int updateUser(User user);

    int deleteUser(int id);

}

5.編寫controller

package com.kk.controller;

import com.kk.mapper.UserMapper;
import com.kk.pojo.User;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
public class UserController {

    @Autowired
    private UserMapper userMapper;

    @GetMapping("/queryUserList")
    public List<User> queryUserList(){
        List<User> userList = userMapper.queryUserList();
        for (User user : userList) {
            System.out.println(user);
        }
        return userList;
    }

    //根據(jù)id選擇用戶
    @GetMapping("/queryUserById")
    public String selectUserById(){
        User user = userMapper.queryUserById(1);
        System.out.println(user);
        return "ok";
    }
    //添加一個用戶
    @GetMapping("/addUser")
    public String addUser(){
        userMapper.addUser(new User(1,"大黃","9999999"));
        userMapper.addUser(new User(3,"大黃","9999999"));
        userMapper.addUser(new User(4,"大黃","9999999"));

        return "ok";
    }
    //修改一個用戶
    @GetMapping("/updateUser")
    public String updateUser(){
        userMapper.updateUser(new User(5,"黃毛","999999"));
        return "ok";
    }
    //根據(jù)id刪除用戶
    @GetMapping("/deleteUser")
    public String deleteUser(){
        userMapper.deleteUser(5);
        return "ok";
    }
}

6.SpringBoot 整合

以前 MyBatis 未與 spring 整合時，配置數(shù)據(jù)源、事務(wù)、連接數(shù)據(jù)庫的賬號、密碼等都是在 myBatis 核心配置文件中進行的
myBatis 與 springboot 整合后，配置數(shù)據(jù)源、事務(wù)、連接數(shù)據(jù)庫的賬號、密碼等就交由 spring 管理。因此，在這里我們即使不使用mybatis配置文件也完全ok！
既然已經(jīng)提供了 myBatis 的映射配置文件，就需要告訴 spring boot 這些文件的位置

# 整合mybatis
# 設(shè)置別名以及設(shè)置能讓spring識別
#指定myBatis的核心配置文件與Mapper映射文件
# 注意：對應(yīng)實體類的路徑
mybatis.type-aliases-package=com.kk.pojo
mybatis.mapper-locations=classpath:mybatis/mapper/*.xml

springboot 官方并沒有提供 myBaits 的啟動器，是 myBatis 官方提供的開發(fā)包來適配的 spring boot，從 pom.xml 文件中的依賴包名也能看出來，并非是以 spring-boot 開頭的；

同理上面全局配置文件中的這兩行配置也是以 mybatis 開頭 而非 spring 開頭也充分說明這些都是 myBatis 官方提供的

從 org.mybatis.spring.boot.autoconfigure.MybatisProperties 中查看所有配置項

@ConfigurationProperties(
    prefix = "mybatis"
)
public class MybatisProperties {
    public static final String MYBATIS_PREFIX = "mybatis";
    private static final ResourcePatternResolver resourceResolver = new PathMatchingResourcePatternResolver();
    private String configLocation;
    private String[] mapperLocations;
    private String typeAliasesPackage;
    private Class<?> typeAliasesSuperType;
    private String typeHandlersPackage;
    private boolean checkConfigLocation = false;
    private ExecutorType executorType;
    private Class<? extends LanguageDriver> defaultScriptingLanguageDriver;
    private Properties configurationProperties;
    @NestedConfigurationProperty
    private Configuration configuration;

到此，相信大家對“SpringBoot中Mybatis+Druid數(shù)據(jù)訪問過程是怎樣的”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！