messagedao.java

北大青鸟 S2 论坛短消息项目源代码提供给大家！呵呵！~

/*
 * s2jsp.xmal.dao.MessageDao.java
 * 2007-08-10
 * 短消息数据库访问类
 */
package s2jsp.xmal.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
import java.util.ArrayList;

import s2jsp.xmal.entity.Message;

public class MessageDao extends BaseDao {
    private Connection        conn  = null;   // 数据库连接
    private PreparedStatement pstmt = null;   // 创建PreparedStatement对象
    private ResultSet         rs    = null;   // 创建结果集对象

    /**
     * 保存一条消息
     * @param message
     * @return
     */
    public int save(Message message){
        String   sql   = "insert into TBL_MESSAGE(note,sendUname,receiveUname,postTime,readSign) values(?,?,?,?,0)";
        String[] param = {message.getNote(),message.getSendUname(),message.getReceiveUname(),message.getPostTime()};
        return super.executeSQL(sql, param);
    }

    /**
     * 删除一条消息
     * @param message
     * @return
     */
    public int delete(int id){
        String sql = "delete from TBL_MESSAGE where id="+id;
        return super.executeSQL(sql, null);
    }

    /**
     * 更新读标记
     * @param message
     * @return
     */
    public int update(Message message){
        String sql = "update TBL_MESSAGE set readSign=1 where id="+message.getId();
        return super.executeSQL(sql, null);
    }

    /**
     * 查询参数用户收到的消息列表
     * @param uid
     * @return
     */
    public List listByReceiveUname(String uname) {
        List list = new ArrayList();
        String sql = "select * from TBL_MESSAGE where receiveUname=?";
        try {
            conn  = this.getConn();
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, uname);
            rs    = pstmt.executeQuery();
            while(rs.next()) {
                Message message = new Message();
                message.setId(rs.getInt("id"));
                message.setNote(rs.getString("note"));
                message.setSendUname(rs.getString("sendUname"));
                message.setReceiveUname(rs.getString("receiveUname"));
                message.setPostTime(rs.getString("postTime"));
                message.setReadSign(rs.getInt("readSign"));
                list.add(message);
            }
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
            this.closeAll(conn, pstmt, rs);
        }
        return list;
    }
    
    /**
     * 根据短信息id查一条短信息
     * @param id
     * @return
     */
    public Message findMessage(int id){
        Message message = null;
        String sql = "select * from TBL_MESSAGE where id=?";
        try {
            conn  = this.getConn();
            pstmt = conn.prepareStatement(sql);
            pstmt.setInt(1, id);
            rs    = pstmt.executeQuery();
            while(rs.next()) {
                message = new Message();
                message.setId(rs.getInt("id"));
                message.setNote(rs.getString("note"));
                message.setSendUname(rs.getString("sendUname"));
                message.setReceiveUname(rs.getString("receiveUname"));
                message.setPostTime(rs.getString("postTime"));
            }
        } catch (ClassNotFoundException e) {
            message = null;
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally{
            this.closeAll(conn, pstmt, rs);
        }
        return message;
    }
}