spring JdbcTemplate小结
?
?
Spring
?
?
提供了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);}?
?
finally { tm.commit(status); }这个代码明显有问题