如何用Elasticsearch实现类似MySQL JOIN的关联查询？

为什么你的查询没有返回结果？ #

你之前的查询尝试跨index_customers和index_orders时，用bool must同时匹配CustomerName和OrderID，但单个文档不可能同时包含这两个字段：客户文档只有客户相关字段，订单文档只有订单相关字段，因此没有符合条件的文档被返回。

如何获取两个索引中CustomerID=2的文档？ #

直接分别查询两个索引即可：

查询客户文档 #

GET index_customers/_search
{
  "query": {
    "term": {
      "CustomerID": 2
    }
  }
}

查询订单文档 #

GET index_orders/_search
{
  "query": {
    "term": {
      "CustomerID": 2
    }
  }
}

如何实现类似MySQL内连接的查询效果？ #

Elasticsearch不是关系型数据库，原生不支持SQL式跨表内连接，但可以通过以下两种方式实现类似效果：

方案1：应用层关联（推荐，适配现有索引结构） #

1. 先执行上面的客户查询，获取CustomerID=2的客户信息
2. 再用该CustomerID执行订单查询，获取对应订单
3. 在应用代码中将两类数据合并，得到与SQL查询一致的结果

这种方式简单直接，不需要修改现有索引结构，适合中小数据量场景。

方案2：重新设计索引为父子文档（Elasticsearch层关联） #

如果希望在Elasticsearch内部完成关联，需要重新设计索引结构，使用父子文档类型：

1. 创建带父子关系的索引

PUT index_customer_orders
{
  "mappings": {
    "properties": {
      "CustomerID": { "type": "integer" },
      "CustomerName": { "type": "text" },
      "ContactName": { "type": "text" },
      "Country": { "type": "keyword" },
      "CustomerCreateDate": { "type": "date" },
      "OrderID": { "type": "integer" },
      "OrderDate": { "type": "date" },
      "join_field": {
        "type": "join",
        "relations": {
          "customer": "order" // 定义customer为父文档，order为子文档
        }
      }
    }
  }
}

2. 导入父客户文档

PUT index_customer_orders/_doc/cust_2?refresh
{
  "CustomerID": 2,
  "CustomerName": "Ana Trujillo Emparedados y helados",
  "ContactName": "Ana Trujillo",
  "Country": "Mexico",
  "CustomerCreateDate": "2022-05-03",
  "join_field": "customer"
}

3. 导入子订单文档（指定父文档ID）

PUT index_customer_orders/_doc/order_10308?routing=cust_2&refresh
{
  "CustomerID": 2,
  "OrderID": 10308,
  "OrderDate": "1996-09-18",
  "join_field": {
    "name": "order",
    "parent": "cust_2"
  }
}

4. 查询关联数据

查询CustomerID=2的客户并返回其关联的订单：

GET index_customer_orders/_search
{
  "query": {
    "term": {
      "CustomerID": 2
    }
  },
  "inner_hits": {
    "type": "order" // 指定返回子订单文档
  }
}

或者查询订单并返回对应的客户信息：

GET index_customer_orders/_search
{
  "query": {
    "has_parent": {
      "parent_type": "customer",
      "query": {
        "term": {
          "CustomerID": 2
        }
      },
      "inner_hits": {} // 返回父客户文档
    }
  }
}

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