通用数据库连接类（配置文件）

package dao; import java.sql.*; import com.sun.crypto.provider.RSACipher; public class BaseDao { public static final String driver=Env.env.getProperty("driver"); public static final String url=Env.env.getProperty("url"); public static final String name=Env.env.getProperty("name"); public static final String pwd=Env.env.getProperty("pwd"); public void closeAll(Connection conn,Statement smt,ResultSet rs) { try { if(conn!=null&&!conn.isClosed()) { conn.close(); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { if(smt!=null) smt.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } try { if(rs!=null) rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public Connection getConn() { Connection conn=null; try { Class.forName(driver); conn=DriverManager.getConnection(url,name,pwd); } catch (ClassNotFoundException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return conn; } public int excuteSQL(String sql,String[] param) { Connection conn=null; PreparedStatement pstmt=null; int num=0; try { conn=getConn(); pstmt=conn.prepareStatement(sql); if(param!=null) { for(int i=0;i<param.length;++i) { pstmt.setString(i+1, param[i]); } } num=pstmt.executeUpdate(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally { closeAll(conn, pstmt, null); } return num; } public ResultSet selectSql(String sql,String[] param) { Connection conn=null; PreparedStatement pstmt=null; ResultSet rs=null; try { conn=getConn(); pstmt=conn.prepareStatement(sql); if(param!=null) { System.out.println("length:"+param.length); for(int i=0;i<param.length;++i) { pstmt.setString(i+1, param[i]); } } rs=pstmt.executeQuery(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return rs; } public int excuteSQL(String sql) { return excuteSQL(sql, null); } public ResultSet selectSql(String sql) { return selectSql(sql, null); } }