operdata.java

一個學校的教学综合管理系统,包含了很多的功能。

package basecode.zysz;

import com.zdsoft.datacenter.*;
import com.zdsoft.datastore.*;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */

public class OperData{
  ASDatacenter dc;//数据中心对象
  public ASDatastore findallZy_info() {
    ASDatastore ds = null;
    try {
      dc = new ASDatacenter(); //创建数据中心实例
      dc.connect(); //连接相应数据库;
      String sql = "select a.zy_id,a.zy_code,a.zy_name,a.xz_id,b.xz_name,a.cc_id,c.cc_name,a.xxxs_id,d.xxxs_name " +
          "from zy_dm a,xz_dm b,cc_dm c,xxxs_dm d where a.xz_id = b.xz_id and a.cc_id = c.cc_id and a.xxxs_id = d.xxxs_id"; //构造查询语句
      ds = dc.retrieve(sql); //执行数据中心实例的retrieve方法,返回ASDatastore(数据存储器)的一个实例;
      ds.setTitleLable(new String[]{
      "专业ID", "专业代码", "专业名称", "xz_id","学制","cc_id", "层次", "xxxs_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(zy_id) as zy_id from zy_dm";
      ASDatastore ds = dc.retrieve(sql);
      if (ds.getItemInteger(0, "zy_id").intValue() > 0) {
        sql = "select max(zy_id) as zy_id from zy_dm";
        ds = dc.retrieve(sql);
        id = ds.getItemInteger(0, "zy_id").intValue() + 1;
      }
      sql = "insert into zy_dm(zy_id,zy_code,zy_name,xz_id,cc_id,xxxs_id) values (" +
          id +
          ",'" + (String) obj[1] +
          "','" + (String) obj[2] +
          "'," + ( (Integer) obj[3]).intValue() +
          "," + ( (Integer) obj[4]).intValue() +
          "," + ( (Integer) obj[5]).intValue() +
          ")";
      msg = dc.update(sql);
      if (!msg[0].equals("false"))
        msg[1] = id + "";
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect();
      return msg;
    }
  }

  public String[] modZy_info(Object[] obj) {
  String msg[] = {
      "false", ""};
  try {
    dc = new ASDatacenter(); //创建数据中心实例 bj_id =,
    dc.connect(); //连接相应数据库;
    String sql = "update  zy_dm  set zy_code = '" + (String) obj[1] +
        "',zy_name= '" + (String) obj[2] +
        "',xz_id= " + ((Integer) obj[3]).intValue() +
        ",cc_id= " + ((Integer) obj[4]).intValue() +
        ",xxxs_id= " + ((Integer) obj[5]).intValue() +
        " where zy_id=" + ( (Integer) obj[0]).intValue();
    System.out.println(sql);
    msg = dc.update(sql);
  }
  catch (Exception ex) {
    ex.printStackTrace();
  }
  finally {
    dc.disconnect();
    return msg;
  }
}

  public String[] DelByZyid(int zy_id) {
    String msg[] = {
        "false", ""};
    String columnName[];
    try {
      dc = new ASDatacenter();
      dc.connect();
      msg = dc.update("delete from zy_dm where zy_id = " + zy_id);
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect();
      return msg;
    }
  }
}