operdata.java

来自「一個學校的教学综合管理系统,包含了很多的功能。」· Java 代码 · 共 111 行

package basecode.jxddm;

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 jxd_dm"; //构造查询语句
      ds = dc.retrieve(sql); //执行数据中心实例的retrieve方法,返回ASDatastore(数据存储器)的一个实例;
      ds.setTitleLable(new String[]{
      "jxdid","教学点名称","教学点地址","教学点邮政编码","教学点联系人","教学点电话"});
    }
    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(jxd_id) as jxd_id from jxd_dm";
      ASDatastore ds = dc.retrieve(sql);
      if (ds.getItemInteger(0, "jxd_id").intValue() > 0) {
        sql = "select max(jxd_id) as jxd_id from jxd_dm";
        ds = dc.retrieve(sql);
        id = ds.getItemInteger(0, "jxd_id").intValue() + 1;
      }
      sql = "insert into jxd_dm(jxd_id,jxd_name,jxd_address,jxd_mailcode,jxd_lxr,jxd_phone) values (" +
          id +
          ",'" + (String) obj[1] +"'"+
            ",'" + (String) obj[2] +"'"+
            ",'" + (String) obj[3] +"'"+
            ",'" + (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[] modKc_info(Object[] obj) {
  String msg[] = {
      "false", ""};
  try {
    dc = new ASDatacenter(); //创建数据中心实例 bj_id =,
    dc.connect(); //连接相应数据库;
    String sql = "update  jxd_dm  set jxd_name = '" + (String) obj[1] +
                 "',jxd_address ='"+(String) obj[2] +
                 "',jxd_mailcode ='"+(String) obj[3] +
                 "',jxd_lxr ='"+(String) obj[4] +
                 "',jxd_phone ='"+(String) obj[5] +
        "' where jxd_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 jxd_dm where jxd_id = " + xxxs_id);
    }
    catch (Exception ex) {
      ex.printStackTrace();
    }
    finally {
      dc.disconnect();
      return msg;
    }
  }
}