practiceuploadaction.java

采用Eclispe开发平台

package com.whatratimes.webedu.student;

import com.whatratimes.dbms.DBHelper;
import com.whatratimes.dbms.DeleteSQLExecuter;
import com.whatratimes.dbms.InsertSQLExecuter;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUpload;
import org.apache.commons.fileupload.DiskFileUpload;
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 javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;
import java.util.Iterator;
import java.util.List;

/**
 * User: Tao
 * Date: Jun 17, 2003
 * Time: 2:51:11 AM
 */
public class PracticeUploadAction extends Action
{
    public ActionForward execute(ActionMapping actionMapping, ActionForm actionForm, HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse) throws Exception
    {

        HttpSession session = httpServletRequest.getSession();

        Integer submit_id = Integer.valueOf(session.getAttribute("SubmitId").toString());
        Integer question_seq = Integer.valueOf(session.getAttribute("QuestionSeq").toString());

        boolean isMultipart = FileUpload.isMultipartContent(httpServletRequest);

        DiskFileUpload upload = new DiskFileUpload();

        upload.setSizeMax(1024000);
        upload.setSizeThreshold(1024000);

        // Parse the request
        List /* FileItem */ items = null;
        try
        {
            items = upload.parseRequest(httpServletRequest);
        } catch (Exception e)
        {
            e.printStackTrace();
            return actionMapping.findForward("failed");
        }

        Iterator itr = items.iterator();

//        t_question question = (t_question) session.getAttribute("Question");

        while (itr.hasNext())
        {
            FileItem fi = (FileItem) itr.next();
            if (fi.isFormField() || fi.getSize() == 0)
            {
                continue;
            }

            StringBuffer fn = new StringBuffer(fi.getName());
            String filename = fn.delete(0, fn.lastIndexOf("\\") + 1).toString().trim();

            DeleteSQLExecuter ds = new DeleteSQLExecuter();

            ds.appendTableName("t_exam_question_upload");

            ds.appendWhereCondition("SubmitId", "=", submit_id);
            ds.appendWhereCondition("QuestionSeq", "=", question_seq);
            ds.appendWhereCondition("FileName", "=", filename);

            ds.executeUpdate();

            InsertSQLExecuter sql = new InsertSQLExecuter();

            sql.appendTableName("t_exam_question_upload");
            sql.appendValue("UploadId", new Integer(DBHelper.getNextUploadId()));
            sql.appendValue("SubmitId", submit_id);
            sql.appendValue("QuestionSeq", question_seq);
            sql.appendValue("FileName", filename);
            sql.appendValue("FileType", fi.getContentType());
            sql.appendValue("FileSize", new Integer((int) fi.getSize()));
            sql.appendValue("FileContent", fi.getInputStream());

            sql.executeUpdate();

        }

        StudyHelper.setQuestionUploadedFiles(submit_id, question_seq, session );

        return actionMapping.findForward("success");
    }

}