Support authSource in liquibase-mongodb

gsmet · Jul 8, 2022 · 983f047 · 983f047
1 parent 4805844
commit 983f047
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/...e-mongodb/runtime/src/main/java/io/quarkus/liquibase/mongodb/LiquibaseMongodbFactory.java b/...e-mongodb/runtime/src/main/java/io/quarkus/liquibase/mongodb/LiquibaseMongodbFactory.java
@@ -39,12 +39,15 @@ public Liquibase createLiquibase() {
                                 "Config property 'quarkus.mongodb.database' must be defined when no database " +
                                         "exist in the connection string"));
             }
+            if (mongoClientConfig.credentials.authSource.isPresent()) {
+                connectionString += "?authSource=" + mongoClientConfig.credentials.authSource.get();
+            }
+
             Database database = DatabaseFactory.getInstance().openDatabase(connectionString,
                     this.mongoClientConfig.credentials.username.orElse(null),
                     this.mongoClientConfig.credentials.password.orElse(null),
                     null, resourceAccessor);
 
-            ;
             if (database != null) {
                 liquibaseMongodbConfig.liquibaseCatalogName.ifPresent(database::setLiquibaseCatalogName);
                 liquibaseMongodbConfig.liquibaseSchemaName.ifPresent(database::setLiquibaseSchemaName);