DATAMONGO-1992 - Extract common entity operations API from (Reactive)MongoTemplate.

Introduced EntityOperations and MappedDocument to allow to share common operations from MongoTemplate and ReactiveMongoTemplate.

Author: odrotbohm

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/EntityOperations.java

@@ -119,11 +119,11 @@ private String getCollectionName(Aggregation aggregation) {
 				TypedAggregation<?> typedAggregation = (TypedAggregation<?>) aggregation;
 
 				if (typedAggregation.getInputType() != null) {
-					return template.determineCollectionName(typedAggregation.getInputType());
+					return template.getCollectionName(typedAggregation.getInputType());
 				}
 			}
 
-			return template.determineCollectionName(domainType);
+			return template.getCollectionName(domainType);
 		}
 	}
 }

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ExecutableAggregationOperationSupport.java

@@ -230,7 +230,7 @@ private CursorPreparer getCursorPreparer(Query query, @Nullable CursorPreparer p
 		}
 
 		private String getCollectionName() {
-			return StringUtils.hasText(collection) ? collection : template.determineCollectionName(domainType);
+			return StringUtils.hasText(collection) ? collection : template.getCollectionName(domainType);
 		}
 
 		private String asString() {

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ExecutableFindOperationSupport.java

@@ -129,7 +129,7 @@ public TerminatingBulkInsert<T> withBulkMode(BulkMode bulkMode) {
 		}
 
 		private String getCollectionName() {
-			return StringUtils.hasText(collection) ? collection : template.determineCollectionName(domainType);
+			return StringUtils.hasText(collection) ? collection : template.getCollectionName(domainType);
 		}
 	}
 }

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ExecutableInsertOperationSupport.java

@@ -15,10 +15,11 @@
  */
 package org.springframework.data.mongodb.core;
 
-import java.util.List;
-
 import lombok.NonNull;
 import lombok.RequiredArgsConstructor;
+
+import java.util.List;
+
 import org.springframework.data.mongodb.core.mapreduce.MapReduceOptions;
 import org.springframework.data.mongodb.core.query.Query;
 import org.springframework.lang.Nullable;
@@ -67,8 +68,9 @@ static class ExecutableMapReduceSupport<T>
 		private final @Nullable String reduceFunction;
 		private final @Nullable MapReduceOptions options;
 
-		ExecutableMapReduceSupport(MongoTemplate template, Class<?> domainType, Class<T> returnType, @Nullable String collection,
-				Query query, @Nullable String mapFunction, @Nullable String reduceFunction, @Nullable MapReduceOptions options) {
+		ExecutableMapReduceSupport(MongoTemplate template, Class<?> domainType, Class<T> returnType,
+				@Nullable String collection, Query query, @Nullable String mapFunction, @Nullable String reduceFunction,
+				@Nullable MapReduceOptions options) {
 
 			this.template = template;
 			this.domainType = domainType;
@@ -169,7 +171,7 @@ public ExecutableMapReduce<T> reduce(String reduceFunction) {
 		}
 
 		private String getCollectionName() {
-			return StringUtils.hasText(collection) ? collection : template.determineCollectionName(domainType);
+			return StringUtils.hasText(collection) ? collection : template.getCollectionName(domainType);
 		}
 	}
 }

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ExecutableMapReduceOperationSupport.java

@@ -123,7 +123,7 @@ public List<T> findAndRemove() {
 		}
 
 		private String getCollectionName() {
-			return StringUtils.hasText(collection) ? collection : template.determineCollectionName(domainType);
+			return StringUtils.hasText(collection) ? collection : template.getCollectionName(domainType);
 		}
 	}
 }

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ExecutableRemoveOperationSupport.java

@@ -221,7 +221,7 @@ private UpdateResult doUpdate(boolean multi, boolean upsert) {
 		}
 
 		private String getCollectionName() {
-			return StringUtils.hasText(collection) ? collection : template.determineCollectionName(domainType);
+			return StringUtils.hasText(collection) ? collection : template.getCollectionName(domainType);
 		}
 	}
 }

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ExecutableUpdateOperationSupport.java

@@ -0,0 +1,88 @@
+/*
+ * Copyright 2018 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
+ *
+ *      http://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 org.springframework.data.mongodb.core;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+import java.util.Collection;
+import java.util.List;
+
+import org.bson.Document;
+import org.bson.conversions.Bson;
+import org.springframework.data.mongodb.core.query.Update;
+import org.springframework.data.util.StreamUtils;
+
+import com.mongodb.client.model.Filters;
+
+/**
+ * A MongoDB document in its mapped state. I.e. after a source document has been mapped using mapping information of the
+ * entity the source document was supposed to represent.
+ * 
+ * @author Oliver Gierke
+ * @since 2.1
+ */
+@RequiredArgsConstructor(staticName = "of")
+public class MappedDocument {
+
+	private static final String ID_FIELD = "_id";
+	private static final Document ID_ONLY_PROJECTION = new Document(ID_FIELD, 1);
+
+	private final @Getter Document document;
+
+	public static Document getIdOnlyProjection() {
+		return ID_ONLY_PROJECTION;
+	}
+
+	public static Document getIdIn(Collection<?> ids) {
+		return new Document(ID_FIELD, new Document("$in", ids));
+	}
+
+	public static List<Object> toIds(Collection<Document> documents) {
+
+		return documents.stream()//
+				.map(it -> it.get(ID_FIELD))//
+				.collect(StreamUtils.toUnmodifiableList());
+	}
+
+	public boolean hasId() {
+		return document.containsKey(ID_FIELD);
+	}
+
+	public boolean hasNonNullId() {
+		return hasId() && document.get(ID_FIELD) != null;
+	}
+
+	public Object getId() {
+		return document.get(ID_FIELD);
+	}
+
+	public <T> T getId(Class<T> type) {
+		return document.get(ID_FIELD, type);
+	}
+
+	public boolean isIdPresent(Class<?> type) {
+		return type.isInstance(getId());
+	}
+
+	public Bson getIdFilter() {
+		return Filters.eq(ID_FIELD, document.get(ID_FIELD));
+	}
+
+	public Update updateWithoutId() {
+		return Update.fromDocument(document, ID_FIELD);
+	}
+}