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

在这里插入图片描述

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;// 构造函数注入 JdbcTemplatepublic 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;// 构造函数注入 JdbcTemplatepublic 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() {@Overridepublic 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());}@Overridepublic 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;// 构造函数注入 JdbcTemplatepublic 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;// 构造函数注入 JdbcTemplatepublic 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;// 构造函数注入 JdbcTemplatepublic 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);}}}
}