golang es根据条件动态查询

Question

es内容：

![img](https://i-blog.csdnimg.cn/ask/aa19860622944069b65be2f47c6d0640.png "#left")



    list_res, err := types.EsClient.Search().Index(types.ES_OPERATOR_INDEX).
        Sort("dates.keyword",false).
        From(skip).
        Size((*req).PageSize).
        Pretty(true).
        Do(ctx)



有如上的es查询代码，现在要根据条件进行查询，比如日期不为空，比如operator不为空，应该怎么组合查询

  if operator != ""{
  }

Answer 1

晚上好🌙🌙🌙
本答案参考通义千问

在 Go 语言中使用 Elasticsearch（ES）进行动态查询，通常需要使用 Elasticsearch Query DSL 来构建查询语句。你提供的代码片段是一个基本的搜索请求，但没有包含任何过滤条件。

为了根据 operator 和 dates 等字段进行动态查询，你可以使用 bool 查询 中的 must、should 或 filter 子句来组合多个查询条件。

---

✅ 目标

• 根据 operator 不为空时添加过滤条件
• 根据 dates 不为空时添加过滤条件
• 构建一个可以动态组合查询条件的 ES 请求

---

🔧 解决方案

1. 导入必要的包

   import (
       "github.com/olivere/elastic/v7"
   )
   

2. 构建动态查询条件

   使用 elastic.NewBoolQuery() 来构造布尔查询，并根据条件动态添加子查询：

   var query elastic.Query
   
   if operator != "" {
       // operator 不为空时，添加 term 查询
       query = elastic.NewBoolQuery().Filter(elastic.NewTermQuery("operator.keyword", operator))
   }
   
   if dates != "" {
       // dates 不为空时，添加 term 查询
       if query == nil {
           query = elastic.NewBoolQuery().Filter(elastic.NewTermQuery("dates.keyword", dates))
       } else {
           query = query.Filter(elastic.NewTermQuery("dates.keyword", dates))
       }
   }
   
   // 如果没有设置任何查询条件，使用 match_all
   if query == nil {
       query = elastic.NewMatchAllQuery()
   }
   

3. 将查询应用到 Search 请求中

   list_res, err := types.EsClient.Search().
       Index(types.ES_OPERATOR_INDEX).
       Query(query).                  // 添加动态查询条件
       Sort("dates.keyword", false).  // 排序
       From(skip).
       Size((*req).PageSize).
       Pretty(true).
       Do(ctx)
   

---

📌 示例完整代码

func searchWithConditions(ctx context.Context, operator string, dates string, skip int, pageSize int) (*elastic.SearchResult, error) {
    var query elastic.Query

    if operator != "" {
        query = elastic.NewBoolQuery().Filter(elastic.NewTermQuery("operator.keyword", operator))
    }

    if dates != "" {
        if query == nil {
            query = elastic.NewBoolQuery().Filter(elastic.NewTermQuery("dates.keyword", dates))
        } else {
            query = query.Filter(elastic.NewTermQuery("dates.keyword", dates))
        }
    }

    if query == nil {
        query = elastic.NewMatchAllQuery()
    }

    list_res, err := types.EsClient.Search().
        Index(types.ES_OPERATOR_INDEX).
        Query(query).
        Sort("dates.keyword", false).
        From(skip).
        Size(pageSize).
        Pretty(true).
        Do(ctx)

    return list_res, err
}

---

⚠️ 注意事项

• 字段类型匹配：确保 operator 和 dates 字段在 ES 中是 keyword 类型，否则 term 查询可能无法正确工作。
• 排序字段：如果 dates 是日期类型，建议使用 dates 而不是 dates.keyword 进行排序。
• 动态组合：可以扩展此逻辑，支持更多字段的动态查询（如 status, action 等）。

---

✅ 总结

动态查询的关键在于使用 elastic.NewBoolQuery() 并通过 Filter、Must 等方法灵活组合条件。

• 使用 term 查询适用于精确匹配（如 operator）
• 使用 match 查询适用于全文检索（如 description）
• 使用 bool 查询实现多条件组合

如果你有更多字段需要动态查询，可以继续扩展这个结构。