Java使用Easyexcel导入大批量数据

ps:博主测试的60w数据是没问题的

pom.xml

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

一、Controller

@RequestMapping(value = "importExcel", method = RequestMethod.POST, headers = "content-type=multipart/form-data")
@ApiOperation(value = "导入社区")
@ApiImplicitParams({ @ApiImplicitParam(name = "文件", value = "file") })
public Result  importExcel(@RequestParam(value="file") MultipartFile file) throws ControllerException {
   try {
      Result result = communityService.importExcel(file);
      return result;
   } catch (Exception e) {
      return Result.failed("导入失败");
   }
}

二、实体类

/**
 * 社区信息
 * 
 * @author LXF
 * @email
 * @date 2021-11-10 15:29:38
 */
​
@Data
public class Community implements Serializable {
   private static final long serialVersionUID = 1L;
   @JsonSerialize(using = ToStringSerializer.class)
   @TableId(value = "ID", type = IdType.AUTO)
   private Long id;//
​
   private String nation;// 国家
​
   private String province;// 省市
​
   private String city;
​
   private String county;// 区县
​
   private String town;// 镇
​
   private String community;// 村民委员会
​
   private String village;// 社区(村)
​
   private String address;// 地址
​
   private String headImgUrl;// 头像
​
   private String telephone;// 电话
​
   private String contact;// 联系人
​
   private String content;// 简介
   @JsonSerialize(using = ToStringSerializer.class)
   private Long userId;// 用户编号
​
   private String dmsAccount;// dms账号
​
   private String workAccount;// 工作号
​
   private Integer enabled;// 是否启用：1启用，0屏蔽
   @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
   private Date createTime;// 创建时间
   @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
   private Date updateTime;// 最近一次更新时间
   @JsonSerialize(using = ToStringSerializer.class)
   private Long operatorId;// 操作者
​
   private String operateIp;// 最近一次更新操作的网址
   @JsonSerialize(using = ToStringSerializer.class)
   private Long version;// 版本号
​
}

@Data
public class CommunityImportBo implements Serializable {
   private static final long serialVersionUID = 1L;
​
   private Long id;
​
   @ExcelProperty("国家")
   private String nation;
​
   @ExcelProperty("省")
   private String province;
​
   @ExcelProperty("市")
   private String city;
​
   @ExcelProperty("区县")
   private String county;
​
   @ExcelProperty("乡镇街道")
   private String town;
​
   @ExcelProperty("居委会")
   private String community;
​
}

三、Service

/**
 * 导入社区excel
 *
 * @param file     文件
 * @param
 * @return {@link Result}
 */
Result importExcel(MultipartFile file) throws ServiceException, IOException;

四、ServiceImpl

    /**
    * 导入社区excel
    *
    * @param file     文件
    * @param
    * @return {@link Result}
    */
   @Override
   public Result importExcel(MultipartFile file) throws ServiceException, IOException {
      // 写法1：JDK8+ ,不用额外写一个DemoDataListener
      // since: 3.0.0-beta1
      // 这里 需要指定读用哪个class去读，然后读取第一个sheet 文件流会自动关闭
      // 这里每次会读取3000条数据 然后返回过来 直接调用使用数据就行
      //还有几种写法具体参照官网给的demo，大同小异
      EasyExcel.read(file.getInputStream(), CommunityImportBo.class, new PageReadListener<CommunityImportBo>(dataList -> {
         Community community = new Community();
         community.setUserId(Long.valueOf("1277137734524300032"));
         community.setEnabled(1);
         community.setCreateTime(new Date());
         List<Community> list = new ArrayList<>();
​
         for (CommunityImportBo demoData : dataList) {
            BeanUtil.copyProperties(demoData,community);
            list.add(community);
         }
         communityDao.insertBatchTwo(list);
      })).sheet().doRead();
      return Result.succeed("导入成功");
   }
}

五、Dao

//返回主键
@Options(useGeneratedKeys=true,keyProperty="id")
void insertBatchTwo(List<Community> list);

六、Dao.xml

<insert id="insertBatchTwo"  parameterType="java.util.List">
        insert into community(
        nation,
        province,
        city,
        county,
        town,
        community,
        village,
        address,
        head_img_url,
        telephone,
        contact,
        content,
        user_id,
        dms_account,
        work_account,
        enabled,
        create_time,
        update_time,
        operator_id,
        operate_ip,
        version)
        values
        <foreach collection="list" item="item" index="index" separator=",">
            (
            #{ item.nation},
            #{ item.province},
            #{ item.city},
            #{ item.county},
            #{ item.town},
            #{ item.community},
            #{ item.village},
            #{ item.address},
            #{ item.headImgUrl},
            #{ item.telephone},
            #{ item.contact},
            #{ item.content},
            #{ item.userId},
            #{ item.dmsAccount},
            #{ item.workAccount},
            #{ item.enabled},
            #{ item.createTime},
            #{ item.updateTime},
            #{ item.operatorId},
            #{ item.operateIp},
            #{ item.version}
            )
        </foreach>
</insert>