Elasticsearch 6.2.1 Java API父子文档索引及检索失败求助

我来帮你排查一下Elasticsearch 6.2.1中父子文档无法检索的问题，结合你的操作步骤，可能是以下几个环节出了问题：

1. 索引映射的正确性问题 #

你的关联关系定义里，把join字段嵌套在了versionjoin对象中，这是错误的。在Elasticsearch 6.x中，join类型字段必须是顶级字段，不能嵌套在其他对象属性里。正确的映射应该是这样的：

{
  "mappings": {
    "_doc": {  // 6.x版本默认使用_doc作为唯一文档类型
      "properties": {
        "my_join_field": {
          "type": "join",
          "relations": {
            "version": "accountversion"
          }
        }
        // 这里添加你的其他业务字段，比如date等
      }
    }
  }
}

如果映射定义错误，父子文档的关联关系根本无法生效，自然无法检索到关联结果。

2. 父文档索引的关键细节 #

你提到的父文档索引代码，需要确保my_join_field明确指定为父类型version。用Java API实现的正确示例如下：

String pattern = "YYYY-MM-dd HH:mm:ss";
SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);
String date = simpleDateFormat.format(index_timestamp);

JSONObject obj = new JSONObject();
// 关键：指定join字段为父类型
obj.put("my_join_field", "version");
// 添加其他业务字段
obj.put("date", date);

IndexRequest request = new IndexRequest("your_index_name", "_doc", "parent_doc_id");
request.source(obj.toJSONString(), XContentType.JSON);

// 执行索引请求
RestHighLevelClient client = ...; // 你的客户端实例
client.index(request, RequestOptions.DEFAULT);

如果父文档没有正确设置my_join_field的值为父类型，后续子文档无法关联到它。

3. 子文档索引的核心要求 #

子文档索引有两个必须满足的条件，缺一不可：

• 子文档必须和父文档在同一个分片上，所以必须设置routing为父文档的ID
• my_join_field需要同时指定子类型名称和关联的父文档ID

正确的Java API示例：

JSONObject childObj = new JSONObject();
// 关键：指定子类型和关联的父文档ID
Map<String, Object> joinField = new HashMap<>();
joinField.put("name", "accountversion"); // 子类型名称
joinField.put("parent", "parent_doc_id"); // 父文档的ID
childObj.put("my_join_field", joinField);

// 添加子文档的业务字段
childObj.put("account_info", "xxx");

IndexRequest childRequest = new IndexRequest("your_index_name", "_doc", "child_doc_id");
childRequest.source(childObj.toJSONString(), XContentType.JSON);
// 必须设置routing为父文档ID，保证子文档和父文档在同一分片
childRequest.routing("parent_doc_id");

// 执行索引请求
client.index(childRequest, RequestOptions.DEFAULT);

如果遗漏了routing设置，子文档会被分配到其他分片，Elasticsearch无法建立父子关联。

4. 检索父子文档的正确方式 #

检索父子文档不能用普通的匹配查询，必须使用has_parent或has_child查询。以下是两种常见场景的示例：

场景1：查询某个父文档对应的所有子文档 #

SearchRequest searchRequest = new SearchRequest("your_index_name");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

// 构建has_parent查询，指定父类型和父文档ID条件
HasParentQueryBuilder hasParentQuery = QueryBuilders.hasParentQuery(
    "version",
    QueryBuilders.termQuery("_id", "parent_doc_id"),
    false // false表示返回子文档，true返回父文档
);

sourceBuilder.query(hasParentQuery);
searchRequest.source(sourceBuilder);

SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
// 处理查询结果
SearchHit[] hits = response.getHits().getHits();

场景2：查询父文档并同时获取其关联的子文档（使用inner_hits） #

SearchRequest searchRequest = new SearchRequest("your_index_name");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();

// 查询父文档
TermQueryBuilder parentQuery = QueryBuilders.termQuery("_id", "parent_doc_id");
sourceBuilder.query(parentQuery);

// 添加inner_hits获取关联的子文档
InnerHitBuilder innerHitBuilder = new InnerHitBuilder("associated_children");
innerHitBuilder.setQuery(QueryBuilders.hasChildQuery(
    "accountversion",
    QueryBuilders.matchAllQuery(),
    false
));
sourceBuilder.innerHit(innerHitBuilder);

searchRequest.source(sourceBuilder);
SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);

常见错误总结 #

• join字段嵌套在对象中，未设置为顶级字段
• 子文档索引时未设置routing为父文档ID
• 子文档的join字段未正确指定父文档ID和子类型
• 检索时使用普通查询而非has_parent/has_child查询

你可以对照以上几点检查你的代码和映射，应该能解决无法检索父子文档的问题。

内容的提问来源于stack exchange，提问作者Abhi.G