Java Spring+Elasticsearch全局搜索：从Person类型关联到Country类型的实现

针对你描述的单索引存储多类型关联数据的场景，以下是两种可行的查询方案：

方案一：多步骤链式查询（简单易实现） #

通过三次查询逐步关联获取目标数据，适合对性能要求不高或需要分步处理中间结果的场景：

1. 获取Person对应的Address ID

GET /globalsearch/_search
{
  "query": {
    "bool": {
      "must": [
        {"match": {"type": "person"}},
        {"match": {"id": "PER_0001"}}
      ]
    }
  },
  "_source": ["addressId"] // 只返回需要的字段，减少数据传输
}

执行后得到addressId: ADDR_001

2. 通过Address ID获取Country ID

GET /globalsearch/_search
{
  "query": {
    "bool": {
      "must": [
        {"match": {"type": "address"}},
        {"match": {"id": "ADDR_001"}}
      ]
    }
  },
  "_source": ["countryId"]
}

执行后得到countryId: COUNT_001

3. 通过Country ID获取国家详情

GET /globalsearch/_search
{
  "query": {
    "bool": {
      "must": [
        {"match": {"type": "country"}},
        {"match": {"id": "COUNT_001"}}
      ]
    }
  }
}

方案二：单步关联查询（基于Elasticsearch Terms Lookup） #

利用Elasticsearch的terms查询内置的索引关联功能，一步完成跨文档查询，适合需要单次请求获取结果的场景：

GET /globalsearch/_search
{
  "query": {
    "bool": {
      "must": [
        {"match": {"type": "country"}},
        {
          "terms": {
            "id": {
              "index": "globalsearch",
              "id": "ADDR_001", // 第一步查询得到的Address ID
              "path": "countryId"
            }
          }
        }
      ]
    }
  }
}

如果需要完全自动化一步完成（不需要手动传入Address ID），可以结合脚本查询实现，但注意脚本查询会影响性能，且需要开启Elasticsearch的脚本执行权限：

GET /globalsearch/_search
{
  "query": {
    "bool": {
      "must": [
        {"match": {"type": "country"}},
        {
          "script": {
            "script": {
              "source": """
                // 根据当前Country ID查询对应的Address文档
                def addressDoc = get('globalsearch', ctx._source.id);
                if (addressDoc == null) return false;
                // 根据Address文档中的addressId查询对应的Person文档
                def personDoc = get('globalsearch', addressDoc._source.addressId);
                return personDoc != null && personDoc._source.id == params.targetPersonId;
              """,
              "params": {
                "targetPersonId": "PER_0001"
              }
            }
          }
        }
      ]
    }
  }
}

优化建议 #

如果后续有大量此类关联查询需求，建议在索引设计阶段采用嵌套文档或父子文档结构，替代当前的平级关联存储，能大幅提升关联查询的性能和效率。

内容的提问来源于stack exchange，提问作者Java2Avaj