Exasol: IMPORT/EXPORT (#2256)

* feat: Implement IMPORT statement grammar

For reference see https://docs.exasol.com/db/latest/sql/import.htm

* feat: Classify new keywords in ParserKeywordsUtils

* feat: Implement java classes for IMPORT statement

* feat: Add LOOKAHEADs for IMPORT statement

* fix: Fix issues in IMPORT implementation

* feat: Update keywords

* feat: Allow IMPORT as FromItem in SELECT

* fix: Split double dot to fix broken unit tests

* fix: Fix errors occured during verify step

* test: Implement unit tests for IMPORT

* feat: Simplify grammar

* test: Implement test for sub IMPORT

* fix: Use double dot token in IMPORT

* feat: Implement EXPORT statement

Implement Exasol EXPORT statement (see https://docs.exasol.com/db/latest/sql/export.htm)

* refactor: Fix file extension in IMPORT tests

* test: Implement unit tests for EXPORT statement

* feat: Implement classes for EXPORT statement

* test: Fix EXPORT unit tests

* fix: Implement missing SampleClause methods

* feat: Add further Import tests

* fix: Update Keywords and fix boolean data type matching

* fix: Fix SourceDestinationType implementations

* style: Run spotlessApply

* fix: Fix spotbugsMain

* feat: Add test for RTRIM and LTRIM functions

Refs: #2256

* feat: Add EXPORT feature flag

* feat: Implement EXASOL dialect feature flag

---------

Co-authored-by: Stefan Steinhauser <[email protected]>
Co-authored-by: manticore-projects <[email protected]>

Author: 3 people

src/main/java/module-info.java

@@ -36,7 +36,9 @@
     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;
     exports net.sf.jsqlparser.statement.merge;
     exports net.sf.jsqlparser.statement.piped;

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

@@ -56,6 +56,7 @@ public class ParserKeywordsUtils {
             {"CHECK", RESTRICTED_SQL2016},
             {"CONNECT", RESTRICTED_ALIAS},
             {"CONNECT_BY_ROOT", RESTRICTED_JSQLPARSER},
+            {"CSV", RESTRICTED_JSQLPARSER},
             {"PRIOR", RESTRICTED_JSQLPARSER},
             {"CONSTRAINT", RESTRICTED_SQL2016},
             {"CREATE", RESTRICTED_ALIAS},
@@ -66,12 +67,15 @@ public class ParserKeywordsUtils {
             {"DISTINCTROW", RESTRICTED_SQL2016},
             {"DOUBLE", RESTRICTED_ALIAS},
             {"ELSE", RESTRICTED_JSQLPARSER},
+            {"ERRORS", RESTRICTED_JSQLPARSER},
             {"EXCEPT", RESTRICTED_SQL2016},
             {"EXCLUDES", RESTRICTED_JSQLPARSER},
             {"EXISTS", RESTRICTED_SQL2016},
             {"EXTEND", RESTRICTED_JSQLPARSER},
             {"FALSE", RESTRICTED_SQL2016},
+            {"FBV", RESTRICTED_JSQLPARSER},
             {"FETCH", RESTRICTED_SQL2016},
+            {"FILE", RESTRICTED_JSQLPARSER},
             {"FINAL", RESTRICTED_JSQLPARSER},
             {"FOR", RESTRICTED_SQL2016},
             {"FORCE", RESTRICTED_SQL2016},
@@ -87,6 +91,7 @@ public class ParserKeywordsUtils {
             {"IIF", RESTRICTED_ALIAS},
             {"IGNORE", RESTRICTED_ALIAS},
             {"ILIKE", RESTRICTED_SQL2016},
+            {"IMPORT", RESTRICTED_JSQLPARSER},
             {"IN", RESTRICTED_SQL2016},
             {"INCLUDES", RESTRICTED_JSQLPARSER},
             {"INNER", RESTRICTED_SQL2016},
@@ -122,12 +127,14 @@ public class ParserKeywordsUtils {
             {"RETURNING", RESTRICTED_JSQLPARSER},
             {"RIGHT", RESTRICTED_SQL2016},
             {"SAMPLE", RESTRICTED_ALIAS},
+            {"SCRIPT", RESTRICTED_JSQLPARSER},
             {"SEL", RESTRICTED_ALIAS},
             {"SELECT", RESTRICTED_ALIAS},
             {"SEMI", RESTRICTED_JSQLPARSER},
             {"SET", RESTRICTED_JSQLPARSER},
             {"SOME", RESTRICTED_JSQLPARSER},
             {"START", RESTRICTED_JSQLPARSER},
+            {"STATEMENT", RESTRICTED_JSQLPARSER},
             {"TABLES", RESTRICTED_ALIAS},
             {"TOP", RESTRICTED_SQL2016},
             {"TRAILING", RESTRICTED_SQL2016},
@@ -147,6 +154,7 @@ public class ParserKeywordsUtils {
             {"VALUE", RESTRICTED_JSQLPARSER},
             {"VALUES", RESTRICTED_SQL2016},
             {"VARYING", RESTRICTED_JSQLPARSER},
+            {"VERIFY", RESTRICTED_JSQLPARSER},
             {"WHEN", RESTRICTED_SQL2016},
             {"WHERE", RESTRICTED_SQL2016},
             {"WINDOW", RESTRICTED_SQL2016},

src/main/java/net/sf/jsqlparser/parser/feature/Feature.java

@@ -798,7 +798,18 @@ public enum Feature {
      */
     allowedNestingDepth(10),
 
-    dialect(null);
+    dialect(null),
+
+    /**
+     * "IMPORT"
+     */
+    imprt,
+
+    /**
+     * "EXPORT"
+     */
+    export,
+    ;
 
     private final Object value;
     private final boolean configurable;

src/main/java/net/sf/jsqlparser/schema/Table.java

@@ -17,6 +17,7 @@
 import net.sf.jsqlparser.expression.MySQLIndexHint;
 import net.sf.jsqlparser.expression.SQLServerHints;
 import net.sf.jsqlparser.parser.ASTNodeAccessImpl;
+import net.sf.jsqlparser.statement.ErrorDestination;
 import net.sf.jsqlparser.statement.select.FromItem;
 import net.sf.jsqlparser.statement.select.FromItemVisitor;
 import net.sf.jsqlparser.statement.select.IntoTableVisitor;
@@ -27,7 +28,7 @@
 /**
  * A table. It can have an alias and the schema name it belongs to.
  */
-public class Table extends ASTNodeAccessImpl implements FromItem, MultiPartName {
+public class Table extends ASTNodeAccessImpl implements ErrorDestination, FromItem, MultiPartName {
 
     // private Database database;
     // private String schemaName;

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

@@ -0,0 +1,91 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2022 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement;
+
+import net.sf.jsqlparser.expression.StringValue;
+
+public class CSVColumn {
+    private Long startIndex;
+    private Long endIndex;
+    private StringValue format;
+    private String delimit;
+
+    public CSVColumn(Long startIndex, Long endIndex) {
+        this.startIndex = startIndex;
+        this.endIndex = endIndex;
+    }
+
+    public CSVColumn(Long index) {
+        this(index, null);
+    }
+
+    public Long getStartIndex() {
+        return startIndex;
+    }
+
+    public void setStartIndex(Long startIndex) {
+        this.startIndex = startIndex;
+    }
+
+    public Long getIndex() {
+        return getStartIndex();
+    }
+
+    public void setIndex(Long index) {
+        setStartIndex(index);
+    }
+
+    public Long getEndIndex() {
+        return endIndex;
+    }
+
+    public void setEndIndex(Long endIndex) {
+        this.endIndex = endIndex;
+    }
+
+    public StringValue getFormat() {
+        return format;
+    }
+
+    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();
+
+        sql.append(startIndex);
+        if (endIndex != null) {
+            sql.append(" .. ");
+            sql.append(endIndex);
+        } else if (format != null || delimit != null) {
+            if (format != null) {
+                sql.append(" FORMAT = ");
+                sql.append(format);
+            }
+
+            if (delimit != null) {
+                sql.append(" DELIMIT = ");
+                sql.append(delimit);
+            }
+        }
+
+        return sql.toString();
+    }
+}

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

@@ -0,0 +1,75 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2022 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement;
+
+import net.sf.jsqlparser.expression.StringValue;
+
+public class CSVFileDestination implements ErrorDestination {
+    private ConnectionDefinition connectionDefinition;
+    private boolean local;
+    private boolean secure;
+    private StringValue file;
+
+    public ConnectionDefinition getConnectionDefinition() {
+        return connectionDefinition;
+    }
+
+    public void setConnectionDefinition(ConnectionDefinition connectionDefinition) {
+        this.connectionDefinition = connectionDefinition;
+    }
+
+    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 StringValue getFile() {
+        return file;
+    }
+
+    public void setFile(StringValue file) {
+        this.file = file;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sql = new StringBuilder();
+
+        if (local) {
+            sql.append("LOCAL ");
+            if (secure) {
+                sql.append("SECURE ");
+            }
+        }
+
+        sql.append("CSV");
+
+        if (connectionDefinition != null) {
+            sql.append(" ");
+            sql.append(connectionDefinition);
+        }
+
+        sql.append(" FILE ");
+        sql.append(file);
+
+        return sql.toString();
+    }
+}

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

@@ -0,0 +1,67 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2025 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement;
+
+import net.sf.jsqlparser.expression.StringValue;
+
+import java.io.Serializable;
+
+public class CertificateVerification implements Serializable {
+    private Boolean ignoreCertificate;
+    private StringValue publicKey;
+
+    public StringValue getPublicKey() {
+        return publicKey;
+    }
+
+    public void setPublicKey(StringValue publicKey) {
+        this.publicKey = publicKey;
+    }
+
+    public Boolean getIgnoreCertificate() {
+        return ignoreCertificate;
+    }
+
+    public void setIgnoreCertificate(Boolean ignoreCertificate) {
+        this.ignoreCertificate = ignoreCertificate;
+    }
+
+    public Boolean getVerifyCertificate() {
+        return !ignoreCertificate;
+    }
+
+    public void setVerifyCertificate(Boolean verifyCertificate) {
+        this.ignoreCertificate = !verifyCertificate;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sql = new StringBuilder();
+
+        if (ignoreCertificate != null) {
+            if (ignoreCertificate) {
+                sql.append("IGNORE ");
+            } else {
+                sql.append("VERIFY ");
+            }
+            sql.append("CERTIFICATE");
+        }
+
+        if (publicKey != null) {
+            if (ignoreCertificate != null) {
+                sql.append(" ");
+            }
+            sql.append("PUBLIC KEY ");
+            sql.append(publicKey);
+        }
+
+        return sql.toString();
+    }
+}

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

@@ -0,0 +1,37 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2022 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement;
+
+public class CloudConnectionDefinition extends ConnectionDefinition {
+    private String storage;
+
+    public String getStorage() {
+        return storage;
+    }
+
+    public void setStorage(String storage) {
+        this.storage = storage;
+    }
+
+    @Override
+    public void setCertificateVerification(CertificateVerification certificateVerification) {}
+
+    @Override
+    public String toString() {
+        StringBuilder sql = new StringBuilder();
+
+        sql.append("AT CLOUD ");
+        sql.append(storage);
+        sql.append(" ");
+        appendConnectionDefinition(sql);
+
+        return sql.toString();
+    }
+}