empmodel.java

来自「一个企业小型固定资产系统的源代码。发布出来让刚学习java的人研究。」· Java 代码 · 共 182 行

package project;

/*
 *EmpModel.java：建立职工实体类。
 *包括：与数据库进行增、删、改、查操作。
 */

import java.sql.*;
import java.math.*;

public class EmpModel {
   String empno;  //ID
   String ename;   //名字
   String password;  //密码
   String position;   //职务
   int grade;     //等级
   String remarks;    //备注
   DbConn dbc;
   Connection conn;
    String userid="ff";
  public boolean verifyuser;
   public EmpModel() {
   }
   public EmpModel(String n,String e,String w,String p,String g,String r) {

        empno = n;
        ename = e;
        password=w;
        position = p;
        grade=Integer.parseInt(g);
        remarks = r;
   }
   public EmpModel(String n) {
        empno = n;

   }

   public void insert() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      try {
 String sql="INSERT INTO UserInfo (U_ID,U_Name,U_Password,U_Type,U_Grade,U_Note)";
 sql=sql+" VALUES ((?), (?), (?), (?) ,?, (?))";


      PreparedStatement pstmt = conn.prepareStatement(sql);
      pstmt.setString(1, empno);
      pstmt.setString(2, ename);
      pstmt.setString(3, password);
      pstmt.setString(4, position);
      pstmt.setInt(5, grade);
      pstmt.setString(6, remarks);
      pstmt.execute();
      conn.commit();
      conn.close();
      verifyuser=true;
      }
      catch (java.sql.SQLException s) {
          verifyuser=false;
        System.out.println("exception: " + s.getMessage());
      }
   }

   public void selectAll() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String sql;
   sql = "SELECT * FROM UserInfo";
   sql=sql+" WHERE  U_ID = '"+empno+"'" ;
      try {
      Statement stmt = conn.createStatement();
      ResultSet rset = stmt.executeQuery (sql);
      while (rset.next()) {
         userid=rset.getString(2);
         ename = rset.getString(3);
         password=rset.getString(4);
         position = rset.getString(5);
         grade=rset.getInt(6);
         remarks = rset.getString(7);
      }
      conn.commit();
      rset.close();
      stmt.close();
      conn.close();
      if(userid.equals(empno)){
          verifyuser=true;
      }else {verifyuser=false;}

      } catch (java.sql.SQLException s) {

        System.out.println("exception: " + s.getMessage());
      }
    }
    public boolean selectRec() {
          dbc = new DbConn();
          conn = dbc.getConnection();
          String sql;
          boolean sel=false;
       sql = "SELECT * FROM RecodeInfo ";
       sql=sql+" WHERE  R_U_NO  = '"+empno+"'" ;
          try {
          Statement stmt = conn.createStatement();
          ResultSet rset = stmt.executeQuery (sql);
           sel= rset.next();

          conn.commit();
          rset.close();
          stmt.close();
          conn.close();
          } catch (java.sql.SQLException s) {

            System.out.println("exception: " + s.getMessage());
          }
          return sel;
    }
    public void update() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String sql ="UPDATE UserInfo SET  U_Name = (?) , U_Password = (?) ,";
             sql=sql+" U_Type = (?) , U_Grade = (?) , U_Note = (?)  ";
             sql=sql+" WHERE U_ID = (?) ; ";
      try {
      PreparedStatement pstmt = conn.prepareStatement(sql);
      pstmt.setString(1, ename);
      pstmt.setString(2, password);
      pstmt.setString(3, position);
      pstmt.setInt(4, grade);
       pstmt.setString(5, remarks);
       pstmt.setString(6, empno);

       pstmt.executeUpdate();
      conn.commit();
      conn.close();
       verifyuser=true;

      }
      catch (java.sql.SQLException s) {
           verifyuser=false;
        System.out.println("exception: " + s.getMessage());
      }
   }

   public void delete() {
      dbc = new DbConn();
      conn = dbc.getConnection();
      String sql="DELETE FROM UserInfo ";
           sql = sql +" WHERE UserInfo.U_ID = '"+empno+"'";
      try {
      PreparedStatement pstmt = conn.prepareStatement(sql);
      pstmt.execute();
      conn.commit();
      conn.close();
       verifyuser=true;
      }
      catch (java.sql.SQLException s) {
           verifyuser=false;
        System.out.println("exception: " + s.getMessage());
      }
   }
   public String getEmpno() {
           return empno;
      }
      public String getEname() {
           return ename;
      }
      public String getpassword() {
           return  password;
      }

      public String getPosition() {
           return position;
      }
      public int getgrade() {
             return grade;
      }

      public String getRemarks() {
           return remarks;
   }

}