将Excel文件导入数据库（POI+Excel+MySQL+jsp页面导入）第一次优化

你的名字 2022-02-12 16:04 283阅读 0赞

转自：[https://blog.csdn.net/meng564764406/article/details/52444644][https_blog.csdn.net_meng564764406_article_details_52444644]

版权声明：本文为博主Lynn&Lingfei原创文章，未经博主允许不得转载。 https://blog.csdn.net/meng564764406/article/details/52444644  
本篇文章是根据我的上篇博客，给出的改进版，由于时间有限，仅做了一个简单的优化。

相关文章：将excel导入数据库

2018年4月1日，新增下载地址链接：点击打开源码下载地址

十分抱歉，这个链接地址没有在这篇文章上公布出来。希望不是很晚。

上篇文章的是这样的一个数据流向：

浏览器端打开上传页面，选择文件，上传，将excel上传到服务器，在服务器生成一个excel的文件，并写入Excel，再把excel文件读取存入mysql。

这一次做的优化是，可以再上传后，不再在excel中写入数据，也可以将文件写死，不会再在服务器占用空间。少了一步写入和读取的操作。直接对io流解析存储。

工程还是上篇文章的资源。

Upload.java

package com.app.action;  
   
   
   
import java.io.File;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.PrintWriter;  
import java.util.HashMap;  
import java.util.Iterator;  
import java.util.List;  
import java.util.Map;  
import java.util.UUID;  
   
import javax.servlet.ServletException;  
import javax.servlet.http.HttpServlet;  
import javax.servlet.http.HttpServletRequest;  
import javax.servlet.http.HttpServletResponse;  
   
import org.apache.commons.fileupload.FileItem;  
import org.apache.commons.fileupload.FileUploadBase;  
import org.apache.commons.fileupload.disk.DiskFileItemFactory;  
import org.apache.commons.fileupload.servlet.ServletFileUpload;  
import org.slf4j.Logger;  
import org.slf4j.LoggerFactory;  
   
import com.adtec.framework.common.util.JsonUtil;  
import com.app.excel.InputToFile;  
import com.app.excel.ReadExl\_1;  
import com.app.excel.SaveData2DB;  
import com.app.po.Student\_1;  
   
import net.sf.json.JSONObject;  
   
   
public class UpLoad extends HttpServlet \{  
   
    /\*\*  
     \*   
     \*/  
    private static final long serialVersionUID = 1L;  
   
    private final Logger logger = LoggerFactory.getLogger(this.getClass());  
      
    public void doGet(HttpServletRequest request, HttpServletResponse response)  
            throws ServletException, IOException \{  
            System.out.println("coming.......");  
          
                //得到上传文件的保存目录，将上传的文件存放于WEB-INF目录下，不允许外界直接访问，保证上传文件的安全  
                String savePath = this.getServletContext().getRealPath("/WEB-INF/upload");  
                //上传时生成的临时文件保存目录  
                String tempPath = this.getServletContext().getRealPath("/WEB-INF/temp");//"/WEB-INF/temp"  
                File tmpFile = new File(tempPath);  
                if (!tmpFile.exists()) \{  
                    //创建临时目录  
                    tmpFile.mkdir();  
                \}  
                  
                //消息提示  
                String message = "";  
                try\{  
                    //使用Apache文件上传组件处理文件上传步骤：  
                    //1、创建一个DiskFileItemFactory工厂  
                    DiskFileItemFactory factory = new DiskFileItemFactory();  
                    //设置工厂的缓冲区的大小，当上传的文件大小超过缓冲区的大小时，就会生成一个临时文件存放到指定的临时目录当中。  
                    factory.setSizeThreshold(1024\*100);//设置缓冲区的大小为100KB，如果不指定，那么缓冲区的大小默认是10KB  
                    //设置上传时生成的临时文件的保存目录  
                    factory.setRepository(tmpFile);  
                    //2、创建一个文件上传解析器  
                    ServletFileUpload upload = new ServletFileUpload(factory);  
                    //监听文件上传进度  
                    /\*upload.setProgressListener(new ProgressListener()\{  
                        public void update(long pBytesRead, long pContentLength, int arg2) \{  
                            System.out.println("文件大小为：" + pContentLength + ",当前已处理：" + pBytesRead);  
                              
                        \}  
                    \});\*/  
                     //解决上传文件名的中文乱码  
                    upload.setHeaderEncoding("UTF-8");   
                    //3、判断提交上来的数据是否是上传表单的数据  
                    if(!ServletFileUpload.isMultipartContent(request))\{  
                        //按照传统方式获取数据  
                        return;  
                    \}  
                      
                    //设置上传单个文件的大小的最大值，目前是设置为1024\*1024字节，也就是1MB  
                    upload.setFileSizeMax(1024\*1024);  
                    //设置上传文件总量的最大值，最大值=同时上传的多个文件的大小的最大值的和，目前设置为10MB  
                    upload.setSizeMax(1024\*1024\*10);  
                      
                    //4、使用ServletFileUpload解析器解析上传数据，解析结果返回的是一个List<FileItem>集合，每一个FileItem对应一个Form表单的输入项  
                    List<FileItem> list = upload.parseRequest(request);  
                    for(FileItem item : list)\{  
                        //如果fileitem中封装的是普通输入项的数据  
                        if(item.isFormField())\{  
                            String name = item.getFieldName();  
                            //解决普通输入项的数据的中文乱码问题  
                            String value = item.getString("UTF-8");  
//                            String value = item.getString("gbk");  
                            //value = new String(value.getBytes("iso8859-1"),"UTF-8");  
                            System.out.println(name + "=" + value);  
                        \}else\{//如果fileitem中封装的是上传文件  
                            //得到上传的文件名称，  
                            String filename = item.getName();  
                            System.out.println(filename+"..");  
                            if(filename==null || filename.trim().equals(""))\{  
                                continue;  
                            \}  
                            //注意：不同的浏览器提交的文件名是不一样的，有些浏览器提交上来的文件名是带有路径的，如：  c:\\a\\b\\1.txt，而有些只是单纯的文件名，如：1.txt  
                            //处理获取到的上传文件的文件名的路径部分，只保留文件名部分  
                            filename = filename.substring(filename.lastIndexOf("\\\\")+1);  
                            //得到上传文件的扩展名  
                            String fileExtName = filename.substring(filename.lastIndexOf(".")+1);  
                            //如果需要限制上传的文件类型，那么可以通过文件的扩展名来判断上传的文件类型是否合法  
                            System.out.println("上传的文件的扩展名是："+fileExtName);  
                            //获取item中的上传文件的输入流  
                            InputStream in = item.getInputStream();  
                            //得到文件保存的名称  
                            String saveFilename = makeFileName(filename);  
                            //得到文件的保存目录  
                            String realSavePath = makePath(saveFilename, savePath);  
                              
 //修改的代码/                             
                            File file = new File(realSavePath + "\\\\" + saveFilename);  
                            InputToFile itf = new InputToFile();  
                            file = itf.inputstreamtofile(in, file);  
                            SaveData2DB saveData2DB = new SaveData2DB();  
                            saveData2DB.save(file);                                                                                      
 ///                           
                             
                            \}  
                            //关闭输入流  
                            in.close();  
                            //关闭输出流  
                            out.close();  
                            //删除处理文件上传时生成的临时文件  
                            //item.delete();  
//                            SaveData2DB saveData2DB = new SaveData2DB();  
//                            saveData2DB.save(realSavePath + "\\\\" + saveFilename);  
                            System.out.println("end");  
                              
                            message = "success";  
                        \}  
                    \}  
                \}catch (FileUploadBase.FileSizeLimitExceededException e) \{  
                    e.printStackTrace();  
                    message = "单个文件超出最大值！！！";  
                    /\*request.setAttribute("message", "单个文件超出最大值！！！");\*/  
                   /\* request.getRequestDispatcher("/message.jsp").forward(request, response);\*/  
                    return;  
                \}catch (FileUploadBase.SizeLimitExceededException e) \{  
                    e.printStackTrace();  
                    message = "上传文件的总的大小超出限制的最大值！！！";  
                    /\*request.setAttribute("message", "上传文件的总的大小超出限制的最大值！！！");\*/  
                    /\*request.getRequestDispatcher("/message.jsp").forward(request, response);\*/  
                    return;  
                \}catch (Exception e) \{  
                    message= "文件上传失败！";  
                    e.printStackTrace();  
                \}  
                /\*request.setAttribute("message",message);\*/  
                returnResultJson(response,message);  
                /\*request.getRequestDispatcher("/message.jsp").forward(request, response);\*/  
    \}  
      
       
    private String makeFileName(String filename)\{  //2.jpg  
        //为防止文件覆盖的现象发生，要为上传文件产生一个唯一的文件名  
        return UUID.randomUUID().toString() + "\_" + filename;  
    \}  
      
       
    private String makePath(String filename,String savePath)\{  
        //得到文件名的hashCode的值，得到的就是filename这个字符串对象在内存中的地址  
        int hashcode = filename.hashCode();  
        int dir1 = hashcode&0xf;  //0--15  
        int dir2 = (hashcode&0xf0)>>4;  //0-15  
        //构造新的保存目录  
        String dir = savePath + "\\\\" + dir1 + "\\\\" + dir2;  //upload\\2\\3  upload\\3\\5  
        //File既可以代表文件也可以代表目录  
        File file = new File(dir);  
        //如果目录不存在  
        if(!file.exists())\{  
            //创建目录  
            file.mkdirs();  
        \}  
        return dir;  
    \}  
   
    public void doPost(HttpServletRequest request, HttpServletResponse response)  
            throws ServletException, IOException \{  
        doGet(request, response);  
    \}  
      
    private void returnResultJson(HttpServletResponse response,Object obj) \{  
        PrintWriter pw = null;  
        try \{  
            pw = response.getWriter();  
            JSONObject resultmessage = JsonUtil.generate(obj);  
            response.setCharacterEncoding("UTF-8");  
            response.setContentType("application/json");  
            response.setHeader("Cache-Control", "no-cache");  
            pw.write(resultmessage.toString());  
        \} catch (Exception e) \{  
            pw.write("系统异常，请联系管理员");  
        \} finally \{  
            pw.flush();  
            pw.close();  
        \}  
    \}  
\}  
第二步，在excel包内创建一个新的类  
InputToFile.java

package com.app.excel;  
   
import java.io.File;  
import java.io.FileNotFoundException;  
import java.io.FileOutputStream;  
import java.io.IOException;  
import java.io.InputStream;  
import java.io.OutputStream;  
   
public class InputToFile \{  
   
    public File inputstreamtofile(InputStream ins,File file)\{  
        try \{  
            OutputStream os = new FileOutputStream(file);  
            int bytesRead = 0;  
            byte\[\] buffer = new byte\[8192\];  
            while ((bytesRead = ins.read(buffer, 0, 8192)) != -1) \{  
                os.write(buffer, 0, bytesRead);  
            \}  
        \} catch (FileNotFoundException e) \{  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        \} catch (IOException e) \{  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        \}  
        return file;  
    \}  
      
\}

以上就是优化的所有操作了。抓紧试试吧。

\---------------------   
作者：Lynn\_Meng   
来源：CSDN   
原文：https://blog.csdn.net/meng564764406/article/details/52444644   
版权声明：本文为博主原创文章，转载请附上博文链接！

[https_blog.csdn.net_meng564764406_article_details_52444644]: https://blog.csdn.net/meng564764406/article/details/52444644