Skip to content

Add improved Bulk Write API for Java Reactive Driver #1583

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 31 commits into from
Jan 2, 2025
Merged

Add improved Bulk Write API for Java Reactive Driver #1583

Changes from 1 commit
Commits
Show all changes
31 commits
Select commit Hold shift + click to select a range
e352b31
Add improved Bulk Write API for Java Reactive Driver
vbabanin Dec 13, 2024
a05882d
Disable Kotlin tests.
vbabanin Dec 14, 2024
78760c0
Remove redundant methods.
vbabanin Dec 14, 2024
cb0d596
Remove TODOs.
vbabanin Dec 14, 2024
9e9f33d
Fix retryable wrapping.
vbabanin Dec 14, 2024
9ca1fe7
Remove comments.
vbabanin Dec 14, 2024
9a7d9ba
Remove test skips.
vbabanin Dec 16, 2024
0ca8859
Update driver-sync/src/test/functional/com/mongodb/client/CrudProseTe…
vbabanin Dec 16, 2024
99a460a
Update driver-sync/src/test/functional/com/mongodb/client/CrudProseTe…
vbabanin Dec 16, 2024
ae8763f
Update driver-core/src/main/com/mongodb/internal/async/MutableValue.java
vbabanin Dec 16, 2024
7001d9e
Update driver-reactive-streams/src/main/com/mongodb/reactivestreams/c…
vbabanin Dec 16, 2024
bee199e
Update driver-core/src/main/com/mongodb/internal/async/AsyncRunnable.…
vbabanin Dec 16, 2024
e6a0a7e
Apply suggestions from code review
vbabanin Dec 16, 2024
df2cb88
Update javadoc.
vbabanin Dec 16, 2024
f43fc49
Make CursorHelper generic.
vbabanin Dec 17, 2024
b7c5bfa
Move exhaustCursor method to cursor interface.
vbabanin Dec 17, 2024
c2d9b07
Add assertions.
vbabanin Dec 17, 2024
9c23736
Update driver-core/src/main/com/mongodb/internal/operation/ClientBulk…
vbabanin Dec 17, 2024
f091561
Update driver-core/src/main/com/mongodb/internal/operation/ClientBulk…
vbabanin Dec 17, 2024
91030ab
Update driver-core/src/main/com/mongodb/internal/async/AsyncBatchCurs…
vbabanin Dec 17, 2024
24ce23d
Update driver-core/src/main/com/mongodb/internal/operation/ClientBulk…
vbabanin Dec 17, 2024
b775ea4
Update driver-core/src/main/com/mongodb/internal/operation/ClientBulk…
vbabanin Dec 17, 2024
8110a09
Update driver-core/src/main/com/mongodb/internal/operation/ClientBulk…
vbabanin Dec 17, 2024
e8c1520
Update driver-core/src/main/com/mongodb/internal/operation/ClientBulk…
vbabanin Dec 17, 2024
8f3e522
- Adress formatting issues.
vbabanin Dec 17, 2024
dc85f96
Fix static checks.
vbabanin Dec 17, 2024
c0b7292
Fix test.
vbabanin Dec 17, 2024
fc02c9a
Remove throws.
vbabanin Dec 17, 2024
3f36b21
Remove redundant method.
vbabanin Dec 17, 2024
190a067
Fix typo.
vbabanin Dec 19, 2024
3019e07
Apply suggestions from code review
vbabanin Dec 20, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
12 changes: 0 additions & 12 deletions driver-sync/src/test/functional/com/mongodb/client/unified/UnifiedTestModifications.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -203,18 +203,6 @@ public static void doSkips(final TestDef def) {
def.skipJira("https://jira.mongodb.org/browse/JAVA-5341")
.when(() -> isDiscoverableReplicaSet() && serverVersionLessThan(4, 4))
.test("retryable-writes", "retryable-writes insertOne serverErrors", "RetryableWriteError label is added based on writeConcernError in pre-4.4 mongod response");
def.skipJira("https://jira.mongodb.org/browse/JAVA-4586")
//.testContains("retryable-writes", "client bulkWrite")
.test("retryable-writes", "client bulkWrite retryable writes", "client bulkWrite with no multi: true operations succeeds after retryable top-level error")
.test("retryable-writes", "client bulkWrite retryable writes", "client bulkWrite with multi: true operations fails after retryable top-level error")
.test("retryable-writes", "client bulkWrite retryable writes", "client bulkWrite with no multi: true operations succeeds after retryable writeConcernError")
.test("retryable-writes", "client bulkWrite retryable writes", "client bulkWrite with multi: true operations fails after retryable writeConcernError")
.test("retryable-writes", "client bulkWrite retryable writes", "client bulkWrite with retryWrites: false does not retry")
.test("retryable-writes", "client bulkWrite retryable writes with client errors", "client bulkWrite with one network error succeeds after retry")
.test("retryable-writes", "client bulkWrite retryable writes with client errors", "client bulkWrite with two network errors fails after retry")
//.testContains("retryable-writes", "client.clientBulkWrite")
.test("retryable-writes", "retryable writes handshake failures", "client.clientBulkWrite succeeds after retryable handshake network error")
.test("retryable-writes", "retryable writes handshake failures", "client.clientBulkWrite succeeds after retryable handshake server error (ShutdownInProgress)");

// server-discovery-and-monitoring (SDAM)

Expand Down