首页 > 代码库 > Java BaseDao

Java BaseDao

BaseDao类:

package dao;import java.sql.*;public class BaseDao {    private static final String driver = "oracle.jdbc.driver.OracleDriver";    private static final String url = "jdbc:oracle:thin:@localhost:1521:ACCP";    private static final String uid = "scott";    private static final String pwd = "scott";    private static Connection con;    private static PreparedStatement pstmt;    /**     * 建立连接对象     * @return     */    public static Connection getConnection() {        try {            Class.forName(driver);            con = DriverManager.getConnection(url, uid, pwd);            return con;        } catch (ClassNotFoundException e) {            e.printStackTrace();        } catch (SQLException e) {            e.printStackTrace();        }        return null;    }    /**     * 关闭对象     * @param rs 数据集对象     */    public static void Close(ResultSet rs) {        if (rs != null) {            try {                rs.close();            } catch (SQLException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }        if (pstmt != null) {            try {                pstmt.close();            } catch (SQLException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }        if (con != null) {            try {                con.close();            } catch (SQLException e) {                // TODO Auto-generated catch block                e.printStackTrace();            }        }    }    /**     * 执行查询操作     * @param sql  查询的sql语句     * @param paras  查询的参数 Object[]数组     * @return 结果集     */    public static ResultSet ExecuteQuery(String sql, Object[] paras) {        getConnection();        try {            pstmt = con.prepareStatement(sql);            if (paras != null && paras.length > 0) {                for (int i = 0; i < paras.length; i++) {                    pstmt.setObject(i + 1, paras[i]);                }            }            ResultSet rs = pstmt.executeQuery();            return rs;        } catch (SQLException e) {            e.printStackTrace();            return null;        }    }    /**     * 执行增加、修改、删除操作     * @param sql  操作的sql语句     * @param paras  操作的参数     * @return 受影响的行数     */    public static int ExecuteUpdate(String sql, Object[] paras) {        getConnection();        try {            pstmt = con.prepareStatement(sql);            if (paras != null && paras.length > 0) {                for (int i = 0; i < paras.length; i++) {                    pstmt.setObject(i + 1, paras[i]);                }            }            int rs = pstmt.executeUpdate();            return rs;        } catch (SQLException e) {            e.printStackTrace();            return -1;        }    }}

 

调用:

package dao;import java.sql.*;import java.util.ArrayList;import java.util.List;import entities.Emp;public class empDao {    public List<Emp> GetEmpList() {        ResultSet rs = BaseDao.ExecuteQuery("select * from emp", null);                try {            List<Emp> list = new ArrayList<Emp>();            while (rs.next()) {                Emp e = new Emp();                e.setEmpno(rs.getInt("empno"));                e.setEname(rs.getString("ename"));                e.setJob(rs.getString("job"));                e.setMgr(rs.getInt("mgr"));                e.setHiredate(rs.getDate("hiredate"));                e.setSal(rs.getDouble("sal"));                e.setComm(rs.getDouble("comm"));                e.setDeptno(rs.getInt("deptno"));                list.add(e);            }            return list;        } catch (SQLException e) {            e.printStackTrace();            return null;        } finally {            BaseDao.Close(rs);        }    }}

 

Java BaseDao