diff --git a/build.gradle.kts b/build.gradle.kts index 9197084c8..5b52debd0 100644 --- a/build.gradle.kts +++ b/build.gradle.kts @@ -16,7 +16,7 @@ plugins { allprojects { group = "io.flamingock" - version = "0.0.40-beta" + version = "0.0.42-beta" repositories { mavenCentral() diff --git a/buildSrc/src/main/kotlin/flamingock.release-management.gradle.kts b/buildSrc/src/main/kotlin/flamingock.release-management.gradle.kts index ab9a09e60..c2470ae7b 100644 --- a/buildSrc/src/main/kotlin/flamingock.release-management.gradle.kts +++ b/buildSrc/src/main/kotlin/flamingock.release-management.gradle.kts @@ -82,7 +82,7 @@ if (project != rootProject) { } prerelease { enabled.set(true) - pattern.set(".*-(beta|snapshot|alpha)\\$") + pattern.set("^(0\\..*|.*-(beta\\.?\\d*|snapshot\\.?\\d*|alpha\\.?\\d*|rc\\.?\\d*|RC\\.?\\d*)\$)") } changelog { enabled.set(true) diff --git a/core/target-systems/mongodb-sync-target-system/src/main/java/io/flamingock/targetystem/mongodb/sync/MongoDBSyncTargetSystem.java b/core/target-systems/mongodb-sync-target-system/src/main/java/io/flamingock/targetystem/mongodb/sync/MongoDBSyncTargetSystem.java index 6b862252a..8bcea8c7f 100644 --- a/core/target-systems/mongodb-sync-target-system/src/main/java/io/flamingock/targetystem/mongodb/sync/MongoDBSyncTargetSystem.java +++ b/core/target-systems/mongodb-sync-target-system/src/main/java/io/flamingock/targetystem/mongodb/sync/MongoDBSyncTargetSystem.java @@ -46,6 +46,21 @@ public MongoDBSyncTargetSystem(String id, MongoClient mongoClient, String databa this.databaseName = databaseName; } + public MongoDBSyncTargetSystem withReadConcern(ReadConcern readConcern) { + this.readConcern = readConcern; + return this; + } + + public MongoDBSyncTargetSystem withReadPreference(ReadPreference readPreference) { + this.readPreference = readPreference; + return this; + } + + public MongoDBSyncTargetSystem withWriteConcern(WriteConcern writeConcern) { + this.writeConcern = writeConcern; + return this; + } + public MongoClient getClient() { return mongoClient; } @@ -54,6 +69,18 @@ public MongoDatabase getDatabase() { return database; } + public WriteConcern getWriteConcern() { + return writeConcern; + } + + public ReadConcern getReadConcern() { + return readConcern; + } + + public ReadPreference getReadPreference() { + return readPreference; + } + public TransactionManager getTxManager() { return txWrapper.getTxManager(); } @@ -62,7 +89,10 @@ public TransactionManager getTxManager() { public void initialize(ContextResolver baseContext) { this.validate(); targetSystemContext.addDependency(mongoClient); - database = mongoClient.getDatabase(databaseName); + database = mongoClient.getDatabase(databaseName) + .withReadConcern(readConcern) + .withReadPreference(readPreference) + .withWriteConcern(writeConcern); targetSystemContext.addDependency(database); TransactionManager txManager = new TransactionManager<>(mongoClient::startSession);