• springboot~elasticsearch对nested集合类型的字段进行不等于的检索


    对于es的数据类型来说,如果它是一个复杂类型,而我们需要把复杂类型进行检索,那么应该定义成 nested 类型,而对于它的检索,如果是非集合数据,它与其它类型没有分别;而如果你的nested存储的数据是一个集合,那在进行不等于这种操作时,就需要说明一下了。

    举例子

    "id": "1",
    "operate": [
      {
      "actionTime": "2017-03-21 11:57:37.700",
      "operateType": "WangLu",
      "wordNum": "3188",
      "userName": "zidongluru"
      },
      {
      "actionTime": "2017-03-21 11:57:37.700",
      "operateType": "DaoRu",
      "wordNum": "3188",
      "userName": "qinbixue1609"
      }
    ]
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15

    对于上面的数据,其中operate是一个nested类型的,它存储数据为一个集合,我们查询operateType不等于WangLu的数据,如果直接使用not_must配合term,那结果是不对的,它会把这个文档正常返回,为什么?按说这个operate里是包含了 WangLu 的,如果包含它是不应该返回的;这就是es检索nested集合处理不等于的问题,当会查询所有集合中的元素,有一个不等于 WangLu 的,它就认为是不等于的,这与我们的需求不符合,所以要想其它方法。

    script脚本检索nested集合失败

    {
      "size": 5,
       "_source": [
        "Gid",
        "Type",
        "operate"
      ],
      "query": {
        "bool": {
          "must": [
            {
              "nested": {
                "path": "operate",
                "query": {
                  "script": {
                    "script": "doc['operate.operateType'].stream().map(o->o).filter(o->o=='YiJiaoSu').count()==0"
                   }
                }
              }
            },
            {
              "term": {
                "Gid": "1970325267114815"
              }
            }
          ]
        }
      }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29

    使用function方式解决了这个问题

    {
      "size": 5,
      "_source": [
        "Gid",
        "Type",
        "operate"
      ],
      "query": {
        "bool": {
          "must": [
            {
              "function_score": {
                "query": {
                  "match_all": {}
                },
                "functions": [
                  {
                    "script_score": {
                      "script": {
                        "source": "params._source.operate.stream().map(o->o.operateType).filter(o->o=='YiJiaoSu').count()==0 ? 1 : 0"
                      }
                    }
                  }
                ],
                "min_score": 1
              }
            },
            {
              "term": {
                "Id": "1970325267114815"
              }
            }
          ]
        }
      }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36

    这种由于是集合里的集合再检索,所以需要和其它检索条件一起用,全表检索,性能比较差。

    翻译成java客户端代码

    String val = "条件";
      String name = "nested内部字段名";
      String scoreStr = "params._source.operate==null || params._source.operate.stream().map(o->o." + name + ").filter(o->o=='" + val + "').count()==0? 1 : 0";
      Script sc = new Script(ScriptType.INLINE, Script.DEFAULT_SCRIPT_LANG, scoreStr, MapUtil.empty());
      ScriptScoreFunctionBuilder builder = new ScriptScoreFunctionBuilder(sc);
      FunctionScoreQueryBuilder scoreBuilder = QueryBuilders.functionScoreQuery(builder);
      scoreBuilder.setMinScore(1);
      scoreBuilder.scoreMode(FunctionScoreQuery.ScoreMode.FIRST);
      queryIncludeBuilder.must(scoreBuilder);
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
  • 相关阅读:
    react编程式路由的基本知识
    Scala 环境搭建
    数字后端——DEF文件格式
    mysql数据库的授权访问
    【云原生之k8s】Kubeadm搭建K8S
    实践总结 3 种前端部署后页面检测版本的方法
    速卖通年底布局,自养号测评补单助力销量提升
    SpringBoot用kafka.listener监听接受Kafka消息
    RocketMQ源码(十七)之消费者启动
    Servlet基础(GenericServlet)
  • 原文地址:https://blog.csdn.net/band_mmbx/article/details/126488690