package com.jspdev.ch9;

import javax.servlet.*;
import javax.servlet.http.*;
import com.microsoft.jdbc.sqlserver.SQLServerDriver;
import java.sql.*;
import java.util.*;
import java.io.*;

public class AddMessageServlet extends HttpServlet
{

	private Connection con;
	/**
	 *接收GET請(qǐng)求，執(zhí)行數(shù)據(jù)庫(kù)操作，把視圖派發(fā)到下一個(gè)頁(yè)面
	 */
	public void doGet(HttpServletRequest request,
                      HttpServletResponse response)
        throws IOException, ServletException
    {
    	
    	String name=request.getParameter("name");
		String mail=request.getParameter("email");
		String title=request.getParameter("title");
		String content=request.getParameter("content");
		if(name==null)
		name="";
		if(title==null)
		title="";
		if(content==null)
		content="";
		if(mail==null)
		mail="";
		try
		{
			PreparedStatement stm=con.prepareStatement("insert into message values(?,?,?,?,?)");
			stm.setString(1,title);
			stm.setString(2,name);
			if(mail.length()==0)
			stm.setString(5,null);
			else stm.setString(5,mail);
			stm.setDate(3,new java.sql.Date(new java.util.Date().getTime()));
			stm.setString(4,content);
		    try 
			{
				stm.executeQuery();
			} 
			catch(Exception e) 
			{
			}			
         //把視圖派發(fā)到目標(biāo)
		RequestDispatcher requestDispatcher = request.getRequestDispatcher("/viewMessages_servlet");
		requestDispatcher.forward(request,response);
		}
		catch(Exception e)
		{
			e.printStackTrace();		
		}
	}
    /**
     *和GET請(qǐng)求的處理一樣
     */
	public void doPost(HttpServletRequest request,
	                      HttpServletResponse response)
	        throws IOException, ServletException
	    {
	    	doGet(request,response);
	    }
    /**
     *創(chuàng)建到數(shù)據(jù)庫(kù)的連接
     */
    public   AddMessageServlet()
    {
    	String CLASSFORNAME="com.microsoft.jdbc.sqlserver.SQLServerDriver";
	    String SERVANDDB="jdbc:microsoft:sqlserver://127.0.0.1:1433;DatabaseName=jspdev";
	    String USER="bn";
	    String PWD="bn"; 
	    try
	    {
	    	
	    	Class.forName(CLASSFORNAME);
			con = DriverManager.getConnection(SERVANDDB,USER,PWD);
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
}