java使用common-fileupload实现文件上传

文件上传是网站非常常用的功能，直接使用servlet获取上传文件还得解析请求参数，比较麻烦，所以一般选择采用apache的开源工具，common-fileupload.这个jar包可以再apache官网上面找到，也可以在struts的lib文件夹下面找到，struts上传的功能就是基于这个实现的。

common-fileupload是依赖于common-io这个包的，所以还需要下载这个包。然后导入到你的项目路径下面。

使用代码如下

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("\\"); 
          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);  
    }  
  }  
} 

可能会遇到数据库默认问价大小限制，需要在mysql安装目录下面的my.ini下面更改如下配置，
[mysqld] 
max_allowed_packet=64m 

这样就可以了。当然，注意编码格式。上传文件搞定。还有就是我的一个列名设置为describe，结果和mysql保留字冲
突，出现无法插入信息现象，以后一定要注意。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。