easyexcel读文件入批量入es
创始人
2024-11-14 16:33:41
0

1. 封装实体类,并对应excel表中的列

@Data public class User {      private String md5;      private String id;      @ExcelProperty(value = "age")     private String age;     @ExcelProperty(value = "username")     private String name;   }

2. 批量入库

    private void insertBatchToES(List dataList, String indexName) {         try {             BulkProcessor bulkProcessor = BulkProcessor.builder(                     (request, bulkListener) -> elasticsearchClient.bulkAsync(request, RequestOptions.DEFAULT, bulkListener),                     new BulkProcessor.Listener() {                          @Override                         public void beforeBulk(long executionId, org.elasticsearch.action.bulk.BulkRequest request) {                             // 准备执行前的操作                         }                          @Override                         public void afterBulk(long executionId, org.elasticsearch.action.bulk.BulkRequest request, org.elasticsearch.action.bulk.BulkResponse response) {                             if (response != null) {                                 int insertedCount = request.numberOfActions(); // 获取请求中操作的数量,即插入的条数                                 log.info("批量插入 " + insertedCount + " 条数据成功");                             }                         }                          @Override                         public void afterBulk(long executionId, org.elasticsearch.action.bulk.BulkRequest request, Throwable failure) {                             log.info("批量插入 error");                         }                     })                     // 设置每1000个请求执行一次批处理                     .setBulkActions(500)                     .build();                for(User user : dataList) {                 String jsonString = convertToJson(user);                 IndexRequest indexRequest = new IndexRequest(indexName)                         .id(user.getId())                         .source(jsonString, XContentType.JSON);                 bulkProcessor.add(indexRequest);             }             bulkProcessor.awaitClose(10, TimeUnit.MINUTES);             bulkProcessor.close();          } catch (InterruptedException | JsonProcessingException e) {             e.printStackTrace();         }     } 

将对象转json工具类:

 public String convertToJson(user) throws JsonProcessingException {         String objStr = JSON.toJSONString(user, SerializerFeature.WriteNullListAsEmpty, SerializerFeature.WriteNullNumberAsZero,                 SerializerFeature.WriteNullStringAsEmpty, SerializerFeature.NotWriteDefaultValue);          return objStr;     }

3. 读指定文件excel , 封装List

public void importExcelToES(String excelFilePath, String indexName) {         try {             EasyExcel.read(excelFilePath, User.class, new AnalysisEventListener() {                 private List dataList = new ArrayList<>();                                  @Override                 public void invoke(UserFansExcel data, AnalysisContext analysisContext) {                     long id = generator.nextId();                     data.setId(String.valueOf(id));                                                            if (dataList.size() >= 500) {                         insertBatchToES(filteredList, indexName);                         dataList.clear();                     }                 }                  @Override                 public void doAfterAllAnalysed(AnalysisContext analysisContext) {                     if (!dataList.isEmpty()) {                         insertBatchToES(dataList, indexName);                     }                 }             }).sheet().doRead();         } catch (Exception e) {             e.printStackTrace();         }

3.1 读执行目录下的所有excel文件,这些文件的格式是一样的

public void readExcelFilesFromDirectory(String directoryPath) throws IOException {         List dataList = new ArrayList<>();         File dir = new File(directoryPath);         File[] files = dir.listFiles((d, name) -> name.endsWith(".xlsx"));          if (files != null) {             for (File file : files) {                 System.out.println(file.getName());                 try {                     String primaryUserId = file.getName().replace(".xlsx", "");                     try (FileInputStream fis = new FileInputStream(file)) {                         EasyExcel.read(fis, User.class, new AnalysisEventListener() {                               @Override                             public void invoke(User data, AnalysisContext context) {                                 data.setName(primaryUserId);                                                                 dataList.add(data);                             }                              @Override                             public void doAfterAllAnalysed(AnalysisContext analysisContext) {                              }                            }).sheet().doRead();                     }                 } catch (Exception e) {                     e.printStackTrace();                 }             if(dataList.size() >0){               //这里可以插入数据库                dataList.clear();            }              }         }              }

相关内容

热门资讯

透视神器!德普之星透视辅助(透... 透视神器!德普之星透视辅助(透视)透视辅助(有挂揭秘);1、下载好德普之星透视辅助辅助软件之后点击打...
透视透视挂“哈糖大菠萝怎么开挂... 透视透视挂“哈糖大菠萝怎么开挂”佛手在线大菠萝智能辅助器(透视)必胜教程(果然有挂);1、佛手在线大...
透视实锤!如何下载德普之星辅助... 透视实锤!如何下载德普之星辅助软件(透视)透视软件免费入口官网(有挂黑科技)1、玩家可以在如何下载德...
透视辅助“epoker透视底牌... 透视辅助“epoker透视底牌”约局吧德州透视(透视)透明教程(果然存在有挂)约局吧德州透视辅助器中...
透视挂!德普之星辅助工具如何打... 透视挂!德普之星辅助工具如何打开(透视)透视辅助软件(有挂工具);1、超多福利:超高返利,海量正版游...
透视有挂“aa poker辅助... 透视有挂“aa poker辅助包”pokemmo脚本最新版(透视)详细教程(竟然真的是有挂);1、打...
透视透视!德普之星有透视辅助吗... 透视透视!德普之星有透视辅助吗(透视)私人局透视(有挂攻略);进入游戏-大厅左侧-新手福利-激活码辅...
透视代打“约局吧德州透视”拱趴... 透视代打“约局吧德州透视”拱趴大菠萝机器人(透视)德州论坛(一贯真的有挂)1、拱趴大菠萝机器人系统规...
透视真的!德扑圈透视(透视)透... 透视真的!德扑圈透视(透视)透视辅助软件激活码(有挂细节)1、上手简单,内置详细流程视频教学,新手小...
透视辅助“菠萝辅助器免费版的特... 透视辅助“菠萝辅助器免费版的特点”红龙poker辅助工具(透视)攻略方法(好像存在有挂)1、完成菠萝...