對JDBC的支持 之 7.2 JDBC模板類

時間  2019-11-07
標籤 jdbc 支持 7.2 模板 欄目 Java 简体版
原文   原文鏈接

JDBC模板類

    概述

    Spring JDBC抽象框架core包提供了JDBC模板類，其中JdbcTemplate是core包的核心類，因此其餘模板類都是基於它封裝完成的，JDBC模板類是第一種工做模式。java

    JdbcTemplate類經過模板設計模式幫助咱們消除了冗長的代碼，只作須要作的事情（便可變部分），而且幫咱們作哪些固定部分，如鏈接的建立及關閉。mysql

    JdbcTemplate類對可變部分採用回調接口方式實現，如ConnectionCallback經過回調接口返回給用戶一個鏈接，從而可使用該鏈接作任何事情、StatementCallback經過回調接口返回給用戶一個Statement，從而可使用該Statement作任何事情等等，還有其餘一些回調接口如圖7-3所示。spring

JdbcTemplate支持的回調接口sql

    Spring除了提供JdbcTemplate核心類，還提供了基於JdbcTemplate實現的NamedParameterJdbcTemplate類用於支持命名參數綁定、 SimpleJdbcTemplate類用於支持Java5+的可變參數及自動裝箱拆箱等特性。數據庫

傳統JDBC編程替代方案

前邊咱們已經使用過傳統JDBC編程方式，接下來讓咱們看下Spring JDBC框架提供的更好的解決方案。編程

1）準備須要的jar包並添加到類路徑中：設計模式

//JDBC抽象框架模塊
org.springframework.jdbc-3.0.5.RELEASE.jar     
//Spring事務管理及一致的DAO訪問及非檢查異常模塊 
org.springframework.transaction-3.0.5.RELEASE.jar 
//hsqldb驅動，hsqldb是一個開源的Java實現數據庫，請下載hsqldb2.0.0+版本
hsqldb.jar

2）傳統JDBC編程替代方案：安全

在使用JdbcTemplate模板類時必須經過DataSource獲取數據庫鏈接，Spring JDBC提供了DriverManagerDataSource實現，它經過包裝「DriverManager.getConnection」獲取數據庫鏈接。app

package cn.javass.spring.chapter7;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
public class JdbcTemplateTest {
    private static JdbcTemplate jdbcTemplate;
    @BeforeClass
    public static void setUpClass() {
        String url = "jdbc:hsqldb:mem:test";
        String username = "sa";
        String password = "";
        DriverManagerDataSource dataSource = new DriverManagerDataSource(url, username, password);
        dataSource.setDriverClassName("org.hsqldb.jdbcDriver");
        jdbcTemplate = new JdbcTemplate(dataSource);
    }
    @Test
    public void test() {
        //1.聲明SQL
        String sql = "select * from INFORMATION_SCHEMA.SYSTEM_TABLES";
        jdbcTemplate.query(sql, new RowCallbackHandler() {
            @Override
            public void processRow(ResultSet rs) throws SQLException {
                //2.處理結果集
                String value = rs.getString("TABLE_NAME");
                System.out.println("Column TABLENAME:" + value);
            }
        });
    }
}

接下來讓咱們具體分析一下：框架

1）  jdbc:hsqldb:mem:test：表示使用hsqldb內存數據庫，數據庫名爲「test」。

2）  public static void setUpClass()：使用junit的@BeforeClass註解，表示在因此測試方法以前執行，且只執行一次。在此方法中定義了DataSource並使用DataSource對象建立了JdbcTemplate對象。JdbcTemplate對象是線程安全的。

3）  JdbcTemplate執行流程：首先定義SQL，其次調用JdbcTemplate方法執行SQL，最後經過RowCallbackHandler回調處理ResultSet結果集。

Spring JDBC解決方法相比傳統JDBC編程方式是否是簡單多了，是否是隻有可變部分須要咱們來作，其餘的都由Spring JDBC框架來實現了。

接下來讓咱們深刻JdbcTemplate及其擴展吧。

    JdbcTemplate

首先讓咱們來看下如何使用JdbcTemplate來實現增刪改查。

1、首先建立表結構：

//代碼片斷(cn.javass.spring.chapter7.JdbcTemplateTest)
@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);
}
@After
public void tearDown() {
  String dropTableSql = "drop table test";
  jdbcTemplate.execute(dropTableSql);
}

1）  org.junit包下的@Before和@After 分別表示在測試方法以前和以後執行的方法，對於每一個測試方法都將執行一次；

2）  create memory table test表示建立hsqldb內存表，包含兩個字段id和name，其中id是具備自增功能的主鍵，若是有朋友對此不熟悉hsqldb能夠換成熟悉的數據庫。

2、定義測試骨架，該測試方法將用於實現增刪改查測試：

@Test
public void testCURD() {
    insert();
    delete();
    update();
    select();
}

3、新增測試：

private void insert() {
  jdbcTemplate.update("insert into test(name) values('name1')");
  jdbcTemplate.update("insert into test(name) values('name2')");
  Assert.assertEquals(2, jdbcTemplate.queryForInt("select count(*) from test"));
}

4、刪除測試：

private void delete() {
  jdbcTemplate.update("delete from test where name=?", new Object[]{"name2"});
  Assert.assertEquals(1, jdbcTemplate.queryForInt("select count(*) from test"));
}

5、更新測試：

private void update() {
  jdbcTemplate.update("update test set name='name3' where name=?", new Object[]{"name1"});
  Assert.assertEquals(1, jdbcTemplate.queryForInt("select count(*) from test where name='name3'"));
}

6、查詢測試：

private void select() {
  jdbcTemplate.query("select * from test", new RowCallbackHandler(){
    @Override
    public void processRow(ResultSet rs) throws SQLException {
      System.out.print("====id:" + rs.getInt("id"));
      System.out.println(",name:" + rs.getString("name"));
    }
  });
}

看完以上示例，你們是否以爲JdbcTemplate簡化了咱們不少勞動力呢？接下來讓咱們深刻學習一下JdbcTemplate提供的方法。

JdbcTemplate主要提供如下五類方法：

  • execute方法：能夠用於執行任何SQL語句，通常用於執行DDL語句；

  • update方法及batchUpdate方法：update方法用於執行新增、修改、刪除等語句；batchUpdate方法用於執行批處理相關語句；

  • query方法及queryForXXX方法：用於執行查詢相關語句；

  • call方法：用於執行存儲過程、函數相關語句。

JdbcTemplate類支持的回調類：

  • 預編譯語句及存儲過程建立回調：用於根據JdbcTemplate提供的鏈接建立相應的語句；

  1. PreparedStatementCreator：經過回調獲取JdbcTemplate提供的Connection，由用戶使用該Conncetion建立相關的PreparedStatement；

  2. CallableStatementCreator：經過回調獲取JdbcTemplate提供的Connection，由用戶使用該Conncetion建立相關的CallableStatement；

預編譯語句設值回調：用於給預編譯語句相應參數設值

  1. PreparedStatementSetter：經過回調獲取JdbcTemplate提供的PreparedStatement，由用戶來對相應的預編譯語句相應參數設值；

  2. BatchPreparedStatementSetter：；相似於PreparedStatementSetter，但用於批處理，須要指定批處理大小；

  • 自定義功能回調：提供給用戶一個擴展點，用戶能夠在指定類型的擴展點執行任何數量須要的操做；

  1. ConnectionCallback：經過回調獲取JdbcTemplate提供的Connection，用戶可在該Connection執行任何數量的操做；

  2. StatementCallback：經過回調獲取JdbcTemplate提供的Statement，用戶能夠在該Statement執行任何數量的操做；

  3. PreparedStatementCallback：經過回調獲取JdbcTemplate提供的PreparedStatement，用戶能夠在該PreparedStatement執行任何數量的操做；

  4. CallableStatementCallback：經過回調獲取JdbcTemplate提供的CallableStatement，用戶能夠在該CallableStatement執行任何數量的操做；

  • 結果集處理回調：經過回調處理ResultSet或將ResultSet轉換爲須要的形式；

  1. RowMapper：用於將結果集每行數據轉換爲須要的類型，用戶需實現方法mapRow(ResultSet rs, int rowNum)來完成將每行數據轉換爲相應的類型。

  2. RowCallbackHandler：用於處理ResultSet的每一行結果，用戶需實現方法processRow(ResultSet rs)來完成處理，在該回調方法中無需執行rs.next()，該操做由JdbcTemplate來執行，用戶只需按行獲取數據而後處理便可。

  3. ResultSetExtractor：用於結果集數據提取，用戶需實現方法extractData(ResultSet rs)來處理結果集，用戶必須處理整個結果集；

接下來讓咱們看下具體示例吧，在示例中不可能介紹到JdbcTemplate所有方法及回調類的使用方法，咱們只介紹表明性的，其他的使用都是相似的；

1）預編譯語句及存儲過程建立回調、自定義功能回調使用：

@Test
public void testPpreparedStatement1() {
  int count = jdbcTemplate.execute(new PreparedStatementCreator() {
     @Override
     public PreparedStatement createPreparedStatement(Connection conn)
         throws SQLException {
         return conn.prepareStatement("select count(*) from test");
     }}, new PreparedStatementCallback<Integer>() {
     @Override
     public Integer doInPreparedStatement(PreparedStatement pstmt)
         throws SQLException, DataAccessException {
         pstmt.execute();
         ResultSet rs = pstmt.getResultSet();
         rs.next();
         return rs.getInt(1);
      }});    
   Assert.assertEquals(0, count);
}

首先使用PreparedStatementCreator建立一個預編譯語句，其次由JdbcTemplate經過PreparedStatementCallback回調傳回，由用戶決定如何執行該PreparedStatement。此處咱們使用的是execute方法。

2）預編譯語句設值回調使用：

@Test
public void testPreparedStatement2() {
  String insertSql = "insert into test(name) values (?)";
  int count = jdbcTemplate.update(insertSql, new PreparedStatementSetter() {
      @Override
      public void setValues(PreparedStatement pstmt) 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, PreparedStatementSetter pss)執行預編譯sql，其中sql參數爲「insert into test(name) values (?) 」，該sql有一個佔位符須要在執行前設值，PreparedStatementSetter實現就是爲了設值，使用setValues(PreparedStatement pstmt)回調方法設值相應的佔位符位置的值。JdbcTemplate也提供一種更簡單的方式「update(String sql, Object... args)」來實現設值，因此只要當使用該種方式不知足需求時才應使用PreparedStatementSetter。

3）結果集處理回調：

@Test
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(ResultSet rs, int rowNum) throws SQLException {
          Map row = new HashMap();
          row.put(rs.getInt("id"), rs.getString("name"));
          return row;
  }});
  Assert.assertEquals(1, result.size());
  jdbcTemplate.update("delete from test where name='name5'");     
}

RowMapper接口提供mapRow(ResultSet rs, int rowNum)方法將結果集的每一行轉換爲一個Map，固然能夠轉換爲其餘類，如表的對象畫形式。

@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(ResultSet rs) throws SQLException {
          Map row = new HashMap();
          row.put(rs.getInt("id"), rs.getString("name"));
          result.add(row);
  }});
  Assert.assertEquals(1, result.size());
  jdbcTemplate.update("delete from test where name='name5'");
}

RowCallbackHandler接口也提供方法processRow(ResultSet rs)，能將結果集的行轉換爲須要的形式。

@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(ResultSet rs)
     throws SQLException, DataAccessException {
          List result = new ArrayList();
          while(rs.next()) {
              Map row = new HashMap();
              row.put(rs.getInt("id"), rs.getString("name"));
              result.add(row);
           }
           return result;
  }});
  Assert.assertEquals(0, result.size());
  jdbcTemplate.update("delete from test where name='name5'");
}

ResultSetExtractor使用回調方法extractData(ResultSet rs)提供給用戶整個結果集，讓用戶決定如何處理該結果集。

固然JdbcTemplate提供更簡單的queryForXXX方法，來簡化開發：

//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，但再也不綁定到鏈接上
SqlRowSet rs = jdbcTemplate.queryForRowSet("select * from test");

3） 存儲過程及函數回調：

首先修改JdbcTemplateTest的setUp方法，修改後以下所示：

@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";
    jdbcTemplate.execute(createHsqldbProcedureSql);
}

其中CREATE FUNCTION FUNCTION_TEST用於建立自定義函數，CREATE PROCEDURE PROCEDURE_TEST用於建立存儲過程，注意這些建立語句是數據庫相關的，本示例中的語句只適用於HSQLDB數據庫。

其次修改JdbcTemplateTest的tearDown方法，修改後以下所示：

@After
public void tearDown() {
    jdbcTemplate.execute("DROP FUNCTION FUNCTION_TEST");
    jdbcTemplate.execute("DROP PROCEDURE PROCEDURE_TEST");
    String dropTableSql = "drop table test";
    jdbcTemplate.execute(dropTableSql);
}

其中drop語句用於刪除建立的存儲過程、自定義函數及數據庫表。

接下來看一下hsqldb如何調用自定義函數：

@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>() {
           @Override
           public Integer extractData(ResultSet rs) throws SQLException,
               DataAccessException {
               while(rs.next()) {
                   return rs.getInt(1);
               }
              return 0;
       }));
    Map<String, Object> outValues = jdbcTemplate.call(
       new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection conn) throws SQLException {
              CallableStatement cstmt = conn.prepareCall(callFunctionSql);
              cstmt.setString(1, "test");
              return cstmt;
    }}, params);
    Assert.assertEquals(4, outValues.get("result"));
}

  • {call FUNCTION_TEST(?)}：定義自定義函數的sql語句，注意hsqldb {?= call …}和{call …}含義是同樣的，而好比mysql中兩種含義是不同的；

  • params：用於描述自定義函數佔位符參數或命名參數類型；SqlParameter用於描述IN類型參數、SqlOutParameter用於描述OUT類型參數、SqlInOutParameter用於描述INOUT類型參數、SqlReturnResultSet用於描述調用存儲過程或自定義函數返回的ResultSet類型數據，其中SqlReturnResultSet須要提供結果集處理回調用於將結果集轉換爲相應的形式，hsqldb自定義函數返回值是ResultSet類型。

  • CallableStatementCreator：提供Connection對象用於建立CallableStatement對象

  • outValues：調用call方法將返回類型爲Map<String, Object>對象；

  • outValues.get("result")：獲取結果，即經過SqlReturnResultSet對象轉換過的數據；其中SqlOutParameter、SqlInOutParameter、SqlReturnResultSet指定的name用於從call執行後返回的Map中獲取相應的結果，即name是Map的鍵。

注：由於hsqldb {?= call …}和{call …}含義是同樣的，所以調用自定義函數將返回一個包含結果的ResultSet。

最後讓咱們示例下mysql如何調用自定義函數：

@Test  
public void testCallableStatementCreator2() {  
    JdbcTemplate mysqlJdbcTemplate = new JdbcTemplate(getMysqlDataSource);  
    //2.建立自定義函數  
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);  
//3.準備sql,mysql支持{?= call …}  
final String callFunctionSql = "{?= call FUNCTION_TEST(?)}";  
//4.定義參數  
List<SqlParameter> params = new ArrayList<SqlParameter>();  
params.add(new SqlOutParameter("result", Types.INTEGER));  
params.add(new SqlParameter("str", Types.VARCHAR));  
Map<String, Object> outValues = mysqlJdbcTemplate.call(  
new CallableStatementCreator() {  
    @Override  
    public CallableStatement createCallableStatement(Connection conn) throws SQLException {  
      CallableStatement cstmt = conn.prepareCall(callFunctionSql);  
      cstmt.registerOutParameter(1, Types.INTEGER);  
      cstmt.setString(2, "test");  
        return cstmt;  
    }}, params);  
   Assert.assertEquals(4, outValues.get("result"));  
}  
public DataSource getMysqlDataSource() {  
    String url = "jdbc:mysql://localhost:3306/test";  
    DriverManagerDataSource dataSource =  
        new DriverManagerDataSource(url, "root", "");     dataSource.setDriverClassName("com.mysql.jdbc.Driver");  
    return dataSource;  
}

  • getMysqlDataSource：首先啓動mysql（本書使用5.4.3版本），其次登陸mysql建立test數據庫（「create database test;」），在進行測試前，請先下載並添加mysql-connector-java-5.1.10.jar到classpath；

  • {?= call FUNCTION_TEST(?)}：可使用{?= call …}形式調用自定義函數；

  • params：無需使用SqlReturnResultSet提取結果集數據，而是使用SqlOutParameter來描述自定義函數返回值；

  • CallableStatementCreator：同上個例子含義同樣；

  • cstmt.registerOutParameter(1, Types.INTEGER)：將OUT類型參數註冊爲JDBC類型Types.INTEGER，此處即返回值類型爲Types.INTEGER。

  • outValues.get("result")：獲取結果，直接返回Integer類型，比hsqldb簡單多了吧。

最後看一下如何如何調用存儲過程：

@Test
public void testCallableStatementCreator3() {
    final String callProcedureSql = "{call PROCEDURE_TEST(?, ?)}";
    List<SqlParameter> params = new ArrayList<SqlParameter>();
    params.add(new SqlInOutParameter("inOutName", Types.VARCHAR));
    params.add(new SqlOutParameter("outId", Types.INTEGER));
    Map<String, Object> outValues = jdbcTemplate.call(
      new CallableStatementCreator() {
        @Override
        public CallableStatement createCallableStatement(Connection conn) throws SQLException {
          CallableStatement cstmt = conn.prepareCall(callProcedureSql);
          cstmt.registerOutParameter(1, Types.VARCHAR);
          cstmt.registerOutParameter(2, Types.INTEGER);
          cstmt.setString(1, "test");
          return cstmt;
    }}, params);
    Assert.assertEquals("Hello,test", outValues.get("inOutName"));
    Assert.assertEquals(0, outValues.get("outId"));
}

  • {call PROCEDURE_TEST(?, ?)}：定義存儲過程sql；

  • params：定義存儲過程參數；SqlInOutParameter描述INOUT類型參數、SqlOutParameter描述OUT類型參數；

  • CallableStatementCreator：用於建立CallableStatement，並設值及註冊OUT參數類型；

  • outValues：經過SqlInOutParameter及SqlOutParameter參數定義的name來獲取存儲過程結果。

JdbcTemplate類還提供了不少便利方法，在此就不一一介紹了，但這些方法是由規律可循的，第一種就是提供回調接口讓用戶決定作什麼，第二種能夠認爲是便利方法（如queryForXXX），用於那些比較簡單的操做。

    NamedParameterJdbcTemplate

NamedParameterJdbcTemplate類是基於JdbcTemplate類，並對它進行了封裝從而支持命名參數特性。

NamedParameterJdbcTemplate主要提供如下三類方法：execute方法、query及queryForXXX方法、update及batchUpdate方法。

首先讓咱們看個例子吧：

@Test
public void testNamedParameterJdbcTemplate1() {
NamedParameterJdbcTemplate namedParameterJdbcTemplate = null;
//namedParameterJdbcTemplate =
//    new NamedParameterJdbcTemplate(dataSource);
namedParameterJdbcTemplate =
new NamedParameterJdbcTemplate(jdbcTemplate);
    String insertSql = "insert into test(name) values(:name)";
    String selectSql = "select * from test where name=:name";
    String deleteSql = "delete from test where name=:name";
    Map<String, Object> paramMap = new HashMap<String, Object>();
    paramMap.put("name", "name5");
    namedParameterJdbcTemplate.update(insertSql, paramMap);
    final List<Integer> result = new ArrayList<Integer>();
namedParameterJdbcTemplate.query(selectSql, paramMap,
new RowCallbackHandler() {
        @Override
        public void processRow(ResultSet rs) throws SQLException {
            result.add(rs.getInt("id"));
        }
    });
Assert.assertEquals(1, result.size());
SqlParameterSource paramSource = new MapSqlParameterSource(paramMap);
namedParameterJdbcTemplate.update(deleteSql, paramSource);
}

接下來讓咱們分析一下代碼吧：

1）NamedParameterJdbcTemplate初始化：可使用DataSource或JdbcTemplate 對象做爲構造器參數初始化；

2）insert into test(name) values(:name)：其中「:name」就是命名參數；

3） update(insertSql, paramMap)：其中paramMap是一個Map類型，包含鍵爲「name」，值爲「name5」的鍵值對，也就是爲命名參數設值的數據；

4）query(selectSql, paramMap, new RowCallbackHandler()……)：相似於JdbcTemplate中介紹的，惟一不一樣是須要傳入paramMap來爲命名參數設值；

5）update(

package cn.javass.spring.chapter7;

public class UserModel {

    private int id;

    private String myName;   

    //省略getter和setter     

}

deleteSql, paramSource)：相似於「update(insertSql, paramMap)」，但使用SqlParameterSource參數來爲命名參數設值，此處使用MapSqlParameterSource實現，其就是簡單封裝java.util.Map。

NamedParameterJdbcTemplate類爲命名參數設值有兩種方式：java.util.Map和SqlParameterSource：

1）java.util.Map：使用Map鍵數據來對於命名參數，而Map值數據用於設值；

2）SqlParameterSource：可使用SqlParameterSource實現做爲來實現爲命名參數設值，默認有MapSqlParameterSource和BeanPropertySqlParameterSource實現；MapSqlParameterSource實現很是簡單，只是封裝了java.util.Map；而BeanPropertySqlParameterSource封裝了一個JavaBean對象，經過JavaBean對象屬性來決定命名參數的值。

package cn.javass.spring.chapter7;
public class UserModel {
    private int id;
    private String myName;   
    //省略getter和setter     
}
@Test
public void testNamedParameterJdbcTemplate2() {
    NamedParameterJdbcTemplate namedParameterJdbcTemplate = null;
    namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate);
    UserModel model = new UserModel();
    model.setMyName("name5");
    String insertSql = "insert into test(name) values(:myName)";
    SqlParameterSource paramSource = new BeanPropertySqlParameterSource(model);
    namedParameterJdbcTemplate.update(insertSql, paramSource);
}

能夠看出BeanPropertySqlParameterSource使用能減小不少工做量，但命名參數必須和JavaBean屬性名稱相對應才能夠。

    SimpleJdbcTemplate

SimpleJdbcTemplate類也是基於JdbcTemplate類，但利用Java5+的可變參數列表和自動裝箱和拆箱從而獲取更簡潔的代碼。

SimpleJdbcTemplate主要提供兩類方法：query及queryForXXX方法、update及batchUpdate方法。

首先讓咱們看個例子吧：

//定義UserModel的RowMapper
package cn.javass.spring.chapter7;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class UserRowMapper implements RowMapper<UserModel> {
    @Override
    public UserModel mapRow(ResultSet rs, int rowNum) throws SQLException {
        UserModel model = new UserModel();
        model.setId(rs.getInt("id"));
        model.setMyName(rs.getString("name"));
        return model;
    }
}
@Test
public void testSimpleJdbcTemplate() {
    //還支持DataSource和NamedParameterJdbcTemplate做爲構造器參數
    SimpleJdbcTemplate simpleJdbcTemplate = new SimpleJdbcTemplate(jdbcTemplate);
    String insertSql = "insert into test(id, name) values(?, ?)";
    simpleJdbcTemplate.update(insertSql, 10, "name5");
    String selectSql = "select * from test where id=? and name=?";
    List<Map<String, Object>> result = simpleJdbcTemplate.queryForList(selectSql, 10, "name5");
    Assert.assertEquals(1, result.size());    
    RowMapper<UserModel> mapper = new UserRowMapper();      
    List<UserModel> result2 = simpleJdbcTemplate.query(selectSql, mapper, 10, "name5");
    Assert.assertEquals(1, result2.size());   
}

1）SimpleJdbcTemplate初始化：可使用DataSource、JdbcTemplate或NamedParameterJdbcTemplate對象做爲構造器參數初始化；

2）update(insertSql, 10, "name5")：採用Java5+可變參數列表從而代替new Object[]{10, "name5"}方式；

3）query(selectSql, mapper, 10, "name5")：使用Java5+可變參數列表及RowMapper回調並利用泛型特性來指定返回值類型（List<UserModel>）。

SimpleJdbcTemplate類還支持命名參數特性，如queryForList(String sql, SqlParameterSource args)和queryForList(String sql, Map<String, ?> args) ，相似於NamedParameterJdbcTemplate中使用，在此就不介紹了。

注：SimpleJdbcTemplate還提供相似於ParameterizedRowMapper 用於泛型特性的支持，ParameterizedRowMapper是RowMapper的子類，但從Spring 3.0因爲容許環境須要Java5+，所以再也不須要ParameterizedRowMapper ，而能夠直接使用RowMapper；

query(String sql, ParameterizedRowMapper<T> rm, SqlParameterSource args)

query(String sql, RowMapper<T> rm, Object... args) //直接使用該語句


SimpleJdbcTemplate還提供以下方法用於獲取JdbcTemplate和NamedParameterJdbcTemplate：

1）獲取JdbcTemplate對象方法：JdbcOperations是JdbcTemplate的接口

JdbcOperations getJdbcOperations()

2）獲取NamedParameterJdbcTemplate對象方法：NamedParameterJdbcOperations是NamedParameterJdbcTemplate的接口

NamedParameterJdbcOperations getNamedParameterJdbcOperations()

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程