empmanager.java

资金源码管理系统,用java开发的,有用的人可以试试看

package asset;

import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.Connection;
import java.sql.SQLException;
import javax.swing.table.DefaultTableModel;
import javax.swing.JTable;
import javax.swing.ListSelectionModel;

/**
 * 此类用于职工管理控制
 */
public class EmpManager {
      // 表示与数据库的连接
      private Connection con = ConnectionManager.getConnection();

      // 表示执行静态 sql 语句的对象
      private Statement stmt;

      // 表示返回的结果集
      private ResultSet rs;

      // 表示执行的 sql 语句
      private StringBuffer sql;

      // 此方法用于添加记录
      public void addToEmployee(EmpModel emp) throws SQLException {
          sql = new StringBuffer("insert into employee values("+Integer.parseInt(emp.getempno())+
                ",'"+emp.getename()+"','"+emp.getposition()+"','"+emp.getremarks()+"',DEFAULT)");

          stmt = con.createStatement();
          stmt.executeUpdate(sql.toString());
          ConnectionManager.closeStatement(stmt);
      }

      // 此方法用于修改记录
      public void updateTOEmployee(int index,String update,String empNum)
              throws SQLException {
          switch(index){
               // 职工姓名的修改
               case 1 :
                   sql = new StringBuffer("update employee set ename = '"+update+
                                          "' where empno = "+Integer.parseInt(empNum) );
                   break;
              // 职工职位的修改
              case 2 :
                  sql = new StringBuffer("update employee set position = '"+update+
                                          "' where empno = "+Integer.parseInt(empNum) );
                  break;
             // 职工备注的修改
             case 3 :
                 sql = new StringBuffer("update employee set remarks = '"+update+
                                          "' where empno = "+Integer.parseInt(empNum) );
                 break;
          }
          stmt = con.createStatement();
          stmt.executeUpdate(sql.toString());
          ConnectionManager.closeStatement(stmt);
      }

      // 此方法用于删除记录
      public void deleteFromEmployee(String empno) throws SQLException {
          sql = new StringBuffer("update employee set deleteflag = 0 where empno = "
                                  + Integer.parseInt(empno));
          stmt = con.createStatement();
          stmt.executeUpdate(sql.toString());
          ConnectionManager.closeStatement(stmt);
      }

      // 此方法用于查询记录
      public ResultSet queryFromEmployee(int index,String query) throws
            SQLException {
          switch(index){
             // 按职工姓名查询
             case 0 :
                  sql = new StringBuffer("select * from employee where deleteflag = 1 and ename like '%"
                                           + query +"%'" );
                  break;
             // 按职工职务查询
             case 1:
                  sql = new StringBuffer("select * from employee where deleteflag = 1 and position like '%"
                                    + query + "%'");
                  break;
          }
          stmt = con.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,
                                      ResultSet.CONCUR_UPDATABLE);
          rs = stmt.executeQuery(sql.toString());
          return rs;
    }

    //此方法用于职工表显示
    public void displayEmp(JTable jTable, String sql) {
      try {
        stmt = con.createStatement();
        rs = stmt.executeQuery(sql);

        // 创建table模板
        DefaultTableModel model = new DefaultTableModel();
        model.setColumnIdentifiers(new Object[] {"职工编号", "职工姓名", "职务", "备注"});
        while (rs.next()) {
          model.addRow(new Object[] {rs.getObject(1), rs.getString(2),
                       rs.getString(3), rs.getString(4)});
        }
        jTable.setModel(model);
        jTable.setSelectionMode(ListSelectionModel.SINGLE_SELECTION); //设置jTable只能单行选择
        ConnectionManager.closeResultSet(rs);
        ConnectionManager.closeStatement(stmt);
      }
      catch (SQLException ex) {
      }
    }


}