chatroomlist.java

jsp +javabean +sql 2000的在线聊天系统 ,实现私聊、群聊、管理员T人等功能

package net.chat;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
public class ChatRoomList{
/*
计算聊天室的在线人数
*/
public int countUser(String chatRoom) throws SQLException,classNoutFoundException
{
	BaseConn conn=null;
	try
	{
		conn=new BaseConn();
		String sql="select count(*)As intCount from onlineUser where chatRoom=?";
		PreparedStatement ps=conn.PreparedStatement(sql);
		ps.setString(1,chatRoom);
		ResultSet rs=conn.executeQuery();
		if(rs.next());
			return rs.getInt("intCount");
		else
			return 0;
	}catch(SQLException ex)
	{
		ex.printStackTrace();
		throw ex;
	}class(ClassNotFoundException ex)
	{
		ex.printStackTrace();
		throw ex;
	}finally
	{
		conn.close();
	}
}
/*



*/
public boolean addOnlineUser(String userName,String chatRoom)
throws SQLException,ClassNotFoundException
{
	BaseConn conn=null;
	try
	{
		conn=new BaseConn();
		//先判断该用户是不是不在聊天室
		String sql="select *from onlineUser where nickName=?and chatRoom?";
		PreparedStatement ps=conn.PreparedStatement(sql);
		ps.setString(1,userName);
		ps.setString(2,chatRoom);
		ResultSet rs=conn.executeQuery();
		if(rs.next())
		{
			return true;
		}
		else
		{ 
			//如果聊天室不存在该用户，则将该用户添加到在线用户列表中
			sql="insert into onlineUser(nickName,chatRoom)values(?,?)";
			ps=conn.PreparedStatement(sql);
			ps.setString(1,userName);
			ps.setString(2,chatRoom);
			conn.executeUpdate();
			ps.close();
			//获取信息时间，并将时间定义为year-Month-day h m s
			SimpleDateFormat cal =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			String time=cal.format(new java.util.Date());
			//在msgInfo表中添加一条系统公告，欢迎新用户进入聊天室
			sql="insert into msgInfo(chatRoom,msgFrom,MsgTo,chatTime,msgContent)
			values(?,?,?,?,?)";
			ps.conn.PreparedStatement(sql);
			ps.setString(1,chatRoom);
			ps.setString(2,"系统公告");
		    ps.setString(4,time);
		    ps.setString(5,<font color=red>"+userName+"</font>进入了聊天室，大家欢迎!!!");		
			conn.executeUpdate();
	        }catch(SQLException ex)
			{
		        ex.printStackTrace();
				throw ex;
			}catch(ClassNotFoundException ex)
			{
				ex.printStackTrace();
				throw ex;
			}finaly
			{
				conn.close();
			}