Spring JdbcTemplate的主要使用方法及其举例
Spring JdbcTemplate使用
JdbcTemplate主要提供以下五类方法：
execute方法：可以用于执行任何SQL语句，一般用于执行DDL语句；
update方法及batchUpdate方法：update方法用于执行新增、修改、删除等语句；batchUpdate方法用于执行批处理相关语句；
query方法及queryForXXX方法：用于执行查询相关语句；
call方法：用于执行存储过程、函数相关语句。
 
JdbcTemplate类支持的回调类：
预编译语句及存储过程创建回调：用于根据JdbcTemplate提供的连接创建相应的语句；
        PreparedStatementCreator：通过回调获取JdbcTemplate提供的Connection，由用户使用该Conncetion创建相关的PreparedStatement；
        CallableStatementCreator：通过回调获取JdbcTemplate提供的Connection，由用户使用该Conncetion创建相关的CallableStatement；
预编译语句设值回调：用于给预编译语句相应参数设值；
        PreparedStatementSetter：通过回调获取JdbcTemplate提供的PreparedStatement，由用户来对相应的预编译语句相应参数设值；
        BatchPreparedStatementSetter：；类似于PreparedStatementSetter，但用于批处理，需要指定批处理大小；
自定义功能回调：提供给用户一个扩展点，用户可以在指定类型的扩展点执行任何数量需要的操作；
        ConnectionCallback：通过回调获取JdbcTemplate提供的Connection，用户可在该Connection执行任何数量的操作；
        StatementCallback：通过回调获取JdbcTemplate提供的Statement，用户可以在该Statement执行任何数量的操作；
        PreparedStatementCallback：通过回调获取JdbcTemplate提供的PreparedStatement，用户可以在该PreparedStatement执行任何数量的操作；
        CallableStatementCallback：通过回调获取JdbcTemplate提供的CallableStatement，用户可以在该CallableStatement执行任何数量的操作；
结果集处理回调：通过回调处理ResultSet或将ResultSet转换为需要的形式；
        RowMapper：用于将结果集每行数据转换为需要的类型，用户需实现方法mapRow(ResultSetrs, introwNum)来完成将每行数据转换为相应的类型。
        RowCallbackHandler：用于处理ResultSet的每一行结果，用户需实现方法processRow(ResultSetrs)来完成处理，在该回调方法中无需执行rs.next()，该操作由JdbcTemplate来执行，用户只需按行获取数据然后处理即可。
        ResultSetExtractor：用于结果集数据提取，用户需实现方法extractData(ResultSetrs)来处理结果集，用户必须处理整个结果集；
 
接下来让我们看下具体示例吧，在示例中不可能介绍到JdbcTemplate全部方法及回调类的使用方法，我们只介绍代表性的，其余的使用都是类似的；
 
 
1）预编译语句及存储过程创建回调、自定义功能回调使用：
[java]
<strong>@Test 
public void testPpreparedStatement1() { 
  int count = ute(new PreparedStatementCreator() { 
    @Override 
    public PreparedStatementcreatePreparedStatement(Connection conn) 
        throws SQLException { 
        return conn.prepareStatement("select count(*) from test"); 
    }}, new PreparedStatementCallback<Integer>() { 
    @Override 
    public Integer doInPreparedStatement(PreparedStatementpstmt) 
        throws SQLException, DataAccessException { 
        ute(); 
        ResultSetrs = ResultSet(); 
        rs.next(); 
        Int(1); 
      }});     
  Assert.assertEquals(0, count); 
} 
 </strong><p >首先使用PreparedStatementCreator创建一个预编译语句，其次由JdbcTemplate通过PreparedStatementCallback回调传回，由用户决定如何执行该PreparedStatement。此处我们使用的是execute方法。</p><p ></p><p ><strong>2）预编译语句设值回调使用：</strong></p> 
[java] 
@Test   
public void testPreparedStatement2() {   
  String insertSql = "insert into test(name) values (?)";   
  int count = jdbcTemplate.update(insertSql, new PreparedStatementSetter() {   
      @Override   
      public void setValues(PreparedStatementpstmt) throws SQLException {   
          pstmt.setObject(1, "name4");   
  }});   
  Assert.assertEquals(1, count);       
  String deleteSql = "delete from test where name=?";   
  count = jdbcTemplate.update(deleteSql, new Object[] {"name4"});   
  Assert.assertEquals(1, count);   
}   
 通过JdbcTemplate的int update(String sql, PreparedStatementSetterpss)执行预编译sql，其中sql参数为“insert into test(name) values (?) ”，该sql有一个占位符需要在执行前设值，PreparedStatementSetter实现就是为了设值，使用setValues(PreparedStatementpstmt)回
调方法设值相应的占位符位置的值。JdbcTemplate也提供一种更简单的方式“update(String sql, args)”来实现设值，所以只要当使用该种方式不满足需求时才应使用PreparedStatementSetter。
3）结果集处理回调：
[java] 
public void testResultSet1() { 
  jdbcTemplate.update("insert into test(name) values('name5')"); 
  String listSql = "select * from test"; 
  List result = jdbcTemplate.query(listSql, new RowMapper<Map>() { 
      @Override 
      public Map mapRow(ResultSetrs, introwNum) throws SQLException { 
          Map row = new HashMap(); 
          row.Int("id"), rs.getString("name")); 
          return row; 
  }}); 
  Assert.assertEquals(1, result.size()); 
  jdbcTemplate.update("delete from test where name='name5'");     
} 
RowMapper接口提供mapRow(ResultSetrs, introwNum)方法将结果集的每一行转换为一个Map，当然可以转换为其他类，如表的对象画形式。
[java]
@Test 
public void testResultSet2() { 
  jdbcTemplate.update("insert into test(name) values('name5')"); 
  String listSql = "select * from test"; 
  final List result = new ArrayList(); 
  jdbcTemplate.query(listSql, new RowCallbackHandler() { 
      @Override 
      public void processRow(ResultSetrs) throws SQLException { 
          Map row = new HashMap(); 
          row.Int("id"), rs.getString("name")); 
          result.add(row); 
  }}); 
  Assert.assertEquals(1, result.size()); 
  jdbcTemplate.update("delete from test where name='name5'"); 
} 
RowCallbackHandler接口也提供方法processRow(ResultSetrs)，能将结果集的行转换为需要的形式。
[java] 
@Test 
public void testResultSet3() { 
  jdbcTemplate.update("insert into test(name) values('name5')"); 
  String listSql = "select * from test"; 
  List result = jdbcTemplate.query(listSql, new ResultSetExtractor<List>() { 
      @Override 
      public List extractData(ResultSetrs) 
    throws SQLException, DataAccessException { 
          List result = new ArrayList(); 
          ()) { 
              Map row = new HashMap(); 
              row.Int("id"), rs.getString("name")); 
              result.add(row); 
          } 
          return result; 
  }}); 
  Assert.assertEquals(0, result.size()); 
  jdbcTemplate.update("delete from test where name='name5'"); 
} 
ResultSetExtractor使用回调方法extractData(ResultSetrs)提供给用户整个结果集，让用户决定如何处理该结果集。
当然JdbcTemplate提供更简单的queryForXXX方法，来简化开发：
[java]
//1.查询一行数据并返回int型结果   
jdbcTemplate.queryForInt("select count(*) from test");   
//2. 查询一行数据并将该行数据转换为Map返回   
jdbcTemplate.queryForMap("select * from test where name='name5'");   
//3.查询一行任何类型的数据，最后一个参数指定返回结果类型   
jdbcTemplate.queryForObject("select count(*) from test", Integer.class);   
//4.查询一批数据，默认将每行数据转换为Map       
jdbcTemplate.queryForList("select * from test");   
//5.只查询一列数据列表，列类型是String类型，列名字是name   
jdbcTemplate.queryForList("   
select name from test where name=?", new Object[]{"name5"}, String.class);   
//6.查询一批数据，返回为SqlRowSet，类似于ResultSet，但不再绑定到连接上   
SqlRowSetrs = jdbcTemplate.queryForRowSet("select * from test");   


3） 存储过程及函数回调：
首先修改JdbcTemplateTest的setUp方法，修改后如下所示：
[java]
     
@Before 
public void setUp() { 
    String createTableSql = "create memory table test" + 
    "(id int GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY, " + 
    "name varchar(100))"; 
    jdbcTemplate.update(createTableSql); 
       
    String createHsqldbFunctionSql = 
      "CREATE FUNCTION FUNCTION_TEST(str CHAR(100)) " + 
      "returns INT begin atomic return length(str);end"; 
    jdbcTemplate.update(createHsqldbFunctionSql); 
    String createHsqldbProcedureSql = 
      "CREATE PROCEDURE PROCEDURE_TEST" + 
      "(INOUT inOutName VARCHAR(100), OUT outId INT) " + 
      "MODIFIES SQL DATA " + 
      "BEGIN ATOMIC " + 
      "  insert into test(name) values (inOutName); " + 
      "  SET outId = IDENTITY(); " + 
      "  SET inOutName = 'Hello,' + inOutName; " + 
    "END"; 
    ute(createHsqldbProcedureSql); 
} 
其中CREATE FUNCTION FUNCTION_TEST用于创建自定义函数，CREATE PROCEDURE PROCEDURE_TEST用于创建存储过程，注意这些创建语句是数据库相关的，本示例中的语句只适用于HSQLDB数据库。
 
      其次修改JdbcTemplateTest的tearDown方法，修改后如下所示：
[java]
@After 
public void tearDown() { 
    ute("DROP FUNCTION FUNCTION_TEST"); 
    ute("DROP PROCEDURE PROCEDURE_TEST"); 
    String dropTableSql = "drop table test"; 
    ute(dropTableSql); 
} 
 其中drop语句用于删除创建的存储过程、自定义函数及数据库表。
 
       
@Test 
public void testCallableStatementCreator1() { 
    final String callFunctionSql = "{call FUNCTION_TEST(?)}"; 
    List<SqlParameter>params = new ArrayList<SqlParameter>(); 
    params.add(new SqlParameter(Types.VARCHAR)); 
    params.add(new SqlReturnResultSet("result", 
      new ResultSetExtractor<Integer>() { spring framework扩展点
          @Override 
          public Integer extractData(ResultSetrs) throws SQLException, 
              DataAccessException { 
              ()) { 
                  Int(1); 
              } 
              return 0; 
      })); 
    Map<String, Object>outValues = jdbcTemplate.call( 
      new CallableStatementCreator() { 
            @Override 
            public CallableStatementcreateCallableStatement(Connection conn) throws SQLException { 
              CallableStatementcstmt = conn.prepareCall(callFunctionSql); 
              cstmt.setString(1, "test"); 
              return cstmt; 
    }}, params); 
    Assert.assertEquals(4, ("result")); 
} 
 

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。