大部分网上的 Spring 教程大多讲解的是 SSM 框架，其中的 M 现在指的是 MyBatis 这个第三方 ORM 框架，在我看来，MyBatis 有它的优越性，如 SQL 语句与业务代码分离，业务逻辑处理很灵活等。但是在小型业务系统开发时，由于 SSM 框架定义过于规范，开发具体功能时，会写很多接口，而真正的业务逻辑得不到较优的处理，呆板的框架应用反而适得其反。
本文主要介绍 SpringJDBC 的基础操作，方便研发人员快速的实现数据的增删改查，而不仅仅拘泥于繁重的、各种框架组合而成的项目之中。
SpringJDBC 封装了基础的 JDBC 操作，让我们不用去关心 获取驱动、建立连接、关闭连接等非业务操作，让我们更加专注于业务的实现。
本文将对 SpringJDBC 的用法进行介绍，文主要内容如下：
- 基本的数据操作
- 自增主键的获取
1. 基本的数据操作
1.1 更改
更改 主要使用的是 update 方法
- 重载方法：主要包括三种，按需选择，下面展示的从简单到复杂。
sql = "insert into customer(name,age)values (?,?)";
int rows = jdbcTemplate.update(sql,"周杰伦",35);
int rows1 = jdbcTemplate.update(sql,new Object[]{"周杰伦",35});
int rows2 = jdbcTemplate.update(sql,new Object[]{"周杰伦",35},new int[]{Types.VARCHAR,Types.DECIMAL}); // 显式指定数据类型
- 批量更改：一次性执行多条 update 语句，使用 batchUpdate 方法
- jdbcTemplate.batchUpdate(String[] sql); 固定参数值
- jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter()); 可变参数值
String sql1 = "insert into customer(NAME,AGE) values (1,1)";
String sql2 = "insert into customer(NAME,AGE) values (1,1)";
String sql3 = "insert into customer(NAME,AGE) values (1,1)";
String[] strings = new String[]{sql1,sql2,sql3};
int[] a = jdbcTemplate.batchUpdate(strings); // 固定参数的多条 SQL 语句组成一个数组传入
System.out.println(Arrays.toString(a));
sql = "insert into customer(NAME,AGE) values (?,?)";
final List<String> list = new ArrayList<String>(){};
list.add("1");list.add("2");list.add("3");
int[] b = jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() { // 带可变参数的 SQL 语句传入
public void setValues(PreparedStatement preparedStatement, int i) throws SQLException {
preparedStatement.setString(1,list.get(i));
preparedStatement.setString(2,list.get(i));
}
public int getBatchSize() {
return list.size();
}
});
System.out.println(Arrays.toString(b));
1.2 查询
查询 主要使用的是 query、queryForXX 等函数，而 queryForXX 系列底层其实调用的是 query 方法，故这里只介绍通过 query 方法查询数据。
query 有多个重载方法，例如传入固定参数的 SQL 语句，传入可变参数的 SQL 语句等等，语法类似上面介绍的 update 方法，这里介绍两种带回调方法的查询语句：
(1) void query(String sql, RowCallbackHandler rch)
使用 RowCallbackHandler 既可以返回单行结果，也可以返回多行结果。Spring 会对查询的结果集逐行调用 processRow 方法，用户不用关心怎么读取下一行数据的问题。
sql = "select CUST_ID,NAME,AGE from customer where CUST_ID = ?";
final Customer customer = new Customer();
// 查询单行数据
jdbcTemplate.query(sql, new Object[]{1}, new RowCallbackHandler() {
public void processRow(ResultSet resultSet) throws SQLException {
customer.setCUST_ID(Integer.parseInt(resultSet.getString("CUST_ID")));
customer.setNAME(resultSet.getString("NAME"));
customer.setAGE(Integer.parseInt(resultSet.getString("AGE")));
}
});
System.out.println(customer.toString()); // Customer{CUST_ID=1, NAME='张三', AGE=12}
sql = "select CUST_ID,NAME,AGE from customer";
final List<Customer> customerList = new ArrayList<Customer>();
final Customer customer1 = new Customer();
// 查询到多行数据，代码与上面没有区别，唯一的不同就是将结果集存入 List
jdbcTemplate.query(sql, new RowCallbackHandler() {
public void processRow(ResultSet resultSet) throws SQLException {
customer1.setCUST_ID(Integer.parseInt(resultSet.getString("CUST_ID")));
customer1.setNAME(resultSet.getString("NAME"));
customer1.setAGE(Integer.parseInt(resultSet.getString("AGE")));
customerList.add(customer1);
}
});
System.out.println(customerList);// [Customer{CUST_ID=38, NAME='3', AGE=3}, Customer{CUST_ID=38, NAME='3', AGE=3}]
(2) <T> T queryForObject(String sql, RowMapper<T> rowMapper)
使用 RowMapper 处理结果集，它直接返回的是 List，相比于上面，我们不用手动将对象添加到 List 中
sql = "select CUST_ID,NAME,AGE from customer";
List<Customer> customerList = jdbcTemplate.query(sql, new RowMapper<Customer>() {
public Customer mapRow(ResultSet resultSet, int i) throws SQLException {
Customer customer = new Customer();
customer.setCUST_ID(Integer.parseInt(resultSet.getString("CUST_ID")));
customer.setNAME(resultSet.getString("NAME"));
customer.setAGE(Integer.parseInt(resultSet.getString("AGE")));
return customer;
}
});
System.out.println(customerList); // [Customer{CUST_ID=38, NAME='3', AGE=3}, Customer{CUST_ID=38, NAME='3', AGE=3}]
(3) 方法 a 与方法 b 的使用场景与注意事项
- RowCallbackHandler 接口的实现类是可以有状态，即在多线程环境下，可能会有线程安全的问题。
下面代码就展示了其实现类 RowCountCallbackHandler 打印结果集行数的示例，在多线程环境中，若行数发生变化，下面的结果可能不会一致。而 RowMapper 实现类没有这种情况。
RowCountCallbackHandler countCallbackHandler = new RowCountCallbackHandler();
jdbcTemplate.query("select * from customer",countCallbackHandler);
System.out.println(countCallbackHandler.getRowCount());
- 当处理大结果集时， RowMapper 是将结果集所有数据放到 List<T> 中，这会占用大量 JVM 内存。RowCallbackHandler 接口内的 processRow() 方法则是一边获取数据一边处理。RowMapper 是先获取再处理，RowCallbackHandler 边获取边处理。
2. 自增主键的获取
在数据库层面，一个表往往会有一个主键来唯一标识这一行数据。
新增记录时，返回新增记录对应的自增主键值，即返回的该列属性包含两个，一个是自增，另一个是主键。
SpringJDBC 提供了对自增主键获取的方法，插入数据时，返回插入数据的主键。
定义 KeyHolder 对象即可完成上述功能，步骤如下：
- 执行 statement 语句时，指定绑定主键
connection.prepareStatement(sql1,PreparedStatement.RETURN_GENERATED_KEYS)
final String sql1 = "insert into customer(name,age)values(?,?)";
KeyHolder keyHolder = new GeneratedKeyHolder();
jdbcTemplate.update(new PreparedStatementCreator() {
public PreparedStatement createPreparedStatement(Connection connection) throws SQLException {
PreparedStatement preparedStatement = connection.prepareStatement(sql1,PreparedStatement.RETURN_GENERATED_KEYS);
preparedStatement.setString(1,"suiyia");
preparedStatement.setString(2,"30");
return preparedStatement;
}
},keyHolder);
System.out.println(keyHolder.getKey().toString());
- keyHolder 的返回形式
- Number getKey() 主键是数值类型，单列、一行
- Map<String,Object> getKeys复合类型，多列、一行
- List<Map<String,Object>> getKeyList 复合类型、多列、多行
3. 小结
本文只是对 SpringJDBC 的基本常用操作做了简单介绍，之所以介绍 SpringJDBC，是因为在快速开发的后台系统中，没有足够的时间去写接口等，这种方式在小型简单的系统开发时效率更高。但在大型复杂的系统研发中，踏实写接口，遵守框架的开发规范是很有必要的。
网友评论