operdata.java~1~

这是一个图书和学生信息的管理系统,它可以在数据库里面增加,修改,删除数据来管理图书和学生信息

    String msg[] = {
      "false", ""};
    try {
      dc = new ASDatacenter(); //创建数据中心实例
      dc.connect(); //连接相应数据库;
      dc.setAutoCommit(false);
      String sql = "insert into zy_kc_hour(zy_id,kc_id,kc_hour,kclx_id,kslx_id,class_hour,self_hour,class_experiment,"+
                   "class_discuss,class_computer,self_practice,ismodi) values ("+((Integer)obj[0]).intValue()+ ","
                                                                             + ((Integer)obj[1]).intValue() + ","
                                                                             + ((Integer)obj[2]).intValue() + ","
                                                                             + ((Integer)obj[3]).intValue() + ","
                                                                             + ((Integer)obj[4]).intValue() + ",";
      sql+=obj[5]==null?null+",":(Integer)obj[5] + ",";
      sql+=obj[6]==null?null+",":(Integer)obj[6] + ",";
      sql+=obj[7]==null?null+",":(Integer)obj[7] + ",";
      sql+=obj[8]==null?null+",":(Integer)obj[8] + ",";
      sql+=obj[9]==null?null+",":(Integer)obj[9] + ",";
      sql+=obj[10]==null?null+",":(Integer)obj[10] + ",";
      sql+="'N')";

      msg = dc.update(sql,false);
      if(msg[0].equals("false"))
        flag = false;
      if(flag){
        for(int i = 0;i<objxq.length;i++){
          sql = "insert into zy_kc_xq(zy_id,kc_id,xq_id,xq_week,week_hour,ismodi) values (" + (Integer)objxq[i][0] + ","
                                                                             + (Integer)objxq[i][1] + ","
                                                                             + (Integer)objxq[i][2] + ","
                                                                             + (Integer)objxq[i][3] + ","
                                                                             + (Integer)objxq[i][4] + ",'N')";
         msg = dc.update(sql,false);
         if(msg[0].equals("false")){
           flag = false;
           break;
         }
        }
      }
      if(flag)
        dc.commit();
      else
        dc.rollback();

    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect();
      return msg;
    }
  }
  public String[] modZYJHinfo(Object[] obj,Object[][] objxq) {
    boolean flag = true;
    String msg[] = {
      "false", ""};
    try {
      dc = new ASDatacenter(); //创建数据中心实例
      dc.connect(); //连接相应数据库;
      dc.setAutoCommit(false);
      String sql = "update zy_kc_hour set kc_hour =" + (Integer)obj[2] +","
                                          +"kclx_id =" + (Integer)obj[3] +","
                                          +"kslx_id =" + (Integer)obj[4] +",class_hour = ";

      sql+=obj[5]==null?null+",self_hour =":(Integer)obj[5] +",self_hour =";
      sql+=obj[6]==null?null +",class_experiment =":(Integer)obj[6] +",class_experiment =";
      sql+=obj[7]==null?null+",class_discuss =":(Integer)obj[7] +",class_discuss =";
      sql+=obj[8]==null?null +",class_computer =":(Integer)obj[8] +",class_computer =";
      sql+=obj[9]==null?null +",self_practice =":(Integer)obj[9] +",self_practice =";
      sql+=obj[10]==null?null+",ismodi ='Y'":(Integer)obj[10] +",ismodi ='Y'";

      sql += " where zy_id = " + (Integer)obj[0] + " and kc_id = " +(Integer)obj[1];
       msg = dc.update(sql,false);
      if(msg[0].equals("false"))
        flag = false;
      if(flag){
        sql = "delete from zy_kc_xq where zy_id ="+(Integer)obj[0]+" and kc_id = "+(Integer)obj[1];
        msg = dc.update(sql,false);
      }
      if(msg[0].equals("false"))
          flag = false;
      if(flag){
        for(int i = 0;i<objxq.length;i++){
          sql = "insert into zy_kc_xq(zy_id,kc_id,xq_id,xq_week,week_hour,ismodi) values (" + objxq[i][0] + ","
                                                                             + objxq[i][1] + ","
                                                                             + objxq[i][2] + ","
                                                                             + objxq[i][3] + ","
                                                                             + objxq[i][4] + ",'Y')";
         msg = dc.update(sql,false);
         if(msg[0].equals("false")){
           flag = false;
           break;
         }
        }
      }
      if(flag)
        dc.commit();
      else
        dc.rollback();

    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect();
      return msg;
    }
  }
  public ASDatastore findallZy_info() {
    ASDatastore ds = null;
    try {
      dc = new ASDatacenter(); //创建数据中心实例
      dc.connect(); //连接相应数据库;
      String sql = "select a.bj_id,a.bj_code,a.bj_name,a.jxd_id,b.jxd_name,a.bj_teacher,a.teacher_phone " +
                   "from bj_dm a,jxd_dm b where a.jxd_id = b.jxd_id"; //构造查询语句
      ds = dc.retrieve(sql); //执行数据中心实例的retrieve方法,返回ASDatastore(数据存储器)的一个实例;
      ds.setTitleLable(new String[]{
          "xjdID", "班级代码", "班级名称", "jxd_id","所属教学点","班主任", "班主任电话"});
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect(); //关闭数据库连接
      return ds; //返回ASDatastore类的对象ds
    }
  }

  public String[] addZy_info(Object[] obj) {
    String msg[] = {
      "false", ""};
    int id = 1;
    try {
      dc = new ASDatacenter(); //创建数据中心实例
      dc.connect(); //连接相应数据库;
      String sql = "select count(bj_id) as bj_id from bj_dm";
      ASDatastore ds = dc.retrieve(sql);
      if (ds.getItemInteger(0, "bj_id").intValue() > 0) {
        sql = "select max(bj_id) as bj_id from bj_dm";
        ds = dc.retrieve(sql);
        id = ds.getItemInteger(0, "bj_id").intValue() + 1;
      }
      sql = "insert into bj_dm(bj_id,bj_code,bj_name,jxd_id,bj_teacher,teacher_phone) values (" +
            id +
            ",'" + (String) obj[1] +
            "','" + (String) obj[2] +
            "'," + ( (Integer) obj[3]).intValue() +
            ",'" + (String) obj[4] +
            "','" + (String) obj[5] +
            "')";
      msg = dc.update(sql);
      if (!msg[0].equals("false"))
        msg[1] = id + "";
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect();
      return msg;
    }
  }
  public String[] DelZYSZInfo(int zy_id,int kc_id) {
    boolean flag = true;
    String msg[] = {
      "false", ""};
    try {
      dc = new ASDatacenter();
      dc.connect();
      dc.setAutoCommit(false);
      String sql = "delete from zy_kc_cq where zy_id="+zy_id+" and kc_id = "+kc_id;
      msg = dc.update(sql,false);
      if(msg[0].equals("false"))
        flag = false;
      if(true){
        sql = "delete from zy_kc_hour where zy_id="+zy_id+" and kc_id = "+kc_id;
        msg = dc.update(sql,false);
        if(msg[0].equals("false"))
          flag = false;
      }
      if(flag)
        dc.commit();
      else
        dc.rollback();
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect();
      return msg;
    }
  }
}