【第七章】對JDBC的支持之 7.2 JDBC模板類 ——跟我學spring3 · 跟我學 Spring 系列

# 【第七章】對JDBC的支持之 7.2 JDBC模板類 ——跟我學spring3 ## ## 7.2? JDBC模板類 ### 7.2.1? 概述 Spring JDBC抽象框架core包提供了JDBC模板類，其中JdbcTemplate是core包的核心類，所以其他模板類都是基于它封裝完成的，JDBC模板類是第一種工作模式。 JdbcTemplate類通過模板設計模式幫助我們消除了冗長的代碼，只做需要做的事情（即可變部分），并且幫我們做哪些固定部分，如連接的創建及關閉。 JdbcTemplate類對可變部分采用回調接口方式實現，如ConnectionCallback通過回調接口返回給用戶一個連接，從而可以使用該連接做任何事情、StatementCallback通過回調接口返回給用戶一個Statement，從而可以使用該Statement做任何事情等等，還有其他一些回調接口如圖7-3所示。 ![](https://box.kancloud.cn/2016-05-13_5735471f5a3cd.JPG) 圖7-3 JdbcTemplate支持的回調接口 Spring除了提供JdbcTemplate核心類，還提供了基于JdbcTemplate實現的NamedParameterJdbcTemplate類用于支持命名參數綁定、?SimpleJdbcTemplate類用于支持Java5+的可變參數及自動裝箱拆箱等特性。 ### 7.2.3??????? ?傳統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”獲取數據庫連接，具體DataSource相關請參考【7.5.1控制數據庫連接】。 ``` 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及其擴展吧。 ### 7.2.4??????? ?JdbcTemplate 首先讓我們來看下如何使用JdbcTemplate來實現增刪改查。一、首先創建表結構： ``` //代碼片段(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可以換成熟悉的數據庫。二、定義測試骨架，該測試方法將用于實現增刪改查測試： ``` @Test public void testCURD() { insert(); delete(); update(); select(); } ``` 三、新增測試： ``` 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")); } ``` 四、刪除測試： ``` private void delete() { jdbcTemplate.update("delete from test where name=?", new Object[]{"name2"}); Assert.assertEquals(1, jdbcTemplate.queryForInt("select count(*) from test")); } ``` 五、更新測試： ``` 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'")); } ``` 六、查詢測試： ``` 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提供的連接創建相應的語句； **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）預編譯語句及存儲過程創建回調、自定義功能回調使用：** ``` @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），用于那些比較簡單的操作。 ### 7.2.4? 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(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屬性名稱相對應才可以。 ### 7.2.5? 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()** > > | 原創內容，轉載請注明出處【[http://sishuok.com/forum/blogPost/list/0/2490.html](http://sishuok.com/forum/blogPost/list/0/2490.html#7203)】