clazz) {
- SimpleNode parent = (SimpleNode) node.jjtGetParent();
+ Node parent = (Node) node.jjtGetParent();
while (parent.jjtGetValue() == null || !clazz.isInstance(parent.jjtGetValue())) {
- parent = (SimpleNode) parent.jjtGetParent();
+ parent = (Node) parent.jjtGetParent();
}
return clazz.cast(parent.jjtGetValue());
diff --git a/src/main/java/net/sf/jsqlparser/parser/AbstractJSqlParser.java b/src/main/java/net/sf/jsqlparser/parser/AbstractJSqlParser.java
index a39ac7e32..45580cb5e 100644
--- a/src/main/java/net/sf/jsqlparser/parser/AbstractJSqlParser.java
+++ b/src/main/java/net/sf/jsqlparser/parser/AbstractJSqlParser.java
@@ -21,6 +21,10 @@ public abstract class AbstractJSqlParser {
protected boolean errorRecovery = false;
protected List parseErrors = new ArrayList<>();
+ public enum Dialect {
+ ORACLE, EXASOL
+ }
+
public P withSquareBracketQuotation() {
return withFeature(Feature.allowSquareBracketQuotation, true);
}
@@ -57,6 +61,14 @@ public P withTimeOut(long timeOutMillSeconds) {
return withFeature(Feature.timeOut, timeOutMillSeconds);
}
+ public P withDialect(Dialect dialect) {
+ return withFeature(Feature.dialect, dialect.name());
+ }
+
+ public P withAllowedNestingDepth(int allowedNestingDepth) {
+ return withFeature(Feature.allowedNestingDepth, allowedNestingDepth);
+ }
+
public P withBackslashEscapeCharacter() {
return withFeature(Feature.allowBackslashEscapeCharacter, true);
}
@@ -83,8 +95,21 @@ public P withFeature(Feature f, long value) {
return me();
}
+ public P withFeature(Feature f, String value) {
+ getConfiguration().setValue(f, value);
+ return me();
+ }
+
public abstract FeatureConfiguration getConfiguration();
+ public FeatureConfiguration setValue(Feature feature, Object value) {
+ return getConfiguration().setValue(feature, value);
+ }
+
+ public Object getValue(Feature feature) {
+ return getConfiguration().getValue(feature);
+ }
+
public abstract P me();
public boolean getAsBoolean(Feature f) {
@@ -95,6 +120,18 @@ public Long getAsLong(Feature f) {
return getConfiguration().getAsLong(f);
}
+ public int getAsInt(Feature f) {
+ return getConfiguration().getAsInt(f);
+ }
+
+ public Integer getAsInteger(Feature f) {
+ return getConfiguration().getAsInteger(f);
+ }
+
+ public String getAsString(Feature f) {
+ return getConfiguration().getAsString(f);
+ }
+
public void setErrorRecovery(boolean errorRecovery) {
this.errorRecovery = errorRecovery;
}
diff --git a/src/main/java/net/sf/jsqlparser/parser/CCJSqlParserUtil.java b/src/main/java/net/sf/jsqlparser/parser/CCJSqlParserUtil.java
index 50d583194..bdb25eeb4 100644
--- a/src/main/java/net/sf/jsqlparser/parser/CCJSqlParserUtil.java
+++ b/src/main/java/net/sf/jsqlparser/parser/CCJSqlParserUtil.java
@@ -40,7 +40,6 @@
@SuppressWarnings("PMD.CyclomaticComplexity")
public final class CCJSqlParserUtil {
public final static Logger LOGGER = Logger.getLogger(CCJSqlParserUtil.class.getName());
- public final static int ALLOWED_NESTING_DEPTH = 10;
static {
LOGGER.setLevel(Level.OFF);
@@ -50,7 +49,7 @@ private CCJSqlParserUtil() {}
public static Statement parse(Reader statementReader) throws JSQLParserException {
ExecutorService executorService = Executors.newSingleThreadExecutor();
- Statement statement = null;
+ Statement statement;
CCJSqlParser parser = new CCJSqlParser(new StreamProvider(statementReader));
try {
statement = parseStatement(parser, executorService);
@@ -86,7 +85,7 @@ public static Statement parse(String sql, Consumer consumer)
}
ExecutorService executorService = Executors.newSingleThreadExecutor();
- Statement statement = null;
+ Statement statement;
try {
statement = parse(sql, executorService, consumer);
} finally {
@@ -102,20 +101,22 @@ public static Statement parse(String sql, ExecutorService executorService,
return null;
}
- Statement statement = null;
+ Statement statement;
// first, try to parse fast and simple
CCJSqlParser parser = newParser(sql);
if (consumer != null) {
consumer.accept(parser);
}
- boolean allowComplex = parser.getConfiguration().getAsBoolean(Feature.allowComplexParsing);
+ boolean allowComplex = parser.getAsBoolean(Feature.allowComplexParsing);
+ int allowedNestingDepth = parser.getAsInt(Feature.allowedNestingDepth);
LOGGER.info("Allowed Complex Parsing: " + allowComplex);
try {
LOGGER.info("Trying SIMPLE parsing " + (allowComplex ? "first" : "only"));
statement = parseStatement(parser.withAllowComplexParsing(false), executorService);
} catch (JSQLParserException ex) {
LOGGER.info("Nesting Depth" + getNestingDepth(sql));
- if (allowComplex && getNestingDepth(sql) <= ALLOWED_NESTING_DEPTH) {
+ if (allowComplex
+ && (allowedNestingDepth < 0 || getNestingDepth(sql) <= allowedNestingDepth)) {
LOGGER.info("Trying COMPLEX parsing when SIMPLE parsing failed");
// beware: the parser must not be reused, but needs to be re-initiated
parser = newParser(sql);
@@ -222,23 +223,21 @@ public static Expression parseExpression(String expressionStr, boolean allowPart
} catch (JSQLParserException ex1) {
// when fast simple parsing fails, try complex parsing but only if it has a chance to
// succeed
- if (getNestingDepth(expressionStr) <= ALLOWED_NESTING_DEPTH) {
- CCJSqlParser parser = newParser(expressionStr).withAllowComplexParsing(true);
- if (consumer != null) {
- consumer.accept(parser);
- }
- try {
- expression = parser.Expression();
- if (!allowPartialParse
- && parser.getNextToken().kind != CCJSqlParserTokenManager.EOF) {
- throw new JSQLParserException(
- "could only parse partial expression " + expression.toString());
- }
- } catch (JSQLParserException ex) {
- throw ex;
- } catch (ParseException ex) {
- throw new JSQLParserException(ex);
+ CCJSqlParser parser = newParser(expressionStr).withAllowComplexParsing(true);
+ if (consumer != null) {
+ consumer.accept(parser);
+ }
+ try {
+ expression = parser.Expression();
+ if (!allowPartialParse
+ && parser.getNextToken().kind != CCJSqlParserTokenManager.EOF) {
+ throw new JSQLParserException(
+ "could only parse partial expression " + expression.toString());
}
+ } catch (JSQLParserException ex) {
+ throw ex;
+ } catch (ParseException ex) {
+ throw new JSQLParserException(ex);
}
}
return expression;
@@ -301,24 +300,22 @@ public static Expression parseCondExpression(String conditionalExpressionStr,
throw new JSQLParserException(ex);
}
} catch (JSQLParserException ex1) {
- if (getNestingDepth(conditionalExpressionStr) <= ALLOWED_NESTING_DEPTH) {
- CCJSqlParser parser =
- newParser(conditionalExpressionStr).withAllowComplexParsing(true);
- if (consumer != null) {
- consumer.accept(parser);
- }
- try {
- expression = parser.Expression();
- if (!allowPartialParse
- && parser.getNextToken().kind != CCJSqlParserTokenManager.EOF) {
- throw new JSQLParserException(
- "could only parse partial expression " + expression.toString());
- }
- } catch (JSQLParserException ex) {
- throw ex;
- } catch (ParseException ex) {
- throw new JSQLParserException(ex);
+ CCJSqlParser parser =
+ newParser(conditionalExpressionStr).withAllowComplexParsing(true);
+ if (consumer != null) {
+ consumer.accept(parser);
+ }
+ try {
+ expression = parser.Expression();
+ if (!allowPartialParse
+ && parser.getNextToken().kind != CCJSqlParserTokenManager.EOF) {
+ throw new JSQLParserException(
+ "could only parse partial expression " + expression.toString());
}
+ } catch (JSQLParserException ex) {
+ throw ex;
+ } catch (ParseException ex) {
+ throw new JSQLParserException(ex);
}
}
return expression;
@@ -334,7 +331,7 @@ public static Expression parseCondExpression(String conditionalExpressionStr,
public static Statement parseStatement(CCJSqlParser parser, ExecutorService executorService)
throws JSQLParserException {
- Statement statement = null;
+ Statement statement;
Future future = executorService.submit(new Callable() {
@Override
public Statement call() throws ParseException {
@@ -342,7 +339,7 @@ public Statement call() throws ParseException {
}
});
try {
- statement = future.get(parser.getConfiguration().getAsLong(Feature.timeOut),
+ statement = future.get(parser.getAsLong(Feature.timeOut),
TimeUnit.MILLISECONDS);
} catch (TimeoutException ex) {
parser.interrupted = true;
@@ -397,7 +394,8 @@ public static Statements parseStatements(String sqls, ExecutorService executorSe
if (consumer != null) {
consumer.accept(parser);
}
- boolean allowComplex = parser.getConfiguration().getAsBoolean(Feature.allowComplexParsing);
+ boolean allowComplex = parser.getAsBoolean(Feature.allowComplexParsing);
+ int allowedNestingDepth = parser.getAsInt(Feature.allowedNestingDepth);
// first, try to parse fast and simple
try {
@@ -405,7 +403,8 @@ public static Statements parseStatements(String sqls, ExecutorService executorSe
} catch (JSQLParserException ex) {
// when fast simple parsing fails, try complex parsing but only if it has a chance to
// succeed
- if (allowComplex && getNestingDepth(sqls) <= ALLOWED_NESTING_DEPTH) {
+ if (allowComplex
+ && (allowedNestingDepth < 0 || getNestingDepth(sqls) <= allowedNestingDepth)) {
// beware: parser must not be re-used but needs to be re-initiated
parser = newParser(sqls);
if (consumer != null) {
@@ -434,7 +433,7 @@ public Statements call() throws ParseException {
}
});
try {
- statements = future.get(parser.getConfiguration().getAsLong(Feature.timeOut),
+ statements = future.get(parser.getAsLong(Feature.timeOut),
TimeUnit.MILLISECONDS);
} catch (TimeoutException ex) {
parser.interrupted = true;
@@ -450,17 +449,14 @@ public static void streamStatements(StatementListener listener, InputStream is,
throws JSQLParserException {
try {
CCJSqlParser parser = newParser(is, encoding);
- while (true) {
+ do {
Statement stmt = parser.SingleStatement();
listener.accept(stmt);
if (parser.getToken(1).kind == CCJSqlParserTokenManager.ST_SEMICOLON) {
parser.getNextToken();
}
- if (parser.getToken(1).kind == CCJSqlParserTokenManager.EOF) {
- break;
- }
- }
+ } while (parser.getToken(1).kind != CCJSqlParserTokenManager.EOF);
} catch (Exception ex) {
throw new JSQLParserException(ex);
}
diff --git a/src/main/java/net/sf/jsqlparser/parser/ParserKeywordsUtils.java b/src/main/java/net/sf/jsqlparser/parser/ParserKeywordsUtils.java
index 6e6019a64..19e1ad471 100644
--- a/src/main/java/net/sf/jsqlparser/parser/ParserKeywordsUtils.java
+++ b/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},
@@ -63,14 +64,18 @@ public class ParserKeywordsUtils {
{"CURRENT", RESTRICTED_JSQLPARSER},
{"DEFAULT", RESTRICTED_ALIAS},
{"DISTINCT", RESTRICTED_SQL2016},
+ {"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},
@@ -86,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},
@@ -115,18 +121,22 @@ public class ParserKeywordsUtils {
{"OVERWRITE ", RESTRICTED_JSQLPARSER},
{"PIVOT", RESTRICTED_JSQLPARSER},
{"PREFERRING", RESTRICTED_JSQLPARSER},
+ {"PREWHERE", RESTRICTED_JSQLPARSER},
{"PRIOR", RESTRICTED_ALIAS},
{"PROCEDURE", RESTRICTED_ALIAS},
{"PUBLIC", RESTRICTED_ALIAS},
+ {"RETURNS", RESTRICTED_JSQLPARSER},
{"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 +156,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},
diff --git a/src/main/java/net/sf/jsqlparser/parser/SimpleCharStream.java b/src/main/java/net/sf/jsqlparser/parser/SimpleCharStream.java
index b96578e01..c10c568a6 100644
--- a/src/main/java/net/sf/jsqlparser/parser/SimpleCharStream.java
+++ b/src/main/java/net/sf/jsqlparser/parser/SimpleCharStream.java
@@ -2,29 +2,30 @@
* #%L
* JSQLParser library
* %%
- * Copyright (C) 2004 - 2019 JSQLParser
+ * Copyright (C) 2004 - 2025 JSQLParser
* %%
* Dual licensed under GNU LGPL 2.1 or Apache License 2.0
* #L%
*/
+/* Generated By:JavaCC: Do not edit this line. SimpleCharStream.java Version 8.0.0 */
package net.sf.jsqlparser.parser;
-import java.io.IOException;
+/**
+ * An implementation of interface CharStream, where the stream is assumed to contain only ASCII
+ * characters (without unicode processing).
+ */
-@SuppressWarnings({"PMD.MethodNamingConventions", "PMD.CyclomaticComplexity"})
public class SimpleCharStream {
-
/**
* Whether parser is static.
*/
- @SuppressWarnings("checkstyle:constantname")
public static final boolean staticFlag = false;
/**
* Position in buffer.
*/
public int bufpos = -1;
- protected int bufline[];
- protected int bufcolumn[];
+ protected int[] bufline;
+ protected int[] bufcolumn;
protected int column = 0;
protected int line = 1;
protected boolean prevCharIsCR = false;
@@ -40,52 +41,30 @@ public class SimpleCharStream {
int bufsize;
int available;
int tokenBegin;
- private boolean isStringProvider;
/**
- * Constructor
- *
- * @param dstream
- * @param startline
- * @param startcolumn
- * @param buffersize
+ * Constructor.
*/
- public SimpleCharStream(Provider dstream, int startline,
- int startcolumn, int buffersize) {
+ public SimpleCharStream(Provider dstream, int startline, int startcolumn, int buffersize) {
inputStream = dstream;
- isStringProvider = dstream instanceof StringProvider;
line = startline;
column = startcolumn - 1;
- if (isStringProvider) {
- int bs = ((StringProvider) inputStream)._string.length();
- available = bufsize = bs;
- bufline = new int[bs];
- bufcolumn = new int[bs];
- } else {
- available = bufsize = buffersize;
- buffer = new char[buffersize];
- bufline = new int[buffersize];
- bufcolumn = new int[buffersize];
- }
+ available = bufsize = buffersize;
+ buffer = new char[buffersize];
+ bufline = new int[buffersize];
+ bufcolumn = new int[buffersize];
}
/**
- * Constructor
- *
- * @param dstream
- * @param startline
- * @param startcolumn
+ * Constructor.
*/
- public SimpleCharStream(Provider dstream, int startline,
- int startcolumn) {
+ public SimpleCharStream(Provider dstream, int startline, int startcolumn) {
this(dstream, startline, startcolumn, 4096);
}
/**
- * Constructor
- *
- * @param dstream
+ * Constructor.
*/
public SimpleCharStream(Provider dstream) {
this(dstream, 1, 1, 4096);
@@ -103,10 +82,10 @@ public final int getAbsoluteTokenBegin() {
return absoluteTokenBegin;
}
- protected void ExpandBuff(boolean wrapAround) throws IOException {
+ protected void ExpandBuff(boolean wrapAround) {
char[] newbuffer = new char[bufsize + 2048];
- int newbufline[] = new int[bufsize + 2048];
- int newbufcolumn[] = new int[bufsize + 2048];
+ int[] newbufline = new int[bufsize + 2048];
+ int[] newbufcolumn = new int[bufsize + 2048];
try {
if (wrapAround) {
@@ -136,16 +115,17 @@ protected void ExpandBuff(boolean wrapAround) throws IOException {
maxNextCharInd = bufpos -= tokenBegin;
}
} catch (Throwable t) {
- throw new IOException("Errow expanding the buffer.", t);
+ throw new Error(t.getMessage());
}
+
bufsize += 2048;
available = bufsize;
tokenBegin = 0;
}
- protected void FillBuff() throws IOException {
- if (!isStringProvider && maxNextCharInd == available) {
+ protected void FillBuff() throws java.io.IOException {
+ if (maxNextCharInd == available) {
if (available == bufsize) {
if (tokenBegin > 2048) {
bufpos = maxNextCharInd = 0;
@@ -166,23 +146,13 @@ protected void FillBuff() throws IOException {
int i;
try {
- if (inputStream instanceof StringProvider) {
- i = ((StringProvider) inputStream)._string.length();
- if (maxNextCharInd == i) {
- throw new IOException();
- }
- maxNextCharInd = i;
+ if ((i = inputStream.read(buffer, maxNextCharInd, available - maxNextCharInd)) == -1) {
+ inputStream.close();
+ throw new java.io.IOException();
} else {
- if ((i = inputStream.read(buffer, maxNextCharInd,
- available - maxNextCharInd)) == -1) {
- inputStream.close();
- throw new IOException();
- } else {
- maxNextCharInd += i;
- }
+ maxNextCharInd += i;
}
- return;
- } catch (IOException e) {
+ } catch (java.io.IOException e) {
--bufpos;
backup(0);
if (tokenBegin == -1) {
@@ -194,15 +164,14 @@ protected void FillBuff() throws IOException {
/**
* Start.
- *
- * @return the character read
- * @throws IOException
*/
- public char BeginToken() throws IOException {
+ public char BeginToken() throws java.io.IOException {
tokenBegin = -1;
char c = readChar();
tokenBegin = bufpos;
+
absoluteTokenBegin = totalCharsRead;
+
return c;
}
@@ -230,7 +199,7 @@ protected void UpdateLineColumn(char c) {
break;
case '\t':
column--;
- column += tabSize - (column % tabSize);
+ column += tabSize - column % tabSize;
break;
default:
break;
@@ -240,21 +209,10 @@ protected void UpdateLineColumn(char c) {
bufcolumn[bufpos] = column;
}
- private char readChar(int pos) {
- if (this.inputStream instanceof StringProvider) {
- return ((StringProvider) inputStream)._string.charAt(pos);
- } else {
- return buffer[pos];
- }
- }
-
/**
* Read a character.
- *
- * @return the character read
- * @throws IOException
*/
- public char readChar() throws IOException {
+ public char readChar() throws java.io.IOException {
if (inBuf > 0) {
--inBuf;
@@ -263,7 +221,8 @@ public char readChar() throws IOException {
}
totalCharsRead++;
- return readChar(bufpos);
+
+ return buffer[bufpos];
}
if (++bufpos >= maxNextCharInd) {
@@ -272,53 +231,55 @@ public char readChar() throws IOException {
totalCharsRead++;
- char c = readChar(bufpos);
+ char c = buffer[bufpos];
UpdateLineColumn(c);
return c;
}
+ @Deprecated
/**
- * @return the column
- * @deprecated @see #getEndColumn
+ * @deprecated
+ * @see #getEndColumn
*/
- @Deprecated
+
public int getColumn() {
return bufcolumn[bufpos];
}
+ @Deprecated
/**
- * @return the line
- * @deprecated @see #getEndLine
+ * @deprecated
+ * @see #getEndLine
*/
- @Deprecated
+
public int getLine() {
return bufline[bufpos];
}
/**
- * @return get token end column number.
+ * Get token end column number.
*/
public int getEndColumn() {
return bufcolumn[bufpos];
}
/**
- * @return get token end line number.
+ * Get token end line number.
*/
public int getEndLine() {
return bufline[bufpos];
}
/**
- * @return get token beginning column number.
+ * Get token beginning column number.
*/
public int getBeginColumn() {
return bufcolumn[tokenBegin];
}
/**
- * @return get token beginning line number.
+ * Get token beginning line number.
*/
public int getBeginLine() {
return bufline[tokenBegin];
@@ -326,8 +287,6 @@ public int getBeginLine() {
/**
* Backup a number of characters.
- *
- * @param amount
*/
public void backup(int amount) {
@@ -340,30 +299,17 @@ public void backup(int amount) {
/**
* Reinitialise.
- *
- * @param dstream
- * @param startline
- * @param startcolumn
- * @param buffersize
*/
- public void ReInit(Provider dstream, int startline,
- int startcolumn, int buffersize) {
+ public void ReInit(Provider dstream, int startline, int startcolumn, int buffersize) {
inputStream = dstream;
- isStringProvider = dstream instanceof StringProvider;
line = startline;
column = startcolumn - 1;
- if (isStringProvider) {
- int bs = ((StringProvider) inputStream)._string.length();
- available = bufsize = bs;
- bufline = new int[bs];
- bufcolumn = new int[bs];
- } else {
- if (buffer == null || buffersize != buffer.length) {
- available = bufsize = buffersize;
- buffer = new char[buffersize];
- bufline = new int[buffersize];
- bufcolumn = new int[buffersize];
- }
+
+ if (buffer == null || buffersize != buffer.length) {
+ available = bufsize = buffersize;
+ buffer = new char[buffersize];
+ bufline = new int[buffersize];
+ bufcolumn = new int[buffersize];
}
prevCharIsLF = prevCharIsCR = false;
tokenBegin = inBuf = maxNextCharInd = 0;
@@ -372,72 +318,42 @@ public void ReInit(Provider dstream, int startline,
/**
* Reinitialise.
- *
- * @param dstream
- * @param startline
- * @param startcolumn
*/
- public void ReInit(Provider dstream, int startline,
- int startcolumn) {
+ public void ReInit(Provider dstream, int startline, int startcolumn) {
ReInit(dstream, startline, startcolumn, 4096);
}
/**
* Reinitialise.
- *
- * @param dstream
*/
public void ReInit(Provider dstream) {
ReInit(dstream, 1, 1, 4096);
}
+
/**
- * @return get token literal value.
+ * Get token literal value.
*/
public String GetImage() {
- if (isStringProvider) {
- String data = ((StringProvider) inputStream)._string;
- if (bufpos >= tokenBegin) {
- return data.substring(tokenBegin, bufpos + 1);
- } else {
- return data.substring(tokenBegin, bufsize)
- + data.substring(0, bufpos + 1);
- }
+ if (bufpos >= tokenBegin) {
+ return new String(buffer, tokenBegin, bufpos - tokenBegin + 1);
} else {
- if (bufpos >= tokenBegin) {
- return new String(buffer, tokenBegin, bufpos - tokenBegin + 1);
- } else {
- return new String(buffer, tokenBegin, bufsize - tokenBegin)
- + new String(buffer, 0, bufpos + 1);
- }
+ return new String(buffer, tokenBegin, bufsize - tokenBegin)
+ + new String(buffer, 0, bufpos + 1);
}
}
/**
- * @param len
- * @return get the suffix.
+ * Get the suffix.
*/
public char[] GetSuffix(int len) {
-
char[] ret = new char[len];
- if (isStringProvider) {
- String str = ((StringProvider) inputStream)._string;
- if ((bufpos + 1) >= len) {
- str.getChars(bufpos - len + 1, bufpos - len + 1 + len, ret, 0);
- } else {
- str.getChars(bufsize - (len - bufpos - 1),
- bufsize - (len - bufpos - 1) + len - bufpos - 1, ret, 0);
- str.getChars(0, bufpos + 1, ret, len - bufpos - 1);
- }
+ if ((bufpos + 1) >= len) {
+ System.arraycopy(buffer, bufpos - len + 1, ret, 0, len);
} else {
- if ((bufpos + 1) >= len) {
- System.arraycopy(buffer, bufpos - len + 1, ret, 0, len);
- } else {
- System.arraycopy(buffer, bufsize - (len - bufpos - 1), ret, 0,
- len - bufpos - 1);
- System.arraycopy(buffer, 0, ret, len - bufpos - 1, bufpos + 1);
- }
+ System.arraycopy(buffer, bufsize - (len - bufpos - 1), ret, 0, len - bufpos - 1);
+ System.arraycopy(buffer, 0, ret, len - bufpos - 1, bufpos + 1);
}
return ret;
@@ -454,12 +370,8 @@ public void Done() {
/**
* Method to adjust line and column numbers for the start of a token.
- *
- * @param newLine
- * @param newCol
*/
public void adjustBeginLineColumn(int newLine, int newCol) {
- int nl = newLine;
int start = tokenBegin;
int len;
@@ -471,12 +383,12 @@ public void adjustBeginLineColumn(int newLine, int newCol) {
int i = 0;
int j = 0;
- int k = 0;
- int nextColDiff = 0;
+ int k;
+ int nextColDiff;
int columnDiff = 0;
while (i < len && bufline[j = start % bufsize] == bufline[k = ++start % bufsize]) {
- bufline[j] = nl;
+ bufline[j] = newLine;
nextColDiff = columnDiff + bufcolumn[k] - bufcolumn[j];
bufcolumn[j] = newCol + columnDiff;
columnDiff = nextColDiff;
@@ -484,14 +396,14 @@ public void adjustBeginLineColumn(int newLine, int newCol) {
}
if (i < len) {
- bufline[j] = nl++;
+ bufline[j] = newLine++;
bufcolumn[j] = newCol + columnDiff;
while (i++ < len) {
if (bufline[j = start % bufsize] != bufline[++start % bufsize]) {
- bufline[j] = nl++;
+ bufline[j] = newLine++;
} else {
- bufline[j] = nl;
+ bufline[j] = newLine;
}
}
}
@@ -508,4 +420,4 @@ void setTrackLineColumn(boolean tlc) {
trackLineColumn = tlc;
}
}
-/* JavaCC - OriginalChecksum=47e65cd0a1ed785f7a51c9e0c60893c9 (do not edit this line) */
+/* JavaCC - OriginalChecksum=0cd74e5ad7a4ccb9188541ab8f8b35eb (do not edit this line) */
diff --git a/src/main/java/net/sf/jsqlparser/parser/feature/Feature.java b/src/main/java/net/sf/jsqlparser/parser/feature/Feature.java
index 75b5c78a5..d786f5170 100644
--- a/src/main/java/net/sf/jsqlparser/parser/feature/Feature.java
+++ b/src/main/java/net/sf/jsqlparser/parser/feature/Feature.java
@@ -792,6 +792,36 @@ public enum Feature {
* allows sub selects without parentheses, e.g. `select * from dual where 1 = select 1`
*/
allowUnparenthesizedSubSelects(false),
+
+ /**
+ * maximum nesting depth for trying complex parsing, can bet set to -1 to ignore
+ */
+ allowedNestingDepth(10),
+
+ dialect(null),
+
+ /**
+ * "IMPORT"
+ */
+ imprt,
+
+ /**
+ * "EXPORT"
+ */
+ export,
+
+ /**
+ * MySQL allows a ',' as a separator between key and value entries. We allow that by default,
+ * but it can be disabled here
+ */
+ allowCommaAsKeyValueSeparator(true),
+
+ /**
+ * DB2 and Oracle allow Expressions as JSON_OBJECT key values. This clashes with Informix and
+ * Snowflake Json-Extraction syntax
+ */
+ allowExpressionAsJsonObjectKey(false)
+
;
private final Object value;
diff --git a/src/main/java/net/sf/jsqlparser/parser/feature/FeatureConfiguration.java b/src/main/java/net/sf/jsqlparser/parser/feature/FeatureConfiguration.java
index da5ddd2b0..0106431cc 100644
--- a/src/main/java/net/sf/jsqlparser/parser/feature/FeatureConfiguration.java
+++ b/src/main/java/net/sf/jsqlparser/parser/feature/FeatureConfiguration.java
@@ -19,7 +19,7 @@ public class FeatureConfiguration {
private static final Logger LOG = Logger.getLogger(FeatureConfiguration.class.getName());
- private Map featureEnabled = new EnumMap<>(Feature.class);
+ private final Map featureEnabled = new EnumMap<>(Feature.class);
public FeatureConfiguration() {
// set default-value for all switchable features
@@ -64,6 +64,14 @@ public Long getAsLong(Feature f) {
return Long.valueOf(String.valueOf(getValue(f)));
}
+ public int getAsInt(Feature f) {
+ return Integer.parseInt(String.valueOf(getValue(f)));
+ }
+
+ public Integer getAsInteger(Feature f) {
+ return Integer.parseInt(String.valueOf(getValue(f)));
+ }
+
public String getAsString(Feature f) {
Object value = getValue(f);
return value == null ? null : String.valueOf(value);
diff --git a/src/main/java/net/sf/jsqlparser/schema/Column.java b/src/main/java/net/sf/jsqlparser/schema/Column.java
index 2aa0994cd..1c1427c86 100644
--- a/src/main/java/net/sf/jsqlparser/schema/Column.java
+++ b/src/main/java/net/sf/jsqlparser/schema/Column.java
@@ -16,6 +16,7 @@
import net.sf.jsqlparser.expression.ArrayConstructor;
import net.sf.jsqlparser.expression.Expression;
import net.sf.jsqlparser.expression.ExpressionVisitor;
+import net.sf.jsqlparser.expression.operators.relational.SupportsOldOracleJoinSyntax;
import net.sf.jsqlparser.parser.ASTNodeAccessImpl;
/**
@@ -28,6 +29,10 @@ public class Column extends ASTNodeAccessImpl implements Expression, MultiPartNa
private String commentText;
private ArrayConstructor arrayConstructor;
private String tableDelimiter = ".";
+ private int oldOracleJoinSyntax = SupportsOldOracleJoinSyntax.NO_ORACLE_JOIN;
+
+ // holds the physical table when resolved against an actual schema information
+ private Table resolvedTable = null;
public Column() {}
@@ -50,7 +55,8 @@ public Column(List nameParts, List delimiters) {
}
public Column(String columnName) {
- this(null, columnName);
+ this();
+ setColumnName(columnName);
}
public ArrayConstructor getArrayConstructor() {
@@ -128,8 +134,56 @@ public String getUnquotedColumnName() {
return MultiPartName.unquote(columnName);
}
- public void setColumnName(String string) {
- columnName = string;
+ public void setColumnName(String name) {
+ // BigQuery seems to allow things like: `catalogName.schemaName.tableName` in only one pair
+ // of quotes
+ // however, some people believe that Dots in Names are a good idea, so provide a switch-off
+ boolean splitNamesOnDelimiter = System.getProperty("SPLIT_NAMES_ON_DELIMITER") == null ||
+ !List
+ .of("0", "N", "n", "FALSE", "false", "OFF", "off")
+ .contains(System.getProperty("SPLIT_NAMES_ON_DELIMITER"));
+
+ setName(name, splitNamesOnDelimiter);
+ }
+
+ public void setName(String name, boolean splitNamesOnDelimiter) {
+ if (MultiPartName.isQuoted(name) && name.contains(".") && splitNamesOnDelimiter) {
+ String[] parts = MultiPartName.unquote(name).split("\\.");
+ switch (parts.length) {
+ case 3:
+ this.table = new Table("\"" + parts[0] + "\".\"" + parts[1] + "\"");
+ this.columnName = "\"" + parts[2] + "\"";
+ break;
+ case 2:
+ this.table = new Table("\"" + parts[0] + "\"");
+ this.columnName = "\"" + parts[1] + "\"";
+ break;
+ case 1:
+ this.columnName = "\"" + parts[0] + "\"";
+ break;
+ default:
+ throw new RuntimeException("Invalid column name: " + name);
+ }
+ } else if (name.contains(".") && splitNamesOnDelimiter) {
+ String[] parts = MultiPartName.unquote(name).split("\\.");
+ switch (parts.length) {
+ case 3:
+ this.table = new Table(parts[0] + "." + parts[1]);
+ this.columnName = parts[2];
+ break;
+ case 2:
+ this.table = new Table(parts[0]);
+ this.columnName = parts[1];
+ break;
+ case 1:
+ this.columnName = parts[0];
+ break;
+ default:
+ throw new RuntimeException("Invalid column name: " + name);
+ }
+ } else {
+ this.columnName = name;
+ }
}
public String getTableDelimiter() {
@@ -140,6 +194,14 @@ public void setTableDelimiter(String tableDelimiter) {
this.tableDelimiter = tableDelimiter;
}
+ public int getOldOracleJoinSyntax() {
+ return oldOracleJoinSyntax;
+ }
+
+ public void setOldOracleJoinSyntax(int oldOracleJoinSyntax) {
+ this.oldOracleJoinSyntax = oldOracleJoinSyntax;
+ }
+
@Override
public String getFullyQualifiedName() {
return getFullyQualifiedName(false);
@@ -193,6 +255,7 @@ public T accept(ExpressionVisitor expressionVisitor, S context) {
@Override
public String toString() {
return getFullyQualifiedName(true)
+ + (oldOracleJoinSyntax != SupportsOldOracleJoinSyntax.NO_ORACLE_JOIN ? "(+)" : "")
+ (commentText != null ? " /* " + commentText + "*/ " : "");
}
@@ -216,6 +279,11 @@ public Column withTableDelimiter(String delimiter) {
return this;
}
+ public Column withOldOracleJoinSyntax(int oldOracleJoinSyntax) {
+ this.setOldOracleJoinSyntax(oldOracleJoinSyntax);
+ return this;
+ }
+
public String getCommentText() {
return commentText;
}
@@ -223,4 +291,26 @@ public String getCommentText() {
public void setCommentText(String commentText) {
this.commentText = commentText;
}
+
+ /**
+ * Gets the actual table when resolved against a physical schema information.
+ *
+ * @return the actual table when resolved against a physical schema information
+ */
+ public Table getResolvedTable() {
+ return resolvedTable;
+ }
+
+ /**
+ * Sets resolved table.
+ *
+ * @param resolvedTable the resolved table
+ * @return this column
+ */
+ public Column setResolvedTable(Table resolvedTable) {
+ // clone, not reference
+ this.resolvedTable =
+ resolvedTable != null ? new Table(resolvedTable.getFullyQualifiedName()) : null;
+ return this;
+ }
}
diff --git a/src/main/java/net/sf/jsqlparser/schema/MultiPartName.java b/src/main/java/net/sf/jsqlparser/schema/MultiPartName.java
index e2d985bc1..ce954780d 100644
--- a/src/main/java/net/sf/jsqlparser/schema/MultiPartName.java
+++ b/src/main/java/net/sf/jsqlparser/schema/MultiPartName.java
@@ -9,10 +9,12 @@
*/
package net.sf.jsqlparser.schema;
+import java.util.regex.Matcher;
import java.util.regex.Pattern;
public interface MultiPartName {
Pattern LEADING_TRAILING_QUOTES_PATTERN = Pattern.compile("^[\"\\[`]+|[\"\\]`]+$");
+ Pattern BACKTICK_PATTERN = Pattern.compile("`([^`]*)`");
/**
* Removes leading and trailing quotes from a SQL quoted identifier
@@ -27,10 +29,32 @@ static String unquote(String quotedIdentifier) {
}
static boolean isQuoted(String identifier) {
- return identifier!=null && LEADING_TRAILING_QUOTES_PATTERN.matcher(identifier).find();
+ return identifier != null && LEADING_TRAILING_QUOTES_PATTERN.matcher(identifier).find();
}
String getFullyQualifiedName();
String getUnquotedName();
+
+
+ static String replaceBackticksWithDoubleQuotes(String input) {
+ if (input == null || input.isEmpty()) {
+ return input;
+ }
+
+ Matcher matcher = BACKTICK_PATTERN.matcher(input);
+ StringBuilder sb = new StringBuilder();
+ int lastEnd = 0;
+
+ while (matcher.find()) {
+ sb.append(input, lastEnd, matcher.start()); // text before match
+ sb.append('"').append(matcher.group(1)).append('"'); // replace with double quotes
+ lastEnd = matcher.end();
+ }
+
+ sb.append(input.substring(lastEnd)); // append remaining text
+ return sb.toString();
+ }
+
+
}
diff --git a/src/main/java/net/sf/jsqlparser/schema/Sequence.java b/src/main/java/net/sf/jsqlparser/schema/Sequence.java
index 2f813c1d7..083122434 100644
--- a/src/main/java/net/sf/jsqlparser/schema/Sequence.java
+++ b/src/main/java/net/sf/jsqlparser/schema/Sequence.java
@@ -158,7 +158,7 @@ public Sequence addParameters(Collection parameters) {
* The available parameters to a sequence
*/
public enum ParameterType {
- INCREMENT_BY, START_WITH, RESTART_WITH, MAXVALUE, NOMAXVALUE, MINVALUE, NOMINVALUE, CYCLE, NOCYCLE, CACHE, NOCACHE, ORDER, NOORDER, KEEP, NOKEEP, SESSION, GLOBAL;
+ INCREMENT_BY, INCREMENT, START_WITH, START, RESTART_WITH, MAXVALUE, NOMAXVALUE, MINVALUE, NOMINVALUE, CYCLE, NOCYCLE, CACHE, NOCACHE, ORDER, NOORDER, KEEP, NOKEEP, SESSION, GLOBAL;
public static ParameterType from(String type) {
return Enum.valueOf(ParameterType.class, type.toUpperCase());
@@ -189,8 +189,12 @@ public String formatParameter() {
switch (option) {
case INCREMENT_BY:
return prefix("INCREMENT BY");
+ case INCREMENT:
+ return prefix("INCREMENT");
case START_WITH:
return prefix("START WITH");
+ case START:
+ return prefix("START");
case RESTART_WITH:
if (value != null) {
return prefix("RESTART WITH");
diff --git a/src/main/java/net/sf/jsqlparser/schema/Table.java b/src/main/java/net/sf/jsqlparser/schema/Table.java
index 066326a88..1de14a8a5 100644
--- a/src/main/java/net/sf/jsqlparser/schema/Table.java
+++ b/src/main/java/net/sf/jsqlparser/schema/Table.java
@@ -10,6 +10,7 @@
package net.sf.jsqlparser.schema;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Collections;
import java.util.List;
@@ -17,6 +18,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,11 +29,9 @@
/**
* 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, Cloneable {
- // private Database database;
- // private String schemaName;
- // private String name;
private static final int NAME_IDX = 0;
private static final int SCHEMA_IDX = 1;
@@ -44,8 +44,14 @@ public class Table extends ASTNodeAccessImpl implements FromItem, MultiPartName
private List partDelimiters = new ArrayList<>();
+ // holds the various `time travel` syntax for BigQuery, RedShift, Snowflake or RedShift
+ private String timeTravelStr = null;
+
private Alias alias;
+ // thank you, Google!
+ private String timeTravelStrAfterAlias = null;
+
private SampleClause sampleClause;
private Pivot pivot;
@@ -56,6 +62,9 @@ public class Table extends ASTNodeAccessImpl implements FromItem, MultiPartName
private SQLServerHints sqlServerHints;
+ // holds the physical table when resolved against an actual schema information
+ private Table resolvedTable = null;
+
public Table() {}
/**
@@ -70,6 +79,10 @@ public Table(String name) {
setName(name);
}
+ public Table(String name, boolean splitNamesOnDelimiter) {
+ setName(name, splitNamesOnDelimiter);
+ }
+
public Table(String schemaName, String name) {
setSchemaName(schemaName);
setName(name);
@@ -157,7 +170,49 @@ public String getUnquotedSchemaName() {
}
public Table setSchemaName(String schemaName) {
- this.setIndex(SCHEMA_IDX, schemaName);
+ if (schemaName == null) {
+ setIndex(SCHEMA_IDX, null);
+ return this;
+ }
+
+ // BigQuery seems to allow things like: `catalogName.schemaName.tableName` in only one pair
+ // of quotes
+ // however, some people believe that Dots in Names are a good idea, so provide a switch-off
+ boolean splitNamesOnDelimiter = System.getProperty("SPLIT_NAMES_ON_DELIMITER") == null ||
+ !List
+ .of("0", "N", "n", "FALSE", "false", "OFF", "off")
+ .contains(System.getProperty("SPLIT_NAMES_ON_DELIMITER"));
+
+ if (MultiPartName.isQuoted(schemaName) && schemaName.contains(".")
+ && splitNamesOnDelimiter) {
+ String[] parts = MultiPartName.unquote(schemaName).split("\\.");
+ switch (parts.length) {
+ case 2:
+ setIndex(DATABASE_IDX, "\"" + parts[0] + "\"");
+ setIndex(SCHEMA_IDX, "\"" + parts[1] + "\"");
+ break;
+ case 1:
+ setIndex(SCHEMA_IDX, "\"" + parts[0] + "\"");
+ break;
+ default:
+ throw new RuntimeException("Invalid schema name: " + schemaName);
+ }
+ } else if (schemaName.contains(".") && splitNamesOnDelimiter) {
+ String[] parts = MultiPartName.unquote(schemaName).split("\\.");
+ switch (parts.length) {
+ case 2:
+ setIndex(DATABASE_IDX, parts[0]);
+ setIndex(SCHEMA_IDX, parts[1]);
+ break;
+ case 1:
+ setIndex(SCHEMA_IDX, parts[0]);
+ break;
+ default:
+ throw new RuntimeException("Invalid schema name: " + schemaName);
+ }
+ } else {
+ this.setIndex(SCHEMA_IDX, schemaName);
+ }
return this;
}
@@ -193,12 +248,20 @@ public void setName(String name) {
.of("0", "N", "n", "FALSE", "false", "OFF", "off")
.contains(System.getProperty("SPLIT_NAMES_ON_DELIMITER"));
+ setName(name, splitNamesOnDelimiter);
+ }
+
+ public void setName(String name, boolean splitNamesOnDelimiter) {
if (MultiPartName.isQuoted(name) && name.contains(".") && splitNamesOnDelimiter) {
partItems.clear();
for (String unquotedIdentifier : MultiPartName.unquote(name).split("\\.")) {
partItems.add("\"" + unquotedIdentifier + "\"");
}
Collections.reverse(partItems);
+ } else if (name.contains(".") && splitNamesOnDelimiter) {
+ partItems.clear();
+ partItems.addAll(Arrays.asList(MultiPartName.unquote(name).split("\\.")));
+ Collections.reverse(partItems);
} else {
setIndex(NAME_IDX, name);
}
@@ -230,6 +293,19 @@ public void setAlias(Alias alias) {
this.alias = alias;
}
+ public String getTimeTravelStrAfterAlias() {
+ return timeTravelStrAfterAlias;
+ }
+
+ public Table setTimeTravelStrAfterAlias(String timeTravelStrAfterAlias) {
+ this.timeTravelStrAfterAlias = timeTravelStrAfterAlias;
+ return this;
+ }
+
+ public void setNameParts(List nameParts) {
+ this.partItems = nameParts;
+ }
+
private void setIndex(int idx, String value) {
int size = partItems.size();
for (int i = 0; i < idx - size + 1; i++) {
@@ -290,6 +366,15 @@ public T accept(IntoTableVisitor intoTableVisitor, S context) {
return intoTableVisitor.visit(this, context);
}
+ public String getTimeTravel() {
+ return timeTravelStr;
+ }
+
+ public Table setTimeTravel(String timeTravelStr) {
+ this.timeTravelStr = timeTravelStr;
+ return this;
+ }
+
@Override
public Pivot getPivot() {
return pivot;
@@ -342,10 +427,19 @@ public Table setSampleClause(SampleClause sampleClause) {
public StringBuilder appendTo(StringBuilder builder) {
builder.append(getFullyQualifiedName());
+
+ if (timeTravelStr != null) {
+ builder.append(" ").append(timeTravelStr);
+ }
+
if (alias != null) {
builder.append(alias);
}
+ if (timeTravelStrAfterAlias != null) {
+ builder.append(" ").append(timeTravelStrAfterAlias);
+ }
+
if (sampleClause != null) {
sampleClause.appendTo(builder);
}
@@ -400,4 +494,74 @@ public List getNameParts() {
public List getNamePartDelimiters() {
return partDelimiters;
}
+
+ /**
+ * Gets the actual table when resolved against a physical schema information.
+ *
+ * @return the actual table when resolved against a physical schema information
+ */
+ public Table getResolvedTable() {
+ return resolvedTable;
+ }
+
+ /**
+ * Sets resolved table.
+ *
+ * @param resolvedTable the resolved table
+ * @return this table
+ */
+ public Table setResolvedTable(Table resolvedTable) {
+ // clone, not reference
+ if (resolvedTable != null) {
+ this.resolvedTable = new Table(resolvedTable.getFullyQualifiedName());
+ }
+ return this;
+ }
+
+ /**
+ * Sets a table's catalog and schema only when not set. Useful for setting CURRENT_SCHEMA() and
+ * CURRENT_DATABASE()
+ *
+ * @param currentCatalogName the catalog name
+ * @param currentSchemaName the schema name
+ * @return the provided table
+ */
+ public Table setUnsetCatalogAndSchema(String currentCatalogName, String currentSchemaName) {
+ String databaseName = getDatabaseName();
+ if (databaseName == null || databaseName.isEmpty()) {
+ setDatabaseName(currentCatalogName);
+ }
+
+ String schemaName = getSchemaName();
+ if (schemaName == null || schemaName.isEmpty()) {
+ setSchemaName(currentSchemaName);
+ }
+ return this;
+ }
+
+ /**
+ * Sets a tables' catalog and schema only when not set. Useful for setting CURRENT_SCHEMA() and
+ * CURRENT_DATABASE()
+ *
+ * @param currentCatalogName the current catalog name
+ * @param currentSchemaName the current schema name
+ * @param tables the tables
+ * @return the tables
+ */
+ public static Table[] setUnsetCatalogAndSchema(String currentCatalogName,
+ String currentSchemaName, Table... tables) {
+ for (Table t : tables) {
+ if (t != null) {
+ t.setUnsetCatalogAndSchema(currentCatalogName, currentSchemaName);
+ }
+ }
+ return tables;
+ }
+
+ @Override
+ public Table clone() {
+ Table clone = new Table(this.getFullyQualifiedName());
+ clone.setResolvedTable(this.resolvedTable != null ? this.resolvedTable.clone() : null);
+ return clone;
+ }
}
diff --git a/src/main/java/net/sf/jsqlparser/statement/CSVColumn.java b/src/main/java/net/sf/jsqlparser/statement/CSVColumn.java
new file mode 100644
index 000000000..08c7f4d1d
--- /dev/null
+++ b/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();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/CSVFileDestination.java b/src/main/java/net/sf/jsqlparser/statement/CSVFileDestination.java
new file mode 100644
index 000000000..697368f83
--- /dev/null
+++ b/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();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/CertificateVerification.java b/src/main/java/net/sf/jsqlparser/statement/CertificateVerification.java
new file mode 100644
index 000000000..7aabbb060
--- /dev/null
+++ b/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();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/CloudConnectionDefinition.java b/src/main/java/net/sf/jsqlparser/statement/CloudConnectionDefinition.java
new file mode 100644
index 000000000..82b65fbd7
--- /dev/null
+++ b/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();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/ConnectionDefinition.java b/src/main/java/net/sf/jsqlparser/statement/ConnectionDefinition.java
new file mode 100644
index 000000000..f2887cf82
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/ConnectionDefinition.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;
+
+import java.io.Serializable;
+
+public class ConnectionDefinition implements Serializable {
+ 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();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/ConnectionFileDefinition.java b/src/main/java/net/sf/jsqlparser/statement/ConnectionFileDefinition.java
new file mode 100644
index 000000000..f0e0d0cf1
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/ConnectionFileDefinition.java
@@ -0,0 +1,60 @@
+/*-
+ * #%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;
+
+import java.util.List;
+
+public class ConnectionFileDefinition {
+ private ConnectionDefinition connectionDefinition;
+ private List filePaths;
+
+ public ConnectionFileDefinition(List filePaths) {
+ this(null, filePaths);
+ }
+
+ public ConnectionFileDefinition(ConnectionDefinition connectionDefinition,
+ List filePaths) {
+ this.connectionDefinition = connectionDefinition;
+ this.filePaths = filePaths;
+ }
+
+ public ConnectionDefinition getConnectionDefinition() {
+ return connectionDefinition;
+ }
+
+ public void setConnectionDefinition(ConnectionDefinition connectionDefinition) {
+ this.connectionDefinition = connectionDefinition;
+ }
+
+ public List getFilePaths() {
+ return filePaths;
+ }
+
+ public void setFilePaths(List filePaths) {
+ this.filePaths = filePaths;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sql = new StringBuilder();
+
+ if (connectionDefinition != null) {
+ sql.append(connectionDefinition);
+ }
+
+ for (StringValue filePath : filePaths) {
+ sql.append(" FILE ").append(filePath);
+ }
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/DBMSType.java b/src/main/java/net/sf/jsqlparser/statement/DBMSType.java
new file mode 100644
index 000000000..4b3d667da
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/DBMSType.java
@@ -0,0 +1,52 @@
+/*-
+ * #%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.expression.StringValue;
+
+public class DBMSType implements SourceDestinationType {
+ private final Kind dbmsType;
+ private StringValue jdbcDriverDefinition;
+
+ public DBMSType(String dbmsType) {
+ this(dbmsType, null);
+ }
+
+ public DBMSType(String dbmsType, String jdbcDriverDefinition) {
+ this.dbmsType = Kind.valueOf(dbmsType.toUpperCase());
+ if (jdbcDriverDefinition != null) {
+ this.jdbcDriverDefinition = new StringValue(jdbcDriverDefinition);
+ }
+ }
+
+ private enum Kind {
+ EXA, ORA, JDBC
+ }
+
+ public StringValue getJDBCDriverDefinition() {
+ return jdbcDriverDefinition;
+ }
+
+ public void setJDBCDriverDefinition(StringValue jdbcDriverDefinition) {
+ this.jdbcDriverDefinition = jdbcDriverDefinition;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sql = new StringBuilder();
+
+ sql.append(dbmsType);
+ if (jdbcDriverDefinition != null) {
+ sql.append(" DRIVER = ").append(jdbcDriverDefinition);
+ }
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/ErrorClause.java b/src/main/java/net/sf/jsqlparser/statement/ErrorClause.java
new file mode 100644
index 000000000..92db1a3dc
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/ErrorClause.java
@@ -0,0 +1,90 @@
+/*-
+ * #%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.Expression;
+
+import java.io.Serializable;
+
+public class ErrorClause implements Serializable {
+ private ErrorDestination errorDestination;
+ private Expression expression;
+ private RejectClause rejectClause;
+ private boolean replace;
+ private boolean truncate;
+
+ public ErrorDestination getErrorDestination() {
+ return errorDestination;
+ }
+
+ public void setErrorDestination(ErrorDestination errorDestination) {
+ this.errorDestination = errorDestination;
+ }
+
+ public Expression getExpression() {
+ return expression;
+ }
+
+ public void setExpression(Expression expression) {
+ this.expression = expression;
+ }
+
+ public RejectClause getRejectClause() {
+ return rejectClause;
+ }
+
+ public void setRejectClause(RejectClause rejectClause) {
+ this.rejectClause = rejectClause;
+ }
+
+ public boolean isReplace() {
+ return replace;
+ }
+
+ public void setReplace(boolean replace) {
+ this.replace = replace;
+ }
+
+ public boolean isTruncate() {
+ return truncate;
+ }
+
+ public void setTruncate(boolean truncate) {
+ this.truncate = truncate;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sql = new StringBuilder();
+
+ if (errorDestination != null) {
+ sql.append("ERRORS INTO ");
+ sql.append(errorDestination);
+ if (expression != null) {
+ sql.append(" (");
+ sql.append(expression);
+ sql.append(")");
+ }
+
+ if (replace) {
+ sql.append(" REPLACE");
+ } else if (truncate) {
+ sql.append(" TRUNCATE");
+ }
+ }
+
+ if (rejectClause != null) {
+ sql.append(" ");
+ sql.append(rejectClause);
+ }
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/ErrorDestination.java b/src/main/java/net/sf/jsqlparser/statement/ErrorDestination.java
new file mode 100644
index 000000000..258a39ebb
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/ErrorDestination.java
@@ -0,0 +1,13 @@
+/*-
+ * #%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 interface ErrorDestination {
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/FBVColumn.java b/src/main/java/net/sf/jsqlparser/statement/FBVColumn.java
new file mode 100644
index 000000000..a1846efd9
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/FBVColumn.java
@@ -0,0 +1,98 @@
+/*-
+ * #%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.Expression;
+import net.sf.jsqlparser.expression.LongValue;
+import net.sf.jsqlparser.expression.StringValue;
+
+public class FBVColumn {
+ private boolean precedesComma;
+ private String key;
+ private Expression value;
+ private String stringValue;
+
+ private FBVColumn(String key, Expression value) {
+ this.key = key;
+ this.value = value;
+ this.stringValue = null;
+ }
+
+ public FBVColumn(String key, String value) {
+ this.key = key;
+ this.value = null;
+ this.stringValue = value;
+ }
+
+ public FBVColumn(String key, StringValue value) {
+ this(key, (Expression) value);
+ }
+
+ public FBVColumn(String key, LongValue value) {
+ this(key, (Expression) value);
+ }
+
+ public boolean precedesComma() {
+ return precedesComma;
+ }
+
+ public void setPrecedesComma(boolean precedesComma) {
+ this.precedesComma = precedesComma;
+ }
+
+ public String getKey() {
+ return key;
+ }
+
+ public void setKey(String key) {
+ this.key = key;
+ }
+
+ public Expression getValue() {
+ return value;
+ }
+
+ public void setValue(String value) {
+ this.stringValue = value;
+ this.value = null;
+ }
+
+ private void setValue(Expression value) {
+ this.value = value;
+ this.stringValue = null;
+ }
+
+ public void setValue(StringValue value) {
+ setValue((Expression) value);
+ }
+
+ public void setValue(LongValue value) {
+ setValue((Expression) value);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sql = new StringBuilder();
+
+ if (precedesComma) {
+ sql.append(", ");
+ }
+
+ sql.append(key);
+ sql.append(" = ");
+ if (stringValue != null) {
+ sql.append(stringValue);
+ } else {
+ sql.append(value);
+ }
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/FileOption.java b/src/main/java/net/sf/jsqlparser/statement/FileOption.java
new file mode 100644
index 000000000..ff91f571b
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/FileOption.java
@@ -0,0 +1,85 @@
+/*-
+ * #%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.Expression;
+import net.sf.jsqlparser.expression.LongValue;
+import net.sf.jsqlparser.expression.StringValue;
+
+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) {
+ this(key, (Expression) null);
+ }
+
+ public FileOption(String key, StringValue value) {
+ this(key, (Expression) value);
+ }
+
+ public FileOption(String key, LongValue value) {
+ this(key, (Expression) value);
+ }
+
+ public String getKey() {
+ return key;
+ }
+
+ public void setKey(String key) {
+ this.key = key;
+ }
+
+ public Expression getValue() {
+ return value;
+ }
+
+ public void setValue(StringValue value) {
+ this.value = value;
+ }
+
+ 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 || stringValue != null) {
+ sql.append(" = ");
+ if (stringValue != null) {
+ sql.append(stringValue);
+ } else {
+ sql.append(value);
+ }
+ }
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/FileSourceDestination.java b/src/main/java/net/sf/jsqlparser/statement/FileSourceDestination.java
new file mode 100644
index 000000000..d5a79ed8f
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/FileSourceDestination.java
@@ -0,0 +1,133 @@
+/*-
+ * #%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 connectionFileDefinitions;
+ private Boolean local;
+ private Boolean secure;
+ private List csvColumns;
+ private List fbvColumns;
+ private List fileOptions;
+ private CertificateVerification certificateVerification;
+
+ protected SourceDestinationType getType() {
+ return type;
+ }
+
+ protected void setType(SourceDestinationType type) {
+ this.type = type;
+ }
+
+ public List getConnectionFileDefinitions() {
+ return connectionFileDefinitions;
+ }
+
+ public void setConnectionFileDefinitions(
+ List 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 getCSVColumns() {
+ return csvColumns;
+ }
+
+ public void setCSVColumns(List csvColumns) {
+ this.csvColumns = csvColumns;
+ }
+
+ public List getFBVColumns() {
+ return fbvColumns;
+ }
+
+ public void setFBVColumns(List fbvColumns) {
+ this.fbvColumns = fbvColumns;
+ }
+
+ public List getFileOptions() {
+ return fileOptions;
+ }
+
+ public void setFileOptions(List 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();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/FileType.java b/src/main/java/net/sf/jsqlparser/statement/FileType.java
new file mode 100644
index 000000000..7ea1535f9
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/FileType.java
@@ -0,0 +1,27 @@
+/*-
+ * #%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;
+
+public class FileType implements SourceDestinationType {
+ private final Kind fileType;
+
+ public FileType(String fileType) {
+ this.fileType = Kind.valueOf(fileType.toUpperCase());
+ }
+
+ private enum Kind {
+ CSV, FBV
+ }
+
+ @Override
+ public String toString() {
+ return fileType.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/LikeClause.java b/src/main/java/net/sf/jsqlparser/statement/LikeClause.java
new file mode 100644
index 000000000..448b4de72
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/LikeClause.java
@@ -0,0 +1,142 @@
+/*-
+ * #%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.schema.Column;
+import net.sf.jsqlparser.schema.Table;
+import net.sf.jsqlparser.statement.imprt.ImportColumn;
+import net.sf.jsqlparser.statement.select.PlainSelect;
+import net.sf.jsqlparser.statement.select.SelectItem;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * Exasol Like Clause
+ *
+ * @see Like Clause in CREATE
+ * TABLE
+ * @see Like Clause in IMPORT
+ */
+public class LikeClause implements ImportColumn, Serializable {
+ private Table table;
+ private List> columnsList;
+
+ private Boolean includingDefaults;
+ private Boolean includingIdentity;
+ private Boolean includingComments;
+
+ public Table getTable() {
+ return table;
+ }
+
+ public void setTable(Table table) {
+ this.table = table;
+ }
+
+ public List> getColumnsList() {
+ return columnsList;
+ }
+
+ public void setColumnsList(List> columnsList) {
+ this.columnsList = columnsList;
+ }
+
+ public Boolean isIncludingDefaults() {
+ return includingDefaults;
+ }
+
+ public void setIncludingDefaults(Boolean includingDefaults) {
+ this.includingDefaults = includingDefaults;
+ }
+
+ public Boolean isExcludingDefaults() {
+ return includingDefaults == null ? null : !includingDefaults;
+ }
+
+ public void setExcludingDefaults(Boolean excludingDefaults) {
+ this.includingDefaults = !excludingDefaults;
+ }
+
+ public Boolean isIncludingIdentity() {
+ return includingIdentity;
+ }
+
+ public void setIncludingIdentity(Boolean includingIdentity) {
+ this.includingIdentity = includingIdentity;
+ }
+
+ public Boolean isExcludingIdentity() {
+ return includingIdentity == null ? null : !includingIdentity;
+ }
+
+ public void setExcludingIdentity(Boolean excludingIdentity) {
+ this.includingIdentity = !excludingIdentity;
+ }
+
+ public Boolean isIncludingComments() {
+ return includingComments;
+ }
+
+ public void setIncludingComments(Boolean includingComments) {
+ this.includingComments = includingComments;
+ }
+
+ public Boolean isExcludingComments() {
+ return includingComments == null ? null : !includingComments;
+ }
+
+ public void setExcludingComments(Boolean excludingComments) {
+ this.includingComments = !excludingComments;
+ }
+
+ public StringBuilder appendTo(StringBuilder builder) {
+ builder.append(" LIKE ");
+ builder.append(table);
+ if (columnsList != null) {
+ builder.append(" ");
+ PlainSelect.appendStringListTo(builder, columnsList, true, true);
+ }
+
+ if (includingDefaults != null) {
+ if (includingDefaults) {
+ builder.append(" INCLUDING ");
+ } else {
+ builder.append(" EXCLUDING ");
+ }
+ builder.append(" DEFAULTS ");
+ }
+
+ if (includingIdentity != null) {
+ if (includingIdentity) {
+ builder.append(" INCLUDING ");
+ } else {
+ builder.append(" EXCLUDING ");
+ }
+ builder.append(" IDENTITY ");
+ }
+
+ if (includingComments != null) {
+ if (includingComments) {
+ builder.append(" INCLUDING ");
+ } else {
+ builder.append(" EXCLUDING ");
+ }
+ builder.append(" COMMENTS ");
+ }
+
+ return builder;
+ }
+
+ @Override
+ public String toString() {
+ return appendTo(new StringBuilder()).toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/RejectClause.java b/src/main/java/net/sf/jsqlparser/statement/RejectClause.java
new file mode 100644
index 000000000..5ca9f9714
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/RejectClause.java
@@ -0,0 +1,53 @@
+/*-
+ * #%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.LongValue;
+
+import java.io.Serializable;
+
+public class RejectClause implements Serializable {
+ private LongValue limit;
+ private boolean errors;
+
+ public LongValue getLimit() {
+ return limit;
+ }
+
+ public void setLimit(LongValue limit) {
+ this.limit = limit;
+ }
+
+ public boolean isErrors() {
+ return errors;
+ }
+
+ public void setErrors(boolean errors) {
+ this.errors = errors;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sql = new StringBuilder();
+
+ sql.append("REJECT LIMIT ");
+ if (limit != null) {
+ sql.append(limit);
+ } else {
+ sql.append("UNLIMITED");
+ }
+
+ if (errors) {
+ sql.append(" ERRORS");
+ }
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/ScriptSourceDestination.java b/src/main/java/net/sf/jsqlparser/statement/ScriptSourceDestination.java
new file mode 100644
index 000000000..c1193b037
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/ScriptSourceDestination.java
@@ -0,0 +1,99 @@
+/*-
+ * #%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.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 implements ImportFromItem, ExportIntoItem, Serializable {
+ private Table script;
+ private ConnectionDefinition connectionDefinition;
+ private List properties;
+ private List values;
+ private ErrorClause errorClause;
+
+ public Table getScript() {
+ return script;
+ }
+
+ public void setScript(Table script) {
+ this.script = script;
+ }
+
+ public ConnectionDefinition getConnectionDefinition() {
+ return connectionDefinition;
+ }
+
+ public void setConnectionDefinition(ConnectionDefinition connectionDefinition) {
+ this.connectionDefinition = connectionDefinition;
+ }
+
+ public List getProperties() {
+ return properties;
+ }
+
+ public void setProperties(List properties) {
+ this.properties = properties;
+ }
+
+ public List getValues() {
+ return values;
+ }
+
+ public void setValues(List 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();
+
+ sql.append("SCRIPT ");
+ sql.append(script);
+
+ if (connectionDefinition != null) {
+ sql.append(" ");
+ sql.append(connectionDefinition);
+ }
+
+ if (properties != null && values != null) {
+ sql.append(" WITH");
+
+ int max = Math.min(properties.size(), values.size());
+ for (int i = 0; i < max; i++) {
+ sql.append(" ");
+ sql.append(properties.get(i));
+ sql.append(" = ");
+ sql.append(values.get(i));
+ }
+ }
+
+ if (errorClause != null) {
+ sql.append(errorClause);
+ }
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/SessionStatement.java b/src/main/java/net/sf/jsqlparser/statement/SessionStatement.java
new file mode 100644
index 000000000..161054397
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/SessionStatement.java
@@ -0,0 +1,131 @@
+/*-
+ * #%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 java.util.LinkedHashMap;
+import java.util.Map;
+import java.util.Set;
+
+public class SessionStatement implements Statement {
+ public enum Action {
+ START, APPLY, DROP, SHOW, DESCRIBE;
+
+ public static Action from(String flag) {
+ return Enum.valueOf(Action.class, flag.toUpperCase());
+ }
+ }
+
+ final private Action action;
+ final private String id;
+ final private LinkedHashMap options = new LinkedHashMap<>();
+
+ public SessionStatement(Action action, String id) {
+ this.action = action;
+ this.id = id;
+ }
+
+ public SessionStatement(String action, String id) {
+ this(Action.from(action), id);
+ }
+
+ public SessionStatement(String action) {
+ this(action, null);
+ }
+
+
+ public Action getAction() {
+ return action;
+ }
+
+ public String getId() {
+ return id;
+ }
+
+ public int size() {
+ return options.size();
+ }
+
+ public String putOption(String key, String value) {
+ return options.put(key.replaceAll("[\"']", "").toLowerCase(), value.toLowerCase());
+ }
+
+ public boolean hasOptions() {
+ return !options.isEmpty();
+ }
+
+ public void clearOptions() {
+ options.clear();
+ }
+
+ public boolean removeOption(String key, String value) {
+ return options.remove(key, value);
+ }
+
+ public boolean containsOption(String value) {
+ return options.containsValue(value);
+ }
+
+ public String removeOption(String key) {
+ return options.remove(key);
+ }
+
+ public String getOption(String key) {
+ return options.get(key);
+ }
+
+ public Set getOptionKeySet() {
+ return options.keySet();
+ }
+
+ public Map getOptions() {
+ return options;
+ }
+
+ public Set> getOptionEntrySet() {
+ return options.entrySet();
+ }
+
+ public boolean hasOption(String key) {
+ return options.containsKey(key);
+ }
+
+ public String getOptionOrDefault(String key, String defaultValue) {
+ return options.getOrDefault(key, defaultValue);
+ }
+
+ @Override
+ public T accept(StatementVisitor statementVisitor, S context) {
+ return statementVisitor.visit(this, context);
+ }
+
+ @Override
+ public void accept(StatementVisitor statementVisitor) {
+ Statement.super.accept(statementVisitor);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder builder =
+ new StringBuilder("SESSION " + action + " " + (id != null ? id : ""));
+ if (!options.isEmpty()) {
+ builder.append(" WITH ");
+ int i = 0;
+ for (Map.Entry e : options.entrySet()) {
+ if (i++ > 0) {
+ builder.append(", ");
+ }
+ builder.append(e.getKey()).append("=").append(e.getValue());
+ }
+ }
+ builder.append(";");
+
+ return builder.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/SourceDestinationType.java b/src/main/java/net/sf/jsqlparser/statement/SourceDestinationType.java
new file mode 100644
index 000000000..743d21378
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/SourceDestinationType.java
@@ -0,0 +1,13 @@
+/*-
+ * #%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;
+
+public interface SourceDestinationType {
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/StatementVisitor.java b/src/main/java/net/sf/jsqlparser/statement/StatementVisitor.java
index e8be0a5cb..9ebab53a8 100644
--- a/src/main/java/net/sf/jsqlparser/statement/StatementVisitor.java
+++ b/src/main/java/net/sf/jsqlparser/statement/StatementVisitor.java
@@ -17,6 +17,7 @@
import net.sf.jsqlparser.statement.analyze.Analyze;
import net.sf.jsqlparser.statement.comment.Comment;
import net.sf.jsqlparser.statement.create.index.CreateIndex;
+import net.sf.jsqlparser.statement.create.policy.CreatePolicy;
import net.sf.jsqlparser.statement.create.schema.CreateSchema;
import net.sf.jsqlparser.statement.create.sequence.CreateSequence;
import net.sf.jsqlparser.statement.create.synonym.CreateSynonym;
@@ -27,9 +28,12 @@
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;
import net.sf.jsqlparser.statement.insert.ParenthesedInsert;
+import net.sf.jsqlparser.statement.lock.LockStatement;
import net.sf.jsqlparser.statement.merge.Merge;
import net.sf.jsqlparser.statement.refresh.RefreshMaterializedViewStatement;
import net.sf.jsqlparser.statement.select.Select;
@@ -323,4 +327,35 @@ default void visit(ParenthesedUpdate parenthesedUpdate) {
default void visit(ParenthesedDelete parenthesedDelete) {
this.visit(parenthesedDelete, null);
}
+
+ T visit(SessionStatement sessionStatement, S context);
+
+ default void visit(SessionStatement sessionStatement) {
+ this.visit(sessionStatement, null);
+ }
+
+ T visit(Import imprt, S context);
+
+ default void visit(Import imprt) {
+ this.visit(imprt, null);
+ }
+
+ T visit(Export export, S context);
+
+ default void visit(Export export) {
+ this.visit(export, null);
+ }
+
+ T visit(LockStatement lock, S context);
+
+ default void visit(LockStatement lock) {
+ this.visit(lock, null);
+ }
+
+ T visit(CreatePolicy createPolicy, S context);
+
+ default void visit(CreatePolicy createPolicy) {
+ this.visit(createPolicy, null);
+ }
+
}
diff --git a/src/main/java/net/sf/jsqlparser/statement/StatementVisitorAdapter.java b/src/main/java/net/sf/jsqlparser/statement/StatementVisitorAdapter.java
index 0e6ab8698..3b12c01c0 100644
--- a/src/main/java/net/sf/jsqlparser/statement/StatementVisitorAdapter.java
+++ b/src/main/java/net/sf/jsqlparser/statement/StatementVisitorAdapter.java
@@ -9,6 +9,10 @@
*/
package net.sf.jsqlparser.statement;
+import net.sf.jsqlparser.expression.ExpressionVisitor;
+import net.sf.jsqlparser.expression.ExpressionVisitorAdapter;
+import net.sf.jsqlparser.schema.Column;
+import net.sf.jsqlparser.schema.Partition;
import net.sf.jsqlparser.statement.alter.Alter;
import net.sf.jsqlparser.statement.alter.AlterSession;
import net.sf.jsqlparser.statement.alter.AlterSystemStatement;
@@ -17,6 +21,7 @@
import net.sf.jsqlparser.statement.analyze.Analyze;
import net.sf.jsqlparser.statement.comment.Comment;
import net.sf.jsqlparser.statement.create.index.CreateIndex;
+import net.sf.jsqlparser.statement.create.policy.CreatePolicy;
import net.sf.jsqlparser.statement.create.schema.CreateSchema;
import net.sf.jsqlparser.statement.create.sequence.CreateSequence;
import net.sf.jsqlparser.statement.create.synonym.CreateSynonym;
@@ -27,12 +32,27 @@
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;
+import net.sf.jsqlparser.statement.insert.InsertConflictAction;
import net.sf.jsqlparser.statement.insert.ParenthesedInsert;
+import net.sf.jsqlparser.statement.lock.LockStatement;
import net.sf.jsqlparser.statement.merge.Merge;
+import net.sf.jsqlparser.statement.merge.MergeOperationVisitor;
+import net.sf.jsqlparser.statement.merge.MergeOperationVisitorAdapter;
import net.sf.jsqlparser.statement.refresh.RefreshMaterializedViewStatement;
+import net.sf.jsqlparser.statement.select.FromItemVisitor;
+import net.sf.jsqlparser.statement.select.FromItemVisitorAdapter;
+import net.sf.jsqlparser.statement.select.PivotVisitor;
+import net.sf.jsqlparser.statement.select.PivotVisitorAdapter;
import net.sf.jsqlparser.statement.select.Select;
+import net.sf.jsqlparser.statement.select.SelectItemVisitor;
+import net.sf.jsqlparser.statement.select.SelectItemVisitorAdapter;
+import net.sf.jsqlparser.statement.select.SelectVisitor;
+import net.sf.jsqlparser.statement.select.SelectVisitorAdapter;
+import net.sf.jsqlparser.statement.select.WithItem;
import net.sf.jsqlparser.statement.show.ShowIndexStatement;
import net.sf.jsqlparser.statement.show.ShowTablesStatement;
import net.sf.jsqlparser.statement.truncate.Truncate;
@@ -40,8 +60,48 @@
import net.sf.jsqlparser.statement.update.Update;
import net.sf.jsqlparser.statement.upsert.Upsert;
+import java.util.List;
+
@SuppressWarnings({"PMD.UncommentedEmptyMethodBody"})
public class StatementVisitorAdapter implements StatementVisitor {
+ private final ExpressionVisitor expressionVisitor;
+ private final PivotVisitor pivotVisitor;
+ private final SelectItemVisitor selectItemVisitor;
+ private final FromItemVisitor fromItemVisitor;
+ private final SelectVisitor selectVisitor;
+ private final MergeOperationVisitor mergeOperationVisitor;
+
+ public StatementVisitorAdapter() {
+ this.expressionVisitor = new ExpressionVisitorAdapter<>();
+ this.pivotVisitor = new PivotVisitorAdapter<>(this.expressionVisitor);
+ this.selectItemVisitor = new SelectItemVisitorAdapter<>(this.expressionVisitor);
+ this.fromItemVisitor = new FromItemVisitorAdapter<>();
+
+ this.selectVisitor = new SelectVisitorAdapter<>(this.expressionVisitor, this.pivotVisitor,
+ this.selectItemVisitor, this.fromItemVisitor);
+ this.mergeOperationVisitor = new MergeOperationVisitorAdapter<>();
+ }
+
+ public StatementVisitorAdapter(ExpressionVisitor expressionVisitor,
+ PivotVisitor pivotVisitor, SelectItemVisitor selectItemVisitor,
+ FromItemVisitor fromItemVisitor, SelectVisitor selectVisitor,
+ MergeOperationVisitor mergeOperationVisitor) {
+ this.expressionVisitor = expressionVisitor;
+ this.pivotVisitor = pivotVisitor;
+ this.selectItemVisitor = selectItemVisitor;
+ this.fromItemVisitor = fromItemVisitor;
+ this.selectVisitor = selectVisitor;
+ this.mergeOperationVisitor = mergeOperationVisitor;
+ }
+
+ public StatementVisitorAdapter(SelectVisitorAdapter selectVisitor) {
+ this.selectVisitor = selectVisitor;
+ this.expressionVisitor = selectVisitor.getExpressionVisitor();
+ this.pivotVisitor = selectVisitor.getPivotVisitor();
+ this.selectItemVisitor = selectVisitor.getSelectItemVisitor();
+ this.fromItemVisitor = selectVisitor.getFromItemVisitor();
+ this.mergeOperationVisitor = new MergeOperationVisitorAdapter<>();
+ }
@Override
public T visit(Comment comment, S context) {
@@ -57,56 +117,137 @@ public T visit(Commit commit, S context) {
@Override
public T visit(Select select, S context) {
-
- return null;
+ return select.accept(selectVisitor, context);
}
@Override
public T visit(Delete delete, S context) {
+ visitWithItems(delete.getWithItemsList(), context);
+ fromItemVisitor.visitTables(delete.getTables(), context);
+ selectVisitor.visitOutputClause(delete.getOutputClause(), context);
+ fromItemVisitor.visitFromItem(delete.getTable(), context);
+ fromItemVisitor.visitTables(delete.getUsingList(), context);
+ fromItemVisitor.visitJoins(delete.getJoins(), context);
+ expressionVisitor.visitExpression(delete.getWhere(), context);
+
+ expressionVisitor.visitPreferringClause(delete.getPreferringClause(), context);
+
+ expressionVisitor.visitOrderBy(delete.getOrderByElements(), context);
+
+ expressionVisitor.visitLimit(delete.getLimit(), context);
return null;
}
+ private void visitWithItems(List> withItemsList, S context) {
+ if (withItemsList != null) {
+ for (WithItem item : withItemsList) {
+ item.accept(this, context);
+ }
+ }
+ }
+
@Override
public T visit(ParenthesedDelete delete, S context) {
+ delete.getDelete().accept(this, context);
+ return null;
+ }
+ @Override
+ public T visit(SessionStatement sessionStatement, S context) {
return null;
}
@Override
public T visit(Update update, S context) {
-
+ visitWithItems(update.getWithItemsList(), context);
+ fromItemVisitor.visitFromItem(update.getTable(), context);
+ fromItemVisitor.visitJoins(update.getStartJoins(), context);
+ expressionVisitor.visitUpdateSets(update.getUpdateSets(), context);
+ selectVisitor.visitOutputClause(update.getOutputClause(), context);
+ fromItemVisitor.visitFromItem(update.getFromItem(), context);
+ fromItemVisitor.visitJoins(update.getJoins(), context);
+ expressionVisitor.visitExpression(update.getWhere(), context);
+ expressionVisitor.visitPreferringClause(update.getPreferringClause(), context);
+ expressionVisitor.visitOrderBy(update.getOrderByElements(), context);
+ expressionVisitor.visitLimit(update.getLimit(), context);
+ visitReturningClause(update.getReturningClause(), context);
return null;
}
@Override
public T visit(ParenthesedUpdate update, S context) {
-
- return null;
+ return update.getUpdate().accept(this, context);
}
@Override
public T visit(Insert insert, S context) {
+ visitWithItems(insert.getWithItemsList(), context);
+
+ insert.getTable().accept(fromItemVisitor, context);
+
+ if (insert.getColumns() != null) {
+ for (Column column : insert.getColumns()) {
+ column.accept(expressionVisitor, context);
+ }
+ }
+
+ if (insert.getPartitions() != null) {
+ for (Partition partition : insert.getPartitions()) {
+ partition.getColumn().accept(expressionVisitor, context);
+ if (partition.getValue() != null) {
+ partition.getValue().accept(expressionVisitor, context);
+ }
+ }
+ }
+
+ selectVisitor.visitOutputClause(insert.getOutputClause(), context);
+
+ if (insert.getSelect() != null) {
+ insert.getSelect().accept(selectVisitor, null);
+ }
+
+ expressionVisitor.visitUpdateSets(insert.getSetUpdateSets(), context);
+
+ expressionVisitor.visitUpdateSets(insert.getDuplicateUpdateSets(), context);
+
+ final InsertConflictAction conflictAction = insert.getConflictAction();
+ if (conflictAction != null) {
+ expressionVisitor.visitExpression(conflictAction.getWhereExpression(), context);
+ expressionVisitor.visitUpdateSets(conflictAction.getUpdateSets(), context);
+ }
+
+ visitReturningClause(insert.getReturningClause(), context);
+ return null;
+ }
+ private T visitReturningClause(ReturningClause returningClause, S context) {
+ if (returningClause != null) {
+ returningClause.forEach(selectItem -> selectItem.accept(selectItemVisitor, context));
+ // @todo: verify why this is a list of strings and not columns
+ }
return null;
}
@Override
public T visit(ParenthesedInsert insert, S context) {
-
+ insert.getInsert().accept(this, context);
return null;
}
@Override
public T visit(Drop drop, S context) {
+ if (drop.getType().equalsIgnoreCase("table")) {
+ fromItemVisitor.visitFromItem(drop.getName(), context);
+ }
+ // @todo: handle schemas
return null;
}
@Override
public T visit(Truncate truncate, S context) {
-
- return null;
+ return truncate.getTable().accept(fromItemVisitor, context);
}
@Override
@@ -122,13 +263,11 @@ public T visit(CreateSchema createSchema, S context) {
@Override
public T visit(CreateTable createTable, S context) {
-
- return null;
+ return createTable.getTable().accept(fromItemVisitor, context);
}
@Override
public T visit(CreateView createView, S context) {
-
return null;
}
@@ -152,6 +291,18 @@ public T visit(Execute execute, S context) {
return null;
}
+ @Override
+ public T visit(LockStatement lock, S context) {
+
+ return null;
+ }
+
+ @Override
+ public T visit(CreatePolicy createPolicy, S context) {
+
+ return null;
+ }
+
@Override
public T visit(SetStatement set, S context) {
@@ -166,7 +317,12 @@ public T visit(ResetStatement reset, S context) {
@Override
public T visit(Merge merge, S context) {
-
+ visitWithItems(merge.getWithItemsList(), context);
+ fromItemVisitor.visitFromItem(merge.getTable(), context);
+ fromItemVisitor.visitFromItem(merge.getFromItem(), context);
+ expressionVisitor.visitExpression(merge.getOnCondition(), context);
+ mergeOperationVisitor.visit(merge.getOperations(), context);
+ selectVisitor.visitOutputClause(merge.getOutputClause(), context);
return null;
}
@@ -308,4 +464,14 @@ public T visit(UnsupportedStatement unsupportedStatement, S context) {
public T visit(RefreshMaterializedViewStatement materializedView, S context) {
return null;
}
+
+ @Override
+ public T visit(Import imprt, S context) {
+ return null;
+ }
+
+ @Override
+ public T visit(Export export, S context) {
+ return null;
+ }
}
diff --git a/src/main/java/net/sf/jsqlparser/statement/UserIdentification.java b/src/main/java/net/sf/jsqlparser/statement/UserIdentification.java
new file mode 100644
index 000000000..d951931d9
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/UserIdentification.java
@@ -0,0 +1,48 @@
+/*-
+ * #%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;
+
+import java.io.Serializable;
+
+public class UserIdentification implements Serializable {
+ private StringValue user;
+ private StringValue password;
+
+ public StringValue getUser() {
+ return user;
+ }
+
+ public void setUser(StringValue user) {
+ this.user = user;
+ }
+
+ public StringValue getPassword() {
+ return password;
+ }
+
+ public void setPassword(StringValue password) {
+ this.password = password;
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder sql = new StringBuilder();
+
+ sql.append("USER ");
+ sql.append(user);
+
+ sql.append(" IDENTIFIED BY ");
+ sql.append(password);
+
+ return sql.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/alter/AlterExpression.java b/src/main/java/net/sf/jsqlparser/statement/alter/AlterExpression.java
index 372d9c790..336d66b44 100644
--- a/src/main/java/net/sf/jsqlparser/statement/alter/AlterExpression.java
+++ b/src/main/java/net/sf/jsqlparser/statement/alter/AlterExpression.java
@@ -856,6 +856,14 @@ public String toString() {
} else {
if (operation == AlterOperation.COMMENT_WITH_EQUAL_SIGN) {
b.append("COMMENT =").append(" ");
+ } else if (operation == AlterOperation.ENABLE_ROW_LEVEL_SECURITY) {
+ b.append("ENABLE ROW LEVEL SECURITY").append(" ");
+ } else if (operation == AlterOperation.DISABLE_ROW_LEVEL_SECURITY) {
+ b.append("DISABLE ROW LEVEL SECURITY").append(" ");
+ } else if (operation == AlterOperation.FORCE_ROW_LEVEL_SECURITY) {
+ b.append("FORCE ROW LEVEL SECURITY").append(" ");
+ } else if (operation == AlterOperation.NO_FORCE_ROW_LEVEL_SECURITY) {
+ b.append("NO FORCE ROW LEVEL SECURITY").append(" ");
} else {
b.append(operation).append(" ");
}
diff --git a/src/main/java/net/sf/jsqlparser/statement/alter/AlterOperation.java b/src/main/java/net/sf/jsqlparser/statement/alter/AlterOperation.java
index 839685b1a..48fe639ea 100644
--- a/src/main/java/net/sf/jsqlparser/statement/alter/AlterOperation.java
+++ b/src/main/java/net/sf/jsqlparser/statement/alter/AlterOperation.java
@@ -10,7 +10,7 @@
package net.sf.jsqlparser.statement.alter;
public enum AlterOperation {
- ADD, ALTER, DROP, DROP_PRIMARY_KEY, DROP_UNIQUE, DROP_FOREIGN_KEY, MODIFY, CHANGE, CONVERT, COLLATE, ALGORITHM, RENAME, RENAME_TABLE, RENAME_INDEX, RENAME_KEY, RENAME_CONSTRAINT, COMMENT, COMMENT_WITH_EQUAL_SIGN, UNSPECIFIC, ADD_PARTITION, DROP_PARTITION, DISCARD_PARTITION, IMPORT_PARTITION, TRUNCATE_PARTITION, COALESCE_PARTITION, REORGANIZE_PARTITION, EXCHANGE_PARTITION, ANALYZE_PARTITION, CHECK_PARTITION, OPTIMIZE_PARTITION, REBUILD_PARTITION, REPAIR_PARTITION, REMOVE_PARTITIONING, PARTITION_BY, SET_TABLE_OPTION, ENGINE, FORCE, KEY_BLOCK_SIZE, LOCK, DISCARD_TABLESPACE, IMPORT_TABLESPACE, DISABLE_KEYS, ENABLE_KEYS;
+ ADD, ALTER, DROP, DROP_PRIMARY_KEY, DROP_UNIQUE, DROP_FOREIGN_KEY, MODIFY, CHANGE, CONVERT, COLLATE, ALGORITHM, RENAME, RENAME_TABLE, RENAME_INDEX, RENAME_KEY, RENAME_CONSTRAINT, COMMENT, COMMENT_WITH_EQUAL_SIGN, UNSPECIFIC, ADD_PARTITION, DROP_PARTITION, DISCARD_PARTITION, IMPORT_PARTITION, TRUNCATE_PARTITION, COALESCE_PARTITION, REORGANIZE_PARTITION, EXCHANGE_PARTITION, ANALYZE_PARTITION, CHECK_PARTITION, OPTIMIZE_PARTITION, REBUILD_PARTITION, REPAIR_PARTITION, REMOVE_PARTITIONING, PARTITION_BY, SET_TABLE_OPTION, ENGINE, FORCE, KEY_BLOCK_SIZE, LOCK, DISCARD_TABLESPACE, IMPORT_TABLESPACE, DISABLE_KEYS, ENABLE_KEYS, ENABLE_ROW_LEVEL_SECURITY, DISABLE_ROW_LEVEL_SECURITY, FORCE_ROW_LEVEL_SECURITY, NO_FORCE_ROW_LEVEL_SECURITY;
public static AlterOperation from(String operation) {
return Enum.valueOf(AlterOperation.class, operation.toUpperCase());
diff --git a/src/main/java/net/sf/jsqlparser/statement/create/policy/CreatePolicy.java b/src/main/java/net/sf/jsqlparser/statement/create/policy/CreatePolicy.java
new file mode 100644
index 000000000..7c11636aa
--- /dev/null
+++ b/src/main/java/net/sf/jsqlparser/statement/create/policy/CreatePolicy.java
@@ -0,0 +1,131 @@
+/*-
+ * #%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.create.policy;
+
+import net.sf.jsqlparser.expression.Expression;
+import net.sf.jsqlparser.schema.Table;
+import net.sf.jsqlparser.statement.Statement;
+import net.sf.jsqlparser.statement.StatementVisitor;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * PostgreSQL CREATE POLICY statement for Row Level Security (RLS).
+ *
+ * Syntax: CREATE POLICY name ON table_name [ FOR { ALL | SELECT | INSERT | UPDATE | DELETE } ] [ TO
+ * { role_name | PUBLIC | CURRENT_USER | SESSION_USER } [, ...] ] [ USING ( using_expression ) ] [
+ * WITH CHECK ( check_expression ) ]
+ */
+public class CreatePolicy implements Statement {
+
+ private String policyName;
+ private Table table;
+ private String command; // ALL, SELECT, INSERT, UPDATE, DELETE
+ private List roles = new ArrayList<>();
+ private Expression usingExpression;
+ private Expression withCheckExpression;
+
+ public String getPolicyName() {
+ return policyName;
+ }
+
+ public CreatePolicy setPolicyName(String policyName) {
+ this.policyName = policyName;
+ return this;
+ }
+
+ public Table getTable() {
+ return table;
+ }
+
+ public CreatePolicy setTable(Table table) {
+ this.table = table;
+ return this;
+ }
+
+ public String getCommand() {
+ return command;
+ }
+
+ public CreatePolicy setCommand(String command) {
+ this.command = command;
+ return this;
+ }
+
+ public List getRoles() {
+ return roles;
+ }
+
+ public CreatePolicy setRoles(List roles) {
+ this.roles = roles;
+ return this;
+ }
+
+ public CreatePolicy addRole(String role) {
+ this.roles.add(role);
+ return this;
+ }
+
+ public Expression getUsingExpression() {
+ return usingExpression;
+ }
+
+ public CreatePolicy setUsingExpression(Expression usingExpression) {
+ this.usingExpression = usingExpression;
+ return this;
+ }
+
+ public Expression getWithCheckExpression() {
+ return withCheckExpression;
+ }
+
+ public CreatePolicy setWithCheckExpression(Expression withCheckExpression) {
+ this.withCheckExpression = withCheckExpression;
+ return this;
+ }
+
+ @Override
+ public T accept(StatementVisitor statementVisitor, S context) {
+ return statementVisitor.visit(this, context);
+ }
+
+ @Override
+ public String toString() {
+ StringBuilder builder = new StringBuilder("CREATE POLICY ");
+ builder.append(policyName);
+ builder.append(" ON ");
+ builder.append(table.toString());
+
+ if (command != null) {
+ builder.append(" FOR ").append(command);
+ }
+
+ if (roles != null && !roles.isEmpty()) {
+ builder.append(" TO ");
+ for (int i = 0; i < roles.size(); i++) {
+ if (i > 0) {
+ builder.append(", ");
+ }
+ builder.append(roles.get(i));
+ }
+ }
+
+ if (usingExpression != null) {
+ builder.append(" USING (").append(usingExpression.toString()).append(")");
+ }
+
+ if (withCheckExpression != null) {
+ builder.append(" WITH CHECK (").append(withCheckExpression.toString()).append(")");
+ }
+
+ return builder.toString();
+ }
+}
diff --git a/src/main/java/net/sf/jsqlparser/statement/create/schema/CreateSchema.java b/src/main/java/net/sf/jsqlparser/statement/create/schema/CreateSchema.java
index ea4cdc64d..e972c9c30 100644
--- a/src/main/java/net/sf/jsqlparser/statement/create/schema/CreateSchema.java
+++ b/src/main/java/net/sf/jsqlparser/statement/create/schema/CreateSchema.java
@@ -21,6 +21,7 @@
public class CreateSchema implements Statement {
private String authorization;
+ private String catalogName = null;
private String schemaName;
private List schemaPath;
private List statements = new ArrayList<>();
@@ -59,6 +60,15 @@ public void setAuthorization(String authorization) {
this.authorization = authorization;
}
+ public String getCatalogName() {
+ return catalogName;
+ }
+
+ public CreateSchema setCatalogName(String catalogName) {
+ this.catalogName = catalogName;
+ return this;
+ }
+
/**
* The name of the schema
*
@@ -119,7 +129,12 @@ public String toString() {
sql += " IF NOT EXISTS";
}
if (schemaName != null) {
- sql += " " + schemaName;
+ sql += " ";
+
+ if (catalogName!=null) {
+ sql += catalogName + ".";
+ }
+ sql += schemaName;
}
if (authorization != null) {
sql += " AUTHORIZATION " + authorization;
diff --git a/src/main/java/net/sf/jsqlparser/statement/create/table/ColumnDefinition.java b/src/main/java/net/sf/jsqlparser/statement/create/table/ColumnDefinition.java
index 90a0e0e40..a7f47104c 100644
--- a/src/main/java/net/sf/jsqlparser/statement/create/table/ColumnDefinition.java
+++ b/src/main/java/net/sf/jsqlparser/statement/create/table/ColumnDefinition.java
@@ -9,6 +9,7 @@
*/
package net.sf.jsqlparser.statement.create.table;
+import net.sf.jsqlparser.statement.imprt.ImportColumn;
import net.sf.jsqlparser.statement.select.PlainSelect;
import java.io.Serializable;
@@ -21,7 +22,7 @@
/**
* Globally used definition class for columns.
*/
-public class ColumnDefinition implements Serializable {
+public class ColumnDefinition implements ImportColumn, Serializable {
private String columnName;
private ColDataType colDataType;
diff --git a/src/main/java/net/sf/jsqlparser/statement/delete/Delete.java b/src/main/java/net/sf/jsqlparser/statement/delete/Delete.java
index 3072d9872..4e0f45ffe 100644
--- a/src/main/java/net/sf/jsqlparser/statement/delete/Delete.java
+++ b/src/main/java/net/sf/jsqlparser/statement/delete/Delete.java
@@ -17,6 +17,7 @@
import net.sf.jsqlparser.statement.ReturningClause;
import net.sf.jsqlparser.statement.Statement;
import net.sf.jsqlparser.statement.StatementVisitor;
+import net.sf.jsqlparser.statement.select.FromItem;
import net.sf.jsqlparser.statement.select.Join;
import net.sf.jsqlparser.statement.select.Limit;
import net.sf.jsqlparser.statement.select.OrderByElement;
@@ -29,6 +30,7 @@
import java.util.Iterator;
import java.util.List;
import java.util.Optional;
+import java.util.stream.Collectors;
import static java.util.stream.Collectors.joining;
@@ -38,7 +40,7 @@ public class Delete implements Statement {
private Table table;
private OracleHint oracleHint = null;
private List tables;
- private List usingList;
+ private List usingFromItemList;
private List
+# [JSqlParser 5.3 Website](https://jsqlparser.github.io/JSqlParser)