operdata.java

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

package basecode.xzdm;

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 findallKc_info() {
    ASDatastore ds = null;
    try {
      dc = new ASDatacenter(); //创建数据中心实例
      dc.connect(); //连接相应数据库;
      String sql = "select * from xz_dm"; //构造查询语句
      ds = dc.retrieve(sql); //执行数据中心实例的retrieve方法,返回ASDatastore(数据存储器)的一个实例;
      ds.setTitleLable(new String[]{
      "学制编号", "学制名称","学期数"});
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect(); //关闭数据库连接
      return ds; //返回ASDatastore类的对象ds
    }
  }

  public String[] addKc_info(Object[] obj) {
    String msg[] = {
        "false", ""};
    int id = 1;
    try {
      dc = new ASDatacenter(); //创建数据中心实例
      dc.connect(); //连接相应数据库;
      String sql = "select count(xz_id) as xz_id from xz_dm";
      ASDatastore ds = dc.retrieve(sql);
      if (ds.getItemInteger(0, "xz_id").intValue() > 0) {
        sql = "select max(xz_id) as xz_id from xz_dm";
        ds = dc.retrieve(sql);
        id = ds.getItemInteger(0, "xz_id").intValue() + 1;
      }
      sql = "insert into xz_dm(xz_id,xz_name,xqs) values (" +
          id +
          ",'" + (String) obj[1] +
          "," + ((Integer) obj[2]).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[] modKc_info(Object[] obj) {
  String msg[] = {
      "false", ""};
  try {
    dc = new ASDatacenter(); //创建数据中心实例 bj_id =,
    dc.connect(); //连接相应数据库;
    String sql = "update  xz_dm  set xz_name = '" + (String) obj[1] +
                 "', xqs ="+((Integer) obj[2]).intValue() +
                 " where xz_id=" + ( (Integer) obj[0]).intValue();
    msg = dc.update(sql);
  }
  catch (Exception ex) {
    ex.printStackTrace();
  }
  finally {
    dc.disconnect();
    return msg;
  }
}

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