www.pudn.com > msgBook.rar > MsgbookAction.java

package classmate; 
 
import java.sql.Connection; 
import java.sql.SQLException; 
import java.sql.Statement; 
 
import javax.sql.DataSource; 
import javax.servlet.ServletContext; 
import javax.servlet.http.HttpServletRequest; 
import javax.servlet.http.HttpServletResponse; 
 
import org.apache.struts.action.Action; 
import org.apache.struts.action.ActionErrors; 
import org.apache.struts.action.ActionForm; 
import org.apache.struts.action.ActionForward; 
import org.apache.struts.action.ActionMapping; 
import org.apache.struts.action.ActionMessage; 
import org.apache.struts.action.ActionMessages; 
import org.apache.struts.action.DynaActionForm; 
 
public final class MsgbookAction extends Action{ 
    
	public ActionForward execute( 
			ActionMapping mapping, 
			ActionForm form, 
			HttpServletRequest request, 
			HttpServletResponse respone) throws Exception{ 
		DynaActionForm dyform =(DynaActionForm)form; 
		   String name=(String)dyform.get("name"); 
		   String sex=(String)dyform.get("sex"); 
		   String email=(String)dyform.get("email"); 
		   String title=(String)dyform.get("title"); 
		   String content=(String)dyform.get("content"); 
		    
		   //获取数据库连接的数据源 
		   ServletContext context=servlet.getServletContext(); 
		   DataSource dataSource=(DataSource)context.getAttribute("oracleDB1"); 
		   Connection conn=null; 
		   ActionMessages errors=new ActionMessages(); 
		   //连接数据库，将信息插入到数据库中 
		   String strsql="insert into msgbook values('" 
			   + name + "','" 
			   + email + "','" 
			   + title + "','" 
			   + content + ")"; 
		   System.out.println("strsql: "+strsql); 
		   try { 
			   conn=dataSource.getConnection(); 
			   Statement stmt = conn.createStatement(); 
			   int result=0; 
			   result=stmt.executeUpdate(strsql); 
			   //依据插入数据的结果显示不同提示信息 
			   if(result==1){ 
				   errors.add(ActionMessages.GLOBAL_MESSAGE, 
				     new ActionMessage("errors.SubmitSuccess")); 
			   } 
			   else{ 
				   errors.add(ActionMessages.GLOBAL_MESSAGE, 
					 new ActionMessage("errors.SubmitFail")); 
			   } 
		   }catch(SQLException e){ 
			   System.out.println("sqlerror"); 
			   errors.add(ActionMessages.GLOBAL_MESSAGE, 
				     new ActionMessage("errors.SubmitFail")); 
		   }finally{ 
			   if(conn!=null) 
				     conn.close(); 
		   } 
		   if (!errors.isEmpty()){ 
			  saveErrors(request,(ActionErrors) errors); 
		   } 
		   System.out.println("errors: "+errors.size()); 
		    
		   return mapping.findForward("toMsg"); 
		   } 
}