feat: parse PostgreSQL CREATE/ALTER OPERATOR, OPERATOR CLASS/FAMILY and AGGREGATE

CREATE and ALTER OPERATOR, OPERATOR CLASS, OPERATOR FAMILY and AGGREGATE
were unsupported statements, whose text broke an operator such as === into
"== =".

They parse to CreateOperator, AlterOperator, CreateOperatorClass,
AlterOperatorClass, CreateOperatorFamily, AlterOperatorFamily,
CreateAggregate and AlterAggregate. These reuse the models DROP OPERATOR,
DROP AGGREGATE and CREATE TYPE have: ExclusionOperator and
OperatorSignature for an operator, RoutineReference for an aggregate
signature and DefinitionElement for a definition list. OperatorClassItem
is a member of an operator class or family. The statements are wired into
the deparser, visitors, table finder, validation (eight features, enabled
for PostgreSQL) and feature analysis.

An operator name follows PostgreSQL's lexer wherever DDL names an
operator: <==> and @#@ are one name, a name such as +- or => alone is
rejected, and a database may precede the schema. An aggregate signature
needs * or an argument, so DROP AGGREGATE agg() is now a parse error.

Without the PostgreSQL dialect, CREATE and ALTER OPERATOR are read this
way when an operator symbol follows, so Oracle's CREATE OPERATOR name
BINDING stays unsupported, as do MySQL's CREATE AGGREGATE FUNCTION and
SQL Server's CREATE AGGREGATE name (@parameter type).

Signed-off-by: minleejae <mmj9808@gmail.com>

Author: minleejae

README.md

@@ -162,6 +162,7 @@ and missing syntax gets added on demand — [open an issue](https://github.com/J
 | **MySQL utility statements** | `EXPLAIN`/`DESCRIBE [ANALYZE] FORMAT = …` · `EXPLAIN FOR CONNECTION` · `DESCRIBE t col` · `PREPARE … FROM` · `EXECUTE … USING` · `DROP PREPARE` · `DO` |
 | **PostgreSQL administration** | `CREATE`/`ALTER EVENT TRIGGER` · `REINDEX` · `SECURITY LABEL` |
 | **PostgreSQL types and rules** | `CREATE TYPE` (shell, composite, enum, range and base types) · `ALTER TYPE` · `CREATE RULE` · `ALTER RULE` |
+| **PostgreSQL operators and aggregates** | `CREATE`/`ALTER OPERATOR` · `CREATE`/`ALTER OPERATOR CLASS` · `CREATE`/`ALTER OPERATOR FAMILY` · `CREATE`/`ALTER AGGREGATE` |
 | **Informix constraints** | `ALTER TABLE … ADD CONSTRAINT` with trailing constraint names for primary, unique, foreign and check constraints; enable with `parser.withDialect(Dialect.INFORMIX)` |
 | **Salesforce SOQL** | `INCLUDES` · `EXCLUDES` |
 

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

@@ -1001,6 +1001,54 @@ public enum Feature {
      * @see net.sf.jsqlparser.statement.alter.AlterRule
      */
     alterRule,
+    /**
+     * PostgreSQL "CREATE OPERATOR" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.create.operator.CreateOperator
+     */
+    createOperator,
+    /**
+     * PostgreSQL "CREATE OPERATOR CLASS" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.create.operator.CreateOperatorClass
+     */
+    createOperatorClass,
+    /**
+     * PostgreSQL "CREATE OPERATOR FAMILY" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.create.operator.CreateOperatorFamily
+     */
+    createOperatorFamily,
+    /**
+     * PostgreSQL "CREATE AGGREGATE" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.create.aggregate.CreateAggregate
+     */
+    createAggregate,
+    /**
+     * PostgreSQL "ALTER OPERATOR" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.alter.AlterOperator
+     */
+    alterOperator,
+    /**
+     * PostgreSQL "ALTER OPERATOR CLASS" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.alter.AlterOperatorClass
+     */
+    alterOperatorClass,
+    /**
+     * PostgreSQL "ALTER OPERATOR FAMILY" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.alter.AlterOperatorFamily
+     */
+    alterOperatorFamily,
+    /**
+     * PostgreSQL "ALTER AGGREGATE" statement is allowed
+     *
+     * @see net.sf.jsqlparser.statement.alter.AlterAggregate
+     */
+    alterAggregate,
     /**
      * SQL block starting with "BEGIN" and ends with "END" statement is allowed
      *

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

@@ -15,8 +15,8 @@
 
 /**
  * One element of a PostgreSQL definition list, {@code name [= value]}, as in
- * {@code CREATE TYPE name (INPUT = fn, PASSEDBYVALUE)} or
- * {@code ALTER TYPE name SET (SEND = NONE)}. The name keeps its spelling and quoting.
+ * {@code CREATE TYPE name (INPUT = fn, PASSEDBYVALUE)}, {@code ALTER TYPE name SET (SEND = NONE)},
+ * {@code CREATE OPERATOR} or {@code CREATE AGGREGATE}. The name keeps its spelling and quoting.
  */
 public class DefinitionElement implements Serializable {
     private String name;
@@ -62,6 +62,18 @@ public static String toString(List<DefinitionElement> elements) {
         return elements.stream().map(Object::toString).collect(Collectors.joining(", ", "(", ")"));
     }
 
+    /**
+     * Finds an element of a definition list by its name, ignoring case.
+     *
+     * @param elements the elements
+     * @param name the name, such as {@code INPUT}
+     * @return the first element of that name, or {@code null}
+     */
+    public static DefinitionElement find(List<DefinitionElement> elements, String name) {
+        return elements.stream().filter(element -> name.equalsIgnoreCase(element.getName()))
+                .findFirst().orElse(null);
+    }
+
     @Override
     public String toString() {
         return argument == null ? name : name + " = " + argument;

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

@@ -36,6 +36,14 @@
 import net.sf.jsqlparser.statement.alter.AlterPolicy;
 import net.sf.jsqlparser.statement.alter.AlterPublication;
 import net.sf.jsqlparser.statement.alter.AlterRelation;
+import net.sf.jsqlparser.statement.create.operator.CreateOperator;
+import net.sf.jsqlparser.statement.create.operator.CreateOperatorClass;
+import net.sf.jsqlparser.statement.create.operator.CreateOperatorFamily;
+import net.sf.jsqlparser.statement.create.aggregate.CreateAggregate;
+import net.sf.jsqlparser.statement.alter.AlterOperator;
+import net.sf.jsqlparser.statement.alter.AlterOperatorClass;
+import net.sf.jsqlparser.statement.alter.AlterOperatorFamily;
+import net.sf.jsqlparser.statement.alter.AlterAggregate;
 import net.sf.jsqlparser.statement.alter.AlterRule;
 import net.sf.jsqlparser.statement.alter.AlterServer;
 import net.sf.jsqlparser.statement.alter.AlterSession;
@@ -1557,4 +1565,44 @@ public <S> Void visit(CreateCollation statement, S context) {
     public <S> Void visit(AlterRule statement, S context) {
         return schemaOnly();
     }
+
+    @Override
+    public <S> Void visit(CreateOperator statement, S context) {
+        return schemaOnly();
+    }
+
+    @Override
+    public <S> Void visit(CreateOperatorClass statement, S context) {
+        return schemaOnly();
+    }
+
+    @Override
+    public <S> Void visit(CreateOperatorFamily statement, S context) {
+        return schemaOnly();
+    }
+
+    @Override
+    public <S> Void visit(CreateAggregate statement, S context) {
+        return schemaOnly();
+    }
+
+    @Override
+    public <S> Void visit(AlterOperator statement, S context) {
+        return schemaOnly();
+    }
+
+    @Override
+    public <S> Void visit(AlterOperatorClass statement, S context) {
+        return schemaOnly();
+    }
+
+    @Override
+    public <S> Void visit(AlterOperatorFamily statement, S context) {
+        return schemaOnly();
+    }
+
+    @Override
+    public <S> Void visit(AlterAggregate statement, S context) {
+        return schemaOnly();
+    }
 }

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

@@ -24,6 +24,14 @@
 import net.sf.jsqlparser.statement.notify.NotifyStatement;
 import net.sf.jsqlparser.statement.create.collation.CreateCollation;
 import net.sf.jsqlparser.statement.alter.AlterCollation;
+import net.sf.jsqlparser.statement.create.operator.CreateOperator;
+import net.sf.jsqlparser.statement.create.operator.CreateOperatorClass;
+import net.sf.jsqlparser.statement.create.operator.CreateOperatorFamily;
+import net.sf.jsqlparser.statement.create.aggregate.CreateAggregate;
+import net.sf.jsqlparser.statement.alter.AlterOperator;
+import net.sf.jsqlparser.statement.alter.AlterOperatorClass;
+import net.sf.jsqlparser.statement.alter.AlterOperatorFamily;
+import net.sf.jsqlparser.statement.alter.AlterAggregate;
 import net.sf.jsqlparser.statement.alter.AlterRule;
 import net.sf.jsqlparser.statement.alter.AlterRoutine;
 import net.sf.jsqlparser.statement.alter.AlterTrigger;
@@ -1182,4 +1190,68 @@ default <S> T visit(AlterRule statement, S context) {
     default void visit(AlterRule statement) {
         visit(statement, null);
     }
+
+    default <S> T visit(CreateOperator statement, S context) {
+        return null;
+    }
+
+    default void visit(CreateOperator statement) {
+        visit(statement, null);
+    }
+
+    default <S> T visit(CreateOperatorClass statement, S context) {
+        return null;
+    }
+
+    default void visit(CreateOperatorClass statement) {
+        visit(statement, null);
+    }
+
+    default <S> T visit(CreateOperatorFamily statement, S context) {
+        return null;
+    }
+
+    default void visit(CreateOperatorFamily statement) {
+        visit(statement, null);
+    }
+
+    default <S> T visit(CreateAggregate statement, S context) {
+        return null;
+    }
+
+    default void visit(CreateAggregate statement) {
+        visit(statement, null);
+    }
+
+    default <S> T visit(AlterOperator statement, S context) {
+        return null;
+    }
+
+    default void visit(AlterOperator statement) {
+        visit(statement, null);
+    }
+
+    default <S> T visit(AlterOperatorClass statement, S context) {
+        return null;
+    }
+
+    default void visit(AlterOperatorClass statement) {
+        visit(statement, null);
+    }
+
+    default <S> T visit(AlterOperatorFamily statement, S context) {
+        return null;
+    }
+
+    default void visit(AlterOperatorFamily statement) {
+        visit(statement, null);
+    }
+
+    default <S> T visit(AlterAggregate statement, S context) {
+        return null;
+    }
+
+    default void visit(AlterAggregate statement) {
+        visit(statement, null);
+    }
 }

src/main/java/net/sf/jsqlparser/statement/alter/AlterAggregate.java

@@ -0,0 +1,89 @@
+/*-
+ * #%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.alter;
+
+import net.sf.jsqlparser.parser.ASTNodeAccessImpl;
+import net.sf.jsqlparser.statement.RoutineReference;
+import net.sf.jsqlparser.statement.Statement;
+import net.sf.jsqlparser.statement.StatementVisitor;
+
+/**
+ * PostgreSQL {@code ALTER AGGREGATE name (arguments)} with one of {@code RENAME TO new_name},
+ * {@code OWNER TO role} and {@code SET SCHEMA schema}.
+ */
+public class AlterAggregate extends ASTNodeAccessImpl implements Statement {
+    public enum Action {
+        RENAME, OWNER, SET_SCHEMA
+    }
+
+    private RoutineReference aggregate;
+    private Action action;
+    private String newName;
+
+    /**
+     * The name and the argument signature, read as in DROP AGGREGATE.
+     *
+     * @return the aggregate
+     */
+    public RoutineReference getAggregate() {
+        return aggregate;
+    }
+
+    public void setAggregate(RoutineReference aggregate) {
+        this.aggregate = aggregate;
+    }
+
+    public Action getAction() {
+        return action;
+    }
+
+    public void setAction(Action action) {
+        this.action = action;
+    }
+
+    /**
+     * The new name of {@code RENAME TO}, the role of {@code OWNER TO} or the schema of
+     * {@code SET SCHEMA}.
+     *
+     * @return the name, or {@code null} for another action
+     */
+    public String getNewName() {
+        return newName;
+    }
+
+    public void setNewName(String newName) {
+        this.newName = newName;
+    }
+
+    @Override
+    public StringBuilder appendTo(StringBuilder builder) {
+        builder.append("ALTER AGGREGATE ").append(aggregate);
+        switch (action) {
+            case RENAME:
+                return builder.append(" RENAME TO ").append(newName);
+            case OWNER:
+                return builder.append(" OWNER TO ").append(newName);
+            case SET_SCHEMA:
+                return builder.append(" SET SCHEMA ").append(newName);
+            default:
+                throw new IllegalStateException("Unknown aggregate alteration: " + action);
+        }
+    }
+
+    @Override
+    public String toString() {
+        return appendTo(new StringBuilder()).toString();
+    }
+
+    @Override
+    public <T, S> T accept(StatementVisitor<T> statementVisitor, S context) {
+        return statementVisitor.visit(this, context);
+    }
+}