Add MongoDB Bulk Write sample.

Author: christophstrobl

README.adoc

@@ -60,7 +60,7 @@ Contains also examples running on Virtual Threads.
 
 * `aot-optimization` - Use Ahead-Of-Time Repositories with Spring Data MongoDB.
 * `aggregation` - Example project to showcase the MongoDB aggregation framework support.
-* `example` - Example project for general repository functionality (including geo-spatial functionality), Querydsl integration and advanced topics.
+* `example` - Example project for general repository functionality (including geo-spatial functionality), Querydsl integration, bulk write and other advanced topics.
 * `fluent-api` - Example project to show the new fluent API (`MongoTemplate`-alternative) to interact with MongoDB.
 * `geo-json` - Example project showing usage of http://geojson.org[GeoJSON] with MongoDB.
 * `gridfs` - Example project showing usage of gridFS with MongoDB.

jdbc/immutables/src/main/java/example/springdata/jdbc/immutables/Application.java

@@ -19,6 +19,7 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Lazy;
 import org.springframework.core.io.ResourceLoader;
+import org.springframework.data.core.TypeInformation;
 import org.springframework.data.jdbc.core.convert.DefaultJdbcTypeFactory;
 import org.springframework.data.jdbc.core.convert.JdbcConverter;
 import org.springframework.data.jdbc.core.convert.JdbcCustomConversions;
@@ -29,7 +30,6 @@
 import org.springframework.data.relational.core.conversion.RowDocumentAccessor;
 import org.springframework.data.relational.core.dialect.Dialect;
 import org.springframework.data.relational.core.mapping.RelationalPersistentEntity;
-import org.springframework.data.util.TypeInformation;
 import org.springframework.jdbc.core.namedparam.NamedParameterJdbcOperations;
 import org.springframework.util.ClassUtils;
 
@@ -67,7 +67,7 @@ public ImmutablesJdbcConfiguration(ResourceLoader resourceLoader) {
 		 * @param dialect
 		 * @return
 		 */
-		@Override
+//		@Override
 		public JdbcConverter jdbcConverter(JdbcMappingContext mappingContext, NamedParameterJdbcOperations operations,
 				@Lazy RelationResolver relationResolver, JdbcCustomConversions conversions, Dialect dialect) {
 

mongodb/example/README.md

@@ -6,6 +6,7 @@ This project contains examples for:
 * Usage of property-specific converters.
 * `EntityCallback` API usage for before convert/save interaction.
 * Result projections for DTOs and interface types.
+* Bulk write to multiple collections.
 * Query metadata.
 * Unwrapping entities into the parent document.
 

mongodb/example/pom.xml

@@ -49,6 +49,11 @@
 			<groupId>com.fasterxml.jackson.core</groupId>
 			<artifactId>jackson-databind</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework</groupId>
+			<artifactId>spring-core</artifactId>
+			<version>7.0.3</version>
+		</dependency>
 		<dependency>
 			<groupId>org.springframework.data.examples</groupId>
 			<artifactId>spring-data-mongodb-example-utils</artifactId>

mongodb/example/src/main/java/example/springdata/mongodb/bulk/ApplicationConfiguration.java

@@ -0,0 +1,28 @@
+/*
+ * Copyright 2026-present the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.mongodb.bulk;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * Configuration for bulk write example tests.
+ *
+ * @author Christoph Strobl
+ */
+@SpringBootApplication
+class ApplicationConfiguration {
+
+}

mongodb/example/src/main/java/example/springdata/mongodb/bulk/Jedi.java

@@ -0,0 +1,65 @@
+/*
+ * Copyright 2026-present the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.mongodb.bulk;
+
+import org.springframework.data.mongodb.core.mapping.Document;
+
+/**
+ * Domain type for bulk write examples, using Star Wars character names.
+ *
+ * @author Christoph Strobl
+ */
+@Document
+public class Jedi {
+
+	private String id;
+	private String firstname;
+	private String lastname;
+
+	public Jedi(String firstname, String lastname) {
+
+		this.firstname = firstname;
+		this.lastname = lastname;
+	}
+
+	public String getId() {
+		return id;
+	}
+
+	public void setId(String id) {
+		this.id = id;
+	}
+
+	public String getFirstname() {
+		return firstname;
+	}
+
+	public void setFirstname(String firstname) {
+		this.firstname = firstname;
+	}
+
+	public String getLastname() {
+		return lastname;
+	}
+
+	public void setLastname(String lastname) {
+		this.lastname = lastname;
+	}
+
+	public String fullName() {
+		return firstname + " " + lastname;
+	}
+}

mongodb/example/src/main/java/example/springdata/mongodb/bulk/Sith.java

@@ -0,0 +1,25 @@
+/*
+ * Copyright 2026-present the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.mongodb.bulk;
+
+import org.springframework.data.annotation.Id;
+
+/**
+ * @author Christoph Strobl
+ */
+public record Sith(@Id String name, String realName) {
+
+}

mongodb/example/src/test/java/example/springdata/mongodb/advanced/AdvancedIntegrationTests.java

@@ -51,7 +51,7 @@ class AdvancedIntegrationTests {
 
 	@DynamicPropertySource
 	static void setProperties(DynamicPropertyRegistry registry) {
-		registry.add("spring.data.mongodb.uri", mongoDBContainer::getReplicaSetUrl);
+		registry.add("spring.mongodb.uri", mongoDBContainer::getReplicaSetUrl);
 	}
 
 	@Autowired AdvancedRepository repository;

mongodb/example/src/test/java/example/springdata/mongodb/bulk/BulkWriteIntegrationTest.java

@@ -0,0 +1,88 @@
+/*
+ * Copyright 2025 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package example.springdata.mongodb.bulk;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.springframework.data.mongodb.core.query.Criteria.where;
+
+import example.springdata.mongodb.util.MongoContainers;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.data.mongodb.test.autoconfigure.DataMongoTest;
+import org.springframework.data.mongodb.core.MongoOperations;
+import org.springframework.data.mongodb.core.bulk.Bulk;
+import org.springframework.data.mongodb.core.bulk.BulkWriteOptions;
+import org.springframework.data.mongodb.core.bulk.BulkWriteResult;
+import org.springframework.data.mongodb.core.query.Update;
+import org.springframework.test.context.DynamicPropertyRegistry;
+import org.springframework.test.context.DynamicPropertySource;
+import org.testcontainers.junit.jupiter.Container;
+import org.testcontainers.junit.jupiter.Testcontainers;
+import org.testcontainers.mongodb.MongoDBContainer;
+
+/**
+ * Integration test demonstrating {@link MongoOperations#bulkWrite(Bulk, BulkWriteOptions)} with a combination of
+ * insert and update operations in a single request.
+ *
+ * @author Christoph Strobl
+ */
+@Testcontainers
+@DataMongoTest
+class BulkWriteIntegrationTest {
+
+	@Container
+	private static MongoDBContainer mongoDBContainer = MongoContainers.getDefaultContainer();
+
+	@DynamicPropertySource
+	static void setProperties(DynamicPropertyRegistry registry) {
+		registry.add("spring.mongodb.uri", mongoDBContainer::getReplicaSetUrl);
+	}
+
+	@Autowired
+	MongoOperations operations;
+
+	@BeforeEach
+	void setUp() {
+		operations.dropCollection(Jedi.class);
+	}
+
+	@Test
+	void bulkWriteInsertAndUpdateInOrder() {
+
+		Bulk bulk = Bulk.create(builder -> builder.inCollection(Jedi.class, spec -> spec
+				.insert(new Jedi("Luke", "Skywalker"))
+				.insert(new Jedi("Leia", "Princess"))
+				.updateOne(where("firstname").is("Leia"), new Update().set("lastname", "Organa")))
+			.inCollection(Sith.class, spec -> spec.upsert(where("name").is("Darth Sidious"), Update.update("realName", "Palpatine")))
+		);
+
+		BulkWriteResult result = operations.bulkWrite(bulk, BulkWriteOptions.ordered());
+
+		assertThat(result.acknowledged()).isTrue();
+		assertThat(result.insertCount()).isEqualTo(2); // luke & leia
+		assertThat(result.modifiedCount()).isOne(); // leia
+		assertThat(result.upsertCount()).isOne(); // darth sidious
+
+		assertThat(operations.findAll(Jedi.class))
+			.extracting(Jedi::fullName)
+			.containsExactlyInAnyOrder("Luke Skywalker", "Leia Organa");
+
+		assertThat(operations.findAll(Sith.class))
+			.extracting(Sith::name)
+			.containsExactlyInAnyOrder("Darth Sidious");
+	}
+}

mongodb/example/src/test/java/example/springdata/mongodb/converters/CustomerIntegrationTests.java

@@ -49,7 +49,7 @@ class CustomerIntegrationTests {
 
 	@DynamicPropertySource
 	static void setProperties(DynamicPropertyRegistry registry) {
-		registry.add("spring.data.mongodb.uri", mongoDBContainer::getReplicaSetUrl);
+		registry.add("spring.mongodb.uri", mongoDBContainer::getReplicaSetUrl);
 	}
 
 	@Autowired MongoOperations operations;