什么是 JdbcTemplate？
JdbcTemplate 是 Spring 框架中的一个类，用于简化与数据库的交互。它帮助我们处理很多繁琐的任务，例如打开和关闭数据库连接、处理SQL语句、处理异常等。使用 JdbcTemplate，你可以更轻松地执行数据库操作，比如查询、插入、更新和删除数据。
1. 配置 JdbcTemplate
在使用 JdbcTemplate 之前，你需要配置一个数据源（DataSource），它包含了数据库连接的信息。然后，你可以将这个数据源注入到 JdbcTemplate 中。
配置步骤：
- 创建一个配置类：这是一个用来配置
JdbcTemplate的类。 - 定义一个数据源：数据源包含了数据库的连接信息，比如URL、用户名和密码。
- 定义
JdbcTemplate：将数据源注入到JdbcTemplate中。
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import javax.sql.DataSource;
@Configuration
public class JdbcConfig {
// 配置数据源
@Bean
public DataSource dataSource() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver"); // MySQL驱动
dataSource.setUrl("jdbc:mysql://localhost:3306/mydatabase"); // 数据库URL
dataSource.setUsername("username"); // 数据库用户名
dataSource.setPassword("password"); // 数据库密码
return dataSource;
}
// 配置 JdbcTemplate，并注入数据源
@Bean
public JdbcTemplate jdbcTemplate(DataSource dataSource) {
return new JdbcTemplate(dataSource);
}
}
2. 使用 JdbcTemplate 进行数据库操作
查询单个对象
假设你有一个 User 类，表示用户信息。你可以使用 JdbcTemplate 查询数据库中的单个用户。
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.stereotype.Repository;
import java.sql.ResultSet;
import java.sql.SQLException;
@Repository
public class UserRepository {
@Autowired
private JdbcTemplate jdbcTemplate;
// 查询单个用户
public User findUserById(int id) {
String sql = "SELECT * FROM users WHERE id = ?"; // SQL查询语句
return jdbcTemplate.queryForObject(sql, new Object[]{id}, new RowMapper<User>() {
@Override
public User mapRow(ResultSet rs, int rowNum) throws SQLException {
User user = new User();
user.setId(rs.getInt("id"));
user.setName(rs.getString("name"));
user.setEmail(rs.getString("email"));
return user;
}
});
}
}
查询多个对象
你也可以查询多个用户，并将结果放入一个列表中。
import java.util.List;
public List<User> findAllUsers() {
String sql = "SELECT * FROM users";
return jdbcTemplate.query(sql, new RowMapper<User>() {
@Override
public User mapRow(ResultSet rs, int rowNum) throws SQLException {
User user = new User();
user.setId(rs.getInt("id"));
user.setName(rs.getString("name"));
user.setEmail(rs.getString("email"));
return user;
}
});
}
插入数据
插入一个新用户到数据库。
public int addUser(User user) {
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
return jdbcTemplate.update(sql, user.getName(), user.getEmail());
}
更新数据
更新一个已存在的用户信息。
public int updateUser(User user) {
String sql = "UPDATE users SET name = ?, email = ? WHERE id = ?";
return jdbcTemplate.update(sql, user.getName(), user.getEmail(), user.getId());
}
删除数据
删除一个用户。
public int deleteUser(int id) {
String sql = "DELETE FROM users WHERE id = ?";
return jdbcTemplate.update(sql, id);
}
3. 批量操作
如果你需要一次性插入或更新多个记录，可以使用批量操作。
import org.springframework.jdbc.core.BatchPreparedStatementSetter;
public int[] batchUpdate(List<User> users) {
String sql = "INSERT INTO users (name, email) VALUES (?, ?)";
return jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
@Override
public void setValues(PreparedStatement ps, int i) throws SQLException {
User user = users.get(i);
ps.setString(1, user.getName());
ps.setString(2, user.getEmail());
}
@Override
public int getBatchSize() {
return users.size();
}
});
}
总结
- 配置
JdbcTemplate：首先需要配置数据源，然后将其注入到JdbcTemplate中。 - 执行数据库操作：使用
JdbcTemplate提供的方法来执行查询、插入、更新和删除等操作。 - 减少样板代码：
JdbcTemplate自动处理数据库连接、资源管理和异常处理，简化了代码。