跟我学Spring3（7.3）：对JDBC的支持之关系数据库操作对象化

图7-4 关系数据库操作对象化支持类

数据库操作对象化只要有以下几种类型，所以类型是线程安全及可复用的：

• 查询：将数据库操作select封装为对象，查询操作的基类是SqlQuery，所有查询都可以使用该类表示，Spring JDBC还提供了一些更容易使用的MappingSqlQueryWithParameters和MappingSqlQuery用于将结果集映射为Java对象，查询对象类还提供了两个扩展UpdatableSqlQuery和SqlFunction；
• 更新：即增删改操作，将数据库操作insert 、update、delete封装为对象，增删改基类是SqlUpdate，当然还提供了BatchSqlUpdate用于批处理；
• 存储过程及函数：将存储过程及函数调用封装为对象，基类是SqlCall类，提供了StoredProcedure实现。

java代码：

RowMapper<T> newRowMapper(Object[] parameters, Map context)

SqlQuery提供两类方法：

• execute及executeByNamedParam方法：用于查询多行数据，其中executeByNamedParam用于支持命名参数绑定参数；
• findObject及findObjectByNamedParam方法：用于查询单行数据，其中findObjectByNamedParam用于支持命名参数绑定。

演示一下SqlQuery如何使用：

java代码：

@Test  public void testSqlQuery() {   SqlQuery query = new UserModelSqlQuery(jdbcTemplate);   List<UserModel> result = query.execute("name5");   Assert.assertEquals(0, result.size());  }

从测试代码可以SqlQuery使用非常简单，创建SqlQuery实现对象，然后调用相应的方法即可，接下来看一下SqlQuery实现：

java代码：

package cn.javass.spring.chapter7;  //省略import  public class UserModelSqlQuery extends SqlQuery<UserModel> {   public UserModelSqlQuery(JdbcTemplate jdbcTemplate) {   //super.setDataSource(jdbcTemplate.getDataSource());   super.setJdbcTemplate(jdbcTemplate);   super.setSql("select * from test where name=?");   super.declareParameter(new SqlParameter(Types.VARCHAR));   compile();   }   @Override   protected RowMapper<UserModel> newRowMapper(Object[] parameters, Map context) {   return new UserRowMapper();   }  }

java代码：

@Test  public void testMappingSqlQuery() {   jdbcTemplate.update("insert into test(name) values('name5')");   SqlQuery<UserModel> query = new UserModelMappingSqlQuery(jdbcTemplate);   Map<String, Object> paramMap = new HashMap<String, Object>();   paramMap.put("name", "name5");   UserModel result = query.findObjectByNamedParam(paramMap);   Assert.assertNotNull(result);  }

• MappingSqlQuery使用和SqlQuery完全一样，创建MappingSqlQuery实现对象，然后调用相应的方法即可，接下来看一下MappingSqlQuery实现，findObjectByNamedParam方法用于执行命名参数查询：

java代码：

package cn.javass.spring.chapter7;  //省略import  public class UserModelMappingSqlQuery extends MappingSqlQuery<UserModel> {   public UserModelMappingSqlQuery(JdbcTemplate jdbcTemplate) {   super.setDataSource(jdbcTemplate.getDataSource());   super.setSql("select * from test where name=:name");   super.declareParameter(new SqlParameter("name", Types.VARCHAR));   compile();   }   @Override   protected UserModel mapRow(ResultSet rs, int rowNum) throws SQLException {   UserModel model = new UserModel();   model.setId(rs.getInt("id"));   model.setMyName(rs.getString("name"));   return model;   }  }

java代码：

@Test  public void testSqlFunction() {   jdbcTemplate.update("insert into test(name) values('name5')");   String countSql = "select count(*) from test";   SqlFunction<Integer> sqlFunction1 = new SqlFunction<Integer>(jdbcTemplate.getDataSource(), countSql);   Assert.assertEquals(1, sqlFunction1.run());   String selectSql = "select name from test where name=?";   SqlFunction<String> sqlFunction2 = new SqlFunction<String>(jdbcTemplate.getDataSource(), selectSql);   sqlFunction2.declareParameter(new SqlParameter(Types.VARCHAR));   String name = (String) sqlFunction2.runGeneric(new Object[] {"name5"});   Assert.assertEquals("name5", name);  }

如代码所示，SqlFunction初始化时需要DataSource和相应的sql语句，如果有参数需要使用declareParameter对参数类型进行描述；run方法默认返回int型，当然也可以使用runGeneric返回其他类型，如String等。

演示一下SqlUpdate如何使用：

java代码：

package cn.javass.spring.chapter7;  //省略import  public class InsertUserModel extends SqlUpdate {   public InsertUserModel(JdbcTemplate jdbcTemplate) {   super.setJdbcTemplate(jdbcTemplate);   super.setSql("insert into test(name) values(?)");   super.declareParameter(new SqlParameter(Types.VARCHAR));   compile();   }  }

java代码：

@Test  public void testSqlUpdate() {   SqlUpdate insert = new InsertUserModel(jdbcTemplate);   insert.update("name5");    String updateSql = "update test set name=? where name=?";   SqlUpdate update = new SqlUpdate(jdbcTemplate.getDataSource(), updateSql, new int[]{Types.VARCHAR, Types.VARCHAR});   update.update("name6", "name5");   String deleteSql = "delete from test where name=:name";    SqlUpdate delete = new SqlUpdate(jdbcTemplate.getDataSource(), deleteSql, new int[]{Types.VARCHAR});   Map<String, Object> paramMap = new HashMap<String, Object>();   paramMap.put("name", "name5");   delete.updateByNamedParam(paramMap);  }

InsertUserModel类实现类似于SqlQuery实现，用于执行数据库插入操作，SqlUpdate还提供一种更简洁的构造器SqlUpdate(DataSource ds, String sql, int[] types)，其中types用于指定占位符或命名参数类型；SqlUpdate还支持命名参数，使用updateByNamedParam方法来进行命名参数操作。

7.3.4 存储过程及函数

• StoredProcedure用于支持存储过程及函数，该类的使用同样类似于SqlQuery。
• StoredProcedure提供execute方法用于执行存储过程及函数。

一、StoredProcedure如何调用自定义函数：

java代码：

@Test  public void testStoredProcedure1() {   StoredProcedure lengthFunction = new HsqldbLengthFunction(jdbcTemplate);   Map<String,Object> outValues = lengthFunction.execute("test");   Assert.assertEquals(4, outValues.get("result"));  }

StoredProcedure使用非常简单，定义StoredProcedure实现HsqldbLengthFunction，并调用execute方法执行即可，接下来看一下HsqldbLengthFunction实现：

java代码：

package cn.javass.spring.chapter7;  //省略import  public class HsqldbLengthFunction extends StoredProcedure {   public HsqldbLengthFunction(JdbcTemplate jdbcTemplate) {   super.setJdbcTemplate(jdbcTemplate);   super.setSql("FUNCTION_TEST");   super.declareParameter(   new SqlReturnResultSet("result", new ResultSetExtractor<Integer>() {   @Override   public Integer extractData(ResultSet rs) throws SQLException, DataAccessException {   while(rs.next()) {   return rs.getInt(1);   }   return 0;   }   }));   super.declareParameter(new SqlParameter("str", Types.VARCHAR));   compile();   }  }

• StoredProcedure自定义函数使用类似于SqlQuery，首先设置数据源或JdbcTemplate对象，其次定义自定义函数，然后使用declareParameter进行参数描述，最后调用compile（可选）编译自定义函数。

接下来看一下mysql自定义函数如何使用：

java代码：

@Test  public void testStoredProcedure2() {   JdbcTemplate mysqlJdbcTemplate = new JdbcTemplate(getMysqlDataSource());   String createFunctionSql =   "CREATE FUNCTION FUNCTION_TEST(str VARCHAR(100)) " +   "returns INT return LENGTH(str)";   String dropFunctionSql = "DROP FUNCTION IF EXISTS FUNCTION_TEST";   mysqlJdbcTemplate.update(dropFunctionSql);   mysqlJdbcTemplate.update(createFunctionSql);   StoredProcedure lengthFunction = new MysqlLengthFunction(mysqlJdbcTemplate);   Map<String,Object> outValues = lengthFunction.execute("test");   Assert.assertEquals(4, outValues.get("result"));  }

MysqlLengthFunction自定义函数使用与HsqldbLengthFunction使用完全一样，只是内部实现稍有差别：

java代码：

package cn.javass.spring.chapter7;  //省略import  public class MysqlLengthFunction extends StoredProcedure {   public MysqlLengthFunction(JdbcTemplate jdbcTemplate) {   super.setJdbcTemplate(jdbcTemplate);   super.setSql("FUNCTION_TEST");   super.setFunction(true);   super.declareParameter(new SqlOutParameter("result", Types.INTEGER));   super.declareParameter(new SqlParameter("str", Types.VARCHAR));   compile();   }  }

MysqlLengthFunction与HsqldbLengthFunction实现不同的地方有两点：

• setFunction(true)：表示是自定义函数调用，即编译后的sql为{?= call …}形式；如果使用hsqldb不能设置为true，因为在hsqldb中{?= call …}和{call …}含义一样；
• declareParameter(new SqlOutParameter(“result”, Types.INTEGER))：将自定义函数返回值类型直接描述为Types.INTEGER；SqlOutParameter必须指定name，而不用使用SqlReturnResultSet首先获取结果集，然后再从结果集获取返回值，这是mysql与hsqldb的区别；

一、StoredProcedure如何调用存储过程：

java代码：

@Test  public void testStoredProcedure3() {   StoredProcedure procedure = new HsqldbTestProcedure(jdbcTemplate);   Map<String,Object> outValues = procedure.execute("test");   Assert.assertEquals(0, outValues.get("outId"));   Assert.assertEquals("Hello,test", outValues.get("inOutName"));  }

StoredProcedure存储过程实现HsqldbTestProcedure调用与HsqldbLengthFunction调用完全一样，不同的是在实现时，参数描述稍有不同：

java代码：

package cn.javass.spring.chapter7;  //省略import  public class HsqldbTestProcedure extends StoredProcedure {   public HsqldbTestProcedure(JdbcTemplate jdbcTemplate) {   super.setJdbcTemplate(jdbcTemplate);   super.setSql("PROCEDURE_TEST");   super.declareParameter(new SqlInOutParameter("inOutName", Types.VARCHAR));   super.declareParameter(new SqlOutParameter("outId", Types.INTEGER));   compile();   }  }

declareParameter：使用SqlInOutParameter描述INOUT类型参数，使用SqlOutParameter描述OUT类型参数，必须按顺序定义，不能颠倒。

本系列：