userbean.java

来自「用jsp+javabean+servlet写的留言板」· Java 代码 · 共 439 行

package com.mybook.javabean;

public class UserBean {
	public int getMessageCout(){
		int cout=0;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Message";
			db.query(sql);
			while(db.next()){
				cout++;
			}
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return cout;
	}
	public int getReMessageCout(String messageid){
		int cout=0;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from ReMessage where Message='"+messageid+"'";
			db.query(sql);
			while(db.next()){
				cout++;
			}
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return cout;
	}
	public boolean getRull(String xu){
		boolean b=false;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Message where MessageID='"+xu+"'";
			db.query(sql);
			
			if(db.next())if(db.getIntValue("MessageFrom")==0)b=true;
			
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return b;
	}
	public boolean getReRull(String messageid,int xu){
		boolean b=false;
		DBAccess db=new DBAccess();
		int cout=0;
		if(db.createConn()){
			String sql="select * from ReMessage where Message='"+messageid+"'";
			db.query(sql);
			
			while(db.next()){
				cout++;
				if(cout==xu){
					if(db.getIntValue("ReMessageFrom")==0)b=true;
				}
				
			}
			
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return b;
	}
	public int getFace(String xu){
		int face=0;
		if(!getRull(xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select face=Uses.UseFace from Uses,Message where Uses.UseID=Message.MessageFrom and MessageID='"+xu+"'";
				db.query(sql);
				
				if(db.next())face=db.getIntValue("face");
			
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			face=1;
		}
		return face;
	}
	public int getReFace(String messageid,int xu){
		int face=0;
		int cout=0;
		if(!getReRull(messageid,xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select face=Uses.UseFace from Uses,ReMessage where Uses.UseID=ReMessage.ReMessageFrom and Message='"+messageid+"'";
				db.query(sql);
				
				while(db.next()){
					cout++;
					if(cout==xu)face=db.getIntValue("face");
			}
			
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			face=1;
		}
		return face;
	}
	public String getUseName(String xu){
		String name=null;
		if(!getRull(xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select name=Uses.UseName from Uses,Message where Uses.UseID=Message.MessageFrom and MessageID='"+xu+"'";
				db.query(sql);
				if(db.next())name=db.getValue("name");
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			name="未公开";
		}
		return name;
		
	}
	public String getReUseName(String messageid,int xu){
		String name=null;
		int cout=0;
		if(!getReRull(messageid,xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select name=Uses.UseName from Uses,ReMessage where Uses.UseID=ReMessage.ReMessageFrom and Message='"+messageid+"'";
				db.query(sql);
				while(db.next()){
					cout++;
					if(cout==xu)name=db.getValue("name");
				}
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			name="未公开";
		}
		return name;
		
	}
	public String getUseQQ(String xu){
		String qq=null;
		if(!getRull(xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select qq=Uses.UseQQ from Uses,Message where Uses.UseID=Message.MessageFrom and MessageID='"+xu+"'";
				db.query(sql);
				if(db.next())qq=db.getValue("qq");
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			qq="未公开";
		}
		return qq;
		
	}
	public String getReUseQQ(String messageid,int xu){
		String qq=null;
		int cout=0;
		if(!getReRull(messageid,xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select qq=Uses.UseQQ from Uses,ReMessage where Uses.UseID=ReMessage.ReMessageFrom and Message='"+messageid+"'";
				db.query(sql);
				while(db.next()){
					cout++;
					if(cout==xu)qq=db.getValue("qq");
				}
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			qq="未公开";
		}
		return qq;
		
	}
	public String getUseEmail(String xu){
		String email=null;
		if(!getRull(xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select email=Uses.UseEmail from Uses,Message where Uses.UseID=Message.MessageFrom and MessageID='"+xu+"'";
				db.query(sql);
				if(db.next())email=db.getValue("email");
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			email="未公开";
		}
		return email;
	}
	public String getReUseEmail(String messageid,int xu){
		String email=null;
		int cout=0;
		if(!getReRull(messageid,xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select email=Uses.UseEmail from Uses,ReMessage where Uses.UseID=ReMessage.ReMessageFrom and Message='"+messageid+"'";
				db.query(sql);
				while(db.next()){
					cout++;
					if(cout==xu)email=db.getValue("email");
				}
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			email="未公开";
		}
		return email;
	}
	
	public int getQue(String xu){
		int que=0;
		if(!getRull(xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select * from Message where MessageID='"+xu+"'";
				db.query(sql);
				if(db.next())que=db.getIntValue("MessageQue");
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			que=1;
		}
		return que;
		
	}
	public int getReQue(String messageid,int xu){
		int que=0;
		int cout=0;
		if(!getReRull(messageid,xu)){
			DBAccess db=new DBAccess();
			if(db.createConn()){
				String sql="select * from ReMessage where Message='"+messageid+"'";
				db.query(sql);
				while(db.next()){
					cout++;
					if(cout==xu)que=db.getIntValue("ReMessageQue");
				}
				db.closeRs();
				db.closeStm();
				db.createConn();
			}
	    }
		else{
			que=1;
		}
		return que;
		
	}
	public String getTime(String xu){
		String time=null;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Message where MessageID='"+xu+"'";
			db.query(sql);
			if(db.next())time=db.getValue("MessageTime");
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return time;
		
	}
	public String getReTime(String messageid,int xu){
		String time=null;
		int cout=0;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from ReMessage where Message='"+messageid+"'";
			db.query(sql);
			while(db.next()){
				cout++;
				if(cout==xu)time=db.getValue("ReMessageTime");
			}
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return time;
		
	}
	public String getMessage(String xu){
		String message=null;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Message where MessageID='"+xu+"'";
			db.query(sql);
			if(db.next())message=db.getValue("Message");
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return message;
		
	}
	public String getReMessage(String messageid,int xu){
		String message=null;
		int cout=0;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from ReMessage where Message='"+messageid+"'";
			db.query(sql);
		    while(db.next()){
		    	cout++;
		    	if(cout==xu)message=db.getValue("ReMessage");
		    }
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return message;
		
	}
	public boolean vialduser(String username,String password){
		boolean isV=false;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Uses where UseName='"+username+"'and UsePassword='"+password+"'";
			db.query(sql);
			
			if(db.next())isV=true;
			
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return isV;
	}
	public boolean vialdadmin(String username,String password){
		boolean isV=false;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Admin where AdminName='"+username+"'and AdminPassword='"+password+"'";
			db.query(sql);
			
			if(db.next())isV=true;
			
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return isV;
	}
	public boolean vialdadusername(String username){
		boolean isV=false;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Uses where UseName='"+username+"'";
			db.query(sql);
			
			if(db.next())isV=true;
			
			db.closeRs();
			db.closeStm();
			db.createConn();
		}
		return isV;
	}
	public boolean adduser(String username,String password,String email,String qq,String face){
		boolean ad=false;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="insert into Uses(UseName,UsePassword,UseEmail,UseQQ,UseFace) values('"+username+"','"+password+"','"+email+"','"+qq+"',"+face+")";
			if(db.update(sql))ad=true;
			db.closeStm();
			db.createConn();
		}
		return ad;
	}
	public int getuserIdfromusername(String username){
		int id=0;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="select * from Uses where UseName='"+username+"'";
			db.query(sql);
			if(db.next())id=db.getIntValue("UseID");
			db.closeStm();
			db.createConn();
		}
		return id;
	}
	public boolean addmessage(int userid,String message,String que,String time){
		boolean adm=false;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="insert into Message(MessageFrom,Message,MessageQue,MessageTime) values("+userid+",'"+message+"',"+que+",'"+time+"')";
			if(db.update(sql))adm=true;
			db.closeStm();
			db.createConn();
		}
		return adm;
	}
	public boolean addremessage(String message,String remessage,int from,String que,String time){
		boolean adm=false;
		DBAccess db=new DBAccess();
		if(db.createConn()){
			String sql="insert into ReMessage(Message,ReMessage,ReMessageFrom,ReMessageQue,ReMessageTime) values("+message+",'"+remessage+"',"+from+",'"+que+"','"+time+"')";
			if(db.update(sql))adm=true;
			db.closeStm();
			db.createConn();
		}
		return adm;
	}
    

}