一文带你学会Spring JDBC的使用

简介

Spring JDBC是基于JDBC的框架，它提供了许多方便的功能去简化JDBC编码的繁琐。它可以自动管理连接、传播事务，同时提供了一种直观且简洁的方式去执行SQL语句，Spring JDBC已成为了Java应用程序中访问数据库的首选。本文将介绍如何使用Spring JDBC去连接数据库、执行SQL查询与更新，并演示一些常见的用例。

步骤

1. 添加依赖

首先，需要添加Spring JDBC的依赖到你的项目中。如果你正在使用Maven，那么可以在pom.xml文件中添加如下依赖：

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-jdbc</artifactId>
    <version>5.3.5</version>
</dependency>

如果你使用Gradle，可以在build.gradle文件中添加如下依赖：

implementation 'org.springframework:spring-jdbc:5.3.5'

2. 配置数据源

在使用Spring JDBC之前，需要先配置数据源。如果你使用的是关系型数据库，可以使用Spring提供的DataSource接口去配置数据源。Spring可以配置各种各样的数据源（例如Druid、HikariCP等），这里我们以连接MySQL为例，配置一个基本的DataSource：

@Bean
public DataSource dataSource() {
    DriverManagerDataSource dataSource = new DriverManagerDataSource();
    dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");
    dataSource.setUrl("jdbc:mysql://localhost:3306/test_db");
    dataSource.setUsername("root");
    dataSource.setPassword("password");

    return dataSource;
}

在这个例子中，我们使用了DriverManagerDataSource，这是一种简单的数据源实现。你也可以使用其他更高级的数据源实现（例如HikariCP），它们可以提供更好的性能和稳定性。

3. 执行查询

完成数据源的配置之后，可以使用Spring JDBC去执行SQL查询。以下是一个简单的例子，展示如何使用Spring JDBC查询数据库中的数据：

@Autowired
private JdbcTemplate jdbcTemplate;

public List<Customer> findAll() {
    String sql = "SELECT * FROM customers";
    RowMapper<Customer> rowMapper = new CustomerRowMapper();

    return jdbcTemplate.query(sql, rowMapper);
}

在这个例子中，我们使用了JdbcTemplate类去执行SQL查询。JdbcTemplate是Spring JDBC中提供的一个核心类，它封装了大量常用的JDBC操作和异常处理，让我们可以更轻松地执行常见的任务。例如，我们可以使用query方法执行SELECT查询，它需要提供一个SQL语句和结果集的映射器（RowMapper），并返回查询结果。

4. 执行更新

除了查询数据之外，Spring JDBC也可以执行SQL更新（INSERT、UPDATE、DELETE等）。以下是一个简单的例子，演示如何通过JdbcTemplate去更新数据库：

@Autowired
private JdbcTemplate jdbcTemplate;

public void update(Customer customer) {
    String sql = "UPDATE customers SET name = ?, email = ? WHERE id = ?";
    jdbcTemplate.update(sql, customer.getName(), customer.getEmail(), customer.getId());
}

在这个例子中，我们使用了update方法去执行SQL更新。update方法需要提供一个SQL语句和SQL语句中占位符的值，并返回更新的记录数。

示例

接下来，演示一下如何通过Spring JDBC去操作MySQL数据库。在这个例子中，我们将展示如何查询、插入、更新和删除数据。

1. 配置数据源

在这个例子中，我们将使用HikariCP作为数据源，我们需要修改之前的数据源配置：

@Bean
public DataSource dataSource() {
    HikariConfig config = new HikariConfig();
    config.setJdbcUrl("jdbc:mysql://localhost:3306/test_db");
    config.setUsername("root");
    config.setPassword("password");
    config.setDriverClassName("com.mysql.cj.jdbc.Driver");

    return new HikariDataSource(config);
}

2. 定义实体类

我们将创建一个实体类User来表示数据库中的一条记录：

public class User {
    private int id;
    private String name;
    private String email;

    // constructors, getters, and setters
}

3. 查询数据

下面是一个查询数据的例子：

@Autowired
private JdbcTemplate jdbcTemplate;

public List<User> findAll() {
    String sql = "SELECT * FROM users";
    RowMapper<User> rowMapper = new BeanPropertyRowMapper<>(User.class);

    return jdbcTemplate.query(sql, rowMapper);
}

在这个例子中，我们使用了BeanPropertyRowMapper，它是Spring提供的一个映射器，可以根据Java类的属性名自动映射查询结果。

4. 插入数据

以下是一个插入数据的例子：

@Autowired
private JdbcTemplate jdbcTemplate;

public void insert(User user) {
    String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
    jdbcTemplate.update(sql, user.getName(), user.getEmail());
}

在这个例子中，我们使用了update方法去执行INSERT查询。由于我们并不需要返回更新记录数，所以可以使用更简单的update方法。

5. 更新数据

以下是一个更新数据的例子：

@Autowired
private JdbcTemplate jdbcTemplate;

public void update(User user) {
    String sql = "UPDATE users SET name = ?, email = ? WHERE id = ?";
    jdbcTemplate.update(sql, user.getName(), user.getEmail(), user.getId());
}

6. 删除数据

以下是一个删除数据的例子：

@Autowired
private JdbcTemplate jdbcTemplate;

public void delete(int id) {
    String sql = "DELETE FROM users WHERE id = ?";
    jdbcTemplate.update(sql, id);
}

总结

Spring JDBC是一个非常强大的框架，它可以极大地简化JDBC编码的难度。在本文中，我们介绍了如何使用Spring JDBC去连接数据库、执行SQL查询和更新，并提供了一些示例。希望这篇文章对你有所帮助，谢谢！