北大青鸟项目实战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; } }