dms.zip_DMS项目_dms_dms 达内_达内_达内 dms

package dmsjdbc; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import domain.MatchedLogRec; public class EmpDao { private static final String findAll = "select logName,pid,loginTime,logoutTime,duration,logIP from emp"; //private static final String findAll1 = "select empno,ename,sal from (select empno,ename,sal,rownum n from emp where rownum<?) where n>=?"; //private static final String findBySal = "select empno,ename,sal from emp where sal=?"; private static final String insert = "insert into emp(logName,pid,loginTime,logoutTime,duration,logIP) values(?,?,?,?,?,?)"; private static final String update = "update emp set loginTime=?,logoutTime=?,duration=?,logIP=? where logName=? and pid=?"; private static final String delete = "delete from emp where logName=? and pid=?"; public List<MatchedLogRec> findAll() throws SQLException { Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { con = ConnectionUtils.getConnection(); stmt = con.prepareStatement(findAll); rs = stmt.executeQuery(); return toEmpList(rs); } catch (SQLException e) { e.printStackTrace(); throw e; } finally { ConnectionUtils.closeResultSet(rs); ConnectionUtils.closeStatement(stmt); ConnectionUtils.closeConnection(); } } /** * * @param page * @param rowsPerPage * @return * @throws SQLException */ // public List<MatchedLogRec> findAll(int page, int rowsPerPage) throws SQLException { // Connection con = null; // PreparedStatement stmt = null; // ResultSet rs = null; // try { // con = ConnectionUtils.getConnection(); // stmt = con.prepareStatement(findAll1); // int start = (page - 1) * rowsPerPage + 1; // int end = start + rowsPerPage; // stmt.setInt(1, end); // stmt.setInt(2, start); // rs = stmt.executeQuery(); // return toEmpList(rs); // } catch (SQLException e) { // e.printStackTrace(); // throw e; // } finally { // ConnectionUtils.closeResultSet(rs); // ConnectionUtils.closeStatement(stmt); // ConnectionUtils.closeConnection(); // } // } /** * * @param sal * @return * @throws SQLException */ // public List<MatchedLogRec> findBySal(double sal) throws SQLException { // Connection con = null; // PreparedStatement stmt = null; // ResultSet rs = null; // try { // con = ConnectionUtils.getConnection(); // stmt = con.prepareStatement(findBySal); // stmt.setDouble(1, sal); // rs = stmt.executeQuery(); // return toEmpList(rs); // } catch (SQLException e) { // e.printStackTrace(); // throw e; // } finally { // ConnectionUtils.closeResultSet(rs); // ConnectionUtils.closeStatement(stmt); // ConnectionUtils.closeConnection(); // } // } /** * * @param emp * @throws SQLException */ public void insert(MatchedLogRec mlr) throws SQLException { Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { con = ConnectionUtils.getConnection(); stmt = con.prepareStatement(insert); stmt.setString(1, mlr.getLogName()); stmt.setString(2, mlr.getPid()); stmt.setString(3, mlr.getLoginTime()); stmt.setString(4, mlr.getLogoutTime()); stmt.setString(5, mlr.getDuration()); stmt.setString(6, mlr.getLogIP()); stmt.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); throw e; } finally { ConnectionUtils.closeResultSet(rs); ConnectionUtils.closeStatement(stmt); ConnectionUtils.closeConnection(); } } /** * * @param emp * @throws SQLException */ public void update(MatchedLogRec mlr) throws SQLException { Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { con = ConnectionUtils.getConnection(); stmt = con.prepareStatement(update); stmt.setString(1, mlr.getLogName()); stmt.setString(2, mlr.getPid()); stmt.setString(3, mlr.getLoginTime()); stmt.setString(4, mlr.getLogoutTime()); stmt.setString(5, mlr.getDuration()); stmt.setString(6, mlr.getLogIP()); stmt.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); throw e; } finally { ConnectionUtils.closeResultSet(rs); ConnectionUtils.closeStatement(stmt); ConnectionUtils.closeConnection(); } } /** * * @param emp * @throws SQLException */ public void delete(MatchedLogRec mlr) throws SQLException { Connection con = null; PreparedStatement stmt = null; ResultSet rs = null; try { con = ConnectionUtils.getConnection(); stmt = con.prepareStatement(delete); stmt.setString(1, mlr.getLogName()); stmt.setString(2, mlr.getPid()); stmt.executeUpdate(); } catch (SQLException e) { e.printStackTrace(); throw e; } finally { ConnectionUtils.closeResultSet(rs); ConnectionUtils.closeStatement(stmt); ConnectionUtils.closeConnection(); } } /** * * @param rs * @return * @throws SQLException */ private List<MatchedLogRec> toEmpList(ResultSet rs) throws SQLException { List<MatchedLogRec> list = new ArrayList<MatchedLogRec>(); while (rs.next()) { MatchedLogRec mlr = new MatchedLogRec(); mlr.setLogName(rs.getString(1)); mlr.setPid(rs.getString(2)); mlr.setLoginTime(rs.getString(3)); mlr.setLogoutTime(rs.getString(4)); mlr.setDuration(rs.getString(5)); mlr.setLogIP(rs.getString(6)); list.add(mlr); } return list; } }