feat: Implement java classes for IMPORT statement

Author: Stefan Steinhauser

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,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 CSVColumn {
+    private Long startIndex;
+    private Long endIndex;
+    private StringValue format;
+
+    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;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sql = new StringBuilder();
+
+        sql.append(startIndex);
+        if (endIndex != null) {
+            sql.append(" .. ");
+            sql.append(endIndex);
+        } else if (format != null) {
+            sql.append(" FORMAT = ");
+            sql.append(format);
+        }
+
+        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 filePath;
+
+    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 getFilePath() {
+        return filePath;
+    }
+
+    public void setFilePath(StringValue filePath) {
+        this.filePath = filePath;
+    }
+
+    @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(filePath);
+
+        return sql.toString();
+    }
+}

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

@@ -0,0 +1,56 @@
+package net.sf.jsqlparser.statement;
+
+import net.sf.jsqlparser.expression.StringValue;
+
+public class CertificateVerification {
+    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,36 @@
+/*-
+ * #%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);
+        appendConnectionDefinition(sql);
+
+        return sql.toString();
+    }
+}

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

@@ -0,0 +1,89 @@
+/*-
+ * #%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 ConnectionDefinition {
+    private String connectionObjectName;
+    private StringValue connectionDefinition;
+    private UserIdentification userIdentification;
+    private CertificateVerification certificateVerification;
+
+    public String getConnectionObjectName() {
+        return connectionObjectName;
+    }
+
+    public void setConnectionObjectName(String connectionObjectName) {
+        this.connectionObjectName = connectionObjectName;
+    }
+
+    public StringValue getConnectionDefinition() {
+        return connectionDefinition;
+    }
+
+    public void setConnectionDefinition(StringValue connectionDefinition) {
+        this.connectionDefinition = connectionDefinition;
+    }
+
+    public void setConnection(String connectionObjectName) {
+        this.connectionObjectName = connectionObjectName;
+    }
+
+    public void setConnection(StringValue connectionDefinition) {
+        this.connectionDefinition = connectionDefinition;
+    }
+
+    public UserIdentification getUserIdentification() {
+        return userIdentification;
+    }
+
+    public void setUserIdentification(UserIdentification userIdentification) {
+        this.userIdentification = userIdentification;
+    }
+
+    public CertificateVerification getCertificateVerification() {
+        return certificateVerification;
+    }
+
+    public void setCertificateVerification(CertificateVerification certificateVerification) {
+        this.certificateVerification = certificateVerification;
+    }
+
+    protected StringBuilder appendConnectionDefinition(StringBuilder sql) {
+        if (connectionObjectName != null) {
+            sql.append(connectionObjectName);
+        } else if (connectionDefinition != null) {
+            sql.append(connectionDefinition);
+        }
+
+        if (userIdentification != null) {
+            sql.append(" ");
+            sql.append(userIdentification);
+        }
+
+        if (certificateVerification != null) {
+            sql.append(" ");
+            sql.append(certificateVerification);
+        }
+
+        return sql;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder sql = new StringBuilder();
+
+        sql.append("AT ");
+        appendConnectionDefinition(sql);
+
+        return sql.toString();
+    }
+}