messageeo.java

本程序使用ajax技术实现聊天室程序.使用ajax动态获取聊天记录.

package book.chat.table;

import java.sql.ResultSet;
import java.sql.SQLException;

import book.chat.DbManager;

public class MessageEO {
	protected int messageID;// 代表数据库中message_id列

	protected int chatID;// 代表数据库中chat_id列

	protected int userID;// 代表数据库中user_id列

	protected String userName;

	protected String message;// 代表数据库中message列

	protected String postTime;// 代表数据库中post_time列

	public MessageEO() {// 无参的构造方法
		this.messageID = -1;
	}

	public MessageEO(int id) {// 有参的构造方法，参数为chat_id
		this.messageID = id;
		if (!FromDb())// 如果有找到该id的chat
			this.messageID = -1;
	}

	public boolean FromDb() {// 从数据库中读出，并更新bean
		int row = -1;
		// 读记录的sql语句
		String sql = "select * from message where message_id=" + this.messageID;
		ResultSet rs = DbManager.getResultSet(sql);// 执行sql语句并返回ResultSet
		try {
			rs.last();// 移动到最后一行
			row = rs.getRow();// 得到总记录数
			if (row == 1) {// 如果只查询到一条记录，则代表该记录存在并更新该类的属性
				this.messageID = rs.getInt("MESSAGE_ID");
				this.chatID = rs.getInt("CHAT_ID");
				this.userID = rs.getInt("USER_ID");
				this.userName = rs.getString("USER_NAME");
				this.message = rs.getString("MESSAGE");
				this.postTime = rs.getString("POST_TIME");
				return true;
			} else
				return false;
		} catch (SQLException e) {
			e.printStackTrace();
			return false;
		} finally {
			try {// 最后关闭ResutltSet,Statement.并释放连接
				if (rs != null)
					rs.close();
				if (rs.getStatement() != null)
					rs.getStatement().close();
				DbManager.releaseConnection();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}

	public int getChatID() {
		return chatID;
	}

	public void setChatID(int chatID) {
		this.chatID = chatID;
	}

	public String getMessage() {
		return message;
	}

	public void setMessage(String message) {
		this.message = message;
	}

	public int getMessageID() {
		return messageID;
	}

	public void setMessageID(int messageID) {
		this.messageID = messageID;
	}

	public String getPostTime() {
		return postTime;
	}

	public void setPostTime(String postTime) {
		this.postTime = postTime;
	}

	public int getUserID() {
		return userID;
	}

	public void setUserID(int userID) {
		this.userID = userID;
	}

	public String getUserName() {
		return userName;
	}

	public void setUserName(String userName) {
		this.userName = userName;
	}
}