SpringJDBC 用法总结

大部分网上的 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，是因为在快速开发的后台系统中，没有足够的时间去写接口等，这种方式在小型简单的系统开发时效率更高。但在大型复杂的系统研发中，踏实写接口，遵守框架的开发规范是很有必要的。