使用Spring简化JDBC开发
-
Spring中的JDBC简化机制 传统JDBC操作需要手动管理数据库连接、关闭资源并处理异常,代码冗余且易出错。Spring通过其JDBC模块封装了这些重复性工作,提供两个核心模板类:
JdbcTemplate和NamedParameterJdbcTemplate。前者使用位置参数(索引)绑定查询值,后者支持以命名参数形式进行SQL绑定,提升代码可读性和维护性。 -
配置JdbcTemplate
JdbcTemplate实现了JdbcOperations接口,是Spring JDBC的核心工具类。可通过Java配置方式将其注册为Spring容器管理的Bean。
import javax.sql.DataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.jdbc.core.JdbcTemplate;
@Configuration
public class DatabaseConfig {
@Bean
public JdbcTemplate jdbcTemplate(DataSource dataSource) {
return new JdbcTemplate(dataSource);
}
}
- 使用JdbcTemplate执行数据操作
在需要访问数据库的组件中注入
JdbcOperations接口实例,即可调用其方法完成增删改查,无需关注底层连接与异常处理。
插入数据(add)
@Autowired
private JdbcOperations jdbcOperations;
public void saveSpitter(Spitter spitter) {
String sql = "INSERT INTO t_spitter (username, password) VALUES (?, ?)";
jdbcOperations.update(sql, spitter.getUsername(), spitter.getPassword());
}
更新数据(update)
public void updateSpitter(Spitter spitter) {
String sql = "UPDATE t_spitter SET username = ? WHERE id = ?";
jdbcOperations.update(sql, spitter.getUsername(), spitter.getId());
}
删除数据(delete)
public void removeSpitter(Long id) {
String sql = "DELETE FROM t_spitter WHERE id = ?";
jdbcOperations.update(sql, id);
}
查询数据(select)
使用 queryForObject() 方法从结果集中提取单条记录,并通过自定义 RowMapper 映射为实体对象。
@Autowired
private JdbcOperations jdbcOperations;
public Spitter findById(Long id) {
String sql = "SELECT * FROM t_spitter WHERE id = ?";
return jdbcOperations.queryForObject(sql, new SpitterMapper(), id);
}
// RowMapper实现类
public class SpitterMapper implements RowMapper<Spitter> {
@Override
public Spitter mapRow(ResultSet rs, int rowNum) throws SQLException {
Spitter spitter = new Spitter();
spitter.setId(rs.getLong("id"));
spitter.setUsername(rs.getString("username"));
spitter.setPassword(rs.getString("password"));
return spitter;
}
}
- 使用NamedParameterJdbcTemplate支持命名参数
NamedParameterJdbcTemplate允许在SQL语句中使用:paramName形式的命名参数,提高代码可读性。
@Bean
public NamedParameterJdbcTemplate namedParameterJdbcTemplate(DataSource dataSource) {
return new NamedParameterJdbcTemplate(dataSource);
}
结合命名参数执行查询示例:
@Autowired
private JdbcOperations jdbcOperations;
public Spitter findByUsername(String username) {
String sql = "SELECT * FROM t_spitter WHERE username = :username";
Map<String, Object> params = new HashMap<>();
params.put("username", username);
return jdbcOperations.queryForObject(sql, new SpitterMapper(), params);
}