> 文档中心 > (原)java - 抽取ES数据动态添加到list数组集合中

(原)java - 抽取ES数据动态添加到list数组集合中

 

 博客只提供【标题】中关键代码片段,其余为辅助代码,不过多展示,请理解 ~ ~

 //自定义 学科名称数组 ArrayList arraySubList = new ArrayList(); ArrayList arraySubIdList = new ArrayList(); if (elasticsearchRestTemplate.indexExists("s*b")) {     SearchQuery searchQuery = new NativeSearchQueryBuilder()      .withIndices("sb")      .withTypes("_*")      .withQuery(boolQuery)      .build();     //统计学生的发布课程信息     List s*Os = elasticsearchRestTemplate.queryForList(searchQuery, S*O.class);     //根据学生发布课程编号获取学段,学科基本信息     for (int i = 0; i < stuIssueDs.size(); i++) {  String strCourseId = stus.get(i).getCourse_base_id();  //课程统计  BoolQueryBuilder queryCourseInfo = QueryBuilders.boolQuery();  queryCourseInfo.must(QueryBuilders.termQuery("coid", strCourseId));  SearchQuery queryCourse = new NativeSearchQueryBuilder()   .withIndices("so")   .withTypes("_d")   .withQuery(queryCourseInfo)   .build();  List co*List = elasticsearchRestTemplate.queryForList(queryCourse, C*O.class);  for (int j = 0; j < coist.size(); j++) {      BoolQueryBuilder querySubInfo = QueryBuilders.boolQuery();      //学段信息      if (StringUtils.isNotBlank(subjectId)) {   querySubInfo.must(QueryBuilders.termQuery("sde", subjectId));      } else {   querySubInfo.must(QueryBuilders.termQuery("s*de", courseVOFromESList.get(j).getBusiness_subject_id()));      }      //学科信息      if (StringUtils.isNotBlank(stageId)) {   querySubInfo.must(QueryBuilders.termQuery("sde", stageId));      } else {   querySubInfo.must(QueryBuilders.termQuery("s*de", courseVOFromESList.get(j).getBu*_id()));      }      SearchQuery querySubjectInfo = new NativeSearchQueryBuilder().withIndices("st*t").withTypes("_*c").withQuery(querySubInfo).build();      List subList = elasticsearchRestTemplate.queryForList(querySubjectInfo, Su*O.class);      //动态添加 - list数组     //动态添加 - list数组      arraySubList.add(subList.get(0).getSubject_name());      arraySubIdList.add(subList.get(0).getSubject_code());  }     }     List sList = homeworkService.getQuestionAndknowledgeTotal(sO);     for (int i = 0; i < stList.size(); i++) {  //学生学习的课程数量  stList.get(i).setResourceAccount(ss.size());  studList.get(i).setSubjectId(subjectId);  //学科名称    subList.stream().map(S*::getSubject_name).collect(Collectors.toList());//  studentSubResourceVOList.get(i).setSubjectName(subName.toString());     }      return studentSubResourceVOs; }

【参考博客】

https://www.cnblogs.com/jokerjason/p/10419129.html

 

文章中,有问题,可以在评论区评论


转载声明:本文为博主原创文章,未经博主允许不得转载

如果我的文章有帮助到您,欢迎打赏一下鼓励博主