Support BigQuery EXPORT DATA statement

Adds EXPORT DATA [WITH CONNECTION connection] OPTIONS (option_list) AS
query. Options are kept as an expression list, and the exported query is
reachable from TablesNamesFinder.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01EqinwHBKuAtPEmtXr3b5P2

Author: hayssams

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

@@ -93,6 +93,7 @@
 import java.util.Locale;
 import java.util.Set;
 import java.util.function.Predicate;
+import net.sf.jsqlparser.statement.export.ExportDataStatement;
 
 /**
  * Derives a {@link StatementFeatures} verdict from a statement tree.
@@ -528,6 +529,13 @@ public <S> Void visit(AssertStatement assertStatement, S context) {
         return null;
     }
 
+    @Override
+    public <S> Void visit(ExportDataStatement exportDataStatement, S context) {
+        analysis.claimTopLevel();
+        analysis.certain(StmtFeature.READS_DATA, StmtFeature.MODIFIES_DATA);
+        return null;
+    }
+
     @Override
     public <S> Void visit(PurgeStatement purgeStatement, S context) {
         analysis.claimTopLevel();

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

@@ -68,6 +68,7 @@
 import net.sf.jsqlparser.statement.update.ParenthesedUpdate;
 import net.sf.jsqlparser.statement.update.Update;
 import net.sf.jsqlparser.statement.upsert.Upsert;
+import net.sf.jsqlparser.statement.export.ExportDataStatement;
 
 public interface StatementVisitor<T> {
 
@@ -377,6 +378,12 @@ default void visit(AssertStatement assertStatement) {
         this.visit(assertStatement, null);
     }
 
+    <S> T visit(ExportDataStatement exportDataStatement, S context);
+
+    default void visit(ExportDataStatement exportDataStatement) {
+        this.visit(exportDataStatement, null);
+    }
+
     <S> T visit(PurgeStatement purgeStatement, S context);
 
     default void visit(PurgeStatement purgeStatement) {

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

@@ -89,6 +89,7 @@
 
 import java.util.List;
 import net.sf.jsqlparser.util.TableDefinitionTraversal;
+import net.sf.jsqlparser.statement.export.ExportDataStatement;
 
 @SuppressWarnings({"PMD.UncommentedEmptyMethodBody"})
 public class StatementVisitorAdapter<T> implements StatementVisitor<T> {
@@ -623,6 +624,11 @@ public <S> T visit(AssertStatement assertStatement, S context) {
         return null;
     }
 
+    @Override
+    public <S> T visit(ExportDataStatement exportDataStatement, S context) {
+        return null;
+    }
+
     @Override
     public <S> T visit(PurgeStatement purgeStatement, S context) {
         return null;

src/main/java/net/sf/jsqlparser/statement/export/ExportDataStatement.java

@@ -0,0 +1,90 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2026 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement.export;
+
+import net.sf.jsqlparser.expression.Expression;
+import net.sf.jsqlparser.expression.operators.relational.ExpressionList;
+import net.sf.jsqlparser.statement.Statement;
+import net.sf.jsqlparser.statement.StatementVisitor;
+import net.sf.jsqlparser.statement.select.Select;
+
+/**
+ * BigQuery's {@code EXPORT DATA [WITH CONNECTION connection] OPTIONS (option_list) AS query}.
+ *
+ * @see <a href=
+ *      "https://cloud.google.com/bigquery/docs/reference/standard-sql/export-statements">Export
+ *      statements</a>
+ */
+public class ExportDataStatement implements Statement {
+    private String connectionName;
+    private ExpressionList<Expression> options;
+    private Select select;
+
+    public String getConnectionName() {
+        return connectionName;
+    }
+
+    public void setConnectionName(String connectionName) {
+        this.connectionName = connectionName;
+    }
+
+    public ExportDataStatement withConnectionName(String connectionName) {
+        setConnectionName(connectionName);
+        return this;
+    }
+
+    public ExpressionList<Expression> getOptions() {
+        return options;
+    }
+
+    public void setOptions(ExpressionList<Expression> options) {
+        this.options = options;
+    }
+
+    public ExportDataStatement withOptions(ExpressionList<Expression> options) {
+        setOptions(options);
+        return this;
+    }
+
+    public Select getSelect() {
+        return select;
+    }
+
+    public void setSelect(Select select) {
+        this.select = select;
+    }
+
+    public ExportDataStatement withSelect(Select select) {
+        setSelect(select);
+        return this;
+    }
+
+    public StringBuilder appendTo(StringBuilder builder) {
+        builder.append("EXPORT DATA");
+        if (connectionName != null) {
+            builder.append(" WITH CONNECTION ").append(connectionName);
+        }
+        if (options != null) {
+            builder.append(" OPTIONS (").append(options).append(")");
+        }
+        builder.append(" AS ").append(select);
+        return builder;
+    }
+
+    @Override
+    public String toString() {
+        return appendTo(new StringBuilder()).toString();
+    }
+
+    @Override
+    public <T, S> T accept(StatementVisitor<T> statementVisitor, S context) {
+        return statementVisitor.visit(this, context);
+    }
+}

src/main/java/net/sf/jsqlparser/util/TablesNamesFinder.java

@@ -210,6 +210,7 @@
 import net.sf.jsqlparser.statement.update.UpdateSet;
 import net.sf.jsqlparser.statement.upsert.Upsert;
 import net.sf.jsqlparser.statement.AssertStatement;
+import net.sf.jsqlparser.statement.export.ExportDataStatement;
 
 
 /**
@@ -2476,6 +2477,17 @@ public void visit(AssertStatement assertStatement) {
         StatementVisitor.super.visit(assertStatement);
     }
 
+    @Override
+    public <S> Void visit(ExportDataStatement exportDataStatement, S context) {
+        exportDataStatement.getSelect().accept((SelectVisitor<?>) this, context);
+        return null;
+    }
+
+    @Override
+    public void visit(ExportDataStatement exportDataStatement) {
+        StatementVisitor.super.visit(exportDataStatement);
+    }
+
     @Override
     public <S> Void visit(PurgeStatement purgeStatement, S context) {
         if (purgeStatement.getPurgeObjectType() == PurgeObjectType.TABLE) {

src/main/java/net/sf/jsqlparser/util/deparser/StatementDeParser.java

@@ -98,6 +98,7 @@
 import net.sf.jsqlparser.statement.update.Update;
 import net.sf.jsqlparser.statement.upsert.Upsert;
 import net.sf.jsqlparser.statement.AssertStatement;
+import net.sf.jsqlparser.statement.export.ExportDataStatement;
 
 public class StatementDeParser extends AbstractDeParser<Statement>
         implements StatementVisitor<StringBuilder> {
@@ -559,6 +560,12 @@ public <S> StringBuilder visit(AssertStatement assertStatement, S context) {
         return builder;
     }
 
+    @Override
+    public <S> StringBuilder visit(ExportDataStatement exportDataStatement, S context) {
+        exportDataStatement.appendTo(builder);
+        return builder;
+    }
+
     @Override
     public <S> StringBuilder visit(PurgeStatement purgeStatement, S context) {
         purgeStatement.appendTo(builder);

src/main/java/net/sf/jsqlparser/util/validation/validator/StatementValidator.java

@@ -100,6 +100,7 @@
 import net.sf.jsqlparser.util.validation.ValidationCapability;
 import net.sf.jsqlparser.util.validation.metadata.NamedObject;
 import net.sf.jsqlparser.statement.AssertStatement;
+import net.sf.jsqlparser.statement.export.ExportDataStatement;
 
 /**
  * @author gitmotte
@@ -484,6 +485,12 @@ public <S> Void visit(AssertStatement assertStatement, S context) {
         return null;
     }
 
+    @Override
+    public <S> Void visit(ExportDataStatement exportDataStatement, S context) {
+        // TODO: not yet implemented
+        return null;
+    }
+
     @Override
     public <S> Void visit(PurgeStatement purgeStatement, S context) {
         // TODO: not yet implemented
@@ -704,6 +711,10 @@ public void visit(AssertStatement assertStatement) {
         visit(assertStatement, null);
     }
 
+    public void visit(ExportDataStatement exportDataStatement) {
+        visit(exportDataStatement, null);
+    }
+
     public void visit(PurgeStatement purgeStatement) {
         visit(purgeStatement, null);
     }

src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt

@@ -2915,6 +2915,8 @@ Statement SingleStatement() :
             |
             LOOKAHEAD({ getToken(1).kind == K_ASSERT }) stm = AssertStatement()
             |
+            LOOKAHEAD({ getToken(1).kind == K_EXPORT && getToken(2).kind == K_DATA }) stm = ExportDataStatement()
+            |
             stm = PurgeStatement()
             |
             stm = SessionStatement()
@@ -4316,6 +4318,32 @@ RenameTableStatement RenameTableStatement(): {
     }
 }
 
+/**
+ * BigQuery's EXPORT DATA [WITH CONNECTION connection] OPTIONS (option_list) AS query.
+ */
+ExportDataStatement ExportDataStatement() #ExportDataStatement:
+{
+    ExportDataStatement exportDataStatement = new ExportDataStatement();
+    ExpressionList options;
+    ObjectNames connectionName;
+    Select select;
+}
+{
+    <K_EXPORT> <K_DATA>
+    [
+        LOOKAHEAD({ getToken(1).kind == K_WITH && "CONNECTION".equalsIgnoreCase(getToken(2).image) })
+        <K_WITH> <S_IDENTIFIER> connectionName=RelObjectNames()
+        { exportDataStatement.setConnectionName(String.join(".", connectionName.getNames())); }
+    ]
+    [
+        LOOKAHEAD({ isKeywordAhead("OPTIONS") })
+        <S_IDENTIFIER> "(" options=ExpressionList() ")"
+        { exportDataStatement.setOptions(options); }
+    ]
+    <K_AS> select=Select() { exportDataStatement.setSelect(select); }
+    { return exportDataStatement; }
+}
+
 /**
  * BigQuery's ASSERT expression [AS description] debugging statement.
  */

src/test/java/net/sf/jsqlparser/statement/select/BigQueryTest.java

@@ -13,6 +13,7 @@
 import net.sf.jsqlparser.expression.ArrayExpression;
 import net.sf.jsqlparser.statement.AssertStatement;
 import net.sf.jsqlparser.statement.create.table.CreateTable;
+import net.sf.jsqlparser.statement.export.ExportDataStatement;
 import net.sf.jsqlparser.statement.create.table.TablePartitioning;
 import net.sf.jsqlparser.test.TestUtils;
 import org.junit.jupiter.api.Assertions;
@@ -241,4 +242,34 @@ void testAssertRemainsUsableAsIdentifier() throws JSQLParserException {
         String sqlStr = "SELECT assert FROM t";
         TestUtils.assertSqlCanBeParsedAndDeparsed(sqlStr, true);
     }
+
+    @Test
+    void testExportData() throws JSQLParserException {
+        String sqlStr = "EXPORT DATA OPTIONS (uri = 'gs://bucket/*.csv', format = 'CSV', "
+                + "overwrite = true) AS SELECT * FROM t";
+        ExportDataStatement exportData =
+                (ExportDataStatement) TestUtils.assertSqlCanBeParsedAndDeparsed(sqlStr, true);
+
+        Assertions.assertEquals(3, exportData.getOptions().size());
+        Assertions.assertNull(exportData.getConnectionName());
+    }
+
+    @Test
+    void testExportDataWithConnection() throws JSQLParserException {
+        String sqlStr = "EXPORT DATA WITH CONNECTION myproject.us.myconnection "
+                + "OPTIONS (uri = 'gs://bucket/*.csv') AS SELECT a FROM t";
+        ExportDataStatement exportData =
+                (ExportDataStatement) TestUtils.assertSqlCanBeParsedAndDeparsed(sqlStr, true);
+
+        Assertions.assertEquals("myproject.us.myconnection", exportData.getConnectionName());
+    }
+
+    @Test
+    void testExportDataTablesNamesFinder() throws JSQLParserException {
+        String sqlStr = "EXPORT DATA OPTIONS (uri = 'gs://bucket/*.csv') AS SELECT * FROM ds.t";
+
+        Assertions.assertEquals(java.util.Collections.singletonList("ds.t"),
+                new net.sf.jsqlparser.util.TablesNamesFinder<Void>()
+                        .getTableList(net.sf.jsqlparser.parser.CCJSqlParserUtil.parse(sqlStr)));
+    }
 }