JDBC四(web基础学习笔记十)

将功能整合在一个类中

package pb.base;import java.sql.Connection;import java.sql.DriverManager;import java.sql.PReparedStatement;import java.sql.ResultSet;import java.sql.SQLException;import java.sql.Statement;import pb.until.ConfigManager;public class Base {    public Connection conn;    public PreparedStatement pstmt;    public Statement stmt;    public ResultSet rs;        //建立连接    public boolean getConnection(){        // 获取DRIVER，url,用户名密码        String driver = ConfigManager.getintance().getvalue("jdbc.driver");        String url = ConfigManager.getintance().getvalue("jdbc.url");        String uname = ConfigManager.getintance().getvalue("jdbc.uname");        String pwd = ConfigManager.getintance().getvalue("jdbc.upwd");        // (1)使用Class.forName()加载驱动        try {            Class.forName(driver);            // (2)DriverManager.getConnection(URL,用户名，密码)获取数据库的连接Connection            // Oracle连接方式jdbc:oracle:thin:@localhost:1521:orcl            conn = DriverManager.getConnection(url, uname, pwd);        } catch (ClassNotFoundException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return false;        }catch (SQLException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return false;        }        return true;    }    //增加，修改，删除    public int  executeUpdate(String sql,Object [] pararm){                int UpdateRow=0;        getConnection();        try {            pstmt=conn.prepareStatement(sql);            //遍历数组设置每个值            for(int i=0;i<pararm.length;i++){                pstmt.setObject(i+1, pararm[i]);            }            UpdateRow = pstmt.executeUpdate();        } catch (SQLException e) {            // TODO Auto-generated catch block            e.printStackTrace();        }        return UpdateRow;    }          //查询    public ResultSet executeSQL(String sql,Object [] pararm){        getConnection();        try {            pstmt=conn.prepareStatement(sql);            //遍历数组设置每个值            for(int i=0;i<pararm.length;i++){                pstmt.setObject(i+1, pararm[i]);            }            rs = pstmt.executeQuery();        } catch (SQLException e) {            // TODO Auto-generated catch block            e.printStackTrace();        }        return rs;    }            //关闭数据库连接    public boolean CloseConnection(){            try {                if(rs!=null){                rs.close();                }            } catch (SQLException e) {                // TODO Auto-generated catch block                e.printStackTrace();                return false;            }            try {            if(stmt!=null){            stmt.close();            }        } catch (SQLException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return false;        }        try {            if(pstmt!=null){            pstmt.close();            }        } catch (SQLException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return false;        }        try {            if(conn!=null){            conn.close();            }        } catch (SQLException e) {            // TODO Auto-generated catch block            e.printStackTrace();            return false;        }    return true;            }}