Spring JdbcTemplate小結

提供了JdbcTemplate 來封裝數據庫jdbc操作細節：
包括： 數據庫連接[打開/關閉] ，異常轉義 ，SQL執行 ，查詢結果的轉換

使用模板方式封裝 jdbc數據庫操作-固定流程的動作，提供豐富callback回調接口功能，方便用戶自定義加工細節，更好模塊化jdbc操作，簡化傳統的JDBC操作的復雜和繁瑣過程。

1) 使用JdbcTemplate 更新(insert /update /delete)

int k = jdbcTemplate.update("UPDATE tblname SET prop1=?,prop2=?...", new Object[]{...});

jdbcTemplate.update("INSERT INTO tblname VALUES(?,?,..)", new Object[]{...},
     new int[]{Types.VARCHAR,Types.NUMERIC}); 

jdbcTemplate.update("INSERT INTO tblname VALUES(?,?,..)",                     
        new PreparedStatementSetter(){                          
               public void setValues(PreparedStatement ps) throws SQLException{      
                    ps.setLong(1, user.getId(1)); 
                    ps.setString(2, user.getName(2));   
                    ps.setDate(3, new java.sql.Date(new Date().getTime());  
                    ps.setTimestamp(4, new Timestamp(new Date().getTime());
               }                     
        }
);

2) 使用JdbcTemplate 查詢 (select)

final User user = new User(); 
jdbcTemplate.query("SELECT id,name,.. FROM tblname WHERE id=1", 
       new RowCallbackHandler(){ 
              public void processRow(ResultSet rs) throws SQLException{ 
                    user.setId(rs.getLong(1)); 
                    user.setName(rs.getString(2)); 
              } 
      }
);  

List uGroup = jdbcTemplate.query("SELECT id,name,.. FROM tblname WHERE igroup=1", 
     new RowMapper(){ 
            public Object mapRow(ResultSet rs,int no) throws SQLException{ 
                     User user = new User(); 
                     user.setId(rs.getLong(1)); 
                     user.setName(rs.getString(2)); 
                     return user ; 
            }
     } 
}; 

3)使用JdbcTemplate 便捷方法

List uNames = jdbcTemplate.queryForList("SELECT name FROM tblname WHERE id>?", 
    new Integer []{5}, String.class); 

List<Map> uMapList = (List<Map>) jdbcTemplate.queryForList( "SELECT id, name FROM tblname WHERE id>?",
             new Integer []{5}); 
for(Map<String,Object> uMap :uMapList){ 
      Integer id = uMap.get("id"); 
      String name = uMap.get("name"); 
}; 

String user = jdbcTemplate.queryForObject("SELECT name FROM tblname WHERE id=?",
     new Integer []{5}, String.class ); 

int uNum = jdbcTemplate.queryForInt("SELECT count(*) FROM tblname WHERE id>?", 
    new Integer []{5}); 

4)使用jdbc 操作類

a)擴展 MappingSqlQuery類

class JdbcQueryObject extends MappingSqlQuery { // extends SqlQuery
      public JdbcQueryObject (DataSource ds,String sql){
            this.setDataSource( ds );
            this.setSql( sql );
            this.declareParameter(new Sqlparameter("propName", 
                Types.VARCHAR);// propName 提示作用
        this.compile();
      }
      public Object mapRow(ResultSet rs,int p) throws SQLException{
                 // ...
     }
}
JdbcQueryObject queryObj = new JdbcQueryObject( ds,
      "SELECT .. FROM tblName WHERE param=?");
List list = queryObj.execute(new Object[]{...});

b)使用 SqlFunction 類 查詢單條結果

SqlFunction queryFun = new SqlFunction( ds, 
      "select count(*) from tblName where ..." ,new int[]{Types.CHAR,...} );
queryFun.compile();
queryFun.run(new Object[]{p1,p2,..});

c)使用 SqlUpdate 類 更新

SqlUpdate updateFunc = new SqlUpdate(ds ,"INSERT tblName ...");
updateFunc.declareParameter( new SqlParameter("prop",Types.CHAR) );
updateFunc.compile();
updateFunc.update(new String[]{s1,s1});

5)支持jdbc 事務

spring的事務管理有兩種方式：編程式事務、聲明式事務

這里談一下 基于數據庫單一資源的編程式事務:

spring用實現TransactionDefinition接口的類定義事務的屬性：傳播行為；隔離級別；超時值；只讀標志

默認實現為：DefaultTransactionDefinition類

PlatformTransactionManager tm =

new DataSourceTransactionManager( 
            jdbcTemplate.getDataSource() );
TransactionStatus status = null;
try{
    //null 默認事務屬性配置DefaultTransactionDefinition
    status = tm.getTransaction(null);

  for(final String wd: words){

   try {
     jdbcTemplate.update( insertWordSql, 
          new PreparedStatementSetter(){


public void setValues(PreparedStatement pstate) 
                 throws SQLException {
            pstate.setString(1, wd) ; 
    pstate.setTimestamp(2, 
    new Timestamp( new Date().getTime() ));                             
}                   
    }
 );                 


} catch (DataAccessException e) {
       e.printStackTrace();
       //tm.rollback(status);
    }
    } // end for
} finally {
     tm.commit(status);
}   </pre> 

轉自：http://hwqjavaeye.iteye.com/blog/289330