JDBC模板类（version 1.2）
1.2版本中添加了一个新插入的方法： /** * 在Web开发中struts框架中，页数数据在被存入数据库时会被包装在一个formbean对象中 * 在把这些数据存入数据库时，需要把formbean中值取出来，在插入数据库中这样很麻烦 * 所以我设计了这个方法，只需要一个sql语句(sql语句字段名必须和数据库中的完全一致,字段顺序可以随便) * 和一个封装好数据对象。 * 这个方法对页面数据提交在存入数据库，有很大方便。 * 在这里插入主键时，主键值也应当包含那个封装对象中 * 思想：主要是对sql语句进行分析，解析出要插入字段名称，在利用反射技术将值set到preparedStatement对象中。 * @param sql 数据库插入 sql语句 * @param obj 已经封装好数据对象 * @return 新增成功记录数 * @throws Exception */ public int insert(String sql, Object obj) throws Exception { if(obj==null){ return 0; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; String [] fieldNames=resolveSQL(sql); try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<fieldNames.length;i++){ Object o=valueFromObject(fieldNames[i],obj); PreparedStatementSetValue(ps,o,i+1); } return ps.executeUpdate(); }finally{ jdbcUtil.free(rs,ps,conn); } }?
=================================================================
package daoUtil.daoTemplate;import java.lang.reflect.InvocationTargetException;import java.lang.reflect.Method;import java.sql.Connection;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.util.ArrayList;import java.util.Collection;import jdbcUtil.JdbcUtil;import daoUtil.PrimaryKeyer;import daoUtil.RowMapper;/** * 在写jdbc程序是可以清楚的知道 * 在程序中只有sql语句和其参数值是变化 * 其余程序代码几乎类似（获得连接，关闭连接） * 在这里我对以前所写jdbc程序进行了一下改进 * 将获得连接和关闭连接的程序代码交给一个模板类去做 * 再写jdbc程序时，调用模板类中相应的方法，传入sql语句和其参数值 * 这样大大简化jdbc程序，给我们带来方便 * 程序新版本往后日子会不断更新，渴望javaeye里面高手多多给我指点 * @author kevin.wangwei * Email:wanwei.234@163.com * 2010-1-30 */public class DAOTemplate{ /**jdbc工具类*/ private JdbcUtil jdbcUtil=JdbcUtil.getInstance(); /** * 数据库删除操作 * @param sql 删除操作sql语句 * @param args 删除操作sql语句参数值数组 * @return 删除记录条数 * @throws SQLException */ public int delete(String sql, Object[] args) throws SQLException { if(args==null||args.length==0){ return 0; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]);//在这里我们应该调用下面的PreparedStatementSetValue方法， //不过这样写亦可以，但它不可以处理null值 } return ps.executeUpdate(); }finally{ jdbcUtil.free(rs,ps,conn); } } /** * 数据库更新操作 * @param sql 更新操作sql语句 * @param args sql语句参数值数组 * @return 更新记录条数 * @throws SQLException */ public int update(String sql, Object[] args) throws SQLException { if(args==null||args.length==0){ return 0; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]); } return ps.executeUpdate(); }finally{ jdbcUtil.free(rs,ps,conn); } } /** * 数据库查询操作 采用反射来给包装sql语句参数赋值 * @param sql 查询操作sql语句 * @param args 删除操作sql语句数组数值 * @return 结果对象 * @throws SQLException */ public Object find(String sql, Object[] args,RowMapper rowMapper) throws SQLException { if(args==null||args.length==0){ return 0; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<args.length;i++){ try { PreparedStatementSetValue(ps,args[i],i+1); } catch (Exception e) { e.printStackTrace(); } } rs=ps.executeQuery(); Object obj=null; while(rs.next()){ obj=rowMapper.rowMapping(rs); } return obj; }finally{ jdbcUtil.free(rs,ps,conn); } } /** * 获得表中记录数 * @param sql sql语句 * @param args 参数数组 * @return 表中记录数 * @throws SQLException */ public int getRecordCount(String sql, Object[] args) throws SQLException { if(args==null||args.length==0){ return 0; } int count=0; Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]); } rs=ps.executeQuery(); if(rs.next()){ count=rs.getInt(1); } }finally{ jdbcUtil.free(rs,ps,conn); } return count; } /** * 根据数据库表名，找到该表中所有记录数 * @param tableName 要查询的表 * @return 表中记录数 * @throws SQLException */ public int getRecordCount(String tableName) throws SQLException { if(tableName==null||tableName.equals("")){ return 0; } int count=0; Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; try { conn=jdbcUtil.getConnection(); String sql="select count(*) from "+tableName; ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); if(rs.next()){ count=rs.getInt(1); } }finally{ jdbcUtil.free(rs,ps,conn); } return count; } /** * 数据库插入操作（这是采用接口回调技术，由调用程序来给主键赋值） * @param sql 插入操作 sql语句 * @param args 插入数 * @param primaryIndex 主键在sql语句中位置（小于-1表示用数据自动生成主键不需要插入） * @return 插入记录数 * @throws Exception */ public int insert(String sql, Object[] args, int primaryKeyIndex,PrimaryKeyer primaryKeyer) throws Exception { if(args==null||args.length==0){ return 0; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); if(primaryKeyIndex<=-1){ for(int i=0;i<args.length;i++){ try { PreparedStatementSetValue(ps,args[i],i+1); } catch (Exception e) { e.printStackTrace(); } } }else if(primaryKeyIndex>-1&&primaryKeyIndex<args.length){ for(int i=0;i<args.length;i++){ if(i==primaryKeyIndex){ PreparedStatementSetValue(ps,primaryKeyer.getPrimaryKey(),i+1); //ps.setObject(i+1,primaryKeyer.getPrimaryKey()); }else{ PreparedStatementSetValue(ps,args[i],i+1); } } }else{ throw new IllegalArgumentException("设置主键位置不正确！"); } return ps.executeUpdate(); }finally{ jdbcUtil.free(rs,ps,conn); } } /** * 在Web开发中struts框架中，页数数据在被存入数据库时会被包装在一个formbean对象中 * 在把这些数据存入数据库时，需要把formbean中值取出来，在插入数据库中这样很麻烦 * 所以我设计了这个方法，只需要一个sql语句(sql语句字段名必须和数据库中的完全一致,字段顺序可以随便) * 和一个封装好数据对象。 * 这个方法对页面数据提交在存入数据库，有很大方便。 * 在这里插入主键时，主键值也应当包含那个封装对象中 * 思想：主要是对sql语句进行分析，解析出要插入字段名称，在利用反射技术将值set到preparedStatement对象中。 * @param sql * @param obj * @return * @throws Exception */ public int insert(String sql, Object obj) throws Exception { if(obj==null){ return 0; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; String [] fieldNames=resolveSQL(sql); try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<fieldNames.length;i++){ Object o=valueFromObject(fieldNames[i],obj); PreparedStatementSetValue(ps,o,i+1); } return ps.executeUpdate(); }finally{ jdbcUtil.free(rs,ps,conn); } } /** * 查找符合条件所有记录（这也是采用接口回调技术，由调用程序来决定结果set到什么对象中） * @param sql 查询sql语句 * @param args 查询参数 * @param rowMapper 结果集映射器 * @return Collection 记录集 * @throws SQLException */ public Collection ObjectList(String sql, Object[] args,RowMapper rowMapper) throws SQLException { if(args==null||args.length==0){ return null; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; Collection list=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]); } list=new ArrayList(); rs=ps.executeQuery(); while(rs.next()){ Object obj=rowMapper.rowMapping(rs); list.add(obj); } }finally{ jdbcUtil.free(rs,ps,conn); } return list; } /** * 依据与表对应的JavaBean的Class（采用反射技术将结果集set到JavaBean对象中） * 将查询结果封装为一个JavaBean的对象返回 * @param sql 查询sql语句 * @param args 查询参数 * @param javaBeanClass JavaBean的Class * @return 返回获得JavaBean对象 * @throws Exception */ public Object find(String sql, Object[] args,Class javaBeanClass) throws Exception { if(args==null||args.length==0){ return 0; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]); } rs=ps.executeQuery(); String[] names=jdbcUtil.getResultSetFieldName(rs); Object obj=null; while(rs.next()){ obj=rowMapper(javaBeanClass,rs,names); } return obj; }finally{ jdbcUtil.free(rs,ps,conn); } } /** * 依据与表对应的JavaBean的Class（上面方法重载方法，采用了不同实现机制） * 将查询结果封装为一个包含JavaBean的集合对象返回 * @param sql 查询sql语句 * @param args 查询参数 * @param javaBeanClass javaBeanClass JavaBean的Class * @return 记录集 * @throws Exception */ public Collection ObjectList(String sql, Object[] args,Class javaBeanClass) throws Exception { if(args==null||args.length==0){ return null; } Connection conn=null; PreparedStatement ps=null; ResultSet rs=null; Collection list=null; try { conn=jdbcUtil.getConnection(); ps=jdbcUtil.scrollReadOnlyResultSet(sql,conn); for(int i=0;i<args.length;i++){ ps.setObject(i+1,args[i]); } list=new ArrayList(); rs=ps.executeQuery(); String[] names=jdbcUtil.getResultSetFieldName(rs); while(rs.next()){ Object obj=rowMapper(javaBeanClass,rs,names); list.add(obj); } }finally{ jdbcUtil.free(rs,ps,conn); } return list; } /** * 这个方法是通过反射来将数据库表中对应的javaBean对象set值 * 该JavaBean对象必须有一个无参数的构造函数 * @param clazz javabean 超类 * @param rs 数据库结果集 * @return Object 对象 * @throws Exception */ private Object rowMapper(Class clazz,ResultSet rs,String[] names) throws Exception{ Object obj=clazz.newInstance(); for(int i=0;i<names.length;i++){ String columnName=toUpperCaseFirstLetterForSet(names[i]); Method[] m=clazz.getMethods(); for(int j=0;j<m.length;j++){ String methodName=m[j].getName(); if(columnName.equals(methodName)){ m[j].invoke(obj,rs.getObject(i+1)); break; } } } return obj; } /** * 将字符串一个字母转换为大写 * @param name * @return */ private String toUpperCaseFirstLetterForSet(String name){ if(name!=null&&name.length()>0){ return "set"+name.substring(0,1).toUpperCase()+name.substring(1); } return ""; } /** * 这是采用反射的方法来给PreparedStatement包装sql 语句参数赋值 * @param ps * @param obj 数组中对象 * @param index 参数索引位置 * @throws Exception */ private void PreparedStatementSetValue(PreparedStatement ps,Object obj,int index) throws Exception{ String name=getMethodName(obj); Method[] m=ps.getClass().getMethods(); for(int i=0;i<m.length;i++){ String methodName=m[i].getName(); if(name.equals(methodName)){ //System.out.println(methodName+"==========="); m[i].invoke(ps,index,obj); break; } } } /** * 通过反射获得数组中每个元素类型， * 从而获得PreparedStatement对象setxxx方法名称 * @param obj sql语句参数值 * @return PreparedStatement对象要调用setxxx方法名称 */ private String getMethodName(Object obj){ if(obj==null){ return null; } //System.out.println(obj+"==========="); String className=obj.getClass().getName(); String[] names=className.split("\\."); className=names[names.length-1]; if(className.equalsIgnoreCase("Integer")){ className="Int"; } className="set"+className; return className; } /** * 从sql语句中解析出我们需要字段名称 * @param sql 必须是一个有效 sql插入语句（最好不要用别名） * @return 字段名称数组 */ private String[] resolveSQL(String sql){ sql=sql.toLowerCase(); int left_brackets=sql.indexOf("("); int right_brackets=sql.indexOf(")"); String fieldString=sql.substring(left_brackets+1,right_brackets); String[] fieldNames=fieldString.split(","); return fieldNames; } /** * 根据字段名从包装数据对象中取出于该字段相对应的值 * 通过反射用get方法来获得 * @param fieldName * @return * @throws InvocationTargetException * @throws IllegalAccessException * @throws Exception */ private Object valueFromObject(String fieldName,Object formBean) throws Exception{ String methodName=toUpperCaseFirstLetterForGet(fieldName); Method[] methods=formBean.getClass().getMethods(); for(Method m:methods){ String mName=m.getName(); if(methodName.equals(mName)){ Object value=m.invoke(formBean); return value; } } return null; } /** * 将字符串一个字母转换为大写 * @param name * @return */ private String toUpperCaseFirstLetterForGet(String name){ if(name!=null&&name.length()>0){ name=name.trim(); return "get"+name.substring(0,1).toUpperCase()+name.substring(1); } return ""; }}?
2 楼 zhangskills 2010-02-20 没想到也有人这么想的，我也写了一个类似的，一直怕别人笑我的思路，今天也发上来，有空指点指点，呵呵