userbean.java

运用java+jsp写的一个新闻发布系统

/**********************************************************
Version 1.0
Date:2003-10-22
Description:主页－－主页管理中的用户列表查询、单条信息查询、增加记录、修改记录、删除记录
Other:
Variable List:
1.String id = "-1"//记录唯一编号
2.String username = ""//用户名，唯一识别号

Function List:
1.public void setUserName(String i)//设置记录唯一编号

2.public Vector getData()//取得数据表内容

3.public Hashtable getOneData()//取得当前某一用户信息

4.public int addUser(Hashtable hash)//增加管理员用户
5.public int modUser(Hashtable hash)//修改用户信息
6.public int modRight(Hashtable hash)//修改权限
7.public void delData()//删除数据记录
8.public Vector getYHM()//取得注册但不是管理员的用户名
9.public boolean verifyPwd(String pwd)
10.public int changePwd(Hashtable hash);
11.public String getOrg(String id);//根据人员的编号取得所在部门

History:
***********************************************************/

package oa.bean;

import java.text.*;
import java.util.*;
import java.lang.*;
import java.io.*;
import java.sql.*;
import oa.main.*;


public class UserBean extends ParentBean 
{	
	String username = "";
	String userid = "";

	//设置记录唯一编号
	public void setUserName(String u)
	{
		username = u;
	}

	public void setUserId(String id)
	{
		userid = id;
	}


	//取得数据表内容
	public Vector getData()
	{
		Vector vect = new Vector();
		String sql = "";
		int intGLYH = 0;
		sql = " select * from ZZ_ZGB";

		ResultSet rs = selectRecord(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;
	}


	//取得当前某一用户信息
	public Hashtable getOneData()
	{
		Hashtable hash = new Hashtable();
		int intGLYH = 0;
		String sql = "";

		sql = " select * from ZZ_ZGB where ZGBH = '"+userid+"'";

		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;
	}


	//增加管理员用户
	public int addUser(Hashtable hash)
	{
		int intGLYH = 0;
		String strpersonNo= getMaxzgNo();
		String strOrgNo = ds.toString((String)hash.get("BMBH"));
		String strYHM = ds.toString((String)hash.get("YHM"));
		
		String strMM = ds.toString((String)hash.get("MM"));
		String strXM = ds.toString((String)hash.get("XM"));
		String strXB = ds.toString((String)hash.get("XB"));
		String strQX = ds.toString((String)hash.get("QX"));
		String strCSNY = ds.toString((String)hash.get("CSNY"));
		String stremail = ds.toString((String)hash.get("EMAIL"));
		String strYDDH = ds.toString((String)hash.get("YDDH"));
		String strQQ = ds.toString((String)hash.get("QQ"));

		String strJTDZ = ds.toString((String)hash.get("JTDZ"));
		String stYZBM = ds.toString((String)hash.get("YZBM"));

		String strGRJJ = ds.toString((String)hash.get("GRJJ"));
		//String strFBWZ = ds.toString((String)hash.get("FBWZ"));

		Vector vect =new Vector();
		vect.add("ZZ_ZGB");
		vect.add(addVector("BMBH",strOrgNo,"CHAR"));
		vect.add(addVector("ZGBH",strpersonNo,"CHAR"));
		vect.add(addVector("YHM",strYHM,"CHAR"));
		vect.add(addVector("MM",strMM,"CHAR"));

		vect.add(addVector("XM",strXM,"CHAR"));
		vect.add(addVector("XB",strXB,"CHAR"));
		vect.add(addVector("CSNY",strCSNY,"CHAR"));
		vect.add(addVector("YZBM",stYZBM,"CHAR"));

		vect.add(addVector("QQ",strQQ,"CHAR"));
		vect.add(addVector("JTDZ",strJTDZ,"CHAR"));
		vect.add(addVector("YDDH",strYDDH,"CHAR"));
		vect.add(addVector("EMAIl",stremail,"CHAR"));
		//vect.add(addVector("DJGL",strDJGL,"CHAR"));
		vect.add(addVector("QX",strQX,"CHAR"));
 		vect.add(addVector("GRJJ",strGRJJ,"CHAR"));
		String time=ds.getDateTime();
		time=time.substring(0,10);
    	vect.add(addVector("ZCRQ",time,"CHAR"));
   
		vect.add(addVector("GLYH",String.valueOf(intGLYH),"NUM"));
		vect.add(addVector("ZZZT",String.valueOf(intGLYH),"NUM"));

	  
	    //vect.add("YHM='"+username+"'");
		ResultSet rs = selectRecord("select YHM from ZZ_ZGB where YHM='"+strYHM+"'");
		Statement stmt = null;
		try{
			if(rs.next())
				return 1;
		}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 insertRecord(vect);
	}




	//修改用户信息
	public int modUser(Hashtable hash) 
	{

		String strYHM = ds.toString((String)hash.get("YHM"));
		//String strMM= ds.toString((String)hash.get("MM"));

		String strXM = ds.toString((String)hash.get("XM"));
		String strXB = ds.toString((String)hash.get("XB"));
		String strCSNY = ds.toString((String)hash.get("CSNY"));
		String stremail = ds.toString((String)hash.get("EMAIL"));
		String strYDDH = ds.toString((String)hash.get("YDDH"));

		String strQQ = ds.toString((String)hash.get("QQ"));
		String stYZBM = ds.toString((String)hash.get("YZBM"));
		String strJTDZ = ds.toString((String)hash.get("JTDZ"));
		String strGRJJ = ds.toString((String)hash.get("GRJJ"));

		Vector vect =new Vector();
		vect.add("ZZ_ZGB");
		vect.add(addVector("YHM",strYHM,"CHAR"));
		//vect.add(addVector("MM",strMM,"CHAR"));

		vect.add(addVector("XM",strXM,"CHAR"));
		vect.add(addVector("XB",strXB,"CHAR"));
		vect.add(addVector("CSNY",strCSNY,"CHAR"));
		vect.add(addVector("QQ",strQQ,"CHAR"));
		vect.add(addVector("YZBM",stYZBM,"CHAR"));
		vect.add(addVector("JTDZ",strJTDZ,"CHAR"));
		vect.add(addVector("YDDH",strYDDH,"CHAR"));
		vect.add(addVector("EMAIL",stremail,"CHAR"));
 		vect.add(addVector("GRJJ",strGRJJ,"CHAR"));

	    vect.add("ZGBH='"+userid+"'");
		//ResultSet rs = selectRecord("select YHM from ZZ_ZGB where YHM='"+username+"'");
		return updateRecord(vect);
	}

	//修改权限
	public int modRight(Hashtable hash)
	{
		String sql = "";
		String strQX = ds.toString((String)hash.get("QX"));	

		Vector vect =new Vector();
		vect.add("ZZ_ZGB");
		vect.add(addVector("QX",strQX,"CHAR"));
	    vect.add("ZGBH = '"+userid+"'");

		return updateRecord(vect);
	}

	//取得注册但不是管理员的用户名
	public Vector getYHM()
	{
		Vector vect = new Vector();
		String sql = "";
		int i = 0;
		int intGLYH = 0;

		sql = "select YHM from ZZ_ZGB where YHM is not null and GLYH!=0";
		ResultSet rs = selectRecord(sql);
		Statement stmt = null;
		try{
			while(rs.next())
			{	
				Hashtable hash = new Hashtable();
				String field = ds.toString(String.valueOf(i));
				String value = ds.toString(rs.getString("YHM"));
				hash.put(field,value);
				vect.add(hash);
				i++;
			}
		}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;
	}

	//删除数据记录
	public int delData()
	{
		int intGLYH = 1;
		String sql="";
		sql = "delete from ZZ_ZGB  where ZGBH = '"+userid+"'";
		return deleteRecord(sql);
	}

   //分页时取得一页的数据量
	public Vector getOnePage(int page,int records)
	{
		int intGLYH = 0;
		String sql = " select * from ZZ_ZGB";
		return db.getOnePage(sql,page,records);
	}

	//验证人员秘密
	public boolean verifyPwd(String pwd)
	{
		String sql = "";
		sql = "select MM from ZZ_ZGB where YHM = '"+username.trim()+"'";
		ResultSet rs =selectRecord(sql);
		Statement stmt = null;
		try{
			if(rs.next())
			{
				String strPassword = ds.toString(rs.getString("MM"));
				if(strPassword.equals(pwd))
				{
					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 changePwd(Hashtable hash)
	{
		String sql = "";
		String strQX = ds.toString((String)hash.get("MM"));	

		Vector vect =new Vector();
		vect.add("ZZ_ZGB");
		vect.add(addVector("MM",strQX,"CHAR"));
	    vect.add("YHM = '"+username+"'");

		return updateRecord(vect);
	}

	public String getMaxzgNo()//取得最大职工编号+1
	{
		String sql = "",zgNo="";
		long lzgNo=0,lmaxNo = 0;
		sql = " select ZGBH from ZZ_ZGB ";//where BMBH = '"+strOrgNO+"'"
		ResultSet rs = selectRecord(sql);
		Statement stmt = null;
		try{
		while(rs.next())
		{
			zgNo = ds.toString(rs.getString("ZGBH"));
			lzgNo = Long.parseLong(zgNo);
			if (lzgNo > lmaxNo) {
				lmaxNo = lzgNo;
				//maxNo = zgNo;
			}
		}
		}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);}		
		}
		lmaxNo = lmaxNo + 1;
		return String.valueOf(lmaxNo);
	}

	//根据人员的编号取得所在部门
	public String getOrg(String id)
	{
		String sql = "";
		String orgid = "";
		sql = "select BMBH from zz_zgb where ZGBH='"+id+"'";
		ResultSet rs = selectRecord(sql);
		Statement stmt = null;
		try{
			if(rs.next())
			{
				orgid = ds.toString(rs.getString("BMBH"));
			}
		}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 orgid;
	}

	public static void main(String args[]) 
	{
		UserBean mb = new UserBean();
		//mb.setUserName("xiaoyan");
		System.out.println("begin\r\n\r\n");
		Hashtable hash = new Hashtable();
		hash.put("XM","王八蛋");
		hash.put("XB","男");
		hash.put("MZ","蒙");
		hash.put("QQ","98765432");
		hash.put("MZ","蒙");
		hash.put("QQ","98765432");
		hash.put("YDDH","1310000000");
		hash.put("EMAIL","[e-mail]");
		hash.put("YDDH","1310000000");
		hash.put("email","[e-mail]");
		hash.put("QX","录入员");
		hash.put("FBWZ","20");
		hash.put("GRJJ","我是个王八蛋");
		//mb.getYHM();
		//mb.delData();
		System.out.println(mb.getOnePage(1,10));

		System.out.println("\r\n\r\nend");
	}
}