DATAMONGO-2228 - Fixed loosing branches in AND expressions (MongodbDocumentSerializer)

Author: MikhailKaduchka

spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/MongodbDocumentSerializer.java

@@ -49,6 +49,7 @@
  * @author laimw
  * @author Mark Paluch
  * @author Christoph Strobl
+ * @author Mikhail Kaduchka
  * @since 2.1
  */
 abstract class MongodbDocumentSerializer implements Visitor<Object, Void> {
@@ -184,8 +185,8 @@ public Object visit(Operation<?> expr, Void context) {
 			Map<Object, Object> lhs = (Map<Object, Object>) handle(expr.getArg(0));
 			Map<Object, Object> rhs = (Map<Object, Object>) handle(expr.getArg(1));
 
-			LinkedHashSet<Entry<Object, Object>> lhs2 = new LinkedHashSet<>(lhs.entrySet());
-			lhs2.retainAll(rhs.entrySet());
+			LinkedHashSet<Object> lhs2 = new LinkedHashSet<>(lhs.keySet());
+			lhs2.retainAll(rhs.keySet());
 
 			if (lhs2.isEmpty()) {
 				lhs.putAll(rhs);

spring-data-mongodb/src/test/java/org/springframework/data/mongodb/repository/support/SpringDataMongodbSerializerUnitTests.java

@@ -15,17 +15,11 @@
  */
 package org.springframework.data.mongodb.repository.support;
 
-import static org.hamcrest.Matchers.*;
-import static org.junit.Assert.*;
-import static org.springframework.data.mongodb.core.DocumentTestUtils.*;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-
+import com.querydsl.core.types.Ops;
+import com.querydsl.core.types.PredicateOperation;
+import com.querydsl.core.types.dsl.*;
 import org.bson.Document;
 import org.bson.types.ObjectId;
-import org.hamcrest.collection.IsIterableContainingInOrder;
 import org.junit.Before;
 import org.junit.Test;
 import org.junit.runner.RunWith;
@@ -43,18 +37,21 @@
 import org.springframework.data.mongodb.repository.QAddress;
 import org.springframework.data.mongodb.repository.QPerson;
 
-import com.querydsl.core.types.dsl.BooleanExpression;
-import com.querydsl.core.types.dsl.BooleanOperation;
-import com.querydsl.core.types.dsl.PathBuilder;
-import com.querydsl.core.types.dsl.SimplePath;
-import com.querydsl.core.types.dsl.StringPath;
+import java.util.Collections;
+
+import static com.querydsl.core.types.ExpressionUtils.path;
+import static com.querydsl.core.types.ExpressionUtils.predicate;
+import static com.querydsl.core.types.dsl.Expressions.constant;
+import static org.hamcrest.Matchers.*;
+import static org.junit.Assert.assertThat;
 
 /**
  * Unit tests for {@link SpringDataMongodbSerializer}.
  *
  * @author Oliver Gierke
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Mikhail Kaduchka
  */
 @RunWith(MockitoJUnitRunner.class)
 public class SpringDataMongodbSerializerUnitTests {
@@ -163,6 +160,19 @@ public void shouldRemarshallListsAndDocuments() {
 						+ "\"$ne\" : \"\"}}} , { \"firstname\" : { \"$not\" : { \"$regex\" : \".*\\\\Qfoo\\\\E.*\" , \"$options\" : \"i\"}}}]}"))));
 	}
 
+    @Test // DATAMONGO-2228
+    public void retainsOpsInAndExpression() {
+
+        PredicateOperation testExpression = predicate(Ops.AND,
+                predicate(Ops.EQ, path(Object.class, "name"), constant("John")),
+                predicate(Ops.EQ, path(Object.class, "name"), constant("Sarah"))
+        );
+
+        Document result = (Document) serializer.visit(testExpression, null);
+
+        assertThat(result.toJson(), is("{\"$and\": [{\"name\": \"John\"}, {\"name\": \"Sarah\"}]}"));
+    }
+
 	class Address {
 		String id;
 		String street;