package oop.hg.ytu.servlet;  import java.io.File; import java.io.IOException; import java.io.InputStream; import java.util.List;  import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse;  import oop.hu.ytu.dao.UploadDomain;  import org.apache.commons.fileupload.FileItem; import org.apache.commons.fileupload.disk.DiskFileItemFactory; import org.apache.commons.fileupload.servlet.ServletFileUpload;  public class Upload extends HttpServlet {    /**    * 處理用戶上傳請求    */   private static final long serialVersionUID = 1L;    public void doGet(HttpServletRequest request, HttpServletResponse response)       throws ServletException, IOException {   // String describe = request.getParameter("describe");     DiskFileItemFactory factory = new DiskFileItemFactory();     @SuppressWarnings("deprecation")     String path = request.getRealPath("/upload");//設置磁盤緩沖路徑        factory.setRepository(new File(path));     factory.setSizeThreshold(1024*1024);//設置創建緩沖大小          ServletFileUpload upload = new ServletFileUpload(factory);     upload.setSizeMax(-1);//設置上傳文件限制大小,-1無上限     try {       @SuppressWarnings("unchecked")       List<FileItem> list = upload.parseRequest(request);       String va = null;       for(FileItem item : list){     //   String name = item.getFieldName();         if(item.isFormField()){//判斷是否是文件流                      va = item.getString("UTF-8");         // System.out.println(name+"="+va);       ///   request.setAttribute(name, value);         }else{           String value = item.getName();//會將完整路徑名傳過來           int start = value.lastIndexOf("http://");           String fileName = value.substring(start+1);       //   request.setAttribute(name, fileName);           InputStream in = item.getInputStream();           UploadDomain dao = new UploadDomain();           //item.write(new File(realPath,fileName));           int index = fileName.lastIndexOf(".");           String realFileName = fileName.substring(0,index);           String type = fileName.substring(index+1);           dao.insert(in, realFileName,type,va);//放入到數據庫中                    }       }     } catch (Exception e) {              e.printStackTrace();     }   }    public void doPost(HttpServletRequest request, HttpServletResponse response)       throws ServletException, IOException {     doGet(request, response);    }  }

package oop.hu.ytu.dao;  import java.io.InputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet;  import oop.hg.ytu.utils.JdbcUtils;  /**  * 提供文件上傳支持  * @author Administrator  *  */ public class UploadDomain {   /**    * 將上傳的文件流放入到數據庫中    */   public void insert(InputStream in, String fileName, String type,String describe) throws Exception{//向數據庫中寫入圖片      Connection conn = null;      PreparedStatement ps = null;      ResultSet rs = null;      System.out.println(describe);     try {        // 2.建立連接        conn = JdbcUtils.getConnection();       // 3.創建語句        String sql = "insert into fileupload(file,filename,type,des) values (?,?,?,?)";        ps = conn.prepareStatement(sql);        ps.setBlob(1, in);       ps.setString(2, fileName);       ps.setString(3, type);       ps.setString(4, describe);       // 4.執行語句        ps.executeUpdate();          in.close();              } finally {        JdbcUtils.free(rs, ps, conn);      }    }  }