Skip to content

Commit 5d2095d

Browse files
authored
fix: bring back withXXX methods to MongoDBTargetSystem (#712)
* fix: bring back withXXX methods to MongoDBTargetSystem * fix: change prerelease pattern to accept wider options * fix: update version to 0.0.42-beta
1 parent e962915 commit 5d2095d

File tree

3 files changed

+33
-3
lines changed

3 files changed

+33
-3
lines changed

build.gradle.kts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ plugins {
1616

1717
allprojects {
1818
group = "io.flamingock"
19-
version = "0.0.40-beta"
19+
version = "0.0.42-beta"
2020

2121
repositories {
2222
mavenCentral()

buildSrc/src/main/kotlin/flamingock.release-management.gradle.kts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ if (project != rootProject) {
8282
}
8383
prerelease {
8484
enabled.set(true)
85-
pattern.set(".*-(beta|snapshot|alpha)\\$")
85+
pattern.set("^(0\\..*|.*-(beta\\.?\\d*|snapshot\\.?\\d*|alpha\\.?\\d*|rc\\.?\\d*|RC\\.?\\d*)\$)")
8686
}
8787
changelog {
8888
enabled.set(true)

core/target-systems/mongodb-sync-target-system/src/main/java/io/flamingock/targetystem/mongodb/sync/MongoDBSyncTargetSystem.java

Lines changed: 31 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,21 @@ public MongoDBSyncTargetSystem(String id, MongoClient mongoClient, String databa
4646
this.databaseName = databaseName;
4747
}
4848

49+
public MongoDBSyncTargetSystem withReadConcern(ReadConcern readConcern) {
50+
this.readConcern = readConcern;
51+
return this;
52+
}
53+
54+
public MongoDBSyncTargetSystem withReadPreference(ReadPreference readPreference) {
55+
this.readPreference = readPreference;
56+
return this;
57+
}
58+
59+
public MongoDBSyncTargetSystem withWriteConcern(WriteConcern writeConcern) {
60+
this.writeConcern = writeConcern;
61+
return this;
62+
}
63+
4964
public MongoClient getClient() {
5065
return mongoClient;
5166
}
@@ -54,6 +69,18 @@ public MongoDatabase getDatabase() {
5469
return database;
5570
}
5671

72+
public WriteConcern getWriteConcern() {
73+
return writeConcern;
74+
}
75+
76+
public ReadConcern getReadConcern() {
77+
return readConcern;
78+
}
79+
80+
public ReadPreference getReadPreference() {
81+
return readPreference;
82+
}
83+
5784
public TransactionManager<ClientSession> getTxManager() {
5885
return txWrapper.getTxManager();
5986
}
@@ -62,7 +89,10 @@ public TransactionManager<ClientSession> getTxManager() {
6289
public void initialize(ContextResolver baseContext) {
6390
this.validate();
6491
targetSystemContext.addDependency(mongoClient);
65-
database = mongoClient.getDatabase(databaseName);
92+
database = mongoClient.getDatabase(databaseName)
93+
.withReadConcern(readConcern)
94+
.withReadPreference(readPreference)
95+
.withWriteConcern(writeConcern);
6696
targetSystemContext.addDependency(database);
6797

6898
TransactionManager<ClientSession> txManager = new TransactionManager<>(mongoClient::startSession);

0 commit comments

Comments
 (0)