Exasol: IMPORT/EXPORT

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},
@@ -65,12 +66,15 @@ public class ParserKeywordsUtils {
             {"DISTINCT", 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},
@@ -86,6 +90,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},
@@ -121,12 +126,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},
@@ -146,6 +153,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

@@ -792,6 +792,11 @@ public enum Feature {
      * allows sub selects without parentheses, e.g. `select * from dual where 1 = select 1`
      */
     allowUnparenthesizedSubSelects(false),
+
+    /**
+     * "IMPORT"
+     */
+    imprt,
     ;
 
     private final Object value;

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();
+    }
+}