elasticsql

 _____ _         _     ____ _____ ___  ____  ____   ___   _
| ____| |       /    / ___|_   _|_ _|/ ___|/ ___| / _  | |
|  _| | |      / _   ___  | |  | || |    ___ | | | || |
| |___| |___  / ___   ___) || |  | || |___  ___) | |_| || |___
|_____|_____|/_/   _|____/ |_| |___|____||____/ ___|_____|

概述

该工具将sql转换为elasticsearch dsl

目前支持：

• sql和表达式
• sql或表达式
• 等于(=)支持
• 不等于(!=) 支持
• gt(>) 支持
• gte(>=) 支持
• lt(<) 支持
• LTE(<=) 支持
• sql in (例如 id in (1,2,3) ) 表达式
• sql 不在（例如 id 不在 (1,2,3) ）表达式中
• paren bool 支持（例如，其中 (a=1 或 b=1) 和 (c=1 或 d=1)）
• 类似sql的表达式（目前使用匹配短语，将来可能会更改为通配符）
• 支持sql排序
• SQL限制支持
• sql 不像表达式
• 字段缺失检查
• 支持count(*), count(field), min(field), max(field), avg(field)等聚合
• 支持统计(field)、extend_stats(field)、percentiles(field)等非标准sql函数的聚合
• 空检查表达式（为空/不为空）
• 连接表达式
• 有支持

用法

去获取-u github.com/cch123/elasticsql

演示：

 package main

import (
    "fmt"

    "github.com/cch123/elasticsql"
)

var sql = `
select * from aaa
where a=1 and x = '三个男人'
and create_time between '2015-01-01T00:00:00+0800' and '2016-01-01T00:00:00+0800'
and process_id > 1 order by id desc limit 100,10
`

func main () {
    dsl , esType , _ := elasticsql . Convert ( sql )
    fmt . Println ( dsl )
    fmt . Println ( esType )
}

将产生：

{
    "query" : {
        "bool" : {
            "must" : [
                {
                    "match" : {
                        "a" : {
                            "query" : " 1 " ,
                            "type" : " phrase "
                        }
                    }
                },
                {
                    "match" : {
                        "x" : {
                            "query" : "三个男人" ,
                            "type" : " phrase "
                        }
                    }
                },
                {
                    "range" : {
                        "create_time" : {
                            "from" : " 2015-01-01T00:00:00+0800 " ,
                            "to" : " 2016-01-01T00:00:00+0800 "
                        }
                    }
                },
                {
                    "range" : {
                        "process_id" : {
                            "gt" : " 1 "
                        }
                    }
                }
            ]
        }
    },
    "from" : 100 ,
    "size" : 10 ,
    "sort" : [
        {
            "id" : " desc "
        }
    ]
}

aaa

如果你的sql包含一些关键字，例如。顺序、时间戳，不要忘记转义这些字段，如下所示：

 select * from `order` where `timestamp` = 1 and `desc`.id > 0

警告

要使用这个工具，你需要了解elasticsearch的术语查询和匹配短语查询。

将字段设置为已分析或未分析将得到不同的结果。

细节

更多转换细节请参考wiki

其他信息

在编写这个工具时，我试图避免已弃用的 dsl 过滤器和聚合，因此它与大多数版本的elasticsearch兼容

如果您有任何建议或想法，欢迎提交问题或 Pull Request！

执照

麻省理工学院