Merge branch 'master' of github.com:JSQLParser/JSqlParser

Author: manticore-projects

src/main/java/module-info.java

@@ -25,6 +25,7 @@
     exports net.sf.jsqlparser.statement.alter.sequence;
     exports net.sf.jsqlparser.statement.analyze;
     exports net.sf.jsqlparser.statement.comment;
+    exports net.sf.jsqlparser.statement.create.event;
     exports net.sf.jsqlparser.statement.create.function;
     exports net.sf.jsqlparser.statement.create.index;
     exports net.sf.jsqlparser.statement.create.policy;
@@ -33,6 +34,8 @@
     exports net.sf.jsqlparser.statement.create.sequence;
     exports net.sf.jsqlparser.statement.create.synonym;
     exports net.sf.jsqlparser.statement.create.table;
+    exports net.sf.jsqlparser.statement.create.trigger;
+    exports net.sf.jsqlparser.statement.create.user;
     exports net.sf.jsqlparser.statement.create.view;
     exports net.sf.jsqlparser.statement.delete;
     exports net.sf.jsqlparser.statement.drop;

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

@@ -17,12 +17,16 @@
 import net.sf.jsqlparser.statement.analyze.Analyze;
 import net.sf.jsqlparser.statement.comment.Comment;
 import net.sf.jsqlparser.statement.create.database.CreateDatabase;
+import net.sf.jsqlparser.statement.create.event.AlterEvent;
+import net.sf.jsqlparser.statement.create.event.CreateEvent;
 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;
 import net.sf.jsqlparser.statement.create.table.CreateTable;
+import net.sf.jsqlparser.statement.create.trigger.CreateTrigger;
+import net.sf.jsqlparser.statement.create.user.CreateUser;
 import net.sf.jsqlparser.statement.create.view.AlterView;
 import net.sf.jsqlparser.statement.create.view.CreateView;
 import net.sf.jsqlparser.statement.delete.Delete;
@@ -125,12 +129,30 @@ default void visit(CreateDatabase createDatabase) {
         this.visit(createDatabase, null);
     }
 
+    <S> T visit(CreateUser createUser, S context);
+
+    default void visit(CreateUser createUser) {
+        this.visit(createUser, null);
+    }
+
+    <S> T visit(CreateEvent createEvent, S context);
+
+    default void visit(CreateEvent createEvent) {
+        this.visit(createEvent, null);
+    }
+
     <S> T visit(CreateTable createTable, S context);
 
     default void visit(CreateTable createTable) {
         this.visit(createTable, null);
     }
 
+    <S> T visit(CreateTrigger createTrigger, S context);
+
+    default void visit(CreateTrigger createTrigger) {
+        this.visit(createTrigger, null);
+    }
+
     <S> T visit(CreateView createView, S context);
 
     default void visit(CreateView createView) {
@@ -155,6 +177,12 @@ default void visit(Alter alter) {
         this.visit(alter, null);
     }
 
+    <S> T visit(AlterEvent alterEvent, S context);
+
+    default void visit(AlterEvent alterEvent) {
+        this.visit(alterEvent, null);
+    }
+
     <S> T visit(Statements statements, S context);
 
     default void visit(Statements statements) {

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

@@ -21,12 +21,16 @@
 import net.sf.jsqlparser.statement.analyze.Analyze;
 import net.sf.jsqlparser.statement.comment.Comment;
 import net.sf.jsqlparser.statement.create.database.CreateDatabase;
+import net.sf.jsqlparser.statement.create.event.AlterEvent;
+import net.sf.jsqlparser.statement.create.event.CreateEvent;
 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;
 import net.sf.jsqlparser.statement.create.table.CreateTable;
+import net.sf.jsqlparser.statement.create.trigger.CreateTrigger;
+import net.sf.jsqlparser.statement.create.user.CreateUser;
 import net.sf.jsqlparser.statement.create.view.AlterView;
 import net.sf.jsqlparser.statement.create.view.CreateView;
 import net.sf.jsqlparser.statement.delete.Delete;
@@ -322,11 +326,26 @@ public <S> T visit(CreateDatabase createDatabase, S context) {
         return null;
     }
 
+    @Override
+    public <S> T visit(CreateUser createUser, S context) {
+        return null;
+    }
+
+    @Override
+    public <S> T visit(CreateEvent createEvent, S context) {
+        return null;
+    }
+
     @Override
     public <S> T visit(CreateTable createTable, S context) {
         return createTable.getTable().accept(fromItemVisitor, context);
     }
 
+    @Override
+    public <S> T visit(CreateTrigger createTrigger, S context) {
+        return null;
+    }
+
     @Override
     public <S> T visit(CreateView createView, S context) {
         return null;
@@ -338,6 +357,11 @@ public <S> T visit(Alter alter, S context) {
         return null;
     }
 
+    @Override
+    public <S> T visit(AlterEvent alterEvent, S context) {
+        return null;
+    }
+
     @Override
     public <S> T visit(Statements statements, S context) {
         for (Statement statement : statements) {
@@ -360,6 +384,9 @@ public <S> T visit(LockStatement lock, S context) {
 
     @Override
     public <S> T visit(CreatePolicy createPolicy, S context) {
+        fromItemVisitor.visitFromItem(createPolicy.getTable(), context);
+        expressionVisitor.visitExpression(createPolicy.getUsingExpression(), context);
+        expressionVisitor.visitExpression(createPolicy.getWithCheckExpression(), context);
 
         return null;
     }

src/main/java/net/sf/jsqlparser/statement/create/event/AlterEvent.java

@@ -0,0 +1,51 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2026 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement.create.event;
+
+import net.sf.jsqlparser.schema.Table;
+import net.sf.jsqlparser.statement.StatementVisitor;
+
+/** MySQL {@code ALTER EVENT} statement. */
+public class AlterEvent extends EventStatement {
+
+    private Table renameTo;
+
+    public Table getRenameTo() {
+        return renameTo;
+    }
+
+    public void setRenameTo(Table renameTo) {
+        this.renameTo = renameTo;
+    }
+
+    @Override
+    public <T, S> T accept(StatementVisitor<T> statementVisitor, S context) {
+        return statementVisitor.visit(this, context);
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder builder = new StringBuilder("ALTER EVENT ").append(getEvent());
+        appendScheduleAndCompletion(builder);
+        if (renameTo != null) {
+            builder.append(" RENAME TO ").append(renameTo);
+        }
+        appendStatusAndComment(builder);
+        if (getBody() != null) {
+            builder.append(" DO ").append(getBody());
+        }
+        return builder.toString();
+    }
+
+    public AlterEvent withRenameTo(Table renameTo) {
+        setRenameTo(renameTo);
+        return this;
+    }
+}

src/main/java/net/sf/jsqlparser/statement/create/event/CreateEvent.java

@@ -0,0 +1,49 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2026 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement.create.event;
+
+import net.sf.jsqlparser.statement.StatementVisitor;
+
+/** MySQL {@code CREATE EVENT} statement. */
+public class CreateEvent extends EventStatement {
+
+    private boolean ifNotExists;
+
+    public boolean isIfNotExists() {
+        return ifNotExists;
+    }
+
+    public void setIfNotExists(boolean ifNotExists) {
+        this.ifNotExists = ifNotExists;
+    }
+
+    @Override
+    public <T, S> T accept(StatementVisitor<T> statementVisitor, S context) {
+        return statementVisitor.visit(this, context);
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder builder = new StringBuilder("CREATE EVENT ");
+        if (ifNotExists) {
+            builder.append("IF NOT EXISTS ");
+        }
+        builder.append(getEvent());
+        appendScheduleAndCompletion(builder);
+        appendStatusAndComment(builder);
+        builder.append(" DO ").append(getBody());
+        return builder.toString();
+    }
+
+    public CreateEvent withIfNotExists(boolean ifNotExists) {
+        setIfNotExists(ifNotExists);
+        return this;
+    }
+}

src/main/java/net/sf/jsqlparser/statement/create/event/EventSchedule.java

@@ -0,0 +1,123 @@
+/*-
+ * #%L
+ * JSQLParser library
+ * %%
+ * Copyright (C) 2004 - 2026 JSQLParser
+ * %%
+ * Dual licensed under GNU LGPL 2.1 or Apache License 2.0
+ * #L%
+ */
+package net.sf.jsqlparser.statement.create.event;
+
+import java.io.Serializable;
+import net.sf.jsqlparser.expression.Expression;
+
+/** Structured {@code ON SCHEDULE} clause of a MySQL event. */
+public class EventSchedule implements Serializable {
+
+    public enum Type {
+        AT, EVERY
+    }
+
+    private Type type;
+    private Expression executeAt;
+    private Expression interval;
+    private String intervalUnit;
+    private Expression starts;
+    private Expression ends;
+
+    public Type getType() {
+        return type;
+    }
+
+    public void setType(Type type) {
+        this.type = type;
+    }
+
+    public Expression getExecuteAt() {
+        return executeAt;
+    }
+
+    public void setExecuteAt(Expression executeAt) {
+        this.executeAt = executeAt;
+    }
+
+    public Expression getInterval() {
+        return interval;
+    }
+
+    public void setInterval(Expression interval) {
+        this.interval = interval;
+    }
+
+    public String getIntervalUnit() {
+        return intervalUnit;
+    }
+
+    public void setIntervalUnit(String intervalUnit) {
+        this.intervalUnit = intervalUnit;
+    }
+
+    public Expression getStarts() {
+        return starts;
+    }
+
+    public void setStarts(Expression starts) {
+        this.starts = starts;
+    }
+
+    public Expression getEnds() {
+        return ends;
+    }
+
+    public void setEnds(Expression ends) {
+        this.ends = ends;
+    }
+
+    @Override
+    public String toString() {
+        StringBuilder builder = new StringBuilder();
+        if (type == Type.AT) {
+            builder.append("AT ").append(executeAt);
+        } else if (type == Type.EVERY) {
+            builder.append("EVERY ").append(interval).append(" ").append(intervalUnit);
+            if (starts != null) {
+                builder.append(" STARTS ").append(starts);
+            }
+            if (ends != null) {
+                builder.append(" ENDS ").append(ends);
+            }
+        }
+        return builder.toString();
+    }
+
+    public EventSchedule withType(Type type) {
+        setType(type);
+        return this;
+    }
+
+    public EventSchedule withExecuteAt(Expression executeAt) {
+        setExecuteAt(executeAt);
+        return this;
+    }
+
+    public EventSchedule withInterval(Expression interval) {
+        setInterval(interval);
+        return this;
+    }
+
+    public EventSchedule withIntervalUnit(String intervalUnit) {
+        setIntervalUnit(intervalUnit);
+        return this;
+    }
+
+    public EventSchedule withStarts(Expression starts) {
+        setStarts(starts);
+        return this;
+    }
+
+    public EventSchedule withEnds(Expression ends) {
+        setEnds(ends);
+        return this;
+    }
+}