diff --git a/build.gradle.kts b/build.gradle.kts index 092126f..c7495a1 100644 --- a/build.gradle.kts +++ b/build.gradle.kts @@ -25,8 +25,8 @@ val springBootVersion = "3.1.5" dependencies { api("com.knecon.fforesight:tenant-commons:0.31.0") - api("org.liquibase:liquibase-core:4.20.0") - api("org.liquibase.ext:liquibase-mongodb:4.20.0") + api("org.liquibase:liquibase-core:4.30.0") + api("org.liquibase.ext:liquibase-mongodb:4.30.0") api("org.springframework.boot:spring-boot-starter-data-mongodb:${springBootVersion}") api("org.springframework.boot:spring-boot-starter-validation:${springBootVersion}") api("org.springframework.boot:spring-boot-configuration-processor:${springBootVersion}") diff --git a/src/main/java/com/knecon/fforesight/mongo/database/commons/config/MultiTenantMongoDBFactory.java b/src/main/java/com/knecon/fforesight/mongo/database/commons/config/MultiTenantMongoDBFactory.java index d60de86..4d26e3e 100644 --- a/src/main/java/com/knecon/fforesight/mongo/database/commons/config/MultiTenantMongoDBFactory.java +++ b/src/main/java/com/knecon/fforesight/mongo/database/commons/config/MultiTenantMongoDBFactory.java @@ -1,19 +1,25 @@ package com.knecon.fforesight.mongo.database.commons.config; import java.util.List; +import java.util.concurrent.TimeUnit; import jakarta.validation.constraints.NotNull; import org.bson.Document; +import org.bson.codecs.configuration.CodecRegistry; import org.bson.conversions.Bson; import org.springframework.context.annotation.Configuration; import org.springframework.data.mongodb.core.SimpleMongoClientDatabaseFactory; import com.knecon.fforesight.mongo.database.commons.service.MongoDataSources; import com.mongodb.ClientSessionOptions; +import com.mongodb.ReadConcern; +import com.mongodb.ReadPreference; +import com.mongodb.WriteConcern; import com.mongodb.client.ChangeStreamIterable; import com.mongodb.client.ClientSession; import com.mongodb.client.ListDatabasesIterable; import com.mongodb.client.MongoClient; +import com.mongodb.client.MongoCluster; import com.mongodb.client.MongoDatabase; import com.mongodb.client.MongoIterable; import com.mongodb.connection.ClusterDescription; @@ -40,6 +46,76 @@ public class MultiTenantMongoDBFactory extends SimpleMongoClientDatabaseFactory private static MongoClient getBootstrapMongoClient() { return new MongoClient() { + @Override + public CodecRegistry getCodecRegistry() { + + return null; + } + + + @Override + public ReadPreference getReadPreference() { + + return null; + } + + + @Override + public WriteConcern getWriteConcern() { + + return null; + } + + + @Override + public ReadConcern getReadConcern() { + + return null; + } + + + @Override + public Long getTimeout(TimeUnit timeUnit) { + + return 0L; + } + + + @Override + public MongoCluster withCodecRegistry(CodecRegistry codecRegistry) { + + return null; + } + + + @Override + public MongoCluster withReadPreference(ReadPreference readPreference) { + + return null; + } + + + @Override + public MongoCluster withWriteConcern(WriteConcern writeConcern) { + + return null; + } + + + @Override + public MongoCluster withReadConcern(ReadConcern readConcern) { + + return null; + } + + + @Override + public MongoCluster withTimeout(long l, TimeUnit timeUnit) { + + return null; + } + + @Override public MongoDatabase getDatabase(String s) {