bbsuser.java

用JSP写的论坛源代码 走过路过的各位千万不要错过啊！！！！

package serv;
import java.sql.*;
import java.util.*;



public class bbsuser {
	ResultSet rs;
	String strSQL;
	bbsdb dbconn;//创建数据库连接对象
	int i;
	boolean isUser;
	String loginCode;
	
    public bbsuser()
    {
        dbconn=new bbsdb();
    	rs=null;
    	loginCode=null;
}
    //更新密码
    public void changeUserPassword(String s,String snew)
    {
    	strSQL="update user set userPassword='"+snew+"'where username='"+s+"';";
    	dbconn.executeUpdate(strSQL);
    }
    //到按版面号查询父贴 封装在list中
    public List bbslistfa(String key) throws Exception
	{
		 List list= new ArrayList();
		 try {
				String sql="SELECT child,userName,bbstopic,bbshits,dateandtime from bbs WHERE parentid=0 and boardid='"+key+"'ORDER BY bbsid DESC";
				rs=dbconn.executeQuery(sql);
				while(rs.next())
				{
					bbs bbs=new bbs();
					bbs.setBbsChild(Integer.parseInt(rs.getString("child")));
					bbs.setBbsUsername(rs.getString("userName"));
					bbs.setBbsTopic(rs.getString("bbstopic"));
					bbs.setBbsHits(Integer.parseInt(rs.getString("bbshits")));
					bbs.setBbsDateandtime(rs.getDate("dateandtime"));
					list.add(bbs);
				}
				rs.close();
				} 
		 catch (RuntimeException e) {e.printStackTrace();}	
		 return list;
	}

    //到数据库中查询用户信息 封装在list中
    public List selectuser(String key) throws Exception
	{
    	List list= new ArrayList();
		try {
			String sql="SELECT userName,userSex,userComefrom,userSign,dateAndtime from user WHERE userName='"+key+"'";
			rs=dbconn.executeQuery(sql);
			while(rs.next())
			{
				member member=new member();
				member.setUserName(rs.getString("userName"));
				member.setUserSex(rs.getString("userSex"));
				member.setUserSign(rs.getString("userSign"));
				member.setUserDateandtime(rs.getDate("dateAndtime"));
				list.add(member);
			}
			rs.close();
		} catch (RuntimeException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
		return list;
		
	}
    //获得用户信息
    public boolean getUserInfo(String s)
    {   
    	
    	member m3=new member();
        rs = null;
        strSQL = "select * from user where username='" + s + "'";
        try
        {   
            rs = dbconn.executeQuery(strSQL);
            if(rs.next())
            {
            	isUser=false;
                m3.setUserName(rs.getString("userName"));
                m3.setUserPassword(rs.getString("userPassword"));
                m3.setUserEmail (rs.getString("userEmail"));
                m3.setUserSex(rs.getString("userSex"));
                m3.setUserBirthday(rs.getString("userBirthday"));
                m3.setUserComefrom(rs.getString("userComefrom"));
                m3.setUserSign(rs.getString("userSign"));
                m3.setUserDateandtime(rs.getDate("dateAndtime"));
                
            } 
            else
            {
                isUser =true;
            }
            rs.close();
        }
        catch(SQLException sqlexception)
        {
        	System.err.println("aq.executeQuery: " + sqlexception.getMessage());
            System.err.println("aq.STRSQL:: " + strSQL);
        }
        return isUser;
        }
    //检查请求登录的用户的密码是否正确，若正确则允许登录 
    public boolean checkUserPassword(String s, String s1)
    {
        rs = null;
        strSQL = "select * from user where username='" + s + "' and userpassword='" + s1 + "'";
        try
        {
            rs = dbconn.executeQuery(strSQL);//调用bbsdb类对象dbconn的处理SQL语句的函数，返回到rs
            if(rs.next())
            {
                isUser = true;
                //getUserInfo(s);//调用获得用户信息函数
            } else
            {
                isUser = false;
            }
            rs.close();
        }
        catch(SQLException sqlexception)
        {
            System.err.println("aq.executeQuery: " + sqlexception.getMessage());
            System.err.println("checkuserpassword.STRSQL:: " + strSQL);
        }
        return isUser;
    }
   
    //注册人数
    public int countUser()
    {
    	strSQL="SELECT COUNT(*)AS cc FROM user;";
    	i=0;
    	try{
    		rs=dbconn.executeQuery(strSQL);
    		if(rs.next())
    			i=rs.getInt("cc");
    		rs.close();
    	}catch(SQLException sqlexception){
    		System.err.println("aq.executeQuery:"+sqlexception.getMessage());
    		System.err.println("countUser.STRSQL:"+strSQL);
    	}
    	return i;
    	}
 
    //删除用户
    public void delUser(String s)
    {
    	strSQL="delete from user where username='"+s+"'";
    	dbconn.executeUpdate(strSQL);
    }
    //注册新用户，插入新用户信息到数据库
    public String registryNewuser(member m2)
    {   
    	String name=m2.getUserName();
    	String password=m2.getUserPassword();
    	String email=m2.getUserEmail();
    	String sex=m2.getUserSex();
    	String comefrom=m2.getUserComefrom();
    	String birthday=m2.getUserBirthday();
    	String sign=m2.getUserSign();
    	
    	strSQL = "INSERT INTO user(userName,userPassword,userEmail,userSex,userComefrom,userSign,userBirthday) VALUES('"+name+"','"+password+"','"+email+"','"+sex+"','"+comefrom+"','"+sign+"','"+birthday+"')";
        dbconn.executeUpdate(strSQL);
        return strSQL;
        }
    //更新用户信息
    public void updateUserInfo(String s)
    {
    	
    	member newmember=new member();
        strSQL = "update user set userEmail='" + newmember.getUserEmail()+"',userSex='" + newmember.getUserSex() + "',userComefrom='" + newmember.getUserComefrom()+ 

"',userSign='" + newmember.getUserSign() + "' ,userBirthday='"+newmember.getUserBirthday()+"',where username='" + s + "'";
        dbconn.executeUpdate(strSQL);
    }
    //用户排序
    public ResultSet listUser(int j)
    {
        rs = null;
        switch(j)
        {
        

        case 1: // '\001'
            strSQL = "select * from user order by userName desc";
            break;

        case 2: // '\002'
            strSQL = "select * from user order by dateAndtime desc";
            break;

        default:
            strSQL = "select * from user order by userName desc";
            break;
        }
        rs = dbconn.executeQuery(strSQL);
        return rs;
    }
    
 
    
}