import MySQL, { MysqlSplitListener } from 'src/parser/mysql'; import { MySqlParserListener } from 'src/lib/mysql/MySqlParserListener'; const validSQL1 = `INSERT INTO country_page_view VALUES ('Chinese', 'mumiao', 18), ('Amercian', 'georage', 22);`; const validSQL2 = 'SELECT * FROM tb;'; const inValidSQL = 'CREATE TABLE VALUES;'; describe('MySQL ErrorStrategy test', () => { const mysql = new MySQL(); test('begin inValid', () => { const sql = [inValidSQL, validSQL1, validSQL2].join('\n'); // parse with empty errorListener const parseTree = mysql.parse(sql, () => {}); const splitListener = new MysqlSplitListener(); mysql.listen(splitListener as MySqlParserListener, parseTree); const statementCount = splitListener.statementsContext.length; splitListener.statementsContext.map((item, index) => { if (index !== statementCount - 1 && index !== statementCount - 2) { expect(item.exception).not.toBe(undefined); } else { expect(item.exception).toBe(undefined); } }); }); test('middle inValid', () => { const sql = [validSQL1, inValidSQL, validSQL2].join('\n'); // parse with empty errorListener const parseTree = mysql.parse(sql, () => {}); const splitListener = new MysqlSplitListener(); mysql.listen(splitListener as MySqlParserListener, parseTree); const statementCount = splitListener.statementsContext.length; splitListener.statementsContext.map((item, index) => { if (index !== statementCount - 1 && index !== 0) { expect(item.exception).not.toBe(undefined); } else { expect(item.exception).toBe(undefined); } }); }); test('end inValid', () => { const sql = [validSQL1, validSQL2, inValidSQL].join('\n'); // parse with empty errorListener const parseTree = mysql.parse(sql, () => {}); const splitListener = new MysqlSplitListener(); mysql.listen(splitListener as MySqlParserListener, parseTree); splitListener.statementsContext.map((item, index) => { if (index !== 0 && index !== 1) { expect(item.exception).not.toBe(undefined); } else { expect(item.exception).toBe(undefined); } }); }); });