messagedaoimpl.java

这是一个用JSP技术做的论坛短消息

package impl;

import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import dao.*;

import dao.MessageDao;
import entity.Message;

public class MessageDaoImpl implements MessageDao{
	Connection con=BaseDao.getConnection();
	ResultSet rs=null;
	public int delete(int id) {
		int i = 0;
		try {
			Statement st=con.createStatement(); 
			i = st.executeUpdate(
					"delete from TBL_MESSAGE where id=" + id + "");
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return i;
	} 

	public Message findMessage(int id) {
		Message message=new Message();
		try {
			Statement st=con.createStatement(); 
			ResultSet rs = st.executeQuery("select * from  TBL_MESSAGE where id=" + id + "");
			if(rs.next()){
				message.setId(rs.getInt("id"));
				message.setNote(rs.getString("Note"));
				message.setPostTime(rs.getString("postTime"));
				message.setReadSign(rs.getInt("readSign"));
				message.setReceiveUname(rs.getString("receiveUname"));
				message.setSendUname(rs.getString("sendUname"));
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return message;
	}

	public List listByReceiveUname(String uname) {
		List list = new ArrayList();
		try {
			rs=con.createStatement().executeQuery("select * from TBL_MESSAGE where receiveUname='"+uname+"'");
			while(rs.next()){
				Message message = new Message();
				message.setId(rs.getInt("id"));
				message.setNote(rs.getString("Note"));
				message.setPostTime(rs.getString("postTime"));
				message.setReadSign(rs.getInt("readSign"));
				message.setReceiveUname(rs.getString("receiveUname"));
				message.setSendUname(rs.getString("sendUname"));
				list.add(message);
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return list;
	}

	public int save(Message message) {
		int i=0;
		String note = message.getNote();
		String send = message.getSendUname();
		String receive = message.getReceiveUname();
		String post = message.getPostTime();
		int read = message.getReadSign();
		try {
			Statement st=con.createStatement();
			i=st.executeUpdate("insert into TBL_Message values('"+note+"','"+send+"','"+receive+"','"+post+"','"+read+"')");
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return i;
	}

	public int update(Message message) {
		int i = 0;
		int id = message.getId();
		try {
			Statement st=con.createStatement(); 
			i = st.executeUpdate(
					"update TBL_MESSAGE set readSign=1 where id=" + id + "");
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return i;
	}

}