Java编程

开发平台：
Java

AddEmployeeAction.java：源码内容
							package strutsds;
import java.io.IOException;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import org.apache.struts.action.Action;
import org.apache.struts.action.ActionForm;
import org.apache.struts.action.ActionForward;
import org.apache.struts.action.ActionMapping;
import org.apache.struts.action.ActionErrors;
import org.apache.struts.action.ActionError;
import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.Statement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class AddEmployeeAction extends Action {
  protected void insertUser(ActionForm form)throws Exception {
    String user = null;
    Connection conn = null;
    Statement stmt = null;
    ResultSet rs = null;
    ServletContext context = servlet.getServletContext();
    DataSource dataSource = (DataSource)context.getAttribute(Action.DATA_SOURCE_KEY);
    try {
      EmployeeActionForm eForm = (EmployeeActionForm)form;
      conn = dataSource.getConnection();
      stmt = conn.createStatement();
      StringBuffer sqlString =new StringBuffer("insert into employees ");
      sqlString.append("values ('"
                       + eForm.getUsername() + "', ");
      sqlString.append("'" +
                       eForm.getPassword() + "', ");
      sqlString.append("'"
                       + eForm.getRoleid() + "', ");
      sqlString.append("'"
                       + eForm.getName() + "', ");
      sqlString.append("'"
                       + eForm.getPhone() + "', ");
      sqlString.append("'"
                       + eForm.getEmail() + "', ");
      sqlString.append("'"
                       + eForm.getDepid() + "')");
      System.out.println("insert stmt of emploees in addemployeeaction"+sqlString);
      stmt.execute(sqlString.toString());
      //submit the insertion!
      conn.commit();
    }
    finally {
      if (rs != null) {
        rs.close();
      }
      if (stmt != null) {
        stmt.close();
      }
      if (conn != null) {
        conn.close();
      }
    }
}
  public ActionForward perform(ActionMapping mapping, ActionForm form, HttpServletRequest request, HttpServletResponse httpServletResponse) {
    /**@todo: complete the business logic here, this is just a skeleton.*/
    // Default target to success
        String target = "success";
        /*EmployeesActionMapping employeesMapping =
        (EmployeesActionMapping)mapping;
// Does this action require the user to login
        if ( employeesMapping.isLoginRequired() ) {
        HttpSession session = request.getSession();
        if ( session.getAttribute("USER") == null ) {
// The user is not logged in
        target = "login";
        ActionErrors errors = new ActionErrors();
        errors.add(ActionErrors.GLOBAL_ERROR,
        new ActionError("errors.login.required"));
// Report any errors we have discovered back
// to the original form
        if (!errors.empty()) {
        saveErrors(request, errors);
        }
        return (mapping.findForward(target));
        }
        }*/
        if ( isCancelled(request) ) {
// Cancel button pressed back to employee list
        return (mapping.findForward("success"));
        }
        try {
        insertUser(form);
        }
        catch (Exception e) {
        System.err.println("Setting target to error");
        target = "error";
        ActionErrors errors = new ActionErrors();
        errors.add(ActionErrors.GLOBAL_ERROR,
        new ActionError("errors.database.error",
        e.getMessage()));
// Report any errors
if (!errors.empty()) {
saveErrors(request, errors);
}
}
// Forward to the appropriate View
return (mapping.findForward(target));
}
}

						