java实现多文件上传并保存到数据库

好久没有写博客了，今天项目里需要一个功能，即前台实现多图片上传列表，并后台保存到mysql中。前台后台一起弄，用了半天时间终于搞定了。

实现：前台Layui实现；后台servlet+hibernate

不多废话，先上图

前台实现主要是用的layui框架，框架本身提供多文件上传列表，但是没有查看的功能，我自己实现了图片查看的功能，核心代码如下：

<div class="layui-upload">
  <button type="button" class="layui-btn layui-btn-normal" id="testList">选择图片</button> 
  <div class="layui-upload-list">
    <table class="layui-table">
      <thead>
        <tr><th>文件名</th>
        <th>大小</th>
        <th>状态</th>
        <th>操作</th>
      </tr></thead>
      <tbody id="demoList"></tbody>
    </table>
  </div>
  <button type="button" class="layui-btn" id="testListAction">开始上传</button>
 
</div> 
  

<script src="./layui/layui.js" charset="utf-8"></script>
<!-- 注意：如果你直接复制所有代码到本地，上述js路径需要改成你本地的 -->
<script>
layui.use('upload', function(){
  var $ = layui.jquery
  ,upload = layui.upload;

 

  //多文件列表示例
  var demoListView = $('#demoList')
  ,uploadListIns = upload.render({
    elem: '#testList'
    ,url: '/upload/'
    ,accept: 'file'
    ,multiple: true
    ,auto: false
    ,bindAction: '#testListAction'
    ,choose: function(obj){   
      var files = this.files = obj.pushFile(); //将每次选择的文件追加到文件队列
      //读取本地文件
      obj.preview(function(index, file, result){
        var tr = $(['<tr id="upload-'+ index +'">'
          ,'<td>'+ file.name +'</td>'
          ,'<td>'+ (file.size/1014).toFixed(1) +'kb</td>'
          ,'<td>等待上传</td>'
          ,'<td>'
		  	,'<button class="layui-btn layui-btn-xs demo-look ">查看</button>'
            ,'<button class="layui-btn layui-btn-xs demo-reload layui-hide">重传</button>'
            ,'<button class="layui-btn layui-btn-xs layui-btn-danger demo-delete">删除</button>'
          ,'</td>'
        ,'</tr>'].join(''));
        
        //查看
        tr.find('.demo-look').on('click', function(){
          var imgobj = new Image(); //创建新img对象
		  imgobj.src = result; //指定数据源
		  imgobj.className = 'thumb';
		  var w = $(window).width()-42 , h = $(window).height()-42;
		  layer.open({
			title: '预览',
			type: 1,
			area: [w, h], //宽高
			content: '<img src="'+ result +'" alt="'+ file.name +'" class="layui-upload-img">'
			});
					
        });
		//单个重传
        tr.find('.demo-reload').on('click', function(){
          obj.upload(index, file);
        });
        
        //删除
        tr.find('.demo-delete').on('click', function(){
          delete files[index]; //删除对应的文件
          tr.remove();
          uploadListIns.config.elem.next()[0].value = ''; //清空 input file 值，以免删除后出现同名文件不可选
        });
        
        demoListView.append(tr);
      });
    }
    ,done: function(res, index, upload){
      if(res.code == 0){ //上传成功
        var tr = demoListView.find('tr#upload-'+ index)
        ,tds = tr.children();
        tds.eq(2).html('<span style="color: #5FB878;">上传成功</span>');
        tds.eq(3).html(''); //清空操作
        return delete this.files[index]; //删除文件队列已经上传成功的文件
      }
      this.error(index, upload);
    }
    ,error: function(index, upload){
      var tr = demoListView.find('tr#upload-'+ index)
      ,tds = tr.children();
      tds.eq(2).html('<span style="color: #FF5722;">上传失败</span>');
      tds.eq(3).find('.demo-reload').removeClass('layui-hide'); //显示重传
    }
  });
  
});
</script>

后台一个servlet实现将多图保存到mysql

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.sql.Blob;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.io.InputStream ;
import javax.servlet.ServletConfig;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.sql.rowset.serial.SerialBlob;
import javax.sql.rowset.serial.SerialException;

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import org.hibernate.Hibernate;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.hibernate.cfg.Configuration;

import com.alibaba.fastjson.JSONObject;
import com.pctest.po.TestResAttach;

public class LayuiUpload extends HttpServlet {
 
	// 保存文件的目录
	private static String PATH_FOLDER = "/";
	// 存放临时文件的目录
	private static String TEMP_FOLDER = "/";
	
		
	/**
	 * Constructor of the object.
	 */
	public LayuiUpload() {
		super();
	}
 
	/**
	 * Destruction of the servlet. <br>
	 */
	public void destroy() {
		super.destroy(); // Just puts "destroy" string in log
		// Put your code here
	}
 
	public void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
 
		this.doPost(request, response);
	}
 
	public synchronized void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {
		// 结果json对象
		JSONObject jsonobj = new JSONObject();
		int returnTag = -1;
		String saveName=null;
		//上传的文件名
		String filename=null;
		String id = request.getParameter("ID");
		System.out.println("id============="+id);
		try {
			System.out.println("==========以下为上传代码============");
			request.setCharacterEncoding("utf-8"); // 设置编码
			response.setContentType("text/html;charset=UTF-8");
			// 获得磁盘文件条目工厂
			DiskFileItemFactory factory = new DiskFileItemFactory();
 
			// 如果没以下两行设置的话，上传大的 文件 会占用 很多内存，
			// 设置暂时存放的 存储室 , 这个存储室，可以和 最终存储文件 的目录不同
			/**
			 * 原理 它是先存到 暂时存储室，然后在真正写到 对应目录的硬盘上， 按理来说 当上传一个文件时，其实是上传了两份，第一个是以
			 * .tem 格式的 然后再将其真正写到 对应目录的硬盘上
			 */
			factory.setRepository(new File(TEMP_FOLDER));
			// 设置 缓存的大小，当上传文件的容量超过该缓存时，直接放到 暂时存储室
			factory.setSizeThreshold(1024 * 1024);
			
			// 高水平的API文件上传处理
			ServletFileUpload upload = new ServletFileUpload(factory);
 
			// 提交上来的信息都在这个list里面
			// 这意味着可以上传多个文件
			// 请自行组织代码
			List<FileItem> list = upload.parseRequest(request);
			
			// 获取上传的文件
			for (FileItem file : list) {
				FileItem item = file;
				// 获取文件名
				 filename = getUploadFileName(item);
				System.out.println("获取的文件名============================"
						+ filename);
				String suffix = filename
						.substring(filename.lastIndexOf(".") + 1);
				System.out
						.println("获取的文件后缀名=========================" + suffix);
				String[] regular = { "JPG", "GIF","PNG","JPEG" ,"BMP"};
				boolean flag = false;
				// 判断文件格式是否合法
				for (String str : regular) {
					if (suffix.equalsIgnoreCase(str)) {
						flag = true;
					}
				}
				if (!flag) {
					returnTag = 0;
					throw new Exception("文件格式不合法！");
				}
				
 
				// 保存后的文件名
				 saveName = new Date().getTime()
						+ filename.substring(filename.lastIndexOf("."));
				 String fileExt = filename.substring(filename.lastIndexOf(".")+1);//扩展名
				 InputStream is=item.getInputStream();
		         FileOutputStream fos=new FileOutputStream(file.getName());
		            int len=0;
		            byte[] b=new byte[1024];
		            while((len=is.read(b))!=-1){
		                fos.write(b, 0, len);
		            }
				Blob bb = Hibernate.createBlob(b);
				TestResAttach tt =new TestResAttach();
				SessionFactory sf = new Configuration().configure().buildSessionFactory();
				tt.setFilebody(bb);
				tt.setFileName(saveName);
				tt.setFileType("images/jpg");
				tt.setFileExt(fileExt);
				tt.setFileclass(0);
				Timestamp createtime = new Timestamp(new Date().getTime());
				tt.setCreatetime(createtime);
				tt.setTestid(82);
				tt.setByindex(12);
		        Session s = sf.openSession();
		        s.beginTransaction();
		        s.save(tt);
		        s.getTransaction().commit();
		        s.close();
		        sf.close();
				
			}
			if (returnTag != -1) {
				// 请求失败
				jsonobj.put("STATUS", "1");
			} else {
				jsonobj.put("code", 0);
			}
			response.getWriter().write(jsonobj.toString());
			response.getWriter().close();
		} catch (Exception e) {
			e.printStackTrace();
			jsonobj.put("errorCode", 0);
			response.getWriter().write(jsonobj.toString());
			response.getWriter().close();
 
		}
	}
	private String getUploadFileName(FileItem item) {
		// 获取路径名
		String value = item.getName();
		// 索引到最后一个反斜杠
		int start = value.lastIndexOf("/");
		// 截取 上传文件的 字符串名字，加1是 去掉反斜杠，
		String filename = value.substring(start + 1);
 
		return filename;
	}
 
	/**
	 * Initialization of the servlet. <br>
	 *
	 * @throws ServletException if an error occurs
	 */
	public void init(ServletConfig config) throws ServletException {
		ServletContext servletCtx = config.getServletContext();
		// 初始化路径
		// 缩略图保存路径
		PATH_FOLDER = "C:/source/aaa";
		System.out.println("保存缩略图的目录===========" + PATH_FOLDER);
		// 存放临时文件的目录,存放xxx.tmp文件的目录
		TEMP_FOLDER = servletCtx.getRealPath("/temp");
		System.out.println("存放临时文件的目录===========" + TEMP_FOLDER);
		File dir = new File(PATH_FOLDER);
		if (!dir.isDirectory()) {
			dir.mkdir();
		}
		File dir2 = new File(TEMP_FOLDER);
		if (!dir2.isDirectory()) {
			dir2.mkdir();
		}
	}
 
}

需要注意的一点，图片保存在数据库中的类型是Blob。