SpringBoot 數據篇之使用JDBC

簡介

Spring Data 包含對 JDBC 的存儲庫支持，並將自動爲 CrudRepository 上的方法生成 SQL。對於更高級的查詢，提供了 @Query 註解。

當 classpath 上存在必要的依賴項時，Spring Boot 將自動配置 Spring Data 的 JDBC 存儲庫。它們能夠經過 spring-boot-starter-data-jdbc 的單一依賴項添加到項目中。若有必要，能夠經過將 @EnableJdbcRepositories 批註或 JdbcConfiguration 子類添加到應用程序來控制 Spring Data JDBC 的配置。

API

spring-boot-starter-data-jdbc 引入了 spring-jdbc ，其 JDBC 特性就是基於 spring-jdbc。

而 spring-jdbc 最核心的 API 無疑就是 JdbcTemplate ，能夠說全部的 JDBC 數據訪問，幾乎都是圍繞着這個類去工做的。

Spring 對數據庫的操做在 Jdbc 層面作了深層次的封裝，利用依賴注入，把數據源配置裝配到JdbcTemplate 中，再由 JdbcTemplate 負責具體的數據訪問。

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

• execute 方法：能夠用於執行任何 SQL 語句，通常用於執行 DDL 語句；
• update 方法及 batchUpdate 方法： update 方法用於執行新增、修改、刪除等語句； batchUpdate 方法用於執行批處理相關語句；
• query 方法及 queryForXXX 方法：用於執行查詢相關語句；
• call 方法：用於執行存儲過程、函數相關語句。

爲了方便演示，如下增刪改查操做都圍繞一個名爲 user 的表（該表的主鍵 id 是自增序列）進行，該表的數據實體以下：

public class User {
    private Integer id;
    private String name;
    private Integer age;

    // 省略 getter/setter
}

數據實體只要是一個純粹的 Java Bean 便可，無需任何註解修飾。

execute

使用 execute 執行 DDL 語句，建立一個名爲 test 的數據庫，並在此數據庫下新建一個名爲 user 的表。

public void recreateTable() {
    jdbcTemplate.execute("DROP DATABASE IF EXISTS test");
    jdbcTemplate.execute("CREATE DATABASE test");
    jdbcTemplate.execute("USE test");
    jdbcTemplate.execute("DROP TABLE if EXISTS user");
    jdbcTemplate.execute("DROP TABLE if EXISTS user");
    // @formatter:off
    StringBuilder sb = new StringBuilder();
    sb.append("CREATE TABLE user (id int (10) unsigned NOT NULL AUTO_INCREMENT,\n")
        .append("name varchar (64) NOT NULL DEFAULT '',\n")
        .append("age tinyint (3) NOT NULL DEFAULT 0,\n")
        .append("PRIMARY KEY (ID));\n");
    // @formatter:on
    jdbcTemplate.execute(sb.toString());
}

update

新增數據

public void insert(String name, Integer age) {
    jdbcTemplate.update("INSERT INTO user(name, age) VALUES(?, ?)", name, age);
}

刪除數據

public void delete(String name) {
    jdbcTemplate.update("DELETE FROM user WHERE name = ?", name);
}

修改數據

public void update(User user) {
    jdbcTemplate.update("UPDATE USER SET name=?, age=? WHERE id=?", user.getName(), user.getAge(), user.getId());
}

批處理

public void batchInsert(List<User> users) {
    String sql = "INSERT INTO user(name, age) VALUES(?, ?)";

    List<Object[]> params = new ArrayList<>();

    users.forEach(item -> {
        params.add(new Object[] {item.getName(), item.getAge()});
    });
    jdbcTemplate.batchUpdate(sql, params);
}

query

查單個對象

public User queryByName(String name) {
    try {
        return jdbcTemplate
            .queryForObject("SELECT * FROM user WHERE name = ?", new BeanPropertyRowMapper<>(User.class), name);
    } catch (EmptyResultDataAccessException e) {
        return null;
    }
}

查多個對象

public List<User> list() {
    return jdbcTemplate.query("select * from USER", new BeanPropertyRowMapper(User.class));
}

獲取某個記錄某列或者 count、avg、sum 等函數返回惟一值

public Integer count() {
    try {
        return jdbcTemplate.queryForObject("SELECT COUNT(*) FROM user", Integer.class);
    } catch (EmptyResultDataAccessException e) {
        return null;
    }
}

實戰

配置數據源

在 src/main/resource 目錄下添加 application.properties 配置文件，內容以下：

spring.datasource.url = jdbc:mysql://localhost:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8&useSSL=false
spring.datasource.username = root
spring.datasource.password = root
spring.datasource.driver-class-name = com.mysql.cj.jdbc.Driver

須要根據實際狀況，替換 url 、 username 、 password 。

注入 JdbcTemplate

@Service
public class UserDAOImpl implements UserDAO {

    private JdbcTemplate jdbcTemplate;

    @Autowired
    public UserDAOImpl(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
    
    // ...
}

歡迎歡迎學Java的朋友們加入java架構交流： 855835163 羣內提供免費的Java架構學習資料（裏面有高可用、高併發、高性能及分佈式、Jvm性能調優、Spring源碼，MyBatis，Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多個知識點的架構資料）合理利用本身每一分每一秒的時間來學習提高本身，不要再用"沒有時間「來掩飾本身思想上的懶惰！趁年輕，使勁拼，給將來的本身一個交代！