BBS论坛系统,类似于csdn的博客

package cn.itcast.commons; import java.io.IOException; import java.io.InputStream; import java.lang.reflect.Method; import java.sql.Blob; import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.util.ArrayList; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; public class DBHelper { static{ try { Class.forName(ReaderPro.getReaderPro().getProperty("driverClassName")); } catch (ClassNotFoundException e) { e.printStackTrace(); } } /** * 获取连接的方法 * @return */ private Connection getConnection(){ Connection cn = null; try { cn = DriverManager.getConnection(ReaderPro.getReaderPro().getProperty("url"),ReaderPro.getReaderPro()); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return cn; } /** * 给预编译语句中的占位符赋值 * @param pstmt 要赋值的预编译语句块 * @param params 对应的占位符?的值 */ private void setParams(PreparedStatement pstmt,Object ... params){ //给预编译执行语句中的占位符赋值 if(params!=null && params.length>0){ //说明要执行的sql语句中有占位符? for(int i=0,len=params.length;i<len;i++){ try { pstmt.setObject(i+1,params[i]); } catch (SQLException e) { e.printStackTrace(); } } } } /** * 给预编译语句中的占位符赋值 * @param pstmt 要赋值的预编译语句块 * @param params 对应的占位符?的值 */ private void setParams(PreparedStatement pstmt,List<Object> params){ //给预编译执行语句中的占位符赋值 if(params!=null && params.size()>0){ //说明要执行的sql语句中有占位符? for(int i=0,len=params.size();i<len;i++){ try { pstmt.setObject(i+1,params.get(i)); } catch (SQLException e) { e.printStackTrace(); } } } } /** * 给预编译语句中的占位符赋值 * @param pstmt 要赋值的预编译语句块 * @param params 对应的占位符?的值 */ private void setParams(PreparedStatement pstmt,String ... params){ //给预编译执行语句中的占位符赋值 if(params!=null && params.length>0){ //说明要执行的sql语句中有占位符? for(int i=0,len=params.length;i<len;i++){ try { pstmt.setString(i+1,params[i]); } catch (SQLException e) { e.printStackTrace(); } } } } /** * 关闭资源的方法 * @param rs 要关闭的结果集 * @param pstmt 要关闭的预编译语句 * @param con 要关闭的连接 */ private void closeAll(ResultSet rs,PreparedStatement pstmt,Connection con){ if(rs!=null){ try { rs.close(); } catch (SQLException e) { e.printStackTrace(); } } if(pstmt!=null){ try { pstmt.close(); } catch (SQLException e) { e.printStackTrace(); } } if(con!=null){ try { con.close(); } catch (SQLException e) { e.printStackTrace(); } } } /** * 执行更新操作 * @param sql 要执行更新的sql语句（insert、delete、update） * @param params 要执行的更新语句中占位符?的值，给定的顺序必须跟?的顺序一致 * @return 更新语句执行后，所影响的数据的行数 */ public int update(String sql,String ... params){ Connection con=null; PreparedStatement pstmt=null; int result=0; try { con=this.getConnection(); //获取连接 //创建预编译执行语句 pstmt=con.prepareStatement(sql); this.setParams(pstmt, params); //执行预编译语句，获取结果 result=pstmt.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); } finally{ this.closeAll(null, pstmt, con); } return result; } /** * 查询数据 * @param sql 要执行的查询语句 * @param params 查询语句中占位符?对应值 * @return 返回满足条件的所有数据 */ public List<Map<String,Object>> finds(String sql,Object ... params){ Connection con=null; PreparedStatement pstmt=null; ResultSet rs=null; List<Map<String,Object>> list=new ArrayList<Map<String,Object>>(); int pp = 0; try { con=this.getConnection(); //获取连接 pstmt=con.prepareStatement(sql); //创建预编译执行语句 this.setParams(pstmt, params); //给预编译执行语句中的占位符赋值 rs=pstmt.executeQuery(); //执行预编译语句获取结果集 rs = pstmt.executeQuery(); ResultSetMetaData rsmd=rs.getMetaData(); //获取结果集中列的信息 int colCount=rsmd.getColumnCount(); //获取结果集中列的数量 String[] colNames=new String[colCount]; for(int i=0;i<colCount;i++){ //通过列的索引循环获取每个列的列名 colNames[i]=rsmd.getColumnName(i+1).toLowerCase(); } Map<String,Object> map=null; //每一个map中存放一行数据 //通过列名循环获取每个列的值 Blob blob; Object obj=null; String typeName=null; byte[] bt=null; InputStream is=null; while(rs.next()){ //每循环一次就是一行数据 pp++; map=new HashMap<String,Object>(); for(String colName:colNames){ //循环着一行中的每个列，通过每个列的列名获取这个列的值 obj=rs.getObject(colName); if(obj!=null){ typeName=obj.getClass().getSimpleName(); if("BLOB".equals(typeName)){ try { blob=(Blob)obj; bt=new byte[ (int) blob.length() ]; is=blob.getBinaryStream(); is.read(bt); } catch (IOException e) { e.printStackTrace(); } finally{ if(is!=null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } } map.put(colName,bt); //以列名为键，以对应列的值为值 }else{ map.put(colName,obj); //以列名为键，以对应列的值为值 } }else{ map.put(colName,obj); //以列名为键，以对应列的值为值 } } list.add(map); } } catch (SQLException e) { e.printStackTrace(); } finally{ this.closeAll(rs, pstmt, con); } return list; } public List<String> getAllColnumsName(ResultSet rs) throws Exception{ List<String> list = new ArrayList<String>(); ResultSetMetaData rsmd = rs.getMetaData(); //获取结果集中列的信息 int colCount=rsmd.getColumnCount(); //获取结果集中列的数量 for(int i=0;i<colCount;i++){ //通过列的索引循环获取每个列的列名 String x = rsmd.getColumnName(i+1).toLowerCase(); list.add(x); } return list; } /** * 获取多行值 * @param sql * @param params * @param c * @return */ public <T> List<T> findAll(String sql,List<Object> params,Class c){ List<T> list = new ArrayList<T>(); Connection con=null; PreparedStatement pstmt=null; ResultSet rs=null; try{ con = this.getConnection(); pstmt = con.prepareStatement(sql); //设置参数 this.setParams(pstmt, params); //执行 rs = pstmt.executeQuery(); //获取所有的列名 List<String> columnNames = this.getAllColnumsName(rs); //获取class的所有的方法 Method[] methods = c.getDeclaredMethods(); T t;//实例化对象 String methodName = null;//方法名 String columnName = null;//列名 String typeName = null;//参数类型名 Object val = null;//列对应的值 while(rs.next()){ t = (T)c.newInstance();//实例化一个对象 //获取所有的列 for(int i = 0;i<columnNames.size();i++){ co