ghf.txt

初始化数据库 设置用户入库界面 使读者对数据库有一定的了解

//检查出库文件
        ResultSet result1 = stmt.executeQuery("SELECT S_ID,S_NAME,S_OUT_STOCKS FROM OUT_STORAGE WHERE TO_CHAR(TO_DATE(S_OUT_DATE),'MONYYYY')='" + time + "'");
        int out = 0;
        while (result1.next()) {
          try {
            stmt = conn.createStatement();
            id = result1.getString(1);
            name = result1.getString(2);
            temp = result1.getString(3);
            out = Integer.parseInt(temp);
            stmt.executeUpdate("INSERT INTO TEMP_STORAGE VALUES('" + id + "','" +
                               name + "',0,'" + out + "')");
          }
          catch (SQLException e5) {
            stmt = conn.createStatement();
            stmt.executeUpdate(
                "UPDATE TEMP_STORAGE SET S_OUT_STOCKS=S_OUT_STOCKS+" + out +
                " WHERE S_ID='" + id + "'");
          }
        }
      }catch (SQLException e4) {
        try{
                          stmt.executeUpdate("DROP TABLE TEMP_STORAGE");
                  }catch(SQLException en){}
System.out.println(e);
      }

//输出月入出库记录
      try {
        textArea1.append(year+"年"+month+"月" + "入出库情况\n");
        textArea1.append("    物品编号    物品名称    月入库数    月出库数\n");
        //stmt=conn.createStatement();
        ResultSet result4 = stmt.executeQuery("SELECT * FROM TEMP_STORAGE");
        while (result4.next()) {
          textArea1.append("    "+result4.getString(1) +"       "+ result4.getString(2)  +"       "+
                           result4.getString(3) + "       "+result4.getString(4) + "\n");
        }
      }catch (SQLException e6) {
      System.out.print(e6);
      }
      //删除临时表
      try {
        stmt.executeUpdate("DROP TABLE TEMP_STORAGE");
      }catch (SQLException e4) {}
      break;
    }
}

//处理用户入库
  void JButton6_actionPerformed(ActionEvent e) {
    while(true){
      String id = JTextField1.getText();
      String num = JTextField2.getText();
      String name="";
      if(id.equals("")||num.equals("")){
      textArea1.append("入库单不完整\n");
      break;
      }
      int in_stocks = Integer.parseInt(num);
//检查输入的合法性
      if (id.length() > 12) {
        textArea1.append("物品编号太长,长度不能大于12个字符\n");
      }
      if (in_stocks <= 0) {
        textArea1.append("请输入正确的物品数量\n");
        textArea1.append("请输入正确的物品数量\n");
         break;
      }

//更新库存文件和入库文件
      try {
        String number = "";
        String hight = "";
        ResultSet result = stmt.executeQuery(
            "SELECT S_STOCKS,S_NAME,S_HIGHT_STOCKS FROM STORAGE WHERE S_ID='" +
            id + "'");
        while (result.next()) {
          number = result.getString(1);
          name = result.getString(2);
          hight = result.getString(3);
        }
        if (number.equals("")) {
          JTextField1.setText("");
          JTextField2.setText("");
          JTextField3.setText("");
          JTextField4.setText("");
          JTextField5.setText("");
          JTextField1.setVisible(true);
          JTextField2.setVisible(true);
          JTextField3.setVisible(true);
          JTextField4.setVisible(true);
          JTextField5.setVisible(true);
          textArea1.setVisible(true);
          JLabel1.setVisible(true);
          JLabel1.setText("  物品编号");
          JLabel2.setText("  物品名称");
          JLabel3.setText("  物品数量");
          JLabel4.setText(" 最小物品数");
          JLabel5.setText(" 最大物品数");
          JLabel2.setVisible(true);
          JLabel3.setVisible(true);
          JLabel4.setVisible(true);
          JLabel5.setVisible(true);
          JButton6.setVisible(false);
          JButton7.setVisible(false);
          JButton1.setVisible(true);
          textArea1.append("新物品，请重新输入\n");
          textArea1.append("新物品\n");
          break;
        }
        int hight_stocks = Integer.parseInt(hight);
        int store = Integer.parseInt(number);
        if ( (store + in_stocks) > hight_stocks) {
          textArea1.append("超出最大库存，最大库存为：" + hight_stocks + "\n");
          textArea1.append("多出：" + (in_stocks + store - hight_stocks) + "\n");
          textArea1.append("超出最大库存，最大库存为：" + hight_stocks + "\n");
          textArea1.append("多出：" + (in_stocks + store - hight_stocks) + "\n");
          break;
        }

        //存入库存文件
        stmt.executeUpdate(
            "UPDATE STORAGE SET S_STOCKS='" + (store + in_stocks) +
            "' WHERE S_ID='" + id + "'"
            );

              //存入入库文件
        stmt.executeUpdate(
            "INSERT INTO IN_STORAGE VALUES('" + id + "','" + name + "','" +
            in_stocks + "'," + "CURRENT_DATE" + ")"
            );
        textArea1.append("入库成功\n");
        textArea1.append("物品编号:"+id+"\n物品名称:"+name+"\n物品数量现有库存:"+(store + in_stocks)+"\n");
      }
      catch (SQLException en) {
        textArea1.append("入库失败\n");
      }
      JTextField1.setText("");
      JTextField2.setText("");
      break;
    }
  }

//处理用户出库
  void JButton8_actionPerformed(ActionEvent e) {
while(true){
      String id = JTextField1.getText();
      String number = JTextField2.getText();
      if (id.equals("") || number.equals("")) {
        textArea1.append("物品编号或者物品数量没填\n");
        break;
      }
      int out_stocks = Integer.parseInt(number);
      if (number.length() > 12 || out_stocks <1) {
        textArea1.append("请输入正确的物品数量\n");
       break;
      }
      if (id.length() > 12) {
        textArea1.append("出库物品编号错误，物品编号长度不能大于12个字符\n");
        break;
      }
      JLabel1.setText("  物品编号");
      JLabel2.setText("  物品数量");
//出库
      try {
        //检查库存文件
        String num = "";
        String name = "";
        ResultSet result = stmt.executeQuery(
            "SELECT S_NAME,S_STOCKS FROM STORAGE WHERE S_ID='" + id + "'");
        while (result.next()) {
          name = result.getString(1);
          num = result.getString(2);
        }
        if (num.equals("")) {
          textArea1.append("没有库存\n");
          break;
        }
        int store = Integer.parseInt(num);
        store -= out_stocks;
        if (store < 0) {
          textArea1.append("库存不足，还剩下：" + (out_stocks + store) + "\n");
         break;
        }

//更新库存文件
        stmt.executeUpdate("UPDATE STORAGE SET S_STOCKS='" + store +
                           "' WHERE S_ID='" + id + "'");
        textArea1.append("出库成功\n");
        textArea1.append("物品名称：" + name + "   出库物品数量:" + out_stocks +
                         "   剩下库存量：" + store + "\n");

//更新出库文件
        stmt.executeUpdate("INSERT INTO OUT_STORAGE VALUES('" + id + "','" +
                           name + "','" + out_stocks + "',CURRENT_DATE)");
      }
      catch (SQLException en) {
        System.out.print("Caught:" + en);
      }
      JTextField1.setText("");
      JTextField2.setText("");
      break;
    }
  }

//退出
  void JButton9_actionPerformed(ActionEvent e) {
System.exit(1);
  }

//连接数据库
  void JButton10_actionPerformed(ActionEvent e) {
    while(true){
      int port;
      String s_hname=JTextField1.getText();
      String s_id = JTextField2.getText();
      String s_name = JTextField3.getText();
      String s_password = jPasswordField1.getText();
      String s_port = JTextField5.getText();
      if(s_hname.equals("")){
    s_hname="localhost";
      }
      if (s_port.equals("")) {
        port = 1521;
      }
      else {
        port = Integer.parseInt(s_port);
      }
      if (s_id.equals("")) {
        textArea1.append("请输入数据库名\n");
        break;
      }
      if (s_name.equals("")) {
        textArea1.append("请输入用户名\n");
        break;
      }
      if (s_password.equals("")) {
        textArea1.append("请输入密码\n");
        break;
      }
//连接数据库
      try {
        textArea1.append("正在连接数据库..........\n");
        OracleDataSource ods = new OracleDataSource();
        ods.setDriverType("thin");
        ods.setServerName(s_hname);
        ods.setNetworkProtocol("tcp");
        ods.setDatabaseName(s_name);
        ods.setPortNumber(port);
        ods.setUser(s_name);
        ods.setPassword(s_password);
        conn = ods.getConnection();
        stmt = conn.createStatement();
        load(stmt);
        textArea1.append("连接数据库成功\n");