Support DuckDB 2.0 CREATE EXTENSION REPOSITORY

Adds CREATE EXTENSION REPOSITORY [IF NOT EXISTS] name [WITH PREFIX
prefix], which registers a custom repository to install extensions from.
PostgreSQL's CREATE EXTENSION is unaffected.

Co-Authored-By: Claude Opus 5 (1M context) <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_01EqinwHBKuAtPEmtXr3b5P2

Author: hayssams

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

@@ -94,6 +94,7 @@
 import java.util.Set;
 import java.util.function.Predicate;
 import net.sf.jsqlparser.statement.create.macro.CreateMacro;
+import net.sf.jsqlparser.statement.create.extension.CreateExtensionRepository;
 
 /**
  * Derives a {@link StatementFeatures} verdict from a statement tree.
@@ -592,6 +593,13 @@ public <S> Void visit(CreateMacro createMacro, S context) {
         return null;
     }
 
+    @Override
+    public <S> Void visit(CreateExtensionRepository createExtensionRepository, S context) {
+        analysis.claimTopLevel();
+        analysis.certain(StmtFeature.MODIFIES_SCHEMA);
+        return null;
+    }
+
     @Override
     public <S> Void visit(PurgeStatement purgeStatement, S context) {
         analysis.claimTopLevel();

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

@@ -69,6 +69,7 @@
 import net.sf.jsqlparser.statement.update.Update;
 import net.sf.jsqlparser.statement.upsert.Upsert;
 import net.sf.jsqlparser.statement.create.macro.CreateMacro;
+import net.sf.jsqlparser.statement.create.extension.CreateExtensionRepository;
 
 public interface StatementVisitor<T> {
 
@@ -432,6 +433,12 @@ default void visit(CreateMacro createMacro) {
         this.visit(createMacro, null);
     }
 
+    <S> T visit(CreateExtensionRepository createExtensionRepository, S context);
+
+    default void visit(CreateExtensionRepository createExtensionRepository) {
+        this.visit(createExtensionRepository, null);
+    }
+
     <S> T visit(PurgeStatement purgeStatement, S context);
 
     default void visit(PurgeStatement purgeStatement) {

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

@@ -90,6 +90,7 @@
 import java.util.List;
 import net.sf.jsqlparser.util.TableDefinitionTraversal;
 import net.sf.jsqlparser.statement.create.macro.CreateMacro;
+import net.sf.jsqlparser.statement.create.extension.CreateExtensionRepository;
 
 @SuppressWarnings({"PMD.UncommentedEmptyMethodBody"})
 public class StatementVisitorAdapter<T> implements StatementVisitor<T> {
@@ -669,6 +670,11 @@ public <S> T visit(CreateMacro createMacro, S context) {
         return null;
     }
 
+    @Override
+    public <S> T visit(CreateExtensionRepository createExtensionRepository, S context) {
+        return null;
+    }
+
     @Override
     public <S> T visit(PurgeStatement purgeStatement, S context) {
         return null;

src/main/java/net/sf/jsqlparser/statement/create/extension/CreateExtensionRepository.java

@@ -0,0 +1,85 @@
+/*-
+ * #%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.extension;
+
+import net.sf.jsqlparser.expression.Expression;
+import net.sf.jsqlparser.statement.Statement;
+import net.sf.jsqlparser.statement.StatementVisitor;
+
+/**
+ * DuckDB 2.0's {@code CREATE EXTENSION REPOSITORY [IF NOT EXISTS] name [WITH PREFIX prefix]}, which
+ * registers a custom repository extensions may be installed from.
+ */
+public class CreateExtensionRepository implements Statement {
+    private String name;
+    private boolean ifNotExists;
+    private Expression prefix;
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public CreateExtensionRepository withName(String name) {
+        setName(name);
+        return this;
+    }
+
+    public boolean isIfNotExists() {
+        return ifNotExists;
+    }
+
+    public void setIfNotExists(boolean ifNotExists) {
+        this.ifNotExists = ifNotExists;
+    }
+
+    public CreateExtensionRepository withIfNotExists(boolean ifNotExists) {
+        setIfNotExists(ifNotExists);
+        return this;
+    }
+
+    public Expression getPrefix() {
+        return prefix;
+    }
+
+    public void setPrefix(Expression prefix) {
+        this.prefix = prefix;
+    }
+
+    public CreateExtensionRepository withPrefix(Expression prefix) {
+        setPrefix(prefix);
+        return this;
+    }
+
+    public StringBuilder appendTo(StringBuilder builder) {
+        builder.append("CREATE EXTENSION REPOSITORY ");
+        if (ifNotExists) {
+            builder.append("IF NOT EXISTS ");
+        }
+        builder.append(name);
+        if (prefix != null) {
+            builder.append(" WITH PREFIX ").append(prefix);
+        }
+        return builder;
+    }
+
+    @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);
+    }
+}

src/main/java/net/sf/jsqlparser/util/TablesNamesFinder.java

@@ -219,6 +219,7 @@
 import net.sf.jsqlparser.statement.DeallocateStatement;
 import net.sf.jsqlparser.statement.CopyStatement;
 import net.sf.jsqlparser.statement.create.macro.CreateMacro;
+import net.sf.jsqlparser.statement.create.extension.CreateExtensionRepository;
 
 
 /**
@@ -2594,6 +2595,17 @@ public void visit(CreateMacro createMacro) {
         StatementVisitor.super.visit(createMacro);
     }
 
+    @Override
+    public <S> Void visit(CreateExtensionRepository createExtensionRepository, S context) {
+        // no tables involved in this statement
+        return null;
+    }
+
+    @Override
+    public void visit(CreateExtensionRepository createExtensionRepository) {
+        StatementVisitor.super.visit(createExtensionRepository);
+    }
+
     @Override
     public <S> Void visit(PurgeStatement purgeStatement, S context) {
         if (purgeStatement.getPurgeObjectType() == PurgeObjectType.TABLE) {

src/main/java/net/sf/jsqlparser/util/deparser/StatementDeParser.java

@@ -107,6 +107,7 @@
 import net.sf.jsqlparser.statement.DeallocateStatement;
 import net.sf.jsqlparser.statement.CopyStatement;
 import net.sf.jsqlparser.statement.create.macro.CreateMacro;
+import net.sf.jsqlparser.statement.create.extension.CreateExtensionRepository;
 
 public class StatementDeParser extends AbstractDeParser<Statement>
         implements StatementVisitor<StringBuilder> {
@@ -626,6 +627,12 @@ public <S> StringBuilder visit(CreateMacro createMacro, S context) {
         return builder;
     }
 
+    @Override
+    public <S> StringBuilder visit(CreateExtensionRepository createExtensionRepository, S context) {
+        createExtensionRepository.appendTo(builder);
+        return builder;
+    }
+
     @Override
     public <S> StringBuilder visit(PurgeStatement purgeStatement, S context) {
         purgeStatement.appendTo(builder);

src/main/java/net/sf/jsqlparser/util/validation/validator/StatementValidator.java

@@ -109,6 +109,7 @@
 import net.sf.jsqlparser.statement.DeallocateStatement;
 import net.sf.jsqlparser.statement.CopyStatement;
 import net.sf.jsqlparser.statement.create.macro.CreateMacro;
+import net.sf.jsqlparser.statement.create.extension.CreateExtensionRepository;
 
 /**
  * @author gitmotte
@@ -547,6 +548,12 @@ public <S> Void visit(CreateMacro createMacro, S context) {
         return null;
     }
 
+    @Override
+    public <S> Void visit(CreateExtensionRepository createExtensionRepository, S context) {
+        // TODO: not yet implemented
+        return null;
+    }
+
     @Override
     public <S> Void visit(PurgeStatement purgeStatement, S context) {
         // TODO: not yet implemented
@@ -803,6 +810,10 @@ public void visit(CreateMacro createMacro) {
         visit(createMacro, null);
     }
 
+    public void visit(CreateExtensionRepository createExtensionRepository) {
+        visit(createExtensionRepository, null);
+    }
+
     public void visit(PurgeStatement purgeStatement) {
         visit(purgeStatement, null);
     }

src/main/jjtree/net/sf/jsqlparser/parser/JSqlParserCC.jjt

@@ -17307,6 +17307,12 @@ Statement Create():
         |
         LOOKAHEAD(<K_DOMAIN>) { requireTypeDdlSyntax(!isUsingOrReplace, "OR REPLACE is not supported for CREATE DOMAIN"); } statement = CreateDomain()
         |
+        LOOKAHEAD({ isKeywordAhead("EXTENSION")
+                && "REPOSITORY".equalsIgnoreCase(getToken(2).image) })
+        { requireTypeDdlSyntax(!isUsingOrReplace,
+                "OR REPLACE is not supported for CREATE EXTENSION REPOSITORY"); }
+        statement = CreateExtensionRepository()
+        |
         LOOKAHEAD({ isKeywordAhead("EXTENSION") }) { requireTypeDdlSyntax(!isUsingOrReplace, "OR REPLACE is not supported for CREATE EXTENSION"); } statement = CreateExtension()
         |
         LOOKAHEAD({ isKeywordAhead("PUBLICATION") })
@@ -17710,6 +17716,28 @@ AlterDomain AlterDomain():
     { return result; }
 }
 
+/**
+ * DuckDB 2.0's CREATE EXTENSION REPOSITORY [IF NOT EXISTS] name [WITH PREFIX prefix].
+ */
+CreateExtensionRepository CreateExtensionRepository() #CreateExtensionRepository:
+{
+    CreateExtensionRepository createExtensionRepository = new CreateExtensionRepository();
+    Expression prefix;
+    String name;
+}
+{
+    TypeDdlKeyword("EXTENSION") TypeDdlKeyword("REPOSITORY")
+    [ LOOKAHEAD(3) <K_IF> <K_NOT> <K_EXISTS>
+        { createExtensionRepository.setIfNotExists(true); } ]
+    name=RelObjectName() { createExtensionRepository.setName(name); }
+    // greedy: WITH PREFIX belongs to the repository definition
+    [
+        LOOKAHEAD(2) <K_WITH> TypeDdlKeyword("PREFIX") prefix=SimpleExpression()
+        { createExtensionRepository.setPrefix(prefix); }
+    ]
+    { return createExtensionRepository; }
+}
+
 CreateExtension CreateExtension():
 { CreateExtension result = new CreateExtension(); String name; Expression version; }
 {

src/test/java/net/sf/jsqlparser/statement/select/DuckDBTest.java

@@ -24,6 +24,7 @@
 import net.sf.jsqlparser.statement.DeallocateStatement;
 import net.sf.jsqlparser.statement.CopyStatement;
 import net.sf.jsqlparser.statement.create.macro.CreateMacro;
+import net.sf.jsqlparser.statement.create.extension.CreateExtensionRepository;
 import net.sf.jsqlparser.test.TestUtils;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.Test;
@@ -495,4 +496,31 @@ void testCreateTableMacro() throws JSQLParserException {
         Assertions.assertTrue(createMacro.isTable());
         Assertions.assertNotNull(createMacro.getSelect());
     }
+
+    @Test
+    void testCreateExtensionRepository() throws JSQLParserException {
+        String sqlStr =
+                "CREATE EXTENSION REPOSITORY my_repo WITH PREFIX 'https://extensions.example.org'";
+        CreateExtensionRepository createRepository =
+                (CreateExtensionRepository) TestUtils.assertSqlCanBeParsedAndDeparsed(sqlStr, true);
+
+        Assertions.assertEquals("my_repo", createRepository.getName());
+        Assertions.assertEquals("'https://extensions.example.org'",
+                createRepository.getPrefix().toString());
+    }
+
+    @Test
+    void testCreateExtensionRepositoryIfNotExists() throws JSQLParserException {
+        String sqlStr = "CREATE EXTENSION REPOSITORY IF NOT EXISTS my_repo";
+        CreateExtensionRepository createRepository =
+                (CreateExtensionRepository) TestUtils.assertSqlCanBeParsedAndDeparsed(sqlStr, true);
+
+        Assertions.assertTrue(createRepository.isIfNotExists());
+    }
+
+    @Test
+    void testCreatePostgresExtensionStillParses() throws JSQLParserException {
+        String sqlStr = "CREATE EXTENSION IF NOT EXISTS hstore WITH SCHEMA public CASCADE";
+        TestUtils.assertSqlCanBeParsedAndDeparsed(sqlStr, true);
+    }
 }