package action;
import java.sql.Connection;
import java.sql.PreparedStatement;

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.DataSource;

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;

/**
 * @author dengziyun
 * 增加一名用戶的Action類
 */
public class addUserAction extends Action{
	
	/**
	 * 在此方法中處理HTTP請求，并作響應
	 */
	public ActionForward execute(ActionMapping arg0, ActionForm arg1,
			HttpServletRequest request, HttpServletResponse reponse) throws Exception {
		ActionErrors errors=new ActionErrors();
		//------接收請求參數(shù)------
		String oaUserName=request.getParameter("oaUserName");
	  	String oaUserPassword=request.getParameter("oaUserPassword");
	  	String oaUserTrueName=request.getParameter("oaUserTrueName");
	  	String department=request.getParameter("department");
	  	//------構(gòu)造SQL語句------
	  	String sqlStr=new String("insert into oaUser(oaUserName,oaUserPassword,"+
  			"oaUserTrueName,departmentId) values(?,?,?,?)");
	  	//------插入數(shù)據(jù)------
	  	try{
			//------得到數(shù)據(jù)庫連接------
			Context initCtx = new InitialContext(); 
			Context ctx = (Context) initCtx.lookup("java:comp/env");
			Object obj = (Object) ctx.lookup("jdbc/sqlserver");
			DataSource ds = (javax.sql.DataSource)obj;
			Connection conn = ds.getConnection();
			//------將數(shù)據(jù)插入到數(shù)據(jù)庫------
			PreparedStatement preSQLinsert=conn.prepareStatement(sqlStr);
		  	oaUserName=new String(oaUserName.getBytes("ISO-8859-1"));
		  	preSQLinsert.setString(1,oaUserName);
		  	oaUserPassword=new String(oaUserPassword.getBytes("ISO-8859-1"));
		  	preSQLinsert.setString(2,oaUserPassword);
		  	oaUserTrueName=new String(oaUserTrueName.getBytes("ISO-8859-1"));
		  	preSQLinsert.setString(3,oaUserTrueName);
		  	preSQLinsert.setInt(4,Integer.parseInt(department));
		  	preSQLinsert.executeUpdate();
		  	//------關(guān)閉數(shù)據(jù)庫連接------
		  	if(conn!=null)
		  		conn.close();
		}catch(Exception e){
			e.printStackTrace();
			errors.add("DBOPError",new ActionMessage("DBOPError"));
			saveErrors(request,errors);
			System.out.println(e);
		}
		arg1.reset(arg0,request);
		return arg0.findForward("addUserSuccessJSP");
	}
}