资讯专栏INFORMATION COLUMN

elasticsearch支持类似与sql语句的查询表达式

番茄西红柿 / 2013人阅读

摘要:是用开发的,并作为许可条款下的开放源码发布,是当前流行的企业级搜索引擎。在之前在项目开发中的不同的查询条件都需要多带带些去封装查询语句,后面就想能不能让也支持类似与这类的过滤条件。

写在之前
ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎,基于RESTful web接口。Elasticsearch是用Java开发的,并作为Apache许可条款下的开放源码发布,是当前流行的企业级搜索引擎。设计用于云计算中,能够达到实时搜索,稳定,可靠,快速,安装使用方便。
在之前在项目开发中的不同的查询条件都需要多带带些Java bean去封装查询语句,后面就想能不能让es也支持类似与sql where name=xxx and age=20这类的过滤条件。所以在这儿就写了个解析表达式同时生成es能够支持的query dsl的小工具 支持的操作符号有==,!= ,<,>,>=,<= 同时还支持加括号增加查询条件优先级的功能。

实现
源码中的conditionNode用到了二叉树的结构,表达不是很清楚,直接上个列子吧,比如我要查询的表达式为:

name==yang and age==20

生成的conditionNode 的json结构为

{
"op":"eq",
"type":"normal",
"left":{
    "field":"name",
    "value":"yang",
    "op":"eq",
    "type":"normal"
},
"right":{
    "field":"age",
    "value":"20",
    "op":"eq",
    "type":"normal"
},
"relation":"and"
}

可以看到在最外层的conditionNode的左右两个节点封装多带带的两个conditionNode ,且其关系为and,最后将 解析后的condition生成query dsl:

{
  "bool" : {
"must" : [
  {
    "bool" : {
      "must" : [
        {
          "query_string" : {
            "query" : "name:"yang""
          }
        }
      ],
      "disable_coord" : false,
      "adjust_pure_negative" : true,
      "boost" : 1.0
    }
  },
  {
    "bool" : {
      "must" : [
        {
          "query_string" : {
            "query" : "age:"20"",
            
          }
        }
      ],
      "disable_coord" : false,
      "adjust_pure_negative" : true,
      "boost" : 1.0
    }
  }
],
"disable_coord" : false,
"adjust_pure_negative" : true,
"boost" : 1.0
  }
}

如果只是支持顺序解析倒也没有什么特别的,这里举个添加括号提高查询条件优先级的列子:
expression : (name==yang and age>20) or (name == wang and age<=18)
解析后的conditionNode为:

{
"op":"eq",
"type":"normal",
"left":{
    "op":"eq",
    "type":"normal",
    "left":{
        "field":"name",
        "value":"yang",
        "op":"eq",
        "type":"normal"
    },
    "right":{
        "field":"age",
        "value":"20",
        "op":"gte",
        "type":"normal"
    },
    "relation":"and"
},
"right":{
    "op":"eq",
    "type":"normal",
    "left":{
        "field":"name",
        "value":"wang",
        "op":"eq",
        "type":"normal"
    },
    "right":{
        "field":"age",
        "value":"18",
        "op":"lte",
        "type":"normal"
    },
    "relation":"and"
},
"relation":"or"
}

最后根据该conditionNode生成的dsl语句为:

{
  "bool" : {
"should" : [
  {
    "bool" : {
      "must" : [
        {
          "bool" : {
            "must" : [
              {
                "query_string" : {
                  "query" : "name:"wang""
                }
              }
            ],
            "disable_coord" : false,
            "adjust_pure_negative" : true,
            "boost" : 1.0
          }
        },
        {
          "bool" : {
            "must" : [
              {
                "range" : {
                  "age" : {
                    "from" : null,
                    "to" : "18",
                    "include_lower" : true,
                    "include_upper" : true,
                    "boost" : 1.0
                  }
                }
              }
            ],
            "disable_coord" : false,
            "adjust_pure_negative" : true,
            "boost" : 1.0
          }
        }
      ],
      "disable_coord" : false,
      "adjust_pure_negative" : true,
      "boost" : 1.0
    }
  },
  {
    "bool" : {
      "must" : [
        {
          "bool" : {
            "must" : [
              {
                "query_string" : {
                  "query" : "name:"yang""
                }
              }
            ],
            "disable_coord" : false,
            "adjust_pure_negative" : true,
            "boost" : 1.0
          }
        },
        {
          "bool" : {
            "must" : [
              {
                "range" : {
                  "age" : {
                    "from" : "20",
                    "to" : null,
                    "include_lower" : false,
                    "include_upper" : true,
                    "boost" : 1.0
                  }
                }
              }
            ],
            "disable_coord" : false,
            "adjust_pure_negative" : true,
            "boost" : 1.0
          }
        }
      ],
      "disable_coord" : false,
      "adjust_pure_negative" : true,
      "boost" : 1.0
    }
  }
],
"disable_coord" : false,
"adjust_pure_negative" : true,
"boost" : 1.0
  }
}

    冗余的东西有点多,大家将就着看吧,这里贴上源码地址

https://github.com/jacobyangs...

文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。

转载请注明本文地址:https://www.ucloud.cn/yun/70509.html

相关文章

发表评论

0条评论

最新活动
阅读需要支付1元查看
<