本机集成　　

　　Elasticsearch SQL是为Elasticsearch从头开始构建的。根据基础存储，针对相关节点有效执行每个查询。

没有外部零件

　　无需其他硬件，流程，运行时或库即可查询Elasticsearch；Elasticsearch SQL通过在 Elasticsearch集群中运行来消除多余的运动部件。

轻巧高效

　　Elasticsearch SQL并未抽象化Elasticsearch及其搜索功能-相反，它包含并公开了SQL以允许以相同的声明性，简洁的方式实时进行适当的全文本搜索。

SQL 入门

1、准备数据

本例使用ES版本是7.6.1，准备数据如下：

POST /book/_bulk

{"index":{"_id": "1001"}}
{"id": 1001, "name": "Java编程思想", "author": "小红", "release_date": "2011-06-02", "page_count": 561}
{"index":{"_id": "1002"}}
{"id": 1002, "name": "Java数据结构和算法", "author": "小绿", "release_date": "1989-05-26", "page_count": 482}
{"index":{"_id": "1003"}}
{"id": 1003, "name": "JavaScript权威指南", "author": "小蓝", "release_date": "1965-06-01", "page_count": 604}
{"index":{"_id": "1004"}}
{"id": 1004, "name": "Java并发编程实践", "author": "小白", "release_date": "1975-06-01", "page_count": 704}

2、使用SQL REST API查询

POST /_sql?format=txt
{
    "query": "SELECT * FROM book WHERE release_date < ‘2000-01-01‘"
}

效果如下：

3、使用SQL CLI查询

Elasticsearch附带了一个脚本，用于在其bin目录中运行SQL CLI ：

1）运行sql cli

　　命令(默认连接http://localhost:9200)：./bin/elasticsearch-sql-cli

　　命令(指定连接url)：./bin/elasticsearch-sql-cli http://some.server:9200

　　命令(指定连接url带认证)：./bin/elasticsearch-sql-cli http://sql_user:.server:9200

　　2、使用sql cli执行查询sql命令

　　　　查询sql：SELECT * FROM book WHERE page_count > 500 ORDER BY page_count DESC;

　　　　效果如下：

 SQL和Elasticsearch映射概念

尽管SQL和Elasticsearch对于数据的组织方式（和不同的语义）使用不同的术语，但本质上它们的目的是相同的。

SQL REST API

1、查询

1）普通查询，同上

POST /_sql?format=txt
{
    "query": "SELECT * FROM book ORDER BY page_count DESC LIMIT 5"
}

2）匹配索引查询

POST /_sql?format=txt

{
    "query": "SELECT * FROM \"boo*\" WHERE page_count > 500 ORDER BY page_count DESC"
}

　　注意：索引名需要用双引号（"）引起来

2、响应格式

　　虽然文本格式对人类很有益，但计算机更喜欢结构化的东西。

　　Elasticsearch SQL可以以下格式返回数据，可以通过formatURL中的属性或通过设置AcceptHTTP标头来设置数据：

　　json格式如下：

 3、分页

当数据量较大时，需要分页返回，ES提供了游标的形式来分页

示例

1）第一次请求，设置接收数据大小

POST /_sql?format=sql

{
    "query": "SELECT * FROM book order by release_date",
    "fetch_size" : 1
}

　　效果如下：

2）第二页，使用游标获取数据

POST /_sql?format=json

{
    "cursor": "5/WuAwFaAXNARFhGMVpYSjVRVzVrUm1WMFkyZ0JBQUFBQUFBQUFESVdlbVJGWmtzMmVWVlRXRk4zZW1SSFdETTNhMDFrWnc9Pf////8PBQFmBmF1dGhvcgEGYXV0aG9yAQR0ZXh0AAAAAWYCaWQBAmlkAQRsb25nAAAAAWYEbmFtZQEEbmFtZQEEdGV4dAAAAAFmCnBhZ2VfY291bnQBCnBhZ2VfY291bnQBBGxvbmcAAAABZgxyZWxlYXNlX2RhdGUBDHJlbGVhc2VfZGF0ZQEIZGF0ZXRpbWUBAAABHw=="
}

 　　　　效果如下：

　　请注意，响应数据中，该columns对象只是第一页的一部分。

　　　　cursor结果未返回时，您已到达最后一页。像Elasticsearch的滚动一样，

　　　　SQL可以在Elasticsearch中保持状态以支持游标。与滚动不同，接收最后一页足以保证清除Elasticsearch状态。

　　3）清空cursor

　　　　示例

POST /_sql/close
{
    "cursor": "sDXF1ZXJ5QW5kRmV0Y2gBAAAAAAAAAAEWYUpOYklQMHhRUEtld3RsNnFtYU1hQQ==:BAFmBGRhdGUBZgVsaWtlcwFzB21lc3NhZ2UBZgR1c2Vy9f///w8="
}

 SQL 翻译 API

SQL Translate API接受JSON文档中的SQL，并将其转换为本地Elasticsearch查询。

　　例如：

POST /_sql/translate

{
    "query": "SELECT * FROM book ORDER BY page_count DESC",
    "fetch_size": 10
}

效果如下：

翻译出来的DSL语句，可以用在Elasticsearch查询上