一、基本概念

Elasticsearch是一個基于Lucene的開源、分布式、RESTful搜索引擎。它提供了全文搜索、結(jié)構(gòu)化搜索、分析以及分布式索引等功能。Elasticsearch SQL是Elasticsearch的擴(kuò)展功能，允許用戶使用SQL語法查詢Elasticsearch數(shù)據(jù)。通過SQL接口，開發(fā)者可以利用熟悉的SQL語言，編寫更直觀、更易懂的查詢，并且避免對大量復(fù)雜的原生REST請求的編寫。

二、主要功能和優(yōu)勢

• 易用性：使用熟悉的SQL語法，降低了學(xué)習(xí)成本。
• 靈活性：支持復(fù)雜的查詢和聚合操作。
• 性能：Elasticsearch本身的分布式架構(gòu)和高效查詢引擎保證了查詢性能。
• 集成性：通過JDBC驅(qū)動，可以與各種SQL工具和應(yīng)用程序集成。

Elasticsearch SQL特點(diǎn)

1. 本地集成
Elasticsearch SQL是專門為Elasticsearch構(gòu)建的。每個SQL查詢都根據(jù)底層存儲對相關(guān)節(jié)點(diǎn)有效執(zhí)行。
2. 沒有額外的要求
不依賴其他的硬件、進(jìn)程、運(yùn)行時庫，Elasticsearch SQL可以直接運(yùn)行在Elasticsearch集群上
3. 輕量且高效
像SQL那樣簡潔、高效地完成查詢

三、啟用和使用SQL功能

要在Elasticsearch中啟用和使用SQL功能，你需要安裝X-Pack插件。X-Pack插件包含了許多擴(kuò)展功能，包括SQL接口。安裝完成后，需要在Elasticsearch配置文件中啟用X-Pack插件，并重啟Elasticsearch服務(wù)。

# 安裝X-Pack插件
./bin/elasticsearch-plugin install x-pack
# 啟用X-Pack插件
# 在elasticsearch.yml配置文件中添加以下配置
xpack.sql.enabled: true

在啟用SQL功能后，你可以通過REST API、命令行工具或JDBC驅(qū)動來執(zhí)行SQL查詢。Elasticsearch SQL的語法與標(biāo)準(zhǔn)的SQL語法非常相似，支持SELECT、FROM、WHERE、GROUP BY、HAVING、ORDER BY等常見SQL語句。

四、Elasticsearch SQL的使用

4.1 語法

SELECT select_expr [, ...]
[ FROM table_name ]
[ WHERE condition ]
[ GROUP BY grouping_element [, ...] ]
[ HAVING condition]
[ ORDER BY expression [ ASC | DESC ] [, ...] ]
[ LIMIT [ count ] ]
[ PIVOT ( aggregation_expr FOR column IN ( value [ [ AS ] alias ] [, ...] ) ) ]

目前FROM只支持單表

4.2 sql查詢

# 使用curl命令查詢
curl -X GET "localhost:9200/_sql?format=txt" -H 'Content-Type: application/json' -d'
{
  "query": "SELECT * FROM indexName WHERE age > 30"
}'

format=txt 是指查詢返回結(jié)果的數(shù)據(jù)格式

4.3 將SQL轉(zhuǎn)換為DSL

GET /_sql/translate
{
"query":"SELECT * FROM es_order limit 1"
}

結(jié)果如下：

{
  "size" : 1,
  "_source" : {
    "includes" : [
      "id",
      "orderNo",
      "orderTime"
    ],
    "excludes" : [ ]
  },
  "docvalue_fields" : [
    {
      "field" : "id"
    },
    {
      "field" : "orderNo"
    },
    {
      "field" : "orderTime"
    }
  ],
  "sort" : [
    {
      "_doc" : {
        "order" : "asc"
      }
    }
  ]
}

4.4 全文檢索

當(dāng)使用MATCH或QUERY函數(shù)時，會啟用全文搜索功能，SCORE函數(shù)可以用來統(tǒng)計搜索評分。

MATCH函數(shù)

MATCH(
    field_exp,   
    constant_exp 
    [, options]) 
field_exp：匹配字段
constant_exp：匹配常量表達(dá)式

用法:

GET /_sql?format=txt
{
"query":"select * from es_order where MATCH(address, '武漢') or MATCH(productType, '手機(jī)') limit 10"
}

QUERY()

使用QUERY函數(shù)查詢address中包含Street的記錄。

POST /_sql?format=txt
{
"query":"select id,orderNo,name,address,SCORE()  from es_order where QUERY('address: 武漢') limit 10"
}

4.5 分組統(tǒng)計

GET /_sql?format=txt
{
"query":"select city, count(*) as age_cnt from es_order group by city"
}

這種方式要更加直觀、簡潔。

HAVING
我們可以使用HAVING語句對分組數(shù)據(jù)進(jìn)行二次篩選，比如篩選分組記錄數(shù)量大于1000的信息，查詢語句如下。

POST /_sql?format=txt
{
 "query":"select city, count(*) as age_cnt from es_order group by city having count(*) > 1000"
}

ORDER BY
使用ORDER BY語句對數(shù)據(jù)進(jìn)行排序，比如按照統(tǒng)計字段從高到低排序，查詢語句如下。

POST /_sql?format=txt
{
 "query":"select city, count(*) cc as age_cnt from es_order group by city having count(*) > 1000 order by cc "
}

注意: 目前Elasticsearch SQL還存在一些限制。例如：不支持JOIN、不支持較復(fù)雜的子查詢。所以，有一些相對復(fù)雜一些的功能，還得借助于DSL方式來實(shí)現(xiàn)

4.6 DESCRIBE

使用DESCRIBE語句查看索引中有哪些字段，比如查看es_order索引的字段，查詢語句如下。

POST /_sql?format=txt
{
  "query": "DESCRIBE es_order"
}

4.7 SHOW TABLES

使用SHOW TABLES查看所有的索引

POST /_sql?format=txt
{
  "query": "SHOW TABLES"
}

4.8 查詢支持的函數(shù)

使用SQL查詢ES中的數(shù)據(jù)，不僅可以使用一些SQL中的函數(shù)，還可以使用一些ES中特有的函數(shù)。SHOW FUNCTIONS語句查看所有支持的函數(shù)，比如搜索所有帶有DATE字段的函數(shù)可以使用如下語句。

POST /_sql?format=txt
{
  "query": "SHOW FUNCTIONS LIKE '%DATE%'"
}

五、適用場景及潛在限制

Elasticsearch SQL適用于需要對大量數(shù)據(jù)進(jìn)行復(fù)雜查詢的場景，如數(shù)據(jù)分析、報表生成、數(shù)據(jù)探索等。然而，由于SQL查詢的復(fù)雜性，它可能不適用于所有場景。例如，對于需要高并發(fā)、低延遲的場景，原生REST查詢可能更合適。

此外，雖然Elasticsearch SQL提供了SQL接口，但它并不是完全兼容SQL。例如，它不支持所有的SQL函數(shù)和特性。因此，在使用Elasticsearch SQL時，需要了解它的限制，并根據(jù)實(shí)際情況選擇使用。

總結(jié)來說，Elasticsearch SQL提供了一種直觀、易用的方式查詢Elasticsearch數(shù)據(jù)。它允許開發(fā)者利用熟悉的SQL語言，編寫更直觀、更易懂的查詢，并避免對大量復(fù)雜的原生REST請求的編寫。然而，它的適用場景和性能特點(diǎn)需要在實(shí)際使用中仔細(xì)考慮。

到此這篇關(guān)于在Elasticsearch中啟用和使用SQL功能的文章就介紹到這了,更多相關(guān)Elasticsearch使用SQL內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論