JdbcTemplate

用過Spring開發的，ORM框架一般選擇MyBatis或者Hibernate，不過，Spring對JDBC API的封裝工具JdbcTemplate，也提供了很方便的操作，不需要再在使用jdbc api時捕獲那麼多受檢異常，忍受那麼多樣板式的程式碼了。

JdbcTemplate主要提供以下幾類方法：

1. execute方法：用於執行任何SQL語句，一般用於執行DDL語句；
2. update方法及batchUpdate方法：update方法用於執行新增、修改、刪除等語句；batchUpdate批量執行修改；
3. query方法及queryForXXX方法：用於執行查詢相關語句，query方法返回一個列表，queryForXXX方法一般只返回一個物件；
4. call方法：用於執行儲存過程、函式相關語句，一般使用不到

JdbcTemplate類支援設定自定義的回撥，比如回撥產生預編譯語句和儲存過程。

如PreparedStatementCreator，使用PreparedStatementCreator，我們可以通過回撥獲取到JdbcTemplate提供的資料庫連線Connection，然後再利用該Conncetion建立自定義的預編譯語句PreparedStatement，如，

// 預編譯語句及儲存過程建立回撥、自定義功能回撥使用：
@Test
public void testPreparedStatement1() {
    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方法。

還有CallableStatementCreator，使用CallableStatementCreator，我們可以通過回撥獲取到JdbcTemplate提供的資料庫連線Connection，然後再利用該Conncetion建立自定義的CallableStatement。

還有PreparedStatementSetter，使用PreparedStatementSetter，我們可以通過回撥獲取到Spring建立的預編譯語句PreparedStatement，然後再對該PreparedStatement的佔位符引數’?’設定相應的值。如，

// 預編譯語句設值回撥使用：
@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。

還有BatchPreparedStatementSetter，類似於上面的PreparedStatementSetter，但用於批量設定和批量執行，而且指定批量的量大小size。

還有自定義功能回撥，可以提供一個擴充套件點，在指定型別的擴充套件點可以執行任何數量需要的操作，如，
ConnectionCallback，使用ConnectionCallback，我們可以通過回撥獲取到JdbcTemplate提供的資料庫連線Connection，然後再利用該Conncetion執行任何數量的操作；

StatementCallback，使用StatementCallback，我們可以通過回撥獲取到JdbcTemplate提供的Statement語句，然後再利用該Statement執行任何數量的操作；

PreparedStatementCallback，使用PreparedStatementCallback，我們可以通過回撥獲取到JdbcTemplate提供的預編譯語句PreparedStatement，然後再利用該PreparedStatement執行任何數量的操作；

CallableStatementCallback，使用CallableStatementCallback，我們可以通過回撥獲取到JdbcTemplate提供的回撥語句CallableStatement，然後再利用該CallableStatement執行任何數量的操作。

對於JdbcTemplate查詢出來的資料，如果要對映成Java物件，一般需要傳遞一個RowMapper實現，RowMapper用於將結果集的每行資料轉換為需要的型別，需要實現方法mapRow(ResultSet rs, int rowNum)來完成轉換。如，

// 結果集處理回撥：
@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，當然可以轉換為其他類，如表的物件畫形式。

BeanPropertyRowMapper

對於RowMapper，使用最多的實現是BeanPropertyRowMapper，由名字可以看出，BeanPropertyRowMapper用於匹配Java類屬性和資料庫表字段，其具體實現是，內部存放一個MappedFields的HashMap，key是屬性名稱，value是Java類的屬性。

首先，類的屬性（該屬性要有write方法）名稱全部轉化成小寫，放進map中。

其次，只要類屬性名稱中有大寫字母，把所有這樣的大寫字母都轉化成字串和小寫的形式：“_小寫”，把轉化後的整個屬性名稱放進map中。

注意（BeanPropertyRowMapper中的坑）

BeanPropertyRowMapper預設資料庫欄位名和Python變數名命名類似，以下劃線分割單詞；
預設Java類的屬性名是以camelCase形式或者是下劃線形式（這兩種中的任一種都可以）。

如果資料庫欄位名不使用下劃線分割，則應全部使用小寫。這個時候，Java類屬性名也應全部使用小寫，不能使用camelCase，如資料庫欄位名為companyaddress，那麼Java類該屬性對應的名字也應該為companyaddress，不能為companyAddress。

如，BeanPropertyRowMapper在建立的時候會呼叫initialize方法來初始化，這個時候，就會把Java類的屬性的camelCase風格的名稱轉化成下劃線分割的名稱和全小寫的名稱，如，

除了RowMapper，還有RowCallbackHandler，用於處理結果集中的每一行，需要實現processRow(ResultSet rs)方法。注意，在processRow方法中不要執行rs.next()，這個操作由JdbcTemplate來做，我們只需要獲取資料就行。

@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)，能將結果集的行轉換為需要的形式。

還有ResultSetExtractor，用於提取ResultSet資料，需要實現extractData(ResultSet rs)方法。注意，在extractData方法中需要我們處理整個ResultSet結果集資料。

@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)提供給使用者整個結果集，讓使用者決定如何處理該結果集。

喜歡的可以關注微信公眾號：

更多文章