classofemployee.java

基于mvc的宠物管理系统。servlet+jsp

//该类实现InterfaceOfEmployee接口，用于实现员工各种操作的方法

package com.richard.dao;

import java.util.*;
import com.richard.dto.*;
import java.sql.*;

public class ClassOfEmployee implements InterfaceOfEmployee {
    DBOperate objDBOperate = new DBOperate();

    public ClassOfEmployee() {
    }

    public boolean check(Employee objEmployee) { //该方法用于验证用户登陆信息
       String employeeName=objEmployee.getName();
       String password=objEmployee.getPassword();
       boolean check=false;
       String sqlCommand="select * from employee where name='"+employeeName+"' and password='"+password+"'";
       try {
           ResultSet rs=objDBOperate.getResultSet("petclinic",sqlCommand);
          while(rs.next())
          {
              check=true;
          }
       } catch (Exception ex) {
           System.out.println(ex.getMessage());
       }
       return check;
    }

    public void employeeDelete(Employee objEmployee) { //该方法用于根据员工姓名删除一条员工记录
      int employeeId=objEmployee.getId();
        String sqlCommand="delete from employee where id='"+employeeId+"'";
        try
        {
            PreparedStatement ps= objDBOperate.getPreparedStatement("petclinic",sqlCommand);
            ps.execute();
        }
        catch(Exception ex)
        {
             System.out.println(ex.getMessage());
        }
    }

    public void employeeInsert(Employee objEmployee) { //该方法用于插入一条新的员工记录
       String employeeName=objEmployee.getName();
       String password=objEmployee.getPassword();
       String sqlCommand="insert into employee (name,password) values(?,?)";
       try {
           PreparedStatement ps=objDBOperate.getPreparedStatement("petclinic",sqlCommand);
           ps.setString(1,employeeName);
           ps.setString(2,password);
           ps.execute();
       } catch (Exception ex) {
           System.out.println(ex.getMessage());
       }
    }

    public ArrayList employeeQueryAll(int perPage, int pageNumber) { //该方法用于分页查询所有员工的信息
        ArrayList objArrayList = new ArrayList();
        String sqlCommand = "{call proc_employee (?,?)}";
        try {
            CallableStatement cs = objDBOperate.getConnect("petclinic").prepareCall(sqlCommand);
            cs.setInt(1, perPage);
            cs.setInt(2, pageNumber);
            ResultSet rs = cs.executeQuery();
            while (rs.next()) {
                Employee objEmployee = new Employee();
                objEmployee.setId(rs.getInt(1));
                objEmployee.setName(rs.getString(2));
                objEmployee.setPassword(rs.getString(3));
                objArrayList.add(objEmployee);
            }
        } catch (Exception ex) {
            System.out.println(ex.getMessage());
        }
        return objArrayList;

    }

    public void employeeUpdate(Employee objEmployee) { //该方法用于修改指定员工的密码
        String sqlCommand="update employee set name=?,password=? where id=?";
        try {
          PreparedStatement ps=  objDBOperate.getPreparedStatement("petclinic",sqlCommand);
          ps.setString(1,objEmployee.getName());
          ps.setString(2,objEmployee.getPassword());
          ps.setInt(3,objEmployee.getId());
          ps.execute();
        } catch (Exception ex) {
           System.out.println(ex.getMessage());
        }
    }

    public int totalPages() {
        int totalPages = 0;
        String sqlCommand = "select count(*) from employee";

        try {
            PreparedStatement objStatement = objDBOperate.getPreparedStatement("petclinic",sqlCommand);
            ResultSet rs = objStatement.executeQuery();
            while(rs.next())
            {
            totalPages = rs.getInt(1);
            }

        } catch (Exception ex) {
            System.out.println("错误提示:" + ex.getMessage());
        }
        if(totalPages%12==0)
            return totalPages/12;
        else
            return (totalPages/12)+1;
    }
}