[聊天留言]简单的JSP+JAVABEAN+ACCESS留言簿 修正版_lyb.zip

/** * @(#)MessageBean.java * 在MessageBean中，有两个执行数据库操作的方法，一个是添加一条消息到数据库 * 另一个是显示数据库中的所有留言。 * @solin * @version 1.00 2007/12/18 */ package com.web; import java.sql.*; import java.util.*; import java.text.*; public class MessageBean { private Connection con; MessageVO msg; //获得数据库连接 public MessageBean() { //获取数据库连接 DBConn dbc=new DBConn(); con=dbc.DBConn(); } //设置属性 public void setMessage(MessageVO msg){ this.msg=msg; } //增加一个消息 public void addMessage() throws Exception{ //SQL语句，将留言插入表格lyb //注意，数据库字段的名字 不能设为date否则会出错。这里我的字段为ly_date。 String addLy="insert into record (title, name, email, content, ly_date) values (?,?,?,?,?)"; try{ PreparedStatement stm=con.prepareStatement(addLy); //System.out.println(msg.getTitle());//测试用 //获取数据 String title=msg.getTitle(); String name=msg.getName(); String email=msg.getEmail(); String content=msg.getContent(); //取得util时间，并转换为sql.Timestamp存入数据库。由于sql.Date只能存日期，所以用sql.Timestamp java.util.Date ud=new java.util.Date(); //取得sql.Timestamp时间并打印 java.sql.Timestamp stp=new java.sql.Timestamp(ud.getTime()); //System.out.println(stp);//测试用 //中文字符处理 commonBean cb = new commonBean(); title=cb.ShowCH(title); name=cb.ShowCH(name); content=cb.ShowCH(content); //空email处理 email=cb.trim(email); //插入数据到表格 stm.setString(1,title); stm.setString(2,name); stm.setString(3,email); stm.setString(4,content); stm.setTimestamp(5,stp); //数据库更新 stm.executeUpdate(); //关闭数据库 stm.close(); con.close(); }catch(Exception e){ e.printStackTrace(); throw e; } } //获得所有留言信息，并且返回结果到JSP页面 public Collection getMessage() throws Exception{ //SQL语句，从表格lyb里面获得所有数据 String getLy="select count(*) from record"; String getLy1="select * from record order by id desc"; Collection ret=new ArrayList(); try{ Statement stm=con.createStatement(); ResultSet res=stm.executeQuery(getLy); int msg_count=0; if(res.next()){ msg_count=res.getInt(1); res.close(); } if(msg_count>0){ res=stm.executeQuery(getLy1); while(res.next()){ int id=res.getInt("id"); String title=res.getString("title"); String name=res.getString("name"); String email=res.getString("email"); String content=res.getString("content"); java.sql.Timestamp ts=res.getTimestamp("ly_date"); java.sql.Date date=new java.sql.Date(ts.getTime()); //System.out.println(date); MessageVO message=new MessageVO(); message.setId(id); message.setTitle(title); message.setName(name); message.setEmail(email); message.setContent(content); message.setDate(date); ret.add(message); } res.close(); stm.close(); } con.close(); }catch(Exception e){ e.printStackTrace(); throw e; } return ret; } //删除一条留言 public void deleteMessage(int id) throws Exception { id=id; //SQL语句 String deleteLy="delete from record where id = ?"; try { PreparedStatement pstm=con.prepareStatement(deleteLy); pstm.setInt(1,id); pstm.executeUpdate(); pstm.close(); con.close(); } catch(Exception e) { e.printStackTrace(); throw e; } } //用main测试addMessage() // public static void main (String[] args) { // try{ // MessageVO m = new MessageVO(); // m.setName("solin"); // m.setTitle("test"); // m.setEmail("solin_y@163.com"); // m.setContent("abcd,abcd."); // System.out.println(m.getName()); // System.out.println(m.getTitle()); // System.out.println(m.getEmail()); // System.out.println(m.getContent()); // MessageBean a = new MessageBean(); // a.setMessage(m); // a.addMessage(); // }catch(Exception e){ // System.out.println(e); // } // } // //用main测试getMessage() public static void main (String[] args) { try{ MessageBean g=new MessageBean(); Collection msgs=g.getMessage(); Iterator it=msgs.iterator(); while(it.hasNext()){ MessageVO m=(MessageVO)it.next(); System.out.println(m.getId()); System.out.println(m.getTitle()); System.out.println(m.getName()); System.out.println(m.getEmail()); System.out.println(m.getDateString()); System.out.println(m.getContent()); } }catch(Exception e){ System.out.println(e); } } // //用main测试deleteMessage() // public static void main (String[] args) { // try{ // MessageBean g=new MessageBean(); // g.deleteMessage(20); // }catch(Exception e){ // System.out.println(e); // } // } }