messagedao.java

论坛短消息,用户登录、登出 查看个人的短消息 发送短消息 回复短消息 删除短消息

package com.hlfly.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;

import com.hlfly.conn.DBConn;
import com.hlfly.entity.Message;
import com.hlfly.entity.User;

public class MessageDao {
	
	private Connection conn;
	private PreparedStatement ps;
	private ResultSet rs;
	
	public boolean getUserBy(User u){
		boolean b=false;
		conn=DBConn.getConn();
		String str="select * from TBL_USER where name=? and pass=?";
	    try {
			
	    	ps=conn.prepareStatement(str);
	    	ps.setString(1, u.getName());
	    	ps.setString(2, u.getPass());
	    	rs=ps.executeQuery();
	    	if(rs.next()){
	    	
	    		b=true;
	    	}
	    	
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			DBConn.CloseConn(conn);
		}
		return b;
	}

	//根据接收者查询所有的短信
	public List getListMessageByRuname(String receiveUname){
		List list=new ArrayList();
		conn=DBConn.getConn();
		String str="select * from TBL_MESSAGE where receiveUname=? order by postTime desc";
		try {
			
			ps=conn.prepareStatement(str);
			ps.setString(1, receiveUname);
			rs=ps.executeQuery();
			while(rs.next()){
				
				Message m=new Message(rs.getInt("id"),
						rs.getString("note"),
						rs.getString("sendUname"),
						rs.getString("receiveUname"),
						rs.getDate("postTime"),
						rs.getInt("readSign"));
				list.add(m);
			}
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}finally{
			DBConn.CloseConn(conn);
		}
		return list;
	}
	
	public boolean deleteMessage(int id){
		boolean b=false;
		
		return b;
	}
	//根据短信id查询短信
	public Message getMById(int id){
        Message m=null ;	
		conn=DBConn.getConn();
		String str="select * from TBL_MESSAGE where id="+id;
		try {
			
			ps=conn.prepareStatement(str);
			rs=ps.executeQuery();
			if(rs.next()){
				
				m=new Message();
				m.setId(rs.getInt("id"));
				m.setNote(rs.getString("note"));
				m.setSendUname(rs.getString("sendUname"));
				m.setReceiveUname(rs.getString("receiveUname"));
				m.setPostTime(rs.getDate("postTime"));
				m.setReadSign(rs.getInt("readSign"));
			}
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return m;
	}
	//添加短消息
	public boolean insertMsg(Message m){
		
		boolean b=false;
		conn=DBConn.getConn();
		SimpleDateFormat sdf=new SimpleDateFormat("yy-MM-dd hh:ss:mm");
		String currtime=sdf.format(new Date());
		String str="insert into TBL_MESSAGE values(?,?,?,?,?)";
		try {
			
			ps=conn.prepareStatement(str);
			ps.setString(1, m.getNote());
			ps.setString(2, m.getSendUname());
			ps.setString(3, m.getReceiveUname());
			ps.setString(4, currtime );
			ps.setInt(5, 0);
			int i=ps.executeUpdate();
			if(i>0)
				b=true;
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return b;
		
	}
	//根据id删除短信
	public boolean deleteMById(int id){
		boolean b=false;
		conn=DBConn.getConn();
		String str="delete from TBL_MESSAGE where id="+id;
		try {
			
			ps=conn.prepareStatement(str);
			int i=ps.executeUpdate();
			if(i>0)
				b=true;
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return b;
	}
	//根据id修改阅读状态
	public boolean updateReadSignById(int id){
		boolean b=false;
		conn=DBConn.getConn();
		String str="update TBL_MESSAGE set readSign=1 where id="+id;
		try {
			
			ps=conn.prepareStatement(str);
			int i=ps.executeUpdate();
			if(i>0)
				b=true;
			
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
		return b;
	}

}