persongroupbean.java

Oracle源码：Oracle 数据库管理与应用系统开发代码

package oa.bean;

import java.sql.*;
import java.util.Hashtable;
import java.util.Vector;
import oa.bean.*;

import oa.main.ParentBean;
public class PersonGroupBean extends ParentBean {

	public static void main(String[] args)  {
		PersonGroupBean myBean = new PersonGroupBean();
		String str;
		myBean.setPersonNO("1");
		myBean.setGroupNO("1");
		
		System.out.println(myBean.getMembers());
		

	}
	private String strGroupNO; //群组编号

	private String strPersonNO; //职工编号

	//Constructor
	public PersonGroupBean()  {
		super();
		// TODO Auto-generated constructor stub
	}
	//增加一条个人群组记录
	private int addAGroup(String strPersonNo, String strGroupName)
		 {
		Vector vect = new Vector();
		int intID;
		intID = makeID("ZZ_GRQZB", "ZGBH", "QZBH", strPersonNo, true);
		vect.add("ZZ_GRQZB");
		vect.add(addVector("ZGBH", strPersonNo, "CHAR"));
		vect.add(addVector("QZBH", Integer.toString(intID), "CHAR"));
		vect.add(addVector("QZMC", strGroupName, "CHAR"));
		vect.add(addVector("LXRXHC", "", "CHAR"));
		return insertRecord(vect);
	}
	//增加一条个人群组记录
	private int addANewRec(String strPersonNo)  {

		Vector vect = new Vector();
		//int intID;
		//intID = makeID("ZZ_GRQZB", "ZGBH", "QZBH", strPersonNO, true);
		vect.add("ZZ_GRQZB");
		vect.add(addVector("ZGBH", strPersonNo, "CHAR"));
		//默认组编号为0
		vect.add(addVector("QZBH", "0", "CHAR"));
		vect.add(addVector("QZMC", "默认群", "CHAR"));
		vect.add(addVector("LXRXHC", "-1", "CHAR"));
		return insertRecord(vect);
	}
	//增加一条记录
	public int addRec(String strGroupName)  {
		if (!hasPerson(strPersonNO)) {
			/*
			 * 若没有这个职工的群组记录,则加入"默认组"
			 * "默认组"是一个特殊的组,每一个职工都必须具有这样的一个组
			 * 它是无法删除和修改的,它从逻辑上包含这个职工的所有的联系人
			 * 它的联系人序号串一定为"-1"
			 */
			addANewRec(strPersonNO);
		}
		int err=addAGroup(strPersonNO, strGroupName);
		return err;
	}

	//删除一条个人群组纪录
	public int delRec()  {
		String sql =
			"delete from ZZ_GRQZB "
				+ " where ZGBH='"
				+ strPersonNO
				+ "' and QZBH='"
				+ strGroupNO
				+ "'";
		return deleteRecord(sql);
	}

	//通过职工编号取得 
	public Vector getData()  {
		Vector vect = new Vector();
		String sql;
		/*
		 * 在选择的时候将"默认组"去掉
		 * "默认组"是一个特殊的组,组序号为"0"每一个职工都必须具有这样的一个组
		 * 它是无法删除和修改的,它从逻辑上包含这个职工的所有的联系人
		 * 它的联系人序号串一定为"-1"
		 */
		sql =
			" select ZZ_GRQZB.ZGBH,ZZ_GRQZB.QZBH,ZZ_GRQZB.QZMC,ZZ_GRQZB.LXRXHC "
				+ " from ZZ_GRQZB "
				+ " where ZZ_GRQZB.ZGBH='"
				+ strPersonNO
				+ "'"
				+ " and ZZ_GRQZB.QZBH<>'0' "
				+ " order by ZZ_GRQZB.QZMC ";
		ResultSet rs = db.QuerySQL(sql);
		Statement stmt = null;
		try{
		//取得列数和列名
		ResultSetMetaData rsmd = rs.getMetaData();
		int cols = rsmd.getColumnCount();
		while (rs.next()) {
			Hashtable hash = new Hashtable();
			for (int i = 1; i <= cols; i++) {
				String field = ds.toString(rsmd.getColumnName(i));
				String value = ds.toString(rs.getString(i));
				hash.put(field, value);
			}
			vect.add(hash);
		}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		return vect;
	}

	//	取得个人通讯录人员信息
	private Hashtable getOneDataFromZGB(String str){
		Hashtable hash = new Hashtable();
		String sql = "";
		sql = "select ZGBH,XM,GH from ZZ_ZGB where ZGBH='" + str + "'";
		ResultSet rs = selectRecord(sql);
		Statement stmt = null;
		try{
		ResultSetMetaData rsmd = rs.getMetaData();
		int cols = rsmd.getColumnCount();
		while (rs.next()) {
			for (int i = 1; i <= cols; i++) {
				String field = ds.toString(rsmd.getColumnName(i));
				String value = ds.toString(rs.getString(i));
				hash.put(field, value);
			}
		}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		return hash;
	}

	public String getGroupMembers(){
		String strMemNO = "";
		String[] strMem = null;
		String strMembers = "";
		String sql =
			" select ZGBH,QZBH,LXRXHC "
				+ " from ZZ_GRQZB "
				+ " where ZGBH='"
				+ strPersonNO
				+ "'"
				+ "  and QZBH='"
				+ strGroupNO
				+ "'"
				+ " and ZZ_GRQZB.QZBH<>'0' ";

		ResultSet rs = db.QuerySQL(sql);
		Statement stmt = null;
		try{
		if (rs.next()) {
			strMemNO = ds.toString((String) rs.getString("LXRXHC"));
		} else {
			return null;
		}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		if (strMemNO.equals(""))
			return null;
		strMem = strMemNO.split(",");
		for (int i = 0; i < strMem.length; i++) {
			Hashtable hs = getOneDataFromZGB(ds.toString(strMem[i]));
			strMembers += (String) hs.get("XM");
			if (i != strMem.length - 1)
				strMembers += ",";
		}
		strMembers = ds.toString(strMembers);
		if (strMembers.equals(""))
			return null;
		return (strMembers.trim());
	}

	public Vector getMembers(){
		Vector vect = new Vector();
		String strMemNO = "";
		String[] strMem = null;
		String strMembers = "";
		String sql =
			" select ZGBH,QZBH,LXRXHC "
				+ " from ZZ_GRQZB "
				+ " where ZGBH='"
				+ strPersonNO
				+ "'"
				+ "  and QZBH='"
				+ strGroupNO
				+ "'"
				+ " and ZZ_GRQZB.QZBH<>'0' ";

		ResultSet rs = db.QuerySQL(sql);
		Statement stmt = null;
		try{
		if (rs.next()) {
			strMemNO = ds.toString((String) rs.getString("LXRXHC"));
		} else {
			return vect;
		}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		strMemNO=strMemNO.trim();
		if(strMemNO.equals("")) return vect;
		strMem = strMemNO.split(",");
		for (int i = 0; i < strMem.length; i++) {
			Hashtable hs = getOneDataFromZGB(ds.toString(strMem[i]));
			vect.add(hs);
		}
		strMembers = ds.toString(strMembers);
		return vect;
	}

	//	取得1条个人群组信息
	public Hashtable getOneData(){
		Hashtable hash = new Hashtable();
		String sql =
			" select ZZ_GRQZB.ZGBH,ZZ_GRQZB.QZBH,ZZ_GRQZB.QZMC,ZZ_GRQZB.LXRXHC "
				+ " from ZZ_GRQZB "
				+ " where ZZ_GRQZB.ZGBH = '"
				+ strPersonNO
				+ "'"
				+ " and ZZ_GRQZB.QZBH = "
				+ strGroupNO;
		ResultSet rs = selectRecord(sql);
		Statement stmt = null;
		try{
		ResultSetMetaData rsmd = rs.getMetaData();
		int cols = rsmd.getColumnCount();
		if (rs.next()) {

			for (int i = 1; i <= cols; i++) {
				String field = ds.toString(rsmd.getColumnName(i));
				String value = ds.toString(rs.getString(i));
				hash.put(field, value);
			}
		}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		return hash;
	}

	//	检查ZZ_GRQZB中是否已经由此条记录
	private boolean hasPerson(String strPersonNo_Temp){
		String sql =
			" select ZGBH,QZBH "
				+ " from ZZ_GRQZB "
				+ " where ZGBH='"
				+ strPersonNo_Temp
				+ "'";
		ResultSet rs = db.QuerySQL(sql);
		Statement stmt = null;
		try{
			if (rs.next()) {
				return true;
			}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		return false;
	}

	//检查ZZ_GRQZB中是否已经由此条记录
	public boolean hasRec(String strPersonNO, String strGroupName)
	{
		String sql =
			" select ZGBH,QZBH "
				+ " from ZZ_GRQZB "
				+ " where ZGBH='"
				+ strPersonNO
				+ "'"
				+ " and QZMC='"
				+ strGroupName
				+ "'";
		ResultSet rs = db.QuerySQL(sql);
		Statement stmt = null;
		try{
			if (rs.next()) {
				return true;
			}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		return false;
	}

	//修改个人群组名称
	public int modRec_GroupName(String strNewName){
		String sql =
			"update ZZ_GRQZB set QZMC='"
				+ strNewName
				+ "'"
				+ " where ZGBH='"
				+ strPersonNO
				+ "'"
				+ "   and QZBH='"
				+ strGroupNO
				+ "'";
		return db.ExecuteSQL(sql);
	}

	//	修改个人群组名称
	public int modRec_GroupInfo(Vector vect){
		String str = "";
		int nSize = vect.size();
		for (int i = 0; i < nSize; i++) {
			str += (String) vect.get(i);
			if (i < nSize - 1)
				str += ",";
		}
		String sql =
			"update ZZ_GRQZB set LXRXHC='"
				+ str
				+ "'"
				+ " where ZGBH='"
				+ strPersonNO
				+ "'"
				+ "   and QZBH='"
				+ strGroupNO
				+ "'";
		return db.ExecuteSQL(sql);
	}

	public void setGroupNO(String strValue) {
		strGroupNO = ds.toString(strValue);
	}

	public void setPersonNO(String strValue) {
		strPersonNO = ds.toString(strValue);
	}

	public String toGroupName(){
		String strName = "";
		String sql =
			" select ZGBH,QZBH,QZMC "
				+ " from ZZ_GRQZB "
				+ " where ZGBH='"
				+ strPersonNO
				+ "'"
				+ " and QZBH='"
				+ strGroupNO
				+ "'";
		ResultSet rs = db.QuerySQL(sql);
		Statement stmt = null;
		try{
			if (rs.next()) {
				strName = rs.getString("QZMC");
				return strName;
			}
		}catch(Exception e){System.out.println("运行时出错："+e);}
		finally{
			if(rs!=null)try{ stmt = rs.getStatement(); rs.close();}catch(Exception e){System.out.println("关闭记录集rs时出错"+e);}
			if(stmt!=null) try{stmt.close();}catch(Exception e){System.out.println("关闭声明时statement出错"+e);}		
		}
		return null;
	}
}