快捷導(dǎo)航

Java使用easyExcel批量導(dǎo)入數(shù)據(jù)詳解

更新時(shí)間：2023年08月25日 10:26:31 作者：流蘇打

這篇文章主要介紹了Java使用easyExcel批量導(dǎo)入數(shù)據(jù)詳解,通常我們會(huì)提供一個(gè)模板,此模塊我們可以使用easyExcel導(dǎo)出數(shù)據(jù)生成的一個(gè)Excel文件當(dāng)作模板,提供下載鏈接,用戶在該文件內(nèi)填入規(guī)定的數(shù)據(jù)格式以后可以批量導(dǎo)入數(shù)據(jù)到數(shù)據(jù)庫中,需要的朋友可以參考下

Java使用easyExcel批量導(dǎo)入數(shù)據(jù)

WMS、ERP等管理系統(tǒng)經(jīng)常涉及庫存、人員信息的管理，通常我們會(huì)提供一個(gè)模板

此模塊我們可以使用easyExcel導(dǎo)出數(shù)據(jù)生成的一個(gè)Excel文件當(dāng)作模板，提供下載鏈接。

用戶在該文件內(nèi)填入規(guī)定的數(shù)據(jù)格式以后可以批量導(dǎo)入數(shù)據(jù)到數(shù)據(jù)庫中。

controller層：

    //excel批量導(dǎo)入用戶數(shù)據(jù)
    @PostMapping("/user/import")
    public Object addUserList(@RequestParam("file")  MultipartFile file) {
        try {
            BufferedInputStream in = new BufferedInputStream(file.getInputStream());
            //調(diào)用寫的一個(gè)工具類傳入 文件流，所要轉(zhuǎn)換存儲(chǔ)的類，以及業(yè)務(wù)邏輯（我這邊直接就是插入語句）
            ExcelUtils.readExcel(in, User.class,userDao);
        }catch (Exception e){
            e.printStackTrace();
        }
        return "ok";
    }

ExcelUtils工具類：

網(wǎng)上的一些工具類包括公司內(nèi)部所使用的對(duì)Excel操作的工具包利用了反射、對(duì)于每個(gè)異常都做了處理有固定的返回格式和狀態(tài)碼，導(dǎo)致那那些工具包太大太亂對(duì)于新手同學(xué)來說不太友好，因此我這邊就單獨(dú)寫了一個(gè)簡(jiǎn)易的版本，讓功能實(shí)現(xiàn)即可。

package com.example.webdemo.utils.excel;
import com.alibaba.excel.EasyExcelFactory;
import com.alibaba.excel.ExcelReader;
import com.alibaba.excel.ExcelWriter;
import com.alibaba.excel.event.AnalysisEventListener;
import com.alibaba.excel.metadata.BaseRowModel;
import com.alibaba.excel.metadata.Sheet;
import com.alibaba.excel.support.ExcelTypeEnum;
import com.example.webdemo.Dao.UserDao;
import java.io.*;
import java.util.List;
/**
 * @author zhangqianwei
 * @date 2022/2/16 19:45
 */
public class ExcelUtils {
    /**
     * @param is   導(dǎo)入文件輸入流
     * @param clazz Excel實(shí)體映射類
     * @return
     */
    public static Boolean readExcel(InputStream is, Class clazz, UserDao userDao){
        BufferedInputStream bis = null;
        try {
            bis = new BufferedInputStream(is);
            // 解析每行結(jié)果在listener中處理
            AnalysisEventListener listener = new ExcelListener(userDao);
            ExcelReader excelReader = EasyExcelFactory.getReader(bis, listener);
            excelReader.read(new Sheet(1, 1, clazz));
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        } finally {
            if (bis != null) {
                try {
                    bis.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return true;
    }
   /**
     *
     * @param response http請(qǐng)求報(bào)文
     * @param clazz Excel實(shí)體映射類
     * @param data 導(dǎo)出數(shù)據(jù)
     * @return
     */
    public static Boolean writeExcel(HttpServletResponse response, Class clazz, List<? extends BaseRowModel> data){
        BufferedOutputStream bos= null;
        try {
            ServletOutputStream out = response.getOutputStream();
            ExcelWriter writer = new ExcelWriter(out, ExcelTypeEnum.XLSX, true);
            String fileName = "用戶數(shù)據(jù)";
            //這邊對(duì)應(yīng)的實(shí)體類改為你所導(dǎo)出的實(shí)體類
            Sheet sheet = new Sheet(1, 0, User.class);
            //設(shè)置自適應(yīng)寬度
            sheet.setAutoWidth(Boolean.TRUE);
            // 第一個(gè) sheet 名稱
            sheet.setSheetName("第一個(gè)sheet");
            writer.write(data, sheet);
            //通知瀏覽器以附件的形式下載處理，設(shè)置返回頭要注意文件名有中文
            response.setHeader("Content-disposition", "attachment;filename=" + new String( fileName.getBytes("gb2312"), "ISO8859-1" ) + ".xlsx");
            writer.finish();
            response.setContentType("multipart/form-data");
            response.setCharacterEncoding("utf-8");
            out.flush();
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        } finally {
            if (bos != null) {
                try {
                    bos.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return true;
    }
}

監(jiān)聽類ExcelListener：

Excel批量導(dǎo)入，其實(shí)是監(jiān)聽解析出來的每一行數(shù)據(jù)轉(zhuǎn)換為對(duì)應(yīng)的類，逐個(gè)插入數(shù)據(jù)庫，當(dāng)然也可以監(jiān)聽到每一行數(shù)據(jù)時(shí)候存儲(chǔ)到一個(gè)list中，供后續(xù)業(yè)務(wù)處理。

package com.example.webdemo.utils.excel;
import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;
import com.example.webdemo.Dao.UserDao;
import com.example.webdemo.Entity.User;
import java.util.ArrayList;
import java.util.List;
/**
 * @author zhangqianwei
 * @date 2022/2/16 20:03
 */
/** 解析監(jiān)聽器，
 * 每解析一行會(huì)回調(diào)invoke()方法。
 * 整個(gè)excel解析結(jié)束會(huì)執(zhí)行doAfterAllAnalysed()方法
 */
public class ExcelListener extends AnalysisEventListener {
    private final UserDao userDao;
    //解析出來的每一行數(shù)據(jù)可以存入一個(gè)list中
    private List<Object> datas = new ArrayList<Object>();
    public ExcelListener(UserDao userDao) {
        this.userDao = userDao;
    }
    @Override
    public void invoke(Object object, AnalysisContext context) {
        System.out.println("當(dāng)前行："+context.getCurrentRowNum());
        System.out.println(object);
        datas.add(object);//數(shù)據(jù)存儲(chǔ)到list，供批量處理，或后續(xù)自己業(yè)務(wù)邏輯處理。
        insert(object);//根據(jù)自己業(yè)務(wù)做處理
    }
    private void insert(Object object) {
        User user = (User) object;
        userDao.addUser(user);
    }
    @Override
    public void doAfterAllAnalysed(AnalysisContext context) {
        // datas.clear();//解析結(jié)束銷毀不用的資源
    }
    public List<Object> getDatas() {
        return datas;
    }
    public void setDatas(List<Object> datas) {
        this.datas = datas;
    }
}

User類：