Feat/flink dt sql (#75)
* feat: dt self develop grammar * feat: dt self develop grammar
This commit is contained in:
@ -189,13 +189,28 @@ describe('FlinkSQL Syntax Tests', () => {
|
||||
REMOVE JAR '<path_to_filename>.jar'
|
||||
`;
|
||||
const result = parser.validate(sql);
|
||||
console.log(result);
|
||||
expect(result.length).toBe(0);
|
||||
});
|
||||
|
||||
test('DT Add Statement', () => {
|
||||
const sql = `
|
||||
ADD JAR WITH /home/test.jar;
|
||||
ADD JAR WITH /home/test.jar AS test.jar;
|
||||
ADD FILE WITH /home/admin/sftp/dttest_cn/DsCenter_1687/krb5.conf AS krb5.conf;
|
||||
ADD FILE WITH /home/admin/sftp/dttest_cn/DsCenter_1687/krb5.conf RENAME test.conf;
|
||||
ADD PYTHON_FILES WITH /test.py RENAME test.py;
|
||||
ADD PYTHON_REQUIREMENTS WITH /requirements.txt RENAME requirements.txt;
|
||||
ADD PYTHON_JAR WITH /python_jar.jar RENAME py_jar.jar;
|
||||
ADD PYTHON_PARAMETER /parameter.py;
|
||||
ADD ENGINE FILE WITH /filePath RENAME theName KEY theKey;
|
||||
`;
|
||||
const result = parser.validate(sql);
|
||||
expect(result.length).toBe(0);
|
||||
});
|
||||
|
||||
test('Test invalid Double Line Comment statement', () => {
|
||||
let sql = `-test comment\n`;
|
||||
let result = parser.validate(sql);
|
||||
const sql = `-test comment\n`;
|
||||
const result = parser.validate(sql);
|
||||
expect(result.length).toBe(1);
|
||||
});
|
||||
|
||||
|
Reference in New Issue
Block a user