_____ _ _ ____ _____ ___ ____ ____ ___ _
| ____| | / / ___|_ _|_ _|/ ___|/ ___| / _ | |
| _| | | / _ ___ | | | || | ___ | | | || |
| |___| |___ / ___ ___) || | | || |___ ___) | |_| || |___
|_____|_____|/_/ _|____/ |_| |___|____||____/ ___|_____|
Этот инструмент преобразует sql в elasticsearch dsl
На данный момент поддерживаются:
иди и возьми -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.
Если у вас есть какие-либо советы или идеи, добро пожаловать, отправьте вопрос или запрос на включение!
Массачусетский технологический институт