数据库
首页 > 数据库> > Elasticsearch SQL

Elasticsearch SQL

作者：互联网

Elasticsearch SQL 是一个X-Pack组件，允许对Elasticsearch实时执行类似SQL的查询，为Elasticsearch提供一个强大而轻量的SQL接口。

无论使用REST接口，命令行还是JDBC,任何客户机都可以使用SQL对EsasticSearch进行查询。Elasticsearch SQL是一个将SQL转换为DQL的转换器。主要针对于查询操作。

约定

很多人习惯地把ElasticSerach和数据库进行类比，如 一个ES索引等同于一张数据库表，一条Document记录等同于一行数据库表记录，一个字段等同于表的一个属性....

在Elasticsearch SQL这里，这些类比的合适的，更方便理解SQL和DQL的映射。

SQL和ElasticSerach的映射关系
SQL ElasticSerach 说明
column field 一个字段或属性
row document 一条完整的数据
table index
schema implicit

SQL REST API

SQL REST API 接收json格式的SQL,执行并返回结果，和传统DSL语法详细，形式相同

如：

POST /_sql?format=txt
{
  "query": """
    show tables
  """
}

查询

POST /_sql?format=txt
{
  "query": """
  SELECT key,price,title FROM "dang-dang" order by price desc limit 6
  """
}

结果：

      key      |     price     |                            title                            
---------------+---------------+-------------------------------------------------------------
java1          |¥99.80         |Java从入门到项目实战（全程视频版）                                          
C2             |¥99.80         |C语言从入门到精通（彩印版）案例视频版 编程入门/IT计算机书籍                             
C3             |¥99.80         |C语言从入门到项目实战（全程视频版）                                           
浏览器5           |¥99.78         |腾讯Android自动化测试实战-汇集QQ浏览器应用宝等亿级APP自动化测试精髓【正版图书，达额立减】          
C5             |¥99.70         |Unity与C++网络游戏开发实战：基于VR、AI与分布式架构                              
架构设计4          |¥99.44         |[现货] 微服务架构设计模式 [美] 克里斯・理查森(Chris Richardson) 9787111624127 机

返回的数据格式format

format Axxept HTTP Header 说明
csv text/csv 逗号分隔
json application/json JSON格式
tsv text/tab-separated-values tab分隔
txt text/pain 文本格式
yaml application/yaml yaml格式
vbor application/vbor 简洁的二进制
smile application/smile 类似cbor的二进制

支持的参数

参数名称 默认值 说明
query Mandatory 传递SQL语句
filter none 可选的查询DSL,用于过滤query的执行结果
fetch_size 1000 获取结果的最大数量
request_timeout 90s 请求超时时间
page_timeout 45s 分页请求超时时间
time_zone UTC 时区
filed_multi_value_leniency false 当遇到一个字段多个值时抛出异常，或者从列表中返回第一个值

filter-过滤结果

POST /_sql?format=txt
{
  "query": """
    SELECT key,price,title FROM "dang-dang" limit 20
  """,
  "filter":{
    "range": {
     "price": {
             "gte": 100
           }
    }
  }
}

SQL Translate API

translate 接受JSON格式的SQL,并将其转换为ES查询DSL，一帮用来了解SQL背后转换原理。

POST /_sql/translate
{
  "query": """
    SELECT key,price,title FROM "dang-dang" limit 20
  """
}

响应：

{
  "size" : 20,
  "_source" : false,
  "fields" : [
    {
      "field" : "key"
    },
    {
      "field" : "price"
    },
    {
      "field" : "title"
    }
  ],
  "sort" : [
    {
      "_doc" : {
        "order" : "asc"
      }
    }
  ]
}

SQL

ES SQL 支持一般的SQL查询语法和关键字，如AND,IN,IS,JOIN,LIKE...

标识符

标识符可以有两种类型：带引号和不带引号的

1 不带引号

查询的目标字段和条件均不是关键字，不需要带引号

SELECT title FROM "dang-*"

使用场景：某一类型的索引是 dang-202108,dang-202107,dang-202106，由于索引数据太大，选择按月创建索引，此时需要从多个索引查询同一属性。

2 带引号

由于要查询的字段 from是关键字，需要用引号包起来，否则会和FROM冲突；

第二个因为包含了数学日期，会使解析器混淆，也需要包起来。

SELECT "from" FROM "<logstash-{now/d}>"

单引号和双引号

在SQL中，单引号和双引号具有不同的含义，不能相互转换；

示例：

SELECT "first_name"
    FROM "musicians"
WHERE "last_name" = 'Carroll'

特殊字符

特殊字符 含义
* 在某些上下文中用于表示占位符，也可用于某些聚合函数的参数
, 用于枚举列表的元素
. 用户数字常量或分隔标识符限定符（目录，表，列名等）
() 用于特定的SQL命令，函数声明或控制优先级

注释

ElasticSearch SQL 允许两种注释

标签：price,查询,Elasticsearch,SQL,dang,query,SELECT
来源： https://www.cnblogs.com/chenglc/p/15183495.html