SpringBoot中怎么利用JDBC對數據庫進行操作

這篇文章將為大家詳細講解有關SpringBoot中怎么利用JDBC對數據庫進行操作，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

一、JDBC簡介

JDBC（Java Data Base Connectivity，Java 數據庫連接）,說白了 JDBC 就是一套 Java 訪問數據庫的 API 規范；Spring Boot 支持了主流的 ORM 框架：MyBatis、Hibernate 和 Spring JDBC，幾種 ORM 在不同的場景下各有優勢，在 Spring Boot 體系內都有對應的 Starter 包以方便集成

• 直接在Java中使用JDBC的步驟，比價復雜，需要7步完成:

try {
    // 1、加載數據庫驅動
    Class.forName(driver);
    // 2、獲取數據庫連接
    conn = DriverManager.getConnection(url, username, password);
    // 3、獲取數據庫操作對象
    stmt = conn.createStatement();
    // 4、定義操作的 SQL 語句
    String sql = "select * from user where id = 6";
    // 5、執行數據庫操作
    rs = stmt.executeQuery(sql);
    // 6、獲取并操作結果集
    while (rs.next()) {
    // 解析結果集
    }
} catch (Exception e) {
    // 日志信息
} finally {
    // 7、關閉資源
}

通過上面的示例可以看出直接使用 JDBC 來操作數據庫比較復雜，因此后期在 JDBC 的基礎上又發展出了很多著名的 ORM 框架，其中最為流行的是 Hibernate、MyBatis 和 Spring JDBC，這里主要了解一下 Spring JDBC 在 Spring Boot 中的使用

二、單數據源操作示例

Spring Boot 集成 JDBC 很簡單，需要引入依賴并做基礎配置即可，在開發項目之前需要先創建表，作為項目演示使用。設計一個 User 用戶表，有 id、name、password、age 等字段，對應的 SQL 腳本如下：

DROP TABLE IF EXISTS `users`;
CREATE TABLE `users` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵id',
  `name` varchar(32) DEFAULT NULL COMMENT '用戶名',
  `password` varchar(32) DEFAULT NULL COMMENT '密碼',
  `age`  int DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

1. 添加配置

• 添加依賴包：

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

• 演示項目中使用 MySQL 作為數據庫，因此項目中需要引入 MySQL 驅動包，同時引入 spring-boot-starter-jdbc。打開 pom.xml 文件，按下快捷鍵：Ctrl + Alt + SHIFT + U，或者單擊右鍵，選擇 Diagrams | Show Dependencies 選項，查看項目依賴類圖。

• 彈出“類圖”對話框后，滾動鼠標放大查看，發現 spring-boot-starter-jdbc 直接依賴于 HikariCP 和 spring-jdbc。

• HikariCP 是 Spring Boot 2.0 默認使用的數據庫連接池，也是傳說中最快的數據庫連接池。

• spring-jdbc 是 Spring 封裝對 JDBC 操作的工具包。

• 數據源的配置

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

值得注意的是，在 Spring Boot 2.1.0 中，com.mysql.jdbc.Driver 已經過期，推薦使用 com.mysql.cj.jdbc.Driver。

2. 實體類

• 創建表對應的實體類：

public class User  {
    private Long id;
    private String name;
    private String password;
    private int age;

    public User(String name, String password, int age) {
        this.name = name;
        this.password = password;
        this.age = age;
    }
    // 省略 getter setter
}

3. 封裝 Repository

• 創建 UserRepository 定義我們常用的增刪改查接口；

public interface UserRepository  {
    int save(User user);
    int update(User user);
    int delete(long id);
    List<User> findALL();
    User findById(long id);
}

• 創建 UserRepositoryImpl 類實現 UserRepository 類接口;類上使用 @Repository 注解用于標注數據訪問組件，同時在類中注入 JdbcTemplate，其是 Spring 操作 JDBC 提供的工具類。

@Repository
public class UserRepositoryImpl implements UserRepository {
    @Autowired
    private JdbcTemplate jdbcTemplate;
}

• 接下來封裝保存用戶/更新用戶信息/刪除用戶信息/用戶id查詢/獲取用戶列表的方法

@Override
public int save(User user) {
    return jdbcTemplate.update("INSERT INTO users(name, password, age) values(?, ?, ?)",
          user.getName(), user.getPassword(), user.getAge());
}

@Override
public int update(User user) {
    return jdbcTemplate.update("UPDATE users SET name = ? , password = ? , age = ? WHERE id=?",
           user.getName(), user.getPassword(), user.getAge(), user.getId());
}

@Override
public int delete(long id) {
    return jdbcTemplate.update("DELETE FROM users where id = ? ",id);
}

@Override
public User findById(long id) {
    return jdbcTemplate.queryForObject("SELECT * FROM users WHERE id=?", new Object[] { id }, new BeanPropertyRowMapper<User>(User.class));
}

@Override
public List<User> findALL() {
    return jdbcTemplate.query("SELECT * FROM users", new UserRowMapper());
    // return jdbcTemplate.query("SELECT * FROM users", new BeanPropertyRowMapper(User.class));
}

這里使用了 new BeanPropertyRowMapper<User>(User.class) 對返回的數據進行封裝，它可自動將一行數據映射到指定類的實例中，首先將這個類實例化，然后通過名稱匹配的方式，映射到屬性中去。

findALL() 使用了一個新的方式來封裝結果集的返回，創建一個內部類 UserRowMapper。 UserRowMapper 繼承了 RowMapper，RowMapper 可以將數據中的每一行數據封裝成用戶定義的類，實現 RowMapper 接口覆蓋 mapRow 方法，在 mapRow 方法封裝對數據的返回處理。通過上面代碼可以看出 UserRowMapper 循環遍歷了查詢返回的結果集，遍歷的同時按照屬性進行賦值。這樣在查詢使用時只需要傳入 new UserRowMapper() 即可自動解析返回數據。

class UserRowMapper implements RowMapper<User> {
    @Override
    public User mapRow(ResultSet rs, int rowNum) throws SQLException {
        User user = new User();
        user.setId(rs.getLong("id"));
        user.setName(rs.getString("name"));
        user.setPassword(rs.getString("password"));
        user.setAge(rs.getInt("age"));
    }
}

4. 測試

• 接下里我們對封裝好的 UserRepository 進行測試，測試 UserRepository 中的各個方法是否正確。創建 UserRepositoryTests 類，將 userRepository 注入到類中。

@RunWith(SpringRunner.class)
@SpringBootTest
public class UserRepositoryTests {
    @Autowired
    private UserRepository userRepository;
}

//測試插入數據，直接調用 userRepository 對應的 save 方法
@Test
public void testSave() {
    User user =new User("neo","123456",30);
    userRepository.save(user);
}

//按照上面方式分別測試其他方法...

三、多數據源的使用

在項目中使用多個數據源是很常見的情況，Spring Boot 中多數據源的使用需要自行封裝。我們在上面示例項目的基礎上進行改造。

1. 配置文件

• 添加了兩個數據源，一個是 test1 庫，一個是 test2 庫。

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

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

2. 初始化 JDBC

• 在項目啟動的時候讀取配置文件中的信息，并對 JDBC 初始化。

@Configuration
public class DataSourceConfig {
    @Primary
    @Bean(name = "primaryDataSource")
    @Qualifier("primaryDataSource")
    @ConfigurationProperties(prefix="spring.datasource.primary")
    public DataSource primaryDataSource() {
            return DataSourceBuilder.create().build();
    }

    @Bean(name = "secondaryDataSource")
    @Qualifier("secondaryDataSource")
    @ConfigurationProperties(prefix="spring.datasource.secondary")
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name="primaryJdbcTemplate")
    public JdbcTemplate primaryJdbcTemplate (
        @Qualifier("primaryDataSource")  DataSource dataSource ) {
        return new JdbcTemplate(dataSource);
    }

    @Bean(name="secondaryJdbcTemplate")
    public JdbcTemplate  secondaryJdbcTemplate(
            @Qualifier("secondaryDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }
}

這段代碼表示在啟動的時候根據特定的前綴加載不同的數據源，根據構建好的數據源再創建不同的 JDBC。

3. UserRepository 改造

• 我們對 UserRepository 中的所有方法進行改造，增加一個參數為 JdbcTemplate，如果方法中傳輸了 JdbcTemplate，方法內就會使用傳遞的 JdbcTemplate 進行操作，如果傳遞的 JdbcTemplate 為空，使用默認的 JdbcTemplate 連接操作。

@Repository
public class UserRepositoryImpl implements UserRepository {
    @Autowired
    private JdbcTemplate primaryJdbcTemplate;

    @Override
    public int save(User user,JdbcTemplate jdbcTemplate) {
        if(jdbcTemplate == null){
            jdbcTemplate= primaryJdbcTemplate;
        }
        return jdbcTemplate.update("INSERT INTO users(name, password, age) values(?, ?, ?)",
              user.getName(), user.getPassword(), user.getAge());
    }

  //其他方法省略，詳細內容可以查看源碼
}

4. 多數據源測試

• 測試類中注入了兩個不同數據源的 JdbcTemplate，同時注入 UserRepository。測試使用不同的 JdbcTemplate 插入兩條數據，查看兩個數據庫中是否都保存成功。測試前請先創建 test1 和 test2 數據庫，以及兩個數據庫中的用戶表。

@RunWith(SpringRunner.class)
@SpringBootTest
public class UserRepositoryTests {
    @Autowired
    private UserRepository userRepository;
    @Autowired
    private JdbcTemplate primaryJdbcTemplate;
    @Autowired
    private JdbcTemplate secondaryJdbcTemplate;

    @Test
    public void testSave() {
        User user =new User("smile","123456",30);
        userRepository.save(user,primaryJdbcTemplate);
        userRepository.save(user,secondaryJdbcTemplate);
    }
}

執行 testSave() 成功后，登錄 test1 和 test 2 數據庫查看 user 表，都存在一條 name 為 smile 的用戶信息，說明多數據源插入數據成功，其他方法的測試大體相同。這樣在項目中，我們想使用哪個數據源操作數據庫時，只需要傳入數據源對應的 JdbcTemplate 實例即可。

關于SpringBoot中怎么利用JDBC對數據庫進行操作就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。