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

在这里插入图片描述

在前面的文章中，我们已经学习了如何使用 Spring 的 JDBCTemplate 执行 DML（Data Manipulation Language）操作，包括插入、更新和删除操作。现在，让我们来深入了解如何使用 JDBCTemplate 执行 DQL（Data Query Language）语句，从数据库中检索数据。

什么是 DQL？

DQL 是 SQL 的一部分，它用于从数据库中检索（查询）数据而不对数据进行修改。主要的 SQL DQL 语句包括 SELECT、FROM、WHERE、GROUP BY、HAVING 和 ORDER BY 等，用于指定要检索的数据、数据的来源、筛选条件、分组方式和排序方式等。

使用 JDBCTemplate 执行 DQL 语句

要使用 JDBCTemplate 执行 DQL 语句，我们需要创建一个 JdbcTemplate 对象并配置数据源。以下是一些步骤：

步骤 1：配置数据源

首先，我们需要配置一个数据源，以便 JDBCTemplate 能够获取数据库连接。Spring 支持多种数据源，例如 Apache Commons DBCP、HikariCP 和 C3P0 等。这里我们以 HikariCP 数据源为例进行配置。

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;import javax.sql.DataSource;public class DataSourceConfig {public DataSource dataSource() {HikariConfig config = new HikariConfig();config.setJdbcUrl("jdbc:mysql://localhost:3306/mydatabase");config.setUsername("root");config.setPassword("password");return new HikariDataSource(config);}
}

步骤 2：创建 JdbcTemplate

接下来，我们需要创建一个 JdbcTemplate 对象，并将数据源传递给它。

import org.springframework.jdbc.core.JdbcTemplate;public class JdbcTemplateConfig {private DataSource dataSource;public JdbcTemplateConfig(DataSource dataSource) {this.dataSource = dataSource;}public JdbcTemplate jdbcTemplate() {return new JdbcTemplate(dataSource);}
}

步骤 3：执行查询语句

现在，我们可以使用 JDBCTemplate 执行 DQL 查询语句了。以下是一个示例，演示如何查询数据库中的员工信息：

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;public class EmployeeDao {private JdbcTemplate jdbcTemplate;public EmployeeDao(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}public List<Employee> getAllEmployees() {String sql = "SELECT * FROM employees";return jdbcTemplate.query(sql, new EmployeeRowMapper());}
}class EmployeeRowMapper implements RowMapper<Employee> {@Overridepublic Employee mapRow(ResultSet rs, int rowNum) throws SQLException {Employee employee = new Employee();employee.setId(rs.getInt("id"));employee.setFirstName(rs.getString("first_name"));employee.setLastName(rs.getString("last_name"));employee.setEmail(rs.getString("email"));return employee;}
}

在上述示例中，我们创建了一个 EmployeeDao 类，其中的 getAllEmployees 方法执行了一个 SQL 查询语句，使用 query 方法将查询结果映射到 Employee 对象列表中。

示例代码

下面是一个完整的示例代码，演示了如何使用 JDBCTemplate 执行 DQL 查询语句：

import com.zaxxer.hikari.HikariConfig;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;import javax.sql.DataSource;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;public class Main {public static void main(String[] args) {// 步骤 1：配置数据源DataSource dataSource = configureDataSource();// 步骤 2：创建 JdbcTemplateJdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);// 步骤 3：执行查询EmployeeDao employeeDao = new EmployeeDao(jdbcTemplate);List<Employee> employees = employeeDao.getAllEmployees();// 打印查询结果for (Employee employee : employees) {System.out.println("Employee ID: " + employee.getId());System.out.println("First Name: " + employee.getFirstName());System.out.println("Last Name: " + employee.getLastName());System.out.println("Email: " + employee.getEmail());System.out.println();}}private static DataSource configureDataSource() {HikariConfig config = new HikariConfig();config.setJdbcUrl("jdbc:mysql://localhost:3306/mydatabase");config.setUsername("root");config.setPassword("password");return new HikariDataSource(config);}
}class Employee {private int id;private String firstName;private String lastName;private String email;// 省略 getter 和 setter 方法
}class EmployeeDao {private JdbcTemplate jdbcTemplate;public EmployeeDao(JdbcTemplate jdbcTemplate) {this.jdbcTemplate = jdbcTemplate;}public List<Employee> getAllEmployees() {String sql = "SELECT * FROM employees";return jdbcTemplate.query(sql, new EmployeeRowMapper());}
}class EmployeeRowMapper implements RowMapper<Employee> {@Overridepublic Employee mapRow(ResultSet rs, int rowNum) throws SQLException {Employee employee = new Employee();employee.setId(rs.getInt("id"));employee.setFirstName(rs.getString("first_name"));employee.setLastName(rs.getString("last_name"));employee.setEmail(rs.getString("email"));return employee;}
}