【Java 进阶篇】使用 JDBCTemplate 执行 DML 语句详解

繁依Fanyi

发布于 2023-10-12 18:10:02

2330

发布于 2023-10-12 18:10:02

JDBCTemplate 是 Spring 框架中的一个核心模块，用于简化 JDBC 编程，使数据库操作更加便捷和高效。在本文中，我们将重点介绍如何使用 JDBCTemplate 执行 DML（Data Manipulation Language）语句，包括插入、更新和删除操作。我们将提供详细的步骤和示例代码，以帮助基础小白更好地理解和使用这一功能。

1. 引入依赖

首先，您需要在项目中引入 Spring 的相关依赖，包括 Spring Core 和 Spring JDBC。您可以使用 Maven 或 Gradle 等构建工具来管理依赖。

如果使用 Maven，可以在 pom.xml 文件中添加以下依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-core</artifactId>
        <version>5.3.10</version> <!-- 使用最新版本 -->
    </dependency>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-jdbc</artifactId>
        <version>5.3.10</version> <!-- 使用最新版本 -->
    </dependency>
    <!-- 其他依赖 -->
</dependencies>

2. 配置数据源和 JDBCTemplate

在 Spring 应用程序中，通常使用数据源（DataSource）来管理数据库连接。您需要配置数据源并将其注入到 JDBCTemplate 中。以下是一个简单的配置示例：

<bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
    <property name="driverClassName" value="com.mysql.cj.jdbc.Driver" />
    <property name="url" value="jdbc:mysql://localhost:3306/mydatabase" />
    <property name="username" value="root" />
    <property name="password" value="password" />
</bean>

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource" ref="dataSource" />
</bean>

上述配置示例中，我们使用 DriverManagerDataSource 创建了一个数据源，并将其注入到了 JdbcTemplate 中。

3. 执行插入操作

插入单条记录

要执行插入操作，首先创建一个 SQL 插入语句，然后使用 JDBCTemplate 的 update 方法执行它。以下是一个插入单条记录的示例：

import org.springframework.jdbc.core.JdbcTemplate;

public class EmployeeDao {

    private JdbcTemplate jdbcTemplate;

    // 构造函数注入 JdbcTemplate
    public EmployeeDao(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public void insertEmployee(Employee employee) {
        String sql = "INSERT INTO employees (first_name, last_name, email) VALUES (?, ?, ?)";
        jdbcTemplate.update(sql, employee.getFirstName(), employee.getLastName(), employee.getEmail());
    }
}

在上述示例中，我们创建了一个名为 EmployeeDao 的数据访问对象（DAO），它包含一个 insertEmployee 方法，用于插入单条记录。我们使用 ? 占位符来代替实际的参数值，并将参数值传递给 update 方法。这可以防止 SQL 注入攻击，提高了安全性。

插入多条记录

如果要插入多条记录，可以使用 JDBCTemplate 的批处理功能。以下是一个示例：

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.BatchPreparedStatementSetter;

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;

public class EmployeeDao {

    private JdbcTemplate jdbcTemplate;

    // 构造函数注入 JdbcTemplate
    public EmployeeDao(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public void insertEmployees(List<Employee> employees) {
        String sql = "INSERT INTO employees (first_name, last_name, email) VALUES (?, ?, ?)";
        
        // 使用 BatchPreparedStatementSetter 来设置参数
        BatchPreparedStatementSetter setter = new BatchPreparedStatementSetter() {
            @Override
            public void setValues(PreparedStatement ps, int i) throws SQLException {
                Employee employee = employees.get(i);
                ps.setString(1, employee.getFirstName());
                ps.setString(2, employee.getLastName());
                ps.setString(3, employee.getEmail());
            }
            
            @Override
            public int getBatchSize() {
                return employees.size();
            }
        };
        
        jdbcTemplate.batchUpdate(sql, setter);
    }
}

在上述示例中，我们使用 batchUpdate 方法来执行批处理插入操作。

4. 执行更新操作

更新操作用于修改数据库中已存在的记录。您可以使用 JDBCTemplate 的 update 方法执行更新操作。以下是一个更新操作的示例：

import org.springframework.jdbc.core.JdbcTemplate;

public class EmployeeDao {

    private JdbcTemplate jdbcTemplate;

    // 构造函数注入 JdbcTemplate
    public EmployeeDao(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public void updateEmployee(Employee employee) {
        String sql = "UPDATE employees SET first_name = ?, last_name = ?, email = ? WHERE id = ?";
        jdbcTemplate.update(sql, employee.getFirstName(), employee.getLastName(), employee.getEmail(), employee.getId());
    }
}

在上述示例中，我们创建了一个名为 updateEmployee 的方法，用于更新员工记录。我们使用 SQL 更新语句，并传递员工对象的属性值作为参数。

5. 执行删除操作

删除操作用于从数据库中删除记录。您可以使用 JDBCTemplate 的 update 方法执行删除操作。以下是一个删除操作的示例：

import org.springframework.jdbc.core.JdbcTemplate;

public class EmployeeDao {

    private JdbcTemplate jdbcTemplate;

    // 构造函数注入 JdbcTemplate
    public EmployeeDao(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

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

在上述示例中，我们创建了一个名为 deleteEmployee 的方法，用于删除员工记录。我们使用 SQL 删除语句，并传递员工的唯一标识（通常是 ID）作为参数。

6. 错误处理

在实际应用中，执行 DML 操作时可能会出现各种错误和异常，例如数据库连接失败、SQL 语法错误、数据完整性约束等。为了保证代码的健壮性，应该捕获并处理这些错误和异常。以下是一个简单的错误处理示例：

import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.SQLExceptionTranslator;

public class EmployeeDao {

    private JdbcTemplate jdbcTemplate;

    // 构造函数注入 JdbcTemplate
    public EmployeeDao(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }

    public void insertEmployee(Employee employee) {
        String sql = "INSERT INTO employees (first_name, last_name, email) VALUES (?, ?, ?)";
        try {
            jdbcTemplate.update(sql, employee.getFirstName(), employee.getLastName(), employee.getEmail());
        } catch (DataAccessException e) {
            // 数据访问异常处理
            SQLExceptionTranslator translator = jdbcTemplate.getExceptionTranslator();
            if (translator != null) {
                throw translator.translate("Insert employee failed", sql, e);
            } else {
                throw new RuntimeException("Insert employee failed", e);
            }
        }
    }
}

在上述示例中，我们使用了 Spring 的异常翻译器（SQLExceptionTranslator）来将数据库异常转换为 Spring 的通用数据访问异常（DataAccessException）。这有助于提供更加友好的错误信息和异常处理。