Elasticsearch跨索引关联：按用户ID与心愿单名称查询商品

一、USER_WISHLIST索引结构定义 #

基于需求，我们可以定义如下索引映射，确保userid和wishlist_name支持精确匹配，product_ids存储商品ID数组：

PUT /user_wishlist
{
  "mappings": {
    "properties": {
      "userid": { "type": "keyword" },
      "wishlist_name": { "type": "keyword" },
      "product_ids": { "type": "integer" }
    }
  }
}

数据插入示例：

POST /user_wishlist/_bulk
{"index":{}}
{"userid": "1", "wishlist_name": "xyz", "product_ids": [123, 456]}
{"index":{}}
{"userid": "2", "wishlist_name": "pqr", "product_ids": [123]}
{"index":{}}
{"userid": "1", "wishlist_name": "yyy", "product_ids": [456]}

二、按用户ID+心愿单名称获取商品的查询流程 #

1. 查询目标心愿单的商品ID集合 #

先通过userid和wishlist_name精确匹配，拿到对应的商品ID数组：

GET /user_wishlist/_search
{
  "query": {
    "bool": {
      "must": [
        {"term": {"userid": "1"}},
        {"term": {"wishlist_name": "xyz"}}
      ]
    }
  },
  "_source": ["product_ids"],
  "size": 1 // 每个用户+心愿单名称唯一，只返回一条结果
}

2. 根据商品ID查询商品并实现分页 #

将第一步获取到的product_ids作为条件，查询Product索引并添加分页参数：

GET /product/_search
{
  "query": {
    "terms": {"productid": [123, 456]}
  },
  "from": 0, // 起始位置
  "size": 10, // 每页数量
  "_source": ["productid", "name", "available"]
}

三、深度分页优化 #

当心愿单内商品数量较多时，避免使用from/size导致的性能问题，推荐使用search_after实现高效分页：

第一页查询 #

GET /product/_search
{
  "query": {
    "terms": {"productid": [123, 456, 789, ...]}
  },
  "size": 10,
  "sort": [{"productid": "asc"}], // 指定排序字段，确保分页连续性
  "_source": ["productid", "name", "available"]
}

后续分页查询 #

用上一页返回结果中最后一条数据的productid作为search_after参数：

GET /product/_search
{
  "query": {
    "terms": {"productid": [123, 456, 789, ...]}
  },
  "size": 10,
  "search_after": [789], // 上一页最后一个productid
  "sort": [{"productid": "asc"}],
  "_source": ["productid", "name", "available"]
}

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