Merge remote-tracking branch 'origin/piped_sql'

# Conflicts:
#	README.md

Author: manticore-projects

README.md

@@ -1,8 +1,8 @@
 # [JSqlParser 5.1 Website](https://jsqlparser.github.io/JSqlParser) <img src="src/site/sphinx/_images/logo-no-background.svg" alt="drawing" width="200" align="right"/>
 
-
-[![Gradle CI](https://github.com/JSQLParser/JSqlParser/actions/workflows/ci.yml/badge.svg)](https://github.com/JSQLParser/JSqlParser/actions/workflows/ci.yml)
-[![Coverage Status](https://coveralls.io/repos/JSQLParser/JSqlParser/badge.svg?branch=master)](https://coveralls.io/r/JSQLParser/JSqlParser?branch=master)
+[![Maven deploy snapshot](https://github.com/JSQLParser/JSqlParser/actions/workflows/maven_deploy.yml/badge.svg)](https://github.com/JSQLParser/JSqlParser/actions/workflows/maven_deploy.yml)
+[![Gradle CI](https://github.com/JSQLParser/JSqlParser/actions/workflows/gradle.yml/badge.svg)](https://github.com/JSQLParser/JSqlParser/actions/workflows/gradle.yml)
+[![Coverage Status](https://coveralls.io/repos/JSQLParser/JSqlParser/badge.svg?branch=master)](https://coveralls.io/r/JSQLParser/JSqlParser?branch=master) 
 [![Codacy Badge](https://app.codacy.com/project/badge/Grade/6f9a2d7eb98f45969749e101322634a1)](https://www.codacy.com/gh/JSQLParser/JSqlParser/dashboard?utm_source=github.com&amp;utm_medium=referral&amp;utm_content=JSQLParser/JSqlParser&amp;utm_campaign=Badge_Grade)
 [![Maven Central](https://maven-badges.herokuapp.com/maven-central/com.github.jsqlparser/jsqlparser/badge.svg)](http://maven-badges.herokuapp.com/maven-central/com.github.jsqlparser/jsqlparser) [![Javadocs](https://www.javadoc.io/badge/com.github.jsqlparser/jsqlparser.svg)](https://www.javadoc.io/doc/com.github.jsqlparser/jsqlparser)
 [![Gitter](https://badges.gitter.im/JSQLParser/JSqlParser.svg)](https://gitter.im/JSQLParser/JSqlParser?utm_source=badge&utm_medium=badge&utm_campaign=pr-badge)
@@ -49,6 +49,22 @@ Column b = (Column) equalsTo.getRightExpression();
 Assertions.assertEquals("a", a.getColumnName());
 Assertions.assertEquals("b", b.getColumnName());
 ```
+## Support for `Piped SQL`
+
+Work is progressing for parsing `Piped SQL`, a much saner and more logical way to write queries in its semantic order.
+```sql
+FROM Produce
+|> WHERE
+    item != 'bananas'
+    AND category IN ('fruit', 'nut')
+|> AGGREGATE COUNT(*) AS num_items, SUM(sales) AS total_sales
+   GROUP BY item
+|> ORDER BY item DESC;
+```
+
+For details, please see https://storage.googleapis.com/gweb-research2023-media/pubtools/1004848.pdf,  https://cloud.google.com/bigquery/docs/reference/standard-sql/pipe-syntax and https://duckdb.org/docs/sql/query_syntax/from.html#from-first-syntax
+
+## Java Version
 
 JSQLParser-4.9 was the last JDK8 compatible version. JSQLParser-5.0 and later depend on JDK11 and introduce API breaking changes to the AST Visitors. Please see the Migration Guide for the details.
 
@@ -75,7 +91,7 @@ If you like JSqlParser then please check out its related projects:
 ## Alternatives to JSqlParser?
 [**General SQL Parser**](http://www.sqlparser.com/features/introduce.php?utm_source=github-jsqlparser&utm_medium=text-general) looks pretty good, with extended SQL syntax (like PL/SQL and T-SQL) and java + .NET APIs. The tool is commercial (license available online), with a free download option.
 
-Alternatively the dual-licensed [JOOQ](https://www.jooq.org/doc/latest/manual/sql-building/sql-parser/) provides a hand-written Parser supporting a lot of RDBMS, translation between dialects, SQL transformation, can be used as a JDBC proxy for translation and transformation purposes.
+Alternatively the dual-licensed [JOOQ](https://www.jooq.org/doc/latest/manual/sql-building/sql-parser/) provides a handwritten Parser supporting a lot of RDBMS, translation between dialects, SQL transformation, can be used as a JDBC proxy for translation and transformation purposes.
 
 ## [Documentation](https://jsqlparser.github.io/JSqlParser)
   1. [Samples](https://jsqlparser.github.io/JSqlParser/usage.html#parse-a-sql-statements)

src/main/java/module-info.java

@@ -38,6 +38,7 @@
     exports net.sf.jsqlparser.statement.grant;
     exports net.sf.jsqlparser.statement.insert;
     exports net.sf.jsqlparser.statement.merge;
+    exports net.sf.jsqlparser.statement.piped;
     exports net.sf.jsqlparser.statement.refresh;
     exports net.sf.jsqlparser.statement.select;
     exports net.sf.jsqlparser.statement.show;

src/main/java/net/sf/jsqlparser/expression/Expression.java

@@ -20,7 +20,4 @@ default <T> void accept(ExpressionVisitor<T> expressionVisitor) {
         this.accept(expressionVisitor, null);
     }
 
-    ;
-
-
 }

src/main/java/net/sf/jsqlparser/expression/ExpressionVisitor.java

@@ -57,6 +57,7 @@
 import net.sf.jsqlparser.expression.operators.relational.TSQLLeftJoin;
 import net.sf.jsqlparser.expression.operators.relational.TSQLRightJoin;
 import net.sf.jsqlparser.schema.Column;
+import net.sf.jsqlparser.statement.piped.FromQuery;
 import net.sf.jsqlparser.statement.select.AllColumns;
 import net.sf.jsqlparser.statement.select.AllTableColumns;
 import net.sf.jsqlparser.statement.select.ParenthesedSelect;
@@ -687,4 +688,6 @@ default void visit(Inverse inverse) {
     }
 
     <S> T visit(CosineSimilarity cosineSimilarity, S context);
+
+    <S> T visit(FromQuery fromQuery, S context);
 }

src/main/java/net/sf/jsqlparser/expression/ExpressionVisitorAdapter.java

@@ -57,6 +57,7 @@
 import net.sf.jsqlparser.expression.operators.relational.TSQLLeftJoin;
 import net.sf.jsqlparser.expression.operators.relational.TSQLRightJoin;
 import net.sf.jsqlparser.schema.Column;
+import net.sf.jsqlparser.statement.piped.FromQuery;
 import net.sf.jsqlparser.statement.select.AllColumns;
 import net.sf.jsqlparser.statement.select.AllTableColumns;
 import net.sf.jsqlparser.statement.select.OrderByElement;
@@ -819,4 +820,9 @@ public <S> T visit(CosineSimilarity cosineSimilarity, S context) {
         return null;
     }
 
+    @Override
+    public <S> T visit(FromQuery fromQuery, S context) {
+        return null;
+    }
+
 }

src/main/java/net/sf/jsqlparser/parser/ASTNodeAccessImpl.java

@@ -65,4 +65,9 @@ public <T extends ASTNodeAccess> T getParent(Class<T> clazz) {
 
         return clazz.cast(parent.jjtGetValue());
     }
+
+    @Override
+    public String toString() {
+        return appendTo(new StringBuilder()).toString();
+    }
 }

src/main/java/net/sf/jsqlparser/parser/ParserKeywordsUtils.java

@@ -68,6 +68,7 @@ public class ParserKeywordsUtils {
             {"EXCEPT", RESTRICTED_SQL2016},
             {"EXCLUDES", RESTRICTED_JSQLPARSER},
             {"EXISTS", RESTRICTED_SQL2016},
+            {"EXTEND", RESTRICTED_JSQLPARSER},
             {"FALSE", RESTRICTED_SQL2016},
             {"FETCH", RESTRICTED_SQL2016},
             {"FINAL", RESTRICTED_JSQLPARSER},

src/main/java/net/sf/jsqlparser/statement/StatementVisitor.java

@@ -323,5 +323,4 @@ default void visit(ParenthesedUpdate parenthesedUpdate) {
     default void visit(ParenthesedDelete parenthesedDelete) {
         this.visit(parenthesedDelete, null);
     }
-
 }

src/main/java/net/sf/jsqlparser/statement/piped/AggregatePipeOperator.java

@@ -0,0 +1,80 @@
+package net.sf.jsqlparser.statement.piped;
+
+import net.sf.jsqlparser.statement.select.SelectItem;
+
+import java.util.ArrayList;
+
+public class AggregatePipeOperator extends PipeOperator {
+    private final ArrayList<SelectItem<?>> selectItems = new ArrayList<>();
+    private final ArrayList<SelectItem<?>> groupItems = new ArrayList<>();
+    private boolean usingShortHandOrdering = false;
+
+    public AggregatePipeOperator(SelectItem<?> selectItem) {
+        selectItems.add(selectItem);
+    }
+
+    public ArrayList<SelectItem<?>> getSelectItems() {
+        return selectItems;
+    }
+
+    public ArrayList<SelectItem<?>> getGroupItems() {
+        return groupItems;
+    }
+
+    public AggregatePipeOperator add(SelectItem<?> selectItem) {
+        selectItems.add(selectItem);
+        return this;
+    }
+
+    public AggregatePipeOperator with(SelectItem<?> selectItem) {
+        return this.add(selectItem);
+    }
+
+    public AggregatePipeOperator addGroupItem(SelectItem<?> selectItem) {
+        groupItems.add(selectItem);
+        return this;
+    }
+
+    public AggregatePipeOperator withGroupItem(SelectItem<?> selectItem) {
+        return this.addGroupItem(selectItem);
+    }
+
+    public boolean isUsingShortHandOrdering() {
+        return usingShortHandOrdering;
+    }
+
+    public AggregatePipeOperator setShorthandOrdering(boolean usingShortHandOrdering) {
+        this.usingShortHandOrdering = usingShortHandOrdering;
+        return this;
+    }
+
+    @Override
+    public <T, S> T accept(PipeOperatorVisitor<T> visitor, S context) {
+        return visitor.visit(this, context);
+    }
+
+    @Override
+    public StringBuilder appendTo(StringBuilder builder) {
+        builder.append("|> ").append("AGGREGATE");
+        int i = 0;
+        for (SelectItem<?> selectItem : selectItems) {
+            builder.append(i++ > 0 ? ", " : " ").append(selectItem);
+        }
+        builder.append("\n");
+
+        if (!groupItems.isEmpty()) {
+            builder.append("\t").append("GROUP");
+            if (isUsingShortHandOrdering()) {
+                builder.append(" AND ORDER");
+            }
+            builder.append(" BY");
+            i = 0;
+            for (SelectItem<?> selectItem : groupItems) {
+                builder.append(i++ > 0 ? ", " : " ").append(selectItem);
+            }
+            builder.append("\n");
+        }
+
+        return builder;
+    }
+}

src/main/java/net/sf/jsqlparser/statement/piped/AsPipeOperator.java

@@ -0,0 +1,32 @@
+package net.sf.jsqlparser.statement.piped;
+
+import net.sf.jsqlparser.expression.Alias;
+
+public class AsPipeOperator extends PipeOperator {
+    private Alias alias;
+
+    public AsPipeOperator(Alias alias) {
+        this.alias = alias;
+    }
+
+    public Alias getAlias() {
+        return alias;
+    }
+
+    public AsPipeOperator setAlias(Alias alias) {
+        this.alias = alias;
+        return this;
+    }
+
+    @Override
+    public <T, S> T accept(PipeOperatorVisitor<T> visitor, S context) {
+        return visitor.visit(this, context);
+    }
+
+    @Override
+    public StringBuilder appendTo(StringBuilder builder) {
+        builder.append("|> ").append(alias);
+        builder.append("\n");
+        return builder;
+    }
+}