|
@ -50,7 +50,13 @@ public class ElasticsearchUtil {
|
|
|
|
|
|
public List excute(String sql, Class clazz, String esType, String esIndex) {
|
|
public List excute(String sql, Class clazz, String esType, String esIndex) {
|
|
List saveModels = new ArrayList<>();
|
|
List saveModels = new ArrayList<>();
|
|
|
|
|
|
try {
|
|
try {
|
|
|
|
//解决 group by之后默认是200的问题
|
|
|
|
if(sql.toLowerCase().contains("group by")){
|
|
|
|
sql=sql+" limit 0,2000";
|
|
|
|
}
|
|
|
|
|
|
SQLExprParser parser = new ElasticSqlExprParser(sql);
|
|
SQLExprParser parser = new ElasticSqlExprParser(sql);
|
|
SQLExpr expr = parser.expr();
|
|
SQLExpr expr = parser.expr();
|
|
SQLQueryExpr queryExpr = (SQLQueryExpr) expr;
|
|
SQLQueryExpr queryExpr = (SQLQueryExpr) expr;
|