enteraddarraaction.java

此资源是jsp应用开发 邓子云等编写的一书里的源代码

package action;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;

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 enterAddArraAction extends Action{
	
	/**
	 * 在此方法中处理HTTP请求，并作响应
	 */
	public ActionForward execute(ActionMapping arg0, ActionForm arg1,
			HttpServletRequest request, HttpServletResponse reponse) throws Exception {
		ActionErrors errors=new ActionErrors();
		//------接收请求参数------
		String thingId=request.getParameter("thingId");
		request.setAttribute("thingId",thingId);
		//------如果接收数据有误------
	  	if(thingId==null||thingId.length()==0)
	  		return arg0.findForward("viewThingListdo");
	  	//------构造查询的SQL语句------
	  	String sqlStr="select * from thing where thingId="+thingId;
	  	//------查询出数据，将查询结果数据集写入到request中------
	  	try{
			//------得到数据库连接------
			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();
			//------查询数据------
		  	Statement sql1=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
		  	ResultSet rs1=sql1.executeQuery(sqlStr);
		  	//------该事务的信息放入rsArray1------
		  	Object[][] rsArray1=new Object[1][4];
		  	int i=0;
		  	if(rs1.next()){
		  		rsArray1[i][0]=rs1.getString("thingId");
		  		rsArray1[i][1]=rs1.getString("ThingTitle");
		  		rsArray1[i][2]=rs1.getString("ThingContent");
		  		rsArray1[i][3]=rs1.getString("ThingAddTime");
		  	}
		  	request.setAttribute("rsArray1",rsArray1);
		  	sqlStr="select count(*) as recordCount from thingArra,oaUser where "+
		  		"oaUser.oaUserId=thingArra.oaUserId and thingArra.thingId="+thingId;
		  	Statement sql2=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
		  	ResultSet rs2=sql2.executeQuery(sqlStr);
		  	if(rs2.next()){
		  		int recordCount=rs2.getInt("recordCount");
		  		//------该事务的申批记录放入rsArray2------
		  		Object[][] rsArray2=new Object[recordCount][3];
		  		sqlStr="select thingArra.thingArraEnd as thingArraEnd,thingArra.thingArraId as thingArraId,"
		  	  		+"oaUser.oaUserName as oaUserName,oaUser.oaUserTrueName as oaUserTrueName from thingArra,oaUser"+
			  		" where oaUser.oaUserId=thingArra.oaUserId and thingArra.thingId="+thingId;
		  		java.sql.Statement sql3=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
			  	ResultSet rs3=sql3.executeQuery(sqlStr);
			  	i=0;
			  	while(rs3.next()){
			  		rsArray2[i][0]=rs3.getString("thingArraEnd");
			  		rsArray2[i][1]=rs3.getString("oaUserTrueName");
			  		rsArray2[i][2]=rs3.getString("thingArraId");
			  		i++;
			  	}
			  	request.setAttribute("rsArray2",rsArray2);
		  	}
		  	sqlStr="select count(*) as countRecord from oaUser";
		  	Statement sql4=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
		  	ResultSet rs4=sql4.executeQuery(sqlStr);
		  	if(rs4.next()){
		  		int countRecord=rs4.getInt("countRecord");
		  		sqlStr="select *  from oaUser";
		  		Statement sql5=conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE, ResultSet.CONCUR_READ_ONLY);
			  	ResultSet rs5=sql4.executeQuery(sqlStr);
		  		//------审批人数据放入rsArray3------
			  	Object[][] rsArray3=new Object[countRecord][4];
			  	i=0;
			  	while(rs5.next()){
			  		rsArray3[i][0]=rs5.getString("oaUserId");
			  		rsArray3[i][1]=rs5.getString("oaUserName");
			  		rsArray3[i][2]=rs5.getString("oaUserTrueName");
			  		rsArray3[i][3]=rs5.getString("departmentId");
			  		i++;
			  	}
			  	request.setAttribute("rsArray3",rsArray3);
		  	}  	
		  	//------关闭数据库连接------
		  	if(conn!=null)
		  		conn.close();
		}catch(Exception e){
			e.printStackTrace();
			errors.add("DBOPError",new ActionMessage("DBOPError"));
			saveErrors(request,errors);
			return arg0.findForward("viewThingListdo");
		}
		return arg0.findForward("enterAddArraJSP");
	}
}