fix: column list include function name

taozhi8833998 · Dec 5, 2024 · fd0ab2b · fd0ab2b
1 parent 7912fd5
commit fd0ab2b
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/pegjs/postgresql.pegjs b/pegjs/postgresql.pegjs
@@ -4547,7 +4547,7 @@ column_ref
         column: { expr: col }
       };
     }
-  / col:column_type {
+  / col:column_type !LPAREN {
     // => IGNORE
       columnList.add(`select::null::${col.value}`);
       return {

diff --git a/pegjs/redshift.pegjs b/pegjs/redshift.pegjs
@@ -4025,7 +4025,7 @@ column_ref
         column: { expr: col }
       };
     }
-  / col:column_type {
+  / col:column_type !LPAREN {
     // => IGNORE
       columnList.add(`select::null::${col.value}`);
       return {

diff --git a/pegjs/trino.pegjs b/pegjs/trino.pegjs
@@ -3442,7 +3442,7 @@ column_ref
         ...getLocationObject()
       };
     }
-  / col:column_type {
+  / col:column_type !LPAREN {
     // => IGNORE
       columnList.add(`select::null::${col.value}`);
       return {

diff --git a/test/postgres.spec.js b/test/postgres.spec.js
@@ -2116,6 +2116,9 @@ describe('Postgres', () => {
         }
       })
       expect(parser.sqlify(ast.ast, opt)).to.be.equals('SELECT "col1" + "col2" FROM "t1"')
+      sql = 'SELECT SUM("source"."point" + "other_source"."other_point") FROM foo';
+      ast = parser.parse(sql, opt)
+      expect(ast.columnList).to.be.eql(['select::source::point', 'select::other_source::other_point'])
     })
 
     it('should support conflict be empty', () => {