SpringBoot簡單使用SpringData的jdbc和durid

更新時間：2021年06月21日 08:40:15 作者：冷血～多好

今天給大家?guī)淼氖顷P(guān)于Java的相關(guān)知識,文章圍繞著SpringBoot簡單使用SpringData的jdbc和durid,文中有非常詳細(xì)的介紹及代碼示例,需要的朋友可以參考下

SpringData的jdbc和durid

創(chuàng)建一個項目，勾選以下選項

項目構(gòu)建完成后pom.xml已導(dǎo)入（springboot默認(rèn)導(dǎo)入數(shù)據(jù)庫驅(qū)動為8.0，要使用低版本需要手動改版本）

編寫yaml配置文件連接數(shù)據(jù)庫；

spring:
  datasource:
    username: root
    password: 123
    url: jdbc:mysql://localhost:3306/mybatis?useUnicode=true&characterEncoding=utf-8
    driver-class-name: com.mysql.jdbc.Driver
    #springBoot數(shù)據(jù)庫驅(qū)動默認(rèn)為mysql8.0版本，使用8.0以下版本的數(shù)據(jù)庫需要在pom.xml手動更改數(shù)據(jù)庫驅(qū)動版本

因為SpringBoot已經(jīng)默認(rèn)進(jìn)行了自動配置；去測試類測試一下

@Test
    void contextLoads() throws SQLException {
 
          //查看一下默認(rèn)的數(shù)據(jù)源 :class com.zaxxer.hikari.HikariDataSource
        System.out.println(dataSource.getClass());
 
        //獲得數(shù)據(jù)庫連接
        Connection connection=dataSource.getConnection();
        System.out.println(connection);
 
        //xxxx Template:SpringBoot 已經(jīng)配置好模板bean,拿來即用 CRUD
 
        //關(guān)閉
        connection.close();
 
    }

查看控制臺，輸出為：

class com.zaxxer.hikari.HikariDataSource

說明沒有問題

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

可以使用 spring.datasource.type 指定自定義的數(shù)據(jù)源類型，值為要使用的連接池實現(xiàn)的完全限定名。

有了數(shù)據(jù)庫連接，就可以 CRUD 操作數(shù)據(jù)庫了。使用對象 JdbcTemplate進(jìn)行操作。
即使不使用第三方第數(shù)據(jù)庫操作框架，如 MyBatis等，Spring 本身也對原生的JDBC 做了輕量級的封裝，即JdbcTemplate。
數(shù)據(jù)庫操作的所有 CRUD 方法都在 JdbcTemplate 中。

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

execute方法：可以用于執(zhí)行任何SQL語句，一般用于執(zhí)行DDL語句；
update方法及batchUpdate方法：update方法用于執(zhí)行新增、修改、刪除等語句；batchUpdate方法用于執(zhí)行批處理相關(guān)語句；
query方法及queryForXXX方法：用于執(zhí)行查詢相關(guān)語句；
call方法：用于執(zhí)行存儲過程、函數(shù)相關(guān)語句。

然后進(jìn)行編寫測試類，進(jìn)行crud

創(chuàng)建一個控制類,JDBCController.java

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 {
 
     @Autowired
    JdbcTemplate jdbcTemplate;
 
 
     //查詢數(shù)據(jù)庫的所有信息
    //沒有實體類，數(shù)據(jù)庫中的東西，怎么獲?。縨ap
    @GetMapping("userList")
    public List<Map<String,Object>> userList(){
        String sql="select*from user";
        List<Map<String,Object>> mapList=jdbcTemplate.queryForList(sql);
        return mapList;
    }
 
    //添加一個用戶
    @GetMapping("/addUser")
    public String addUser(){
        String sql="insert into mybatis.user(name,pwd) values('笑','123456')";
       int n= jdbcTemplate.update(sql);
        return String.valueOf(n);
    }
 
 
 
    //更改一個用戶
    @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] ="小明2";
        objects[1] ="456";
        int n= jdbcTemplate.update(sql,objects);
        return String.valueOf(n);
    }
 
    //刪除一個用戶
    @GetMapping("/deleteUser/{id}")
    public String deleteUser(@PathVariable("id") int id){
        String sql="delete from mybatis.user where id=?";
        int n= jdbcTemplate.update(sql,id);
        return String.valueOf(n);
    }
 
 
}

創(chuàng)建一個數(shù)據(jù)庫：mybatis

然后創(chuàng)建數(shù)據(jù)表：

DROP TABLE IF EXISTS `user`;
CREATE TABLE `user`  (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(25) CHARACTER SET gbk COLLATE gbk_chinese_ci NULL DEFAULT NULL,
  `pwd` varchar(25) CHARACTER SET gbk COLLATE gbk_chinese_ci NULL DEFAULT NULL,
  PRIMARY KEY (`id`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 18 CHARACTER SET = gbk COLLATE = gbk_chinese_ci ROW_FORMAT = Compact;
 
-- ----------------------------
-- Records of user
-- ----------------------------
INSERT INTO `user` VALUES (3, '小黑', '789');
INSERT INTO `user` VALUES (4, '可可2', '151');
INSERT INTO `user` VALUES (5, '阿毛', '4566977');
INSERT INTO `user` VALUES (6, '小明', 'cafa1414f');
INSERT INTO `user` VALUES (7, '嘻嘻3', '101112');
INSERT INTO `user` VALUES (8, '很愛很愛你', '101112');
INSERT INTO `user` VALUES (9, '小霞', '159');
INSERT INTO `user` VALUES (10, '嘻嘻5', '101112');
INSERT INTO `user` VALUES (11, '陳', 'dad45');
INSERT INTO `user` VALUES (12, '陳2', 'd2ad45');
INSERT INTO `user` VALUES (13, '小明', '123456');
INSERT INTO `user` VALUES (14, '小明2', '456');
INSERT INTO `user` VALUES (17, '阿毛', '4566977');
 
SET FOREIGN_KEY_CHECKS = 1;

然后啟動服務(wù)，在瀏覽器打開：http://localhost:8080/userList

其它更改，刪除，添加操作也是如此，

Druid 是阿里巴巴開源平臺上一個數(shù)據(jù)庫連接池實現(xiàn)，結(jié)合了 C3P0、DBCP 等 DB 池的優(yōu)點，同時加入了日志監(jiān)控. Druid 可以很好的監(jiān)控 DB 池連接和 SQL 的執(zhí)行情況，天生就是針對監(jiān)控而生的 DB 連接池.

然后更改application.yml

spring:
  datasource:
    username: root
    password: 123
    url: jdbc:mysql://localhost:3306/mybatis?useUnicode=true&characterEncoding=utf-8
    driver-class-name: com.mysql.jdbc.Driver
    #springBoot數(shù)據(jù)庫驅(qū)動默認(rèn)為mysql8.0版本，使用8.0以下版本的數(shù)據(jù)庫需要在pom.xml手動更改數(shù)據(jù)庫驅(qū)動版本
 
    #切換為阿里巴巴druid源
    type: com.alibaba.druid.pool.DruidDataSource
    # 自定義數(shù)據(jù)源
 
 
      #Spring Boot 默認(rèn)是不注入這些屬性值的，需要自己綁定
      #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

然后在pom.xml導(dǎo)入依賴

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

再次在測試類測試

發(fā)現(xiàn)數(shù)據(jù)源已更改為阿里的：class com.alibaba.druid.pool.DruidDataSource

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

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

新建一個配置類：DruidConfig

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.sql.DataSource;
import java.util.HashMap;
import java.util.Map;
 
@Configuration
public class DruidConfig {
 
    @ConfigurationProperties(prefix = "spring.datasource")
    @Bean
    public DataSource druidDataSource(){
 
        return  new DruidDataSource();
    }
 
 
    //后臺監(jiān)控：web.xml,ServletRegistrationBean
    //因為SpringBoot 內(nèi)置了servlet容器，所以沒有web.xml,替代方法
    //訪問：http://localhost:8080/druid
    @Bean
    public ServletRegistrationBean statViewServlet(){
       ServletRegistrationBean bean=   new ServletRegistrationBean<>(new StatViewServlet(),"/druid/*");
 
 
       //后臺需要有人登錄，賬號密碼配置
        HashMap<Object,Object>  initParameters=new HashMap<>();
        initParameters.put("loginUsername","admin");//登錄key 是固定的loginUserUsername loginPassword
        initParameters.put("loginPassword","123456");
 
        //允許誰可以訪問
        initParameters.put("allow","");
        //禁止誰能訪問  initParameters.put("allow","121.0.0.1");
 
        bean.setInitParameters(initParameters);//設(shè)置初始化參數(shù)
         return bean;
 
    }
 
    //filter
    @Bean
    public FilterRegistrationBean webStatFilter(){
 
        FilterRegistrationBean bean=new FilterRegistrationBean();
 
        bean.setFilter(new WebStatFilter());
        //可以過濾哪些請求呢？
        Map<String,String> initParameters=new HashMap<>();
 
        //這些東西不進(jìn)行統(tǒng)計
        initParameters.put("exclusions","*.js,*.css,/druid/*");
 
        bean.setInitParameters(initParameters);
 
       return  bean;
    }
 
}

然后啟動項目

瀏覽器打開：

http://localhost:8080/druid，進(jìn)入登陸頁面，填寫登陸賬號，密碼