Skip to content

Commit 37e6684

Browse files
committed
test: #432 validate unComplete sql
1 parent 9dc6cfc commit 37e6684

File tree

7 files changed

+84
-0
lines changed

7 files changed

+84
-0
lines changed

test/parser/flink/errorListener.test.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ const sql4 = `SELECT * froma aaa`;
88
const sql5 = `CREATE VIEW `;
99
const sql6 = `DROP CATALOG `;
1010
const sql7 = `SELECT SUM(amount) FROM Orders GROUP BY length(users) HAVING SUM( `;
11+
const sql8 = `SELECT COALESCE(SUM(c.amount), 0) AS total_amount FROM cust c`;
12+
const sql9 = `SELECT SUM(c.amount) AS total_amount FROM cust c`;
1113

1214
describe('FlinkSQL validate invalid sql and test msg', () => {
1315
const flink = new FlinkSQL();
@@ -73,6 +75,16 @@ describe('FlinkSQL validate invalid sql and test msg', () => {
7375
);
7476
});
7577

78+
test('validate unComplete sql8', () => {
79+
const errors = flink.validate(sql8);
80+
expect(errors.length).toBe(0);
81+
});
82+
83+
test('validate unComplete sql9', () => {
84+
const errors = flink.validate(sql9);
85+
expect(errors.length).toBe(0);
86+
});
87+
7688
test('validate random text cn', () => {
7789
flink.locale = 'zh_CN';
7890
const errors = flink.validate(randomText);

test/parser/hive/errorListener.test.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@ const sql3 = `DROP VIEW IF EXIsST aaa aaa`;
77
const sql4 = `SELECT * froma aaa`;
88
const sql5 = `CREATE TABLE `;
99
const sql6 = `SELECT col1 FROM t1 GROUP BY col1 HAVING SUM(col2 `;
10+
const sql7 = `SELECT COALESCE(SUM(c.amount), 0) AS total_amount FROM cust c`;
11+
const sql8 = `SELECT SUM(c.amount) AS total_amount FROM cust c`;
1012

1113
describe('HiveSQL validate invalid sql and test msg', () => {
1214
const hive = new HiveSQL();
@@ -64,6 +66,16 @@ describe('HiveSQL validate invalid sql and test msg', () => {
6466
);
6567
});
6668

69+
test('validate unComplete sql7', () => {
70+
const errors = hive.validate(sql7);
71+
expect(errors.length).toBe(0);
72+
});
73+
74+
test('validate unComplete sql8', () => {
75+
const errors = hive.validate(sql8);
76+
expect(errors.length).toBe(0);
77+
});
78+
6779
test('validate random text cn', () => {
6880
hive.locale = 'zh_CN';
6981
const errors = hive.validate(randomText);

test/parser/impala/errorListener.test.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@ const sql3 = `DROP VIEW IF EXIsST aaa aaa`;
77
const sql4 = `SELECT * froma aaa`;
88
const sql5 = `CREATE VIEW `;
99
const sql6 = 'SELECT * FROM t1 LEFT OUTER JOIN t2 ON t1.int_col < ';
10+
const sql7 = `SELECT COALESCE(SUM(c.amount), 0) AS total_amount FROM cust c`;
11+
const sql8 = `SELECT SUM(c.amount) AS total_amount FROM cust c`;
1012

1113
describe('ImpalaSQL validate invalid sql and test msg', () => {
1214
const impala = new ImpalaSQL();
@@ -64,6 +66,16 @@ describe('ImpalaSQL validate invalid sql and test msg', () => {
6466
);
6567
});
6668

69+
test('validate unComplete sql7', () => {
70+
const errors = impala.validate(sql7);
71+
expect(errors.length).toBe(0);
72+
});
73+
74+
test('validate unComplete sql8', () => {
75+
const errors = impala.validate(sql8);
76+
expect(errors.length).toBe(0);
77+
});
78+
6779
test('validate random text cn', () => {
6880
impala.locale = 'zh_CN';
6981
const errors = impala.validate(randomText);

test/parser/mysql/errorListener.test.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,8 @@ const sql2 = `CREATE DATABASE `;
66
const sql3 = `SHOW CREATE DATABASE IF NOT EXIsST aaa aaa`;
77
const sql4 = `SELECT * froma aaa`;
88
const sql5 = `SELECT user, MAX(salary) FROM users where `;
9+
const sql6 = `SELECT COALESCE(SUM(c.amount), 0) AS total_amount FROM cust c`;
10+
const sql7 = `SELECT SUM(c.amount) AS total_amount FROM cust c`;
911

1012
describe('MySQL validate invalid sql and test msg', () => {
1113
const mysql = new MySQL();
@@ -55,6 +57,16 @@ describe('MySQL validate invalid sql and test msg', () => {
5557
);
5658
});
5759

60+
test('validate unComplete sql6', () => {
61+
const errors = mysql.validate(sql6);
62+
expect(errors.length).toBe(0);
63+
});
64+
65+
test('validate unComplete sql7', () => {
66+
const errors = mysql.validate(sql7);
67+
expect(errors.length).toBe(0);
68+
});
69+
5870
test('validate random text cn', () => {
5971
mysql.locale = 'zh_CN';
6072
const errors = mysql.validate(randomText);

test/parser/postgresql/errorListener.test.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,8 @@ const sql2 = `CREATE FUNCTION `;
66
const sql3 = `SELECT name, altitude FROM ONLY cities WHERE `;
77
const sql4 = `DROP PROCEDURE name1 a`;
88
const sql5 = `SELECT * FROM db.tbs GROUP BY sum( `;
9+
const sql6 = `SELECT COALESCE(SUM(c.amount), 0) AS total_amount FROM cust c`;
10+
const sql7 = `SELECT SUM(c.amount) AS total_amount FROM cust c`;
911

1012
describe('PostgreSQL validate invalid sql and test msg', () => {
1113
const pgSQL = new PostgreSQL();
@@ -54,6 +56,16 @@ describe('PostgreSQL validate invalid sql and test msg', () => {
5456
);
5557
});
5658

59+
test('validate unComplete sql6', () => {
60+
const errors = pgSQL.validate(sql6);
61+
expect(errors.length).toBe(0);
62+
});
63+
64+
test('validate unComplete sql7', () => {
65+
const errors = pgSQL.validate(sql7);
66+
expect(errors.length).toBe(0);
67+
});
68+
5769
test('validate random text cn', () => {
5870
pgSQL.locale = 'zh_CN';
5971
const errors = pgSQL.validate(randomText);

test/parser/spark/errorListener.test.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@ const sql1 = `ALTER VIEW`;
55
const sql2 = `SELECT * FROM `;
66
const sql3 = `DROP SCHEMA aaa aaa`;
77
const sql4 = `SELECT name, age FROM person ORDER BY length( `;
8+
const sql5 = `SELECT COALESCE(SUM(c.amount), 0) AS total_amount FROM cust c`;
9+
const sql6 = `SELECT SUM(c.amount) AS total_amount FROM cust c`;
810

911
describe('SparkSQL validate invalid sql and test msg', () => {
1012
const spark = new SparkSQL();
@@ -47,6 +49,16 @@ describe('SparkSQL validate invalid sql and test msg', () => {
4749
);
4850
});
4951

52+
test('validate unComplete sql5', () => {
53+
const errors = spark.validate(sql5);
54+
expect(errors.length).toBe(0);
55+
});
56+
57+
test('validate unComplete sql6', () => {
58+
const errors = spark.validate(sql6);
59+
expect(errors.length).toBe(0);
60+
});
61+
5062
test('validate random text cn', () => {
5163
spark.locale = 'zh_CN';
5264
const errors = spark.validate(randomText);

test/parser/trino/errorListener.test.ts

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,8 @@ const sql1 = `SHOW CREATE TABLE`;
55
const sql2 = `CREATE VIEW `;
66
const sql3 = `SHOW CREATE TABLE aaa aaa`;
77
const sql4 = `SELECT count(*) FROM customer order BY sum(a`;
8+
const sql5 = `SELECT COALESCE(SUM(c.amount), 0) AS total_amount FROM cust c`;
9+
const sql6 = `SELECT SUM(c.amount) AS total_amount FROM cust c`;
810

911
describe('TrinoSQL validate invalid sql and test msg', () => {
1012
const trinoSQL = new TrinoSQL();
@@ -46,6 +48,16 @@ describe('TrinoSQL validate invalid sql and test msg', () => {
4648
);
4749
});
4850

51+
test('validate unComplete sql5', () => {
52+
const errors = trinoSQL.validate(sql5);
53+
expect(errors.length).toBe(0);
54+
});
55+
56+
test('validate unComplete sql6', () => {
57+
const errors = trinoSQL.validate(sql6);
58+
expect(errors.length).toBe(0);
59+
});
60+
4961
test('validate random text cn', () => {
5062
trinoSQL.locale = 'zh_CN';
5163
const errors = trinoSQL.validate(randomText);

0 commit comments

Comments
 (0)