碼上歡樂
相關內容    簡體    繁體

spring對JDBC的支持

本文轉載自   查看原文   2016-08-17 21:36   2071    spring3細致講解

傳統應用程序開發中，進行JDBC編程是相當痛苦的，如下所示：

Java代碼   收藏代碼
  1. //cn.javass.spring.chapter7. TraditionalJdbcTest  
  2. @Test  
  3. public void test() throws Exception {  
  4.     Connection conn = null;  
  5.     PreparedStatement pstmt = null;  
  6.     try {  
  7.       conn = getConnection();              //1.獲取JDBC連接  
  8.                                        //2.聲明SQL  
  9.       String sql = "select * from INFORMATION_SCHEMA.SYSTEM_TABLES";  
  10.       pstmt = conn.prepareStatement(sql);    //3.預編譯SQL  
  11.       ResultSet rs = pstmt.executeQuery();   //4.執行SQL  
  12.       process(rs);                       //5.處理結果集  
  13.       closeResultSet(rs);                 //5.釋放結果集  
  14.       closeStatement(pstmt);              //6.釋放Statement  
  15.       conn.commit();                    //8.提交事務  
  16.     } catch (Exception e) {  
  17.       //9.處理異常並回滾事務  
  18.       conn.rollback();  
  19.       throw e;  
  20.     } finally {  
  21.       //10.釋放JDBC連接，防止JDBC連接不關閉造成的內存泄漏  
  22.       closeConnection(conn);  
  23.     }  
  24. }  

 

       以上代碼片段具有冗長、重復、容易忘記某一步驟從而導致出錯、顯示控制事務、顯示處理受檢查異常等等。

       有朋友可能重構出自己的一套JDBC模板，從而能簡化日常開發，但自己開發的JDBC模板不夠通用，而且對於每一套JDBC模板實現都差不多，從而導致開發人員必須掌握每一套模板。

       Spring JDBC提供了一套JDBC抽象框架，用於簡化JDBC開發

 

 

Spring JDBC抽象框架core包提供了JDBC模板類，其中JdbcTemplate是core包的核心類，所以其他模板類都是基於它封裝完成的

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

 

JdbcTemplate類通過模板設計模式幫助我們消除了冗長的代碼，只做需要做的事情（即可變部分），並且幫我們做哪些固定部分，如連接的創建及關閉。

 

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

 

 

 JdbcTemplate支持的回調接口

 

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

 

傳統JDBC編程替代方案

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

1）准備需要的jar包並添加到類路徑中：

 

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

 

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

在使用JdbcTemplate模板類時必須通過DataSource獲取數據庫連接，Spring JDBC提供了DriverManagerDataSource實現，它通過包裝“DriverManager.getConnection”獲取數據庫連接，具體DataSource相關請參考【7.5.1控制數據庫連接】。

 
Java代碼   收藏代碼
  1. package cn.javass.spring.chapter7;  
  2. import java.sql.ResultSet;  
  3. import java.sql.SQLException;  
  4. import org.junit.AfterClass;  
  5. import org.junit.BeforeClass;  
  6. import org.junit.Test;  
  7. import org.springframework.jdbc.core.JdbcTemplate;  
  8. import org.springframework.jdbc.core.RowCallbackHandler;  
  9. import org.springframework.jdbc.datasource.DriverManagerDataSource;  
  10. public class JdbcTemplateTest {  
  11.     private static JdbcTemplate jdbcTemplate;  
  12.     @BeforeClass  
  13.     public static void setUpClass() {  
  14.         String url = "jdbc:hsqldb:mem:test";  
  15.         String username = "sa";  
  16.         String password = "";  
  17.         DriverManagerDataSource dataSource = new DriverManagerDataSource(url, username, password);  
  18.         dataSource.setDriverClassName("org.hsqldb.jdbcDriver");  
  19.         jdbcTemplate = new JdbcTemplate(dataSource);  
  20.     }  
  21.     @Test  
  22.     public void test() {  
  23.         //1.聲明SQL  
  24.         String sql = "select * from INFORMATION_SCHEMA.SYSTEM_TABLES";  
  25.         jdbcTemplate.query(sql, new RowCallbackHandler() {  
  26.             @Override  
  27.             public void processRow(ResultSet rs) throws SQLException {  
  28.                 //2.處理結果集  
  29.                 String value = rs.getString("TABLE_NAME");  
  30.                 System.out.println("Column TABLENAME:" + value);  
  31.             }  
  32.         });  
  33.     }  
  34. }  
  35.    

 

接下來讓我們具體分析一下：

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及其擴展吧。

 

7.2.4         JdbcTemplate

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

一、首先創建表結構：

 
Java代碼   收藏代碼
  1. //代碼片段(cn.javass.spring.chapter7.JdbcTemplateTest)  
  2. @Before  
  3. public void setUp() {  
  4.    String createTableSql = "create memory table test" + "(id int GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY, " + "name varchar(100))";  
  5.    jdbcTemplate.update(createTableSql);  
  6. }  
  7. @After  
  8. public void tearDown() {  
  9.   String dropTableSql = "drop table test";  
  10.   jdbcTemplate.execute(dropTableSql);  
  11. }  

 

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

 

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

 

 

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

 
Java代碼   收藏代碼
  1. @Test  
  2. public void testCURD() {  
  3.     insert();  
  4.     delete();  
  5.     update();  
  6.     select();  
  7. }  

 

三、新增測試：

 
Java代碼   收藏代碼
  1. private void insert() {  
  2.   jdbcTemplate.update("insert into test(name) values('name1')");  
  3.   jdbcTemplate.update("insert into test(name) values('name2')");  
  4.   Assert.assertEquals(2, jdbcTemplate.queryForInt("select count(*) from test"));  
  5. }  

 

四、刪除測試：

 
Java代碼   收藏代碼
  1. private void delete() {  
  2.   jdbcTemplate.update("delete from test where name=?", new Object[]{"name2"});  
  3.   Assert.assertEquals(1, jdbcTemplate.queryForInt("select count(*) from test"));  
  4. }  

 

五、更新測試：

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

 

 

六、查詢測試：

 

java代碼：
Java代碼   收藏代碼
  1. private void select() {  
  2.   jdbcTemplate.query("select * from test", new RowCallbackHandler(){  
  3.     @Override  
  4.     public void processRow(ResultSet rs) throws SQLException {  
  5.       System.out.print("====id:" + rs.getInt("id"));  
  6.       System.out.println(",name:" + rs.getString("name"));  
  7.     }  
  8.   });  
  9. }  

 

       看完以上示例，大家是否覺得JdbcTemplate簡化了我們很多勞動力呢？接下來讓我們深入學習一下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(ResultSet rs, int rowNum)來完成將每行數據轉換為相應的類型。

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

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

 

接下來讓我們看下具體示例吧，在示例中不可能介紹到JdbcTemplate全部方法及回調類的使用方法，我們只介紹代表性的，其余的使用都是類似的；

 

 

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

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testPpreparedStatement1() {  
  3.   int count = jdbcTemplate.execute(new PreparedStatementCreator() {  
  4.      @Override  
  5.      public PreparedStatement createPreparedStatement(Connection conn)  
  6.          throws SQLException {  
  7.          return conn.prepareStatement("select count(*) from test");  
  8.      }}, new PreparedStatementCallback<Integer>() {  
  9.      @Override  
  10.      public Integer doInPreparedStatement(PreparedStatement pstmt)  
  11.          throws SQLException, DataAccessException {  
  12.          pstmt.execute();  
  13.          ResultSet rs = pstmt.getResultSet();  
  14.          rs.next();  
  15.          return rs.getInt(1);  
  16.       }});      
  17.    Assert.assertEquals(0, count);  
  18. }  
  19.    

 

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

 

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

 

Java代碼   收藏代碼
  1.       
  2. @Test  
  3. public void testPreparedStatement2() {  
  4.   String insertSql = "insert into test(name) values (?)";  
  5.   int count = jdbcTemplate.update(insertSql, new PreparedStatementSetter() {  
  6.       @Override  
  7.       public void setValues(PreparedStatement pstmt) throws SQLException {  
  8.           pstmt.setObject(1, "name4");  
  9.   }});  
  10.   Assert.assertEquals(1, count);      
  11.   String deleteSql = "delete from test where name=?";  
  12.   count = jdbcTemplate.update(deleteSql, new Object[] {"name4"});  
  13.   Assert.assertEquals(1, count);  
  14. }  

 

      通過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）結果集處理回調：

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testResultSet1() {  
  3.   jdbcTemplate.update("insert into test(name) values('name5')");  
  4.   String listSql = "select * from test";  
  5.   List result = jdbcTemplate.query(listSql, new RowMapper<Map>() {  
  6.       @Override  
  7.       public Map mapRow(ResultSet rs, int rowNum) throws SQLException {  
  8.           Map row = new HashMap();  
  9.           row.put(rs.getInt("id"), rs.getString("name"));  
  10.           return row;  
  11.   }});  
  12.   Assert.assertEquals(1, result.size());  
  13.   jdbcTemplate.update("delete from test where name='name5'");       
  14. }  

 

RowMapper接口提供mapRow(ResultSet rs, int rowNum)方法將結果集的每一行轉換為一個Map，當然可以轉換為其他類，如表的對象畫形式。

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testResultSet2() {  
  3.   jdbcTemplate.update("insert into test(name) values('name5')");  
  4.   String listSql = "select * from test";  
  5.   final List result = new ArrayList();  
  6.   jdbcTemplate.query(listSql, new RowCallbackHandler() {  
  7.       @Override  
  8.       public void processRow(ResultSet rs) throws SQLException {  
  9.           Map row = new HashMap();  
  10.           row.put(rs.getInt("id"), rs.getString("name"));  
  11.           result.add(row);  
  12.   }});  
  13.   Assert.assertEquals(1, result.size());  
  14.   jdbcTemplate.update("delete from test where name='name5'");  
  15. }  

 

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

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testResultSet3() {  
  3.   jdbcTemplate.update("insert into test(name) values('name5')");  
  4.   String listSql = "select * from test";  
  5.   List result = jdbcTemplate.query(listSql, new ResultSetExtractor<List>() {  
  6.       @Override  
  7.       public List extractData(ResultSet rs)  
  8.      throws SQLException, DataAccessException {  
  9.           List result = new ArrayList();  
  10.           while(rs.next()) {  
  11.               Map row = new HashMap();  
  12.               row.put(rs.getInt("id"), rs.getString("name"));  
  13.               result.add(row);  
  14.            }  
  15.            return result;  
  16.   }});  
  17.   Assert.assertEquals(0, result.size());  
  18.   jdbcTemplate.update("delete from test where name='name5'");  
  19. }  

 

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

 

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

Java代碼   收藏代碼
  1. //1.查詢一行數據並返回int型結果  
  2. jdbcTemplate.queryForInt("select count(*) from test");  
  3. //2. 查詢一行數據並將該行數據轉換為Map返回  
  4. jdbcTemplate.queryForMap("select * from test where name='name5'");  
  5. //3.查詢一行任何類型的數據，最后一個參數指定返回結果類型  
  6. jdbcTemplate.queryForObject("select count(*) from test", Integer.class);  
  7. //4.查詢一批數據，默認將每行數據轉換為Map       
  8. jdbcTemplate.queryForList("select * from test");  
  9. //5.只查詢一列數據列表，列類型是String類型，列名字是name  
  10. jdbcTemplate.queryForList("  
  11. select name from test where name=?", new Object[]{"name5"}, String.class);  
  12. //6.查詢一批數據，返回為SqlRowSet，類似於ResultSet，但不再綁定到連接上  
  13. SqlRowSet rs = jdbcTemplate.queryForRowSet("select * from test");  

 

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

首先修改JdbcTemplateTest的setUp方法，修改后如下所示：

Java代碼   收藏代碼
  1.       
  2. @Before  
  3. public void setUp() {  
  4.     String createTableSql = "create memory table test" +  
  5.     "(id int GENERATED BY DEFAULT AS IDENTITY PRIMARY KEY, " +  
  6.     "name varchar(100))";  
  7.     jdbcTemplate.update(createTableSql);  
  8.          
  9.     String createHsqldbFunctionSql =  
  10.       "CREATE FUNCTION FUNCTION_TEST(str CHAR(100)) " +  
  11.       "returns INT begin atomic return length(str);end";  
  12.     jdbcTemplate.update(createHsqldbFunctionSql);  
  13.     String createHsqldbProcedureSql =  
  14.       "CREATE PROCEDURE PROCEDURE_TEST" +  
  15.       "(INOUT inOutName VARCHAR(100), OUT outId INT) " +  
  16.       "MODIFIES SQL DATA " +  
  17.       "BEGIN ATOMIC " +  
  18.       "  insert into test(name) values (inOutName); " +  
  19.       "  SET outId = IDENTITY(); " +  
  20.       "  SET inOutName = 'Hello,' + inOutName; " +  
  21.     "END";  
  22.     jdbcTemplate.execute(createHsqldbProcedureSql);  
  23. }  

 

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

 

       其次修改JdbcTemplateTest的tearDown方法，修改后如下所示：

 

Java代碼   收藏代碼
  1. @After  
  2. public void tearDown() {  
  3.     jdbcTemplate.execute("DROP FUNCTION FUNCTION_TEST");  
  4.     jdbcTemplate.execute("DROP PROCEDURE PROCEDURE_TEST");  
  5.     String dropTableSql = "drop table test";  
  6.     jdbcTemplate.execute(dropTableSql);  
  7. }  

 

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

 

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

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testCallableStatementCreator1() {  
  3.     final String callFunctionSql = "{call FUNCTION_TEST(?)}";  
  4.     List<SqlParameter> params = new ArrayList<SqlParameter>();  
  5.     params.add(new SqlParameter(Types.VARCHAR));  
  6.     params.add(new SqlReturnResultSet("result",  
  7.        new ResultSetExtractor<Integer>() {  
  8.            @Override  
  9.            public Integer extractData(ResultSet rs) throws SQLException,  
  10.                DataAccessException {  
  11.                while(rs.next()) {  
  12.                    return rs.getInt(1);  
  13.                }  
  14.               return 0;  
  15.        }));  
  16.     Map<String, Object> outValues = jdbcTemplate.call(  
  17.        new CallableStatementCreator() {  
  18.             @Override  
  19.             public CallableStatement createCallableStatement(Connection conn) throws SQLException {  
  20.               CallableStatement cstmt = conn.prepareCall(callFunctionSql);  
  21.               cstmt.setString(1, "test");  
  22.               return cstmt;  
  23.     }}, params);  
  24.     Assert.assertEquals(4, outValues.get("result"));  
  25. }  
  26.    

 

  • {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如何調用自定義函數：

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testCallableStatementCreator2() {  
  3.     JdbcTemplate mysqlJdbcTemplate = new JdbcTemplate(getMysqlDataSource);  
  4.     //2.創建自定義函數  
  5. String createFunctionSql =  
  6.     "CREATE FUNCTION FUNCTION_TEST(str VARCHAR(100)) " +  
  7.      "returns INT return LENGTH(str)";  
  8. String dropFunctionSql = "DROP FUNCTION IF EXISTS FUNCTION_TEST";  
  9. mysqlJdbcTemplate.update(dropFunctionSql);         
  10. mysqlJdbcTemplate.update(createFunctionSql);  
  11. //3.准備sql,mysql支持{?= call …}  
  12. final String callFunctionSql = "{?= call FUNCTION_TEST(?)}";  
  13. //4.定義參數  
  14. List<SqlParameter> params = new ArrayList<SqlParameter>();  
  15. params.add(new SqlOutParameter("result", Types.INTEGER));  
  16. params.add(new SqlParameter("str", Types.VARCHAR));  
  17. Map<String, Object> outValues = mysqlJdbcTemplate.call(  
  18. new CallableStatementCreator() {  
  19.     @Override  
  20.     public CallableStatement createCallableStatement(Connection conn) throws SQLException {  
  21.       CallableStatement cstmt = conn.prepareCall(callFunctionSql);  
  22.       cstmt.registerOutParameter(1, Types.INTEGER);  
  23.       cstmt.setString(2, "test");  
  24.         return cstmt;  
  25.     }}, params);  
  26.    Assert.assertEquals(4, outValues.get("result"));  
  27. }  
  28. public DataSource getMysqlDataSource() {  
  29.     String url = "jdbc:mysql://localhost:3306/test";  
  30.     DriverManagerDataSource dataSource =  
  31.         new DriverManagerDataSource(url, "root", "");     dataSource.setDriverClassName("com.mysql.jdbc.Driver");  
  32.     return dataSource;  
  33. }  
  34.    
  • 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簡單多了吧。

 

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

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testCallableStatementCreator3() {  
  3.     final String callProcedureSql = "{call PROCEDURE_TEST(?, ?)}";  
  4.     List<SqlParameter> params = new ArrayList<SqlParameter>();  
  5.     params.add(new SqlInOutParameter("inOutName", Types.VARCHAR));  
  6.     params.add(new SqlOutParameter("outId", Types.INTEGER));  
  7.     Map<String, Object> outValues = jdbcTemplate.call(  
  8.       new CallableStatementCreator() {  
  9.         @Override  
  10.         public CallableStatement createCallableStatement(Connection conn) throws SQLException {  
  11.           CallableStatement cstmt = conn.prepareCall(callProcedureSql);  
  12.           cstmt.registerOutParameter(1, Types.VARCHAR);  
  13.           cstmt.registerOutParameter(2, Types.INTEGER);  
  14.           cstmt.setString(1, "test");  
  15.           return cstmt;  
  16.     }}, params);  
  17.     Assert.assertEquals("Hello,test", outValues.get("inOutName"));  
  18.     Assert.assertEquals(0, outValues.get("outId"));  
  19. }  
  20.    
  • {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方法。

首先讓我們看個例子吧：

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testNamedParameterJdbcTemplate1() {  
  3. NamedParameterJdbcTemplate namedParameterJdbcTemplate = null;  
  4. //namedParameterJdbcTemplate =  
  5. //    new NamedParameterJdbcTemplate(dataSource);  
  6. namedParameterJdbcTemplate =  
  7. new NamedParameterJdbcTemplate(jdbcTemplate);  
  8.     String insertSql = "insert into test(name) values(:name)";  
  9.     String selectSql = "select * from test where name=:name";  
  10.     String deleteSql = "delete from test where name=:name";  
  11.     Map<String, Object> paramMap = new HashMap<String, Object>();  
  12.     paramMap.put("name", "name5");  
  13.     namedParameterJdbcTemplate.update(insertSql, paramMap);  
  14.     final List<Integer> result = new ArrayList<Integer>();  
  15. namedParameterJdbcTemplate.query(selectSql, paramMap,  
  16. new RowCallbackHandler() {  
  17.         @Override  
  18.         public void processRow(ResultSet rs) throws SQLException {  
  19.             result.add(rs.getInt("id"));  
  20.         }  
  21.     });  
  22. Assert.assertEquals(1, result.size());  
  23. SqlParameterSource paramSource = new MapSqlParameterSource(paramMap);  
  24. namedParameterJdbcTemplate.update(deleteSql, paramSource);  
  25. }  

 

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

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(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對象屬性來決定命名參數的值。

 

Java代碼   收藏代碼
  1. package cn.javass.spring.chapter7;  
  2. public class UserModel {  
  3.     private int id;  
  4.     private String myName;     
  5.     //省略getter和setter       
  6. }  

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testNamedParameterJdbcTemplate2() {  
  3.     NamedParameterJdbcTemplate namedParameterJdbcTemplate = null;  
  4.     namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(jdbcTemplate);  
  5.     UserModel model = new UserModel();  
  6.     model.setMyName("name5");  
  7.     String insertSql = "insert into test(name) values(:myName)";  
  8.     SqlParameterSource paramSource = new BeanPropertySqlParameterSource(model);  
  9.     namedParameterJdbcTemplate.update(insertSql, paramSource);  
  10. }  

 

可以看出BeanPropertySqlParameterSource使用能減少很多工作量，但命名參數必須和JavaBean屬性名稱相對應才可以。

 

SimpleJdbcTemplate

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

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

首先讓我們看個例子吧：

 

Java代碼   收藏代碼
  1. //定義UserModel的RowMapper  
  2. package cn.javass.spring.chapter7;  
  3. import java.sql.ResultSet;  
  4. import java.sql.SQLException;  
  5. import org.springframework.jdbc.core.RowMapper;  
  6. public class UserRowMapper implements RowMapper<UserModel> {  
  7.     @Override  
  8.     public UserModel mapRow(ResultSet rs, int rowNum) throws SQLException {  
  9.         UserModel model = new UserModel();  
  10.         model.setId(rs.getInt("id"));  
  11.         model.setMyName(rs.getString("name"));  
  12.         return model;  
  13.     }  
  14. }  

 

Java代碼   收藏代碼
  1. @Test  
  2. public void testSimpleJdbcTemplate() {  
  3.     //還支持DataSource和NamedParameterJdbcTemplate作為構造器參數  
  4.     SimpleJdbcTemplate simpleJdbcTemplate = new SimpleJdbcTemplate(jdbcTemplate);  
  5.     String insertSql = "insert into test(id, name) values(?, ?)";  
  6.     simpleJdbcTemplate.update(insertSql, 10, "name5");  
  7.     String selectSql = "select * from test where id=? and name=?";  
  8.     List<Map<String, Object>> result = simpleJdbcTemplate.queryForList(selectSql, 10, "name5");  
  9.     Assert.assertEquals(1, result.size());      
  10.     RowMapper<UserModel> mapper = new UserRowMapper();        
  11.     List<UserModel> result2 = simpleJdbcTemplate.query(selectSql, mapper, 10, "name5");  
  12.     Assert.assertEquals(1, result2.size());     
  13. }  

 

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()

 

 

 


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 Spring項目對JDBC的支持和基本使用 Spring框架學習六：Spring對JDBC的支持 Spring對 JDBC 的支持，JdbcTemplate類的使用 spring的jdbc Spring JDBC Springboot使用jdbc以及事務支持 SpringBoot 集成Spring JDBC Spring JDBC（二）SimpleJdbcInsert Spring-JDBC配置 Spring整合jdbc編程
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM