<form action="/bbs/Publish" method="post">
<p>消息标题： <input type="text" name="title" size="156"/></p>
<p>消息内容：<FCK:editor instanceName="content" basePath="/fckeditor" toolbarSet="myToolbar" height="300" width="970"></FCK:editor></P><p align="center"><input type="submit" value="提交"/>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<input type="reset" value="重置" /></p></form>

package com.congbbs.dao;import com.congbbs.javabean.Message;
public interface MessageDao {   //添加消息public void addMessage(Message message);

}

package com.congbbs.dao.imple;import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;import com.congbbs.dao.MessageDao;
import com.congbbs.javabean.Message;import com.congbbs.util.DbConn;public class MessageDaoImpl implements MessageDao {//插入一条消息
    @Overridepublic void addMessage(Message message) {　　　　　//通过工具类获得数据库的链接Connection conn = DbConn.getConnection();　　　　　//编写sql语句String sql = "insert into tb_message(messageTitle, messageContent,userID, publishTime)"+"values(?,?,?,?)";PreparedStatement ps = null;try {ps = conn.prepareStatement(sql);ps.setString(1, message.getMessageTitle());   //将传过来的数据对应装配到sql语句中ps.setString(2, message.getMessageContent());ps.setInt(3, message.getUserID());ps.setTimestamp(4, new Timestamp(message.getPublishTime().getTime()));  // 获取当前操作的时间ps.execute(); //将数据提交到数据库中} catch (Exception e) {e.printStackTrace();}finally {           //关闭相应的数据连接对象DbConn.close(ps);DbConn.close(conn);}}
}

package com.congbbs.factory;import com.congbbs.dao.MessageDao;
import com.congbbs.dao.imple.MessageDaoImpl;public class MessageDaoFactory {public static MessageDao getMessageDaoInstance(){return new MessageDaoImpl();}
}

package com.congbbs.servlet;import java.io.IOException;
import java.util.Date;import javax.servlet.RequestDispatcher;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;import com.congbbs.dao.MessageDao;
import com.congbbs.factory.MessageDaoFactory;
import com.congbbs.javabean.Message;
import com.congbbs.javabean.User;public class Publish extends HttpServlet {private static final long serialVersionUID = 1L;protected void doGet(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {doPost(request, response);}protected void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException {request.setCharacterEncoding("UTF-8");     //设置request请求的编码response.setCharacterEncoding("UTF-8");    //设置response相应的编码response.setContentType("text/html; charset=UTF-8");   //告知浏览器该页面的解析格式和编码String title = request.getParameter("title");    //接收表单提交的数据,这里的"title"要了表单中的name属性一致String content = request.getParameter("content"); //同理ServletContext servletContext = getServletContext();   //获得servlet内置的上下文对象RequestDispatcher dispatcher = null;    //定义分发对象User user = (User)request.getSession().getAttribute("user");  //获取登录时提交在session中的用户对象数据//进行简单的验证，将信息反馈回页面if(user == null){request.setAttribute("error", "要发布消息必须先登录！！");dispatcher = servletContext.getRequestDispatcher("/jsp/publish.jsp");  //转发回原界面}else {if(title == null || "".equals(title)){request.setAttribute("error", "必须要输入消息标题！！");dispatcher = servletContext.getRequestDispatcher("/jsp/publish.jsp");}else{if(content == null || "".equals(content)){request.setAttribute("error", "不能发布空消息！！！");dispatcher = servletContext.getRequestDispatcher("/jsp/publish.jsp");}else {Message message = new Message();      //通过数据验证后，将数据装配到一个message对象中传给后台
                    message.setUserID(user.getUserID());message.setMessageTitle(title);message.setMessageContent(content);message.setPublishTime(new Date());MessageDao messageDao = MessageDaoFactory.getMessageDaoInstance();  //获得message业务处理的实例messageDao.addMessage(message);   //调用插入方法dispatcher = servletContext.getRequestDispatcher("/GetMessageList");  //插入成功转发到显示消息的servlet进行查询显示
                }}}dispatcher.forward(request, response);  //跳转页面
    }}

@org.junit.Testpublic void testAddMessage(){MessageDao messageDao = MessageDaoFactory.getMessageDaoInstance();Message message = new Message();message.setMessageTitle("测试信息");message.setMessageContent("插入成功");message.setUserID(Integer.parseInt("10086"));message.setPublishTime(new Date());messageDao.addMessage(message);System.out.println("插入成功。。。。。。。。。");}