57 lines
1.3 KiB
JavaScript
57 lines
1.3 KiB
JavaScript
const Parser = require('../core/astParser');
|
|
const Cache = require("../core/cache");
|
|
const sqlSyntaxParser = require("../core/sqlSyntaxParser");
|
|
const sqlAutoCompleteParser = require("../core/sqlAutoCompleteParser");
|
|
const filter = require("./filter");
|
|
|
|
|
|
const astCache = new Cache();
|
|
|
|
function parse(sql) {
|
|
const cleanSql = filter.cleanSql(sql);
|
|
console.log(cleanSql)
|
|
let ast = astCache.get(cleanSql);
|
|
if (ast) {
|
|
return ast
|
|
} else {
|
|
ast = Parser.parse(cleanSql).ast;
|
|
astCache.set(cleanSql, ast);
|
|
return ast;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* sql sql
|
|
* type 语法类型。默认hive
|
|
* return 返回解析对象
|
|
*/
|
|
function parseSyntax(sql, type) {
|
|
if (typeof type == "undefined") {
|
|
type = "hive"
|
|
}
|
|
let sql1=sql;
|
|
let sql2='';
|
|
if(sql instanceof Array){
|
|
sql1=sql[0];
|
|
sql2=sql[1];
|
|
}
|
|
return sqlSyntaxParser.parser.parseSyntax(sql1, sql2, type, false)
|
|
}
|
|
|
|
function parserSql(sql, type) {
|
|
if (typeof type == "undefined") {
|
|
type = "hive"
|
|
}
|
|
let sql1=sql;
|
|
let sql2='';
|
|
if(sql instanceof Array){
|
|
sql1=sql[0];
|
|
sql2=sql[1];
|
|
}
|
|
return sqlAutoCompleteParser.parser.parseSql(sql1, sql2, type, false)
|
|
}
|
|
|
|
exports.parse = parse;
|
|
exports.parseSyntax = parseSyntax;
|
|
exports.parserSql = parserSql;
|