easyExcel模板数据导入数据库-阿里云开发者社区

最近项目中需要用到Excel表格的上传下载功能，于是选择了EasyExcel这款工具，总的来说非常的好用，下面就做一个简单的演示
一、依赖

pom.xml 中需要添加的依赖

com.alibaba
easyexcel
2.2.7

二、创建实体类:和模板一致对应

这里用到了 @ExcelProperty 注解，这个注解很重要必要的一个注解，注解中的两个参数value,index分别代表列名，列序号
1.value 通过标题文本对应
2.index 通过文本行号对应
图片.png
package com.sinosoft.springbootplus.org.param;

import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.annotation.write.style.ColumnWidth;
import com.alibaba.excel.annotation.write.style.ContentRowHeight;
import com.alibaba.excel.annotation.write.style.HeadRowHeight;
import lombok.Data;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.Date;

/**

监管机构系统-考勤管理导入
*
@author ljk
@date 2022-05-18
*/
@Data
@ContentRowHeight(21)
@HeadRowHeight(30)
@ColumnWidth(25)
public class JgjgPersonAttendanceImport {

@ExcelProperty(value = {"地区"},index = 0)
private String areaName;

@ExcelProperty(value = {"处室"},index = 1)
private String officeName;

@ExcelProperty(value = {"姓名"},index = 2)
private String personName;

@ExcelProperty(value = {"请假类型"},index = 3)
private String leaveType;

@ExcelProperty(value = {"开始时间"},index = 4)
private Date startTime;

@ExcelProperty(value = {"结束时间"},index = 5)
private Date endTime;

@ExcelProperty(value = {"时长"},index = 6)
private Integer time;

@ExcelProperty(value = {"天数"},index = 7)
private BigDecimal day;

}
三、监听器（easyexcel是在监听器层完成excel数据读取）:
由于读取excel需要实现监听器，并且该监听器不能被spring容器管理，所以我们spring的注解不能在里面用，所以我们需要将service层的接口传入该监听器，实现将excel的内容存储至数据库中。
有个很重要的点监听器不能被spring管理，要每次读取excel都要new,然后里面用到spring可以构造方法传进去
package com.sinosoft.springbootplus.org.domain.entity;

import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;
import com.alibaba.fastjson.JSON;
import com.sinosoft.springbootplus.org.convert.JgjgPersonAttendanceConvert;
import com.sinosoft.springbootplus.org.domain.service.JgjgPersonAttendanceDomain;
import com.sinosoft.springbootplus.org.param.JgjgPersonAttendanceImport;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.List;
/**

监管机构系统-考勤管理
*
@author ljk
@since 2022-05-20
/
public class JgjgPersonAttendanceListener extends AnalysisEventListener {
private static final Logger LOGGER = LoggerFactory.getLogger(JgjgPersonAttendanceListener.class);
/*
- 每隔5条存储数据库，实际使用中可以3000条，然后清理list ，方便内存回收
  */
  private static final int BATCH_COUNT = 5;
  List list = new ArrayList();
  
  private JgjgPersonAttendanceDomain jgjgPersonAttendanceDomain;
  
  public JgjgPersonAttendanceListener() {
  
  }
  
  public JgjgPersonAttendanceListener(JgjgPersonAttendanceDomain jgjgPersonAttendanceDomain) {
  this.jgjgPersonAttendanceDomain = jgjgPersonAttendanceDomain;
  }
  
  /**
- 这个每一条数据解析都会来调用
  *
- @param jgjgPersonAttendanceImport
- one row value. Is is same as {@link AnalysisContext#readRowHolder()}
- @param context
  */
  @Override
  public void invoke(JgjgPersonAttendanceImport jgjgPersonAttendanceImport, AnalysisContext context) {
  LOGGER.info("解析到一条数据:{}", JSON.toJSONString(jgjgPersonAttendanceImport));
  list.add(jgjgPersonAttendanceImport);
  // 达到BATCH_COUNT了，需要去存储一次数据库，防止数据几万条数据在内存，容易OOM
  if (list.size() >= BATCH_COUNT) {
```
 saveData();
 // 存储完成清理 list
 list.clear();
```
  }
  }
  
  /**
- 所有数据解析完成了都会来调用
  *
- @param context
  */
  @Override
  public void doAfterAllAnalysed(AnalysisContext context) {
  // 这里也要保存数据，确保最后遗留的数据也存储到数据库
  saveData();
  LOGGER.info("所有数据解析完成！");
  }
  
  /**
- 加上存储数据库
  */
  private void saveData() {
  LOGGER.info("{}条数据，开始存储数据库！", list.size());
  for (JgjgPersonAttendanceImport jgjgPersonAttendanceImport : list) {
```
 /*SimpleDateFormat formatTime = new SimpleDateFormat("yyyy-MM-dd");
 jgjgPersonAttendanceImport.setStartTime(formatTime.format(jgjgPersonAttendanceImport.getStartTime()));
 jgjgPersonAttendanceImport.setEndTime(formatTime.format(jgjgPersonAttendanceImport.getEndTime()));*/
 //判断状态重新赋值
 if (jgjgPersonAttendanceImport.getLeaveType().equals("病假")){
     jgjgPersonAttendanceImport.setLeaveType("0");
 }else if (jgjgPersonAttendanceImport.getLeaveType().equals("事假")){
     jgjgPersonAttendanceImport.setLeaveType("1");
 }else if (jgjgPersonAttendanceImport.getLeaveType().equals("产假")){
     jgjgPersonAttendanceImport.setLeaveType("2");
 }else if (jgjgPersonAttendanceImport.getLeaveType().equals("婚假")){
     jgjgPersonAttendanceImport.setLeaveType("3");
 }else if (jgjgPersonAttendanceImport.getLeaveType().equals("丧假")){
     jgjgPersonAttendanceImport.setLeaveType("4");
 }else if (jgjgPersonAttendanceImport.getLeaveType().equals("其他")){
     jgjgPersonAttendanceImport.setLeaveType("5");
 }
 JgjgPersonAttendance jgjgPersonAttendance =
         JgjgPersonAttendanceConvert.INSTANCE.jgjgPersonAttendanceImportToJgjgPersonAttendance(jgjgPersonAttendanceImport);
 jgjgPersonAttendanceDomain.saveJgjgPersonAttendance(jgjgPersonAttendance);
```
  }
  LOGGER.info("存储数据库成功！");
  }
  }

四、controller层
//导入
@PostMapping("/insertList")
@ApiOperation(value = "获取JgjgPersonAttendance导入", notes = "监管机构系统-导入")
public void insetJgjgPersonAttendanceImport(MultipartFile file){
jgjgPersonAttendanceServiceImpl.insetJgjgPersonAttendanceImport(file);
}

easyExcel模板数据导入数据库
遨游在知识的海洋里无法自拔
于 2022-05-29 14:29:26 发布 1134
收藏 7
文章标签： java postman 开发语言
版权

最近项目中需要用到Excel表格的上传下载功能，于是选择了EasyExcel这款工具，总的来说非常的好用，下面就做一个简单的演示。

官方文档地址

    EasyExcel · 语雀
    Alibaba Easy Excel - 简单、省内存的Java解析Excel工具 | 首页

一、依赖

pom.xml 中需要添加的依赖

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

二、创建实体类:和模板一致对应

这里用到了 @ExcelProperty 注解，这个注解很重要必要的一个注解，注解中的两个参数value,index分别代表列名，列序号
1.value 通过标题文本对应
2.index 通过文本行号对应

package com.sinosoft.springbootplus.org.param;

import com.alibaba.excel.annotation.ExcelProperty;
import com.alibaba.excel.annotation.write.style.ColumnWidth;
import com.alibaba.excel.annotation.write.style.ContentRowHeight;
import com.alibaba.excel.annotation.write.style.HeadRowHeight;
import lombok.Data;

import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * <pre>
 * 监管机构系统-考勤管理 导入
 * </pre>
 *
 * @author ljk
 * @date 2022-05-18
 */
@Data
@ContentRowHeight(21)
@HeadRowHeight(30)
@ColumnWidth(25)
public class JgjgPersonAttendanceImport {

    @ExcelProperty(value = {"地区"},index = 0)
    private String areaName;

    @ExcelProperty(value = {"处室"},index = 1)
    private String officeName;

    @ExcelProperty(value = {"姓名"},index = 2)
    private String personName;

    @ExcelProperty(value = {"请假类型"},index = 3)
    private String leaveType;

    @ExcelProperty(value = {"开始时间"},index = 4)
    private Date startTime;

    @ExcelProperty(value = {"结束时间"},index = 5)
    private Date endTime;

    @ExcelProperty(value = {"时长"},index = 6)
    private Integer time;

    @ExcelProperty(value = {"天数"},index = 7)
    private BigDecimal day;


}

三、监听器（easyexcel是在监听器层完成excel数据读取）:

       由于读取excel需要实现监听器，并且该监听器不能被spring容器管理，所以我们spring的注解不能在里面用，所以我们需要将service层的接口传入该监听器，实现将excel的内容存储至数据库中。
       有个很重要的点 监听器不能被spring管理，要每次读取excel都要new,然后里面用到spring可以构造方法传进去

package com.sinosoft.springbootplus.org.domain.entity;

import com.alibaba.excel.context.AnalysisContext;
import com.alibaba.excel.event.AnalysisEventListener;
import com.alibaba.fastjson.JSON;
import com.sinosoft.springbootplus.org.convert.JgjgPersonAttendanceConvert;
import com.sinosoft.springbootplus.org.domain.service.JgjgPersonAttendanceDomain;
import com.sinosoft.springbootplus.org.param.JgjgPersonAttendanceImport;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.ArrayList;
import java.util.List;
/**
 * <pre>
 * 监管机构系统-考勤管理
 * </pre>
 *
 * @author ljk
 * @since 2022-05-20
 */
public class JgjgPersonAttendanceListener  extends AnalysisEventListener<JgjgPersonAttendanceImport> {
    private static final Logger LOGGER = LoggerFactory.getLogger(JgjgPersonAttendanceListener.class);
    /**
     * 每隔5条存储数据库，实际使用中可以3000条，然后清理list ，方便内存回收
     */
    private static final int BATCH_COUNT = 5;
    List<JgjgPersonAttendanceImport> list = new ArrayList<JgjgPersonAttendanceImport>();

    private JgjgPersonAttendanceDomain jgjgPersonAttendanceDomain;

    public JgjgPersonAttendanceListener() {

    }

    public JgjgPersonAttendanceListener(JgjgPersonAttendanceDomain jgjgPersonAttendanceDomain) {
        this.jgjgPersonAttendanceDomain = jgjgPersonAttendanceDomain;
    }

    /**
     * 这个每一条数据解析都会来调用
     *
     * @param jgjgPersonAttendanceImport
     *            one row value. Is is same as {@link AnalysisContext#readRowHolder()}
     * @param context
     */
    @Override
    public void invoke(JgjgPersonAttendanceImport jgjgPersonAttendanceImport, AnalysisContext context) {
        LOGGER.info("解析到一条数据:{}", JSON.toJSONString(jgjgPersonAttendanceImport));
        list.add(jgjgPersonAttendanceImport);
        // 达到BATCH_COUNT了，需要去存储一次数据库，防止数据几万条数据在内存，容易OOM
        if (list.size() >= BATCH_COUNT) {
            saveData();
            // 存储完成清理 list
            list.clear();
        }
    }

    /**
     * 所有数据解析完成了 都会来调用
     *
     * @param context
     */
    @Override
    public void doAfterAllAnalysed(AnalysisContext context) {
        // 这里也要保存数据，确保最后遗留的数据也存储到数据库
        saveData();
        LOGGER.info("所有数据解析完成！");
    }

    /**
     * 加上存储数据库
     */
    private void saveData() {
        LOGGER.info("{}条数据，开始存储数据库！", list.size());
        for (JgjgPersonAttendanceImport jgjgPersonAttendanceImport : list) {
            /*SimpleDateFormat formatTime = new SimpleDateFormat("yyyy-MM-dd");
            jgjgPersonAttendanceImport.setStartTime(formatTime.format(jgjgPersonAttendanceImport.getStartTime()));
            jgjgPersonAttendanceImport.setEndTime(formatTime.format(jgjgPersonAttendanceImport.getEndTime()));*/
            //判断状态重新赋值
            if (jgjgPersonAttendanceImport.getLeaveType().equals("病假")){
                jgjgPersonAttendanceImport.setLeaveType("0");
            }else if (jgjgPersonAttendanceImport.getLeaveType().equals("事假")){
                jgjgPersonAttendanceImport.setLeaveType("1");
            }else if (jgjgPersonAttendanceImport.getLeaveType().equals("产假")){
                jgjgPersonAttendanceImport.setLeaveType("2");
            }else if (jgjgPersonAttendanceImport.getLeaveType().equals("婚假")){
                jgjgPersonAttendanceImport.setLeaveType("3");
            }else if (jgjgPersonAttendanceImport.getLeaveType().equals("丧假")){
                jgjgPersonAttendanceImport.setLeaveType("4");
            }else if (jgjgPersonAttendanceImport.getLeaveType().equals("其他")){
                jgjgPersonAttendanceImport.setLeaveType("5");
            }
            JgjgPersonAttendance jgjgPersonAttendance =
                    JgjgPersonAttendanceConvert.INSTANCE.jgjgPersonAttendanceImportToJgjgPersonAttendance(jgjgPersonAttendanceImport);
            jgjgPersonAttendanceDomain.saveJgjgPersonAttendance(jgjgPersonAttendance);
        }
        LOGGER.info("存储数据库成功！");
    }
}

四、controller层

//导入
    @PostMapping("/insertList")
    @ApiOperation(value = "获取JgjgPersonAttendance导入", notes = "监管机构系统-导入")
    public void insetJgjgPersonAttendanceImport(MultipartFile file){
        jgjgPersonAttendanceServiceImpl.insetJgjgPersonAttendanceImport(file);
    }

五、service层
//导入
public void insetJgjgPersonAttendanceImport(MultipartFile file){
try {
InputStream inputStream = file.getInputStream();
EasyExcel.read(inputStream, JgjgPersonAttendanceImport.class, new JgjgPersonAttendanceListener(jgjgPersonAttendanceDomain)).sheet().doRead();
} catch (IOException e) {
e.printStackTrace();
}

easyExcel模板数据导入数据库

热门文章

最新文章

相关课程

相关电子书

相关实验场景