feat: Implement classes for EXPORT statement

Author: Stefan Steinhauser

src/main/java/module-info.java

@@ -36,6 +36,7 @@
     exports net.sf.jsqlparser.statement.delete;
     exports net.sf.jsqlparser.statement.drop;
     exports net.sf.jsqlparser.statement.execute;
+    exports net.sf.jsqlparser.statement.export;
     exports net.sf.jsqlparser.statement.grant;
     exports net.sf.jsqlparser.statement.imprt;
     exports net.sf.jsqlparser.statement.insert;

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

@@ -15,6 +15,7 @@ public class CSVColumn {
     private Long startIndex;
     private Long endIndex;
     private StringValue format;
+    private String delimit;
 
     public CSVColumn(Long startIndex, Long endIndex) {
         this.startIndex = startIndex;
@@ -57,6 +58,14 @@ public void setFormat(StringValue format) {
         this.format = format;
     }
 
+    public String getDelimit() {
+        return delimit;
+    }
+
+    public void setDelimit(String delimit) {
+        this.delimit = delimit;
+    }
+
     @Override
     public String toString() {
         StringBuilder sql = new StringBuilder();
@@ -65,9 +74,14 @@ public String toString() {
         if (endIndex != null) {
             sql.append(" .. ");
             sql.append(endIndex);
-        } else if (format != null) {
-            sql.append(" FORMAT = ");
-            sql.append(format);
+        } else if (format != null || delimit != null) {
+            if (format != null) {
+                sql.append(" FORMAT = ");
+                sql.append(format);
+            } else {
+                sql.append(" DELIMIT = ");
+                sql.append(delimit);
+            }
         }
 
         return sql.toString();

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

@@ -16,10 +16,18 @@
 public class FileOption {
     private String key;
     private Expression value;
+    private String stringValue;
 
     private FileOption(String key, Expression value) {
         this.key = key;
         this.value = value;
+        this.stringValue = null;
+    }
+
+    public FileOption(String key, String value) {
+        this.key = key;
+        this.value = null;
+        this.stringValue = value;
     }
 
     public FileOption(String key) {
@@ -54,14 +62,22 @@ public void setValue(LongValue value) {
         this.value = value;
     }
 
+    public void setValue(String value) {
+        this.stringValue = value;
+    }
+
     @Override
     public String toString() {
         StringBuilder sql = new StringBuilder();
 
         sql.append(key);
-        if (value != null) {
+        if (value != null || stringValue != null) {
             sql.append(" = ");
-            sql.append(value);
+            if (stringValue != null) {
+                sql.append(stringValue);
+            } else {
+                sql.append(value);
+            }
         }
 
         return sql.toString();

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

@@ -0,0 +1,132 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2019 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement;
+
+import net.sf.jsqlparser.statement.select.PlainSelect;
+
+import java.io.Serializable;
+import java.util.List;
+import java.util.Objects;
+
+public abstract class FileSourceDestination implements Serializable {
+    private SourceDestinationType type;
+    private List<ConnectionFileDefinition> connectionFileDefinitions;
+    private Boolean local;
+    private Boolean secure;
+    private List<CSVColumn> csvColumns;
+    private List<FBVColumn> fbvColumns;
+    private List<FileOption> fileOptions;
+    private CertificateVerification certificateVerification;
+
+    protected SourceDestinationType getType() {
+        return type;
+    }
+
+    protected void setType(SourceDestinationType type) {
+        this.type = type;
+    }
+
+    public List<ConnectionFileDefinition> getConnectionFileDefinitions() {
+        return connectionFileDefinitions;
+    }
+
+    public void setConnectionFileDefinitions(List<ConnectionFileDefinition> connectionFileDefinitions) {
+        this.connectionFileDefinitions = connectionFileDefinitions;
+    }
+
+    public Boolean isLocal() {
+        return local;
+    }
+
+    public void setLocal(Boolean local) {
+        this.local = local;
+    }
+
+    public Boolean isSecure() {
+        return secure;
+    }
+
+    public void setSecure(Boolean secure) {
+        this.secure = secure;
+    }
+
+    public List<CSVColumn> getCSVColumns() {
+        return csvColumns;
+    }
+
+    public void setCSVColumns(List<CSVColumn> csvColumns) {
+        this.csvColumns = csvColumns;
+    }
+
+    public List<FBVColumn> getFBVColumns() {
+        return fbvColumns;
+    }
+
+    public void setFBVColumns(List<FBVColumn> fbvColumns) {
+        this.fbvColumns = fbvColumns;
+    }
+
+    public List<FileOption> getFileOptions() {
+        return fileOptions;
+    }
+
+    public void setFileOptions(List<FileOption> fileOptions) {
+        this.fileOptions = fileOptions;
+    }
+
+    public CertificateVerification getCertificateVerification() {
+        return certificateVerification;
+    }
+
+    public void setCertificateVerification(CertificateVerification certificateVerification) {
+        this.certificateVerification = certificateVerification;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sql = new StringBuilder();
+
+        if (local != null) {
+            if (local) {
+                sql.append("LOCAL ");
+            }
+
+            if (Objects.requireNonNullElse(secure, false)) {
+                sql.append("SECURE ");
+            }
+        }
+
+        sql.append(type);
+        if (connectionFileDefinitions != null) {
+            sql.append(" ");
+            PlainSelect.appendStringListTo(sql, connectionFileDefinitions, false, false);
+        }
+
+        if (csvColumns != null) {
+            sql.append(" ");
+            PlainSelect.appendStringListTo(sql, csvColumns, true, true);
+        } else if (fbvColumns != null) {
+            sql.append(" ");
+            PlainSelect.appendStringListTo(sql, fbvColumns, false, true);
+        }
+
+        if (fileOptions != null) {
+            sql.append(" ");
+            PlainSelect.appendStringListTo(sql, fileOptions, false, false);
+        }
+
+        if (certificateVerification != null) {
+            sql.append(" ");
+            sql.append(certificateVerification);
+        }
+
+        return sql.toString();
+    }
+}

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

@@ -11,16 +11,18 @@
 
 import net.sf.jsqlparser.expression.StringValue;
 import net.sf.jsqlparser.schema.Table;
+import net.sf.jsqlparser.statement.export.ExportIntoItem;
 import net.sf.jsqlparser.statement.imprt.ImportFromItem;
 
 import java.io.Serializable;
 import java.util.List;
 
-public class ScriptSourceDestination extends ImportFromItem implements Serializable {
+public class ScriptSourceDestination implements ImportFromItem, ExportIntoItem, Serializable {
     private Table script;
     private ConnectionDefinition connectionDefinition;
     private List<String> properties;
     private List<StringValue> values;
+    private ErrorClause errorClause;
 
     public Table getScript() {
         return script;
@@ -54,6 +56,16 @@ public void setValues(List<StringValue> values) {
         this.values = values;
     }
 
+    @Override
+    public ErrorClause getErrorClause() {
+        return errorClause;
+    }
+
+    @Override
+    public void setErrorClause(ErrorClause errorClause) {
+        this.errorClause = errorClause;
+    }
+
     @Override
     public String toString() {
         StringBuilder sql = new StringBuilder();

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

@@ -27,6 +27,7 @@
 import net.sf.jsqlparser.statement.delete.ParenthesedDelete;
 import net.sf.jsqlparser.statement.drop.Drop;
 import net.sf.jsqlparser.statement.execute.Execute;
+import net.sf.jsqlparser.statement.export.Export;
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
@@ -330,4 +331,10 @@ default void visit(ParenthesedDelete parenthesedDelete) {
     default void visit(Import imprt) {
         this.visit(imprt, null);
     }
+
+    <S> T visit(Export export, S context);
+
+    default void visit(Export export) {
+        this.visit(export, null);
+    }
 }

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

@@ -27,6 +27,7 @@
 import net.sf.jsqlparser.statement.delete.ParenthesedDelete;
 import net.sf.jsqlparser.statement.drop.Drop;
 import net.sf.jsqlparser.statement.execute.Execute;
+import net.sf.jsqlparser.statement.export.Export;
 import net.sf.jsqlparser.statement.grant.Grant;
 import net.sf.jsqlparser.statement.imprt.Import;
 import net.sf.jsqlparser.statement.insert.Insert;
@@ -314,4 +315,9 @@ public <S> T visit(RefreshMaterializedViewStatement materializedView, S context)
     public <S> T visit(Import imprt, S context) {
         return null;
     }
+
+    @Override
+    public <S> T visit(Export export, S context) {
+        return null;
+    }
 }