阿里EasyExcel导入Excel大批量数据用法

约定不等于承诺〃 2024-04-03 11:42 30阅读 0赞

### 阿里EasyExcel导入Excel大批量数据用法 ###

\-pom文件依赖

<dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>easyexcel</artifactId>
                <version>3.0.5</version>
            </dependency>

*  导入（读）数据–第一步创建一个监听器ExcelDataListener.java继承AnalysisEventListener类

// 1.编写一个监听器 ExcelDataListener.java继承AnalysisEventListener类
    //    重写invoke方法
    
    package com.xiaogui.log.utils;
    
    import com.alibaba.excel.context.AnalysisContext;
    import com.alibaba.excel.event.AnalysisEventListener;
    import com.alibaba.excel.metadata.Cell;
    import com.alibaba.excel.read.metadata.holder.ReadRowHolder;
    import com.alibaba.excel.support.ExcelTypeEnum;
    import com.alibaba.fastjson.JSON;
    import com.xiaogui.log.mapper.LogMapper;
    import com.xiaogui.log.vo.resp.RespLogInfo;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.stereotype.Component;
    
    import java.util.*;
    
    
    
    @Component
    @Slf4j
    public class ExcelDataListener extends AnalysisEventListener<RespLogInfo> {
        /**
         * 每隔10条存储数据库，实际使用中可以3000条，然后清理list ，方便内存回收
         */
        private static final int BATCH_COUNT = 10;
        List<与Excel表头对应的Entity> list = new ArrayList<>();
        /**
         * 假设这个是一个DAO，当然有业务逻辑这个也可以是一个service。
         * 当然如果不用存储这个对象没用。
         */
        private final Mapper Mapper;
    
        /**
         * 如果使用了spring,请使用这个构造方法。
         * 每次创建Listener的时候需要把spring管理的类传进来
         */
        public ExcelDataListener(Mapper mapper) {
            this.logMapper = logMapper;
        }
    
        /**
         * 这个每一条数据解析都会来调用
         */
        @Override
        public void invoke(与Excel表头对应的Entity data, AnalysisContext context) {
            log.info("解析到一条数据:{}", JSON.toJSONString(data));
            list.add(data);
            // 达到BATCH_COUNT了，需要去存储一次数据库，防止数据几万条数据在内存，容易OOM
            if (list.size() >= BATCH_COUNT) {
                for (Entity entity: list) {
                    mapper.insertSelective(entity);
                }
                // 存储完成清理 list
                list.clear();
            }
        }
    
        /**
         * 所有数据解析完成了 都会来调用
         */
        @Override
        public void doAfterAllAnalysed(AnalysisContext context) {
            log.info("所有数据解析完成！");
        }
    }

*  导入（读）数据–第二步-使用read读取，并且引入（可以注入也可以new一个ExcelDataListener）

/**
             * 读取数据
             */
            // 写法1：
            String fileName = "文件路径/文件名.xlsx";
            // 这里 需要指定读用哪个class去读，然后读取第一个sheet 文件流会自动关闭
            ExcelDataListener excelDataListener = new ExcelDataListener();
            EasyExcel.read(fileName,与Excel表头对应的Entity.class,excelDataListener   ).sheet().doRead();
    
            // 写法2：
            ExcelReader excelReader = EasyExcel.read(fileName, 与Excel表头对应的Entity.class,excelDataListener   ).build();
            ReadSheet readSheet = EasyExcel.readSheet(0).build();
            excelReader.read(readSheet);
            // 这里千万别忘记关闭，读的时候会创建临时文件，到时磁盘会崩的
            excelReader.finish();