Springboot使用EasyExcel读取大量数据并且将得到的数据分批插入到数据库中

       
            com.alibaba
            easyexcel
            2.1.6
        

    @ExcelProperty(value = "BIRTHDAY", index = 5)
    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
    private Date birthday;

//创建的监听器必须继承 AnalysisEventListener，泛型为刚刚创建的实体类
public class ExcelListener extends AnalysisEventListener {
//由于数据是按行读取，所以此处需要创建两个静态变量来实现批量插入
    public  static  int vipCount;
//EasyExcel不能使用Spring注解，所以直接创建一个对应的Service（这个Service就是Controller中所调用的Service）
    public AddVipsServiceTest addVipsService;
    public  static List list=new ArrayList();

    public ExcelListener() {
    }
//有参构造
    public ExcelListener(AddVipsServiceTest addVipsServiceTest) {
        this.addVipsService = addVipsServiceTest;
    }
    //此处为得到一行后的数据转换为实体类
    @Override
    public void invoke(Users users, AnalysisContext context) {
    //添加到list中
        list.add(users);
        vipCount++;
        //得到当前操作表格的所有行数，由于行数包含了表头，所以需要减一为所有数据的条目数
        Integer a =context.getTotalCount()-1;
        //读取的行数到行尾时，将剩下的数据全部插入到数据库中
        if (a==vipCount){
//            System.out.println(list);
            addVipsService.addVip(list);
        }
        //每当list中存储的条目数达到2000条时，批量插入到数据库中，并清空当前list的数据
        if (list.size()%2000==0){
//            System.out.println(list);
            addVipsService.addVip(list);
//            System.out.println(2);
            list.clear();
        }
    }

    //最开始执行的函数，可以返回表头的数据
    @Override
    public void invokeHeadMap(Map headMap, AnalysisContext context) {
        System.out.println(headMap);
    }

    //全部读取完成之后执行函数
    @Override
    public void doAfterAllAnalysed(AnalysisContext context) {
        System.out.println("读取表格内容完毕");
    }
}

//此处编写插入的方法
@Service
public class AddVipsServiceTest {
    @Autowired
   private VipMapper vipMapper;
    @Transactional(rollbackFor = Exception.class)
    public Integer addVip(List list) {
        vipMapper.insertVips(list);
        return 1;
    }

    public void readExcel(String path,AddVipsServiceTest addVipsServiceTest){

    }
}

 @Service
public class AddVipsService extends AddVipsServiceTest{
//path为读取文件的路径，此处需要继承刚才创建的Service并重写readExcel方法
    @Override
    public void readExcel(String path,AddVipsServiceTest addVipsServiceTest) {
        EasyExcel.read(path,Users.class, new ExcelListener(addVipsServiceTest)).sheet().doRead();
    }
}

    public ReturnT orderStatusClose(String param){
        XxlJobLogger.log("["+this.name+"]开始");
//        System.out.println(vipMapper);
//传入对应的表格地址
        addVipsService.readExcel("C:\\Users\\Desktop\\VIP.xlsx",addVipsService);
        XxlJobLogger.log("["+this.name+"]结束");
        return ReturnT.SUCCESS;
    }