#519 - Add example for reactive Querydsl for MongoDB.

closes: #519
Original pull request: #520.

mongodb/querydsl/src/main/java/example/springdata/mongodb/Customer.java

@@ -0,0 +1,99 @@
+/*
+ * Copyright 2019 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;
+
+import org.springframework.data.mongodb.core.mapping.Document;
+import org.springframework.util.Assert;
+
+/**
+ * An entity to represent a customer.
+ *
+ * @author Christoph Strobl
+ */
+@Document
+public class Customer {
+
+	private String id, firstname, lastname;
+
+	/**
+	 * Creates a new {@link Customer} with the given firstname and lastname.
+	 *
+	 * @param firstname must not be {@literal null} or empty.
+	 * @param lastname must not be {@literal null} or empty.
+	 */
+	public Customer(String firstname, String lastname) {
+
+		Assert.hasText(firstname, "Firstname must not be null or empty!");
+		Assert.hasText(lastname, "Lastname must not be null or empty!");
+
+		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;
+	}
+
+	@Override
+	public String toString() {
+		return "Customer{" + "id='" + id + '\'' + ", firstname='" + firstname + '\'' + ", lastname='" + lastname + '\''
+				+ '}';
+	}
+
+	@Override
+	public boolean equals(Object o) {
+		if (this == o)
+			return true;
+		if (o == null || getClass() != o.getClass())
+			return false;
+
+		Customer customer = (Customer) o;
+
+		if (id != null ? !id.equals(customer.id) : customer.id != null)
+			return false;
+		if (firstname != null ? !firstname.equals(customer.firstname) : customer.firstname != null)
+			return false;
+		return lastname != null ? lastname.equals(customer.lastname) : customer.lastname == null;
+	}
+
+	@Override
+	public int hashCode() {
+		int result = id != null ? id.hashCode() : 0;
+		result = 31 * result + (firstname != null ? firstname.hashCode() : 0);
+		result = 31 * result + (lastname != null ? lastname.hashCode() : 0);
+		return result;
+	}
+}

mongodb/querydsl/src/main/java/example/springdata/mongodb/reactive/ApplicationConfiguration.java

@@ -0,0 +1,27 @@
+/*
+ * Copyright 2019 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.reactive;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * Configuration to connect to MongoDB using a {@link com.mongodb.reactivestreams.client.MongoClient}. <br />
+ * Enables Spring Data repositories for MongoDB.
+ *
+ * @author Christoph Strobl
+ */
+@SpringBootApplication
+class ApplicationConfiguration {}

mongodb/querydsl/src/main/java/example/springdata/mongodb/reactive/ReactiveCustomerQuerydslRepository.java

@@ -0,0 +1,31 @@
+/*
+ * Copyright 2019 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.reactive;
+
+import example.springdata.mongodb.Customer;
+
+import org.springframework.data.querydsl.ReactiveQuerydslPredicateExecutor;
+import org.springframework.data.repository.reactive.ReactiveCrudRepository;
+
+/**
+ * Reactive Querydsl supporting repository interface to manage {@link Customer} instances.
+ *
+ * @author Christoph Strobl
+ */
+interface ReactiveCustomerQuerydslRepository
+		extends ReactiveCrudRepository<Customer, String>, ReactiveQuerydslPredicateExecutor<Customer> {
+
+}

mongodb/querydsl/src/main/java/example/springdata/mongodb/sync/ApplicationConfiguration.java

@@ -0,0 +1,29 @@
+/*
+ * Copyright 2019 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.sync;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+import com.mongodb.MongoClient;
+
+/**
+ * Configuration to connect to MongoDB using a {@link MongoClient}. <br />
+ * Enables Spring Data repositories for MongoDB.
+ *
+ * @author Christoph Strobl
+ */
+@SpringBootApplication
+class ApplicationConfiguration {}

mongodb/querydsl/src/main/java/example/springdata/mongodb/sync/CustomerQuerydslRepository.java

@@ -0,0 +1,30 @@
+/*
+ * Copyright 2019 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.sync;
+
+import example.springdata.mongodb.Customer;
+
+import org.springframework.data.querydsl.QuerydslPredicateExecutor;
+import org.springframework.data.repository.CrudRepository;
+
+/**
+ * Sync Querydsl supporting repository interface to manage {@link Customer} instances.
+ *
+ * @author Christoph Strobl
+ */
+interface CustomerQuerydslRepository extends CrudRepository<Customer, String>, QuerydslPredicateExecutor<Customer> {
+
+}

mongodb/querydsl/src/test/java/example/springdata/mongodb/reactive/ReactiveCustomerRepositoryTests.java

@@ -0,0 +1,68 @@
+/*
+ * Copyright 2019 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.reactive;
+
+import static org.assertj.core.api.Assertions.*;
+
+import example.springdata.mongodb.Customer;
+import example.springdata.mongodb.QCustomer;
+import reactor.test.StepVerifier;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.mongodb.core.MongoOperations;
+import org.springframework.test.context.junit4.SpringRunner;
+
+/**
+ * @author Christoph Strobl
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class ReactiveCustomerRepositoryTests {
+
+	@Autowired ReactiveCustomerQuerydslRepository repository;
+	@Autowired MongoOperations operations;
+
+	Customer dave, oliver, carter;
+
+	@Before
+	public void setUp() {
+
+		repository.deleteAll().as(StepVerifier::create).verifyComplete();
+
+		dave = new Customer("Dave", "Matthews");
+		oliver = new Customer("Oliver August", "Matthews");
+		carter = new Customer("Carter", "Beauford");
+
+		repository.save(dave).then().as(StepVerifier::create).verifyComplete();
+		repository.save(oliver).then().as(StepVerifier::create).verifyComplete();
+		repository.save(carter).then().as(StepVerifier::create).verifyComplete();
+	}
+
+	@Test
+	public void findAllByPredicate() {
+
+		repository.findAll(QCustomer.customer.lastname.eq("Matthews")) //
+				.collectList() //
+				.as(StepVerifier::create) //
+				.assertNext(it -> assertThat(it).containsExactlyInAnyOrder(dave, oliver)) //
+				.verifyComplete();
+	}
+
+}

mongodb/querydsl/src/test/java/example/springdata/mongodb/sync/CustomerRepositoryTests.java

@@ -0,0 +1,58 @@
+/*
+ * Copyright 2019 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.sync;
+
+import static org.assertj.core.api.Assertions.*;
+
+import example.springdata.mongodb.Customer;
+import example.springdata.mongodb.QCustomer;
+
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.mongodb.core.MongoOperations;
+import org.springframework.test.context.junit4.SpringRunner;
+
+/**
+ * @author Christoph Strobl
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class CustomerRepositoryTests {
+
+	@Autowired CustomerQuerydslRepository repository;
+	@Autowired MongoOperations operations;
+
+	Customer dave, oliver, carter;
+
+	@Before
+	public void setUp() {
+
+		repository.deleteAll();
+
+		dave = repository.save(new Customer("Dave", "Matthews"));
+		oliver = repository.save(new Customer("Oliver August", "Matthews"));
+		carter = repository.save(new Customer("Carter", "Beauford"));
+	}
+
+	@Test
+	public void findAllByPredicate() {
+		assertThat(repository.findAll(QCustomer.customer.lastname.eq("Matthews"))).containsExactlyInAnyOrder(dave, oliver);
+	}
+
+}

mongodb/querydsl/src/test/resources/application.properties

@@ -0,0 +1,2 @@
+# Random port for embedded MongoDB
+spring.data.mongodb.port=0