Project mangled encrypted field names. (#2058)

Closes #2057.

Author: mikereiche

src/main/java/org/springframework/data/couchbase/core/convert/MappingCouchbaseConverter.java

@@ -1130,7 +1130,7 @@ public <R> R getPropertyValue(final CouchbasePersistentProperty property) {
 		}
 	}
 
-	String maybeMangle(PersistentProperty<?> property) {
+	public String maybeMangle(PersistentProperty<?> property) {
 		Assert.notNull(property, "property");
 		if (!conversions.hasValueConverter(property)) {
 			return ((CouchbasePersistentProperty) property).getFieldName();

src/main/java/org/springframework/data/couchbase/repository/query/StringBasedN1qlQueryParser.java

@@ -34,6 +34,7 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.data.couchbase.core.convert.CouchbaseConverter;
+import org.springframework.data.couchbase.core.convert.MappingCouchbaseConverter;
 import org.springframework.data.couchbase.core.mapping.CouchbaseDocument;
 import org.springframework.data.couchbase.core.mapping.CouchbaseList;
 import org.springframework.data.couchbase.core.mapping.CouchbasePersistentProperty;
@@ -332,7 +333,13 @@ private void getProjectedFieldsInternal(String bucketName, CouchbasePersistentPr
 				if (fieldList == null || fieldList.contains(prop.getFieldName())) {
 					PersistentPropertyPath<CouchbasePersistentProperty> path = couchbaseConverter.getMappingContext()
 							.getPersistentPropertyPath(prop.getName(), persistentEntity.getTypeInformation().getType());
-					projectField = N1qlQueryCreator.addMetaIfRequired(bucketName, path, prop, persistentEntity).toString();
+					String unmangled = prop.getFieldName();
+					String maybeMangled =((MappingCouchbaseConverter)couchbaseConverter).maybeMangle(prop);
+					if(maybeMangled.equals(unmangled)) {
+						projectField = N1qlQueryCreator.addMetaIfRequired(bucketName, path, prop, persistentEntity).toString();
+					} else {
+						projectField = i(maybeMangled).toString();
+					}
 					if (sb.length() > 0) {
 						sb.append(", ");
 					}

src/test/java/org/springframework/data/couchbase/repository/CouchbaseRepositoryFieldLevelEncryptionIntegrationTests.java

@@ -154,10 +154,14 @@ void writeSpring_readSpring() {
 		assertFalse(userEncryptedRepository.existsById(user.getId()));
 		userEncryptedRepository.save(user);
 		// read the user with Spring
+
 		Optional<UserEncrypted> writeSpringReadSpring = userEncryptedRepository.findById(user.getId());
 		assertTrue(writeSpringReadSpring.isPresent());
 		writeSpringReadSpring.ifPresent(u -> assertEquals(user, u));
 
+		List<UserEncrypted> writeSpringReadSpring2 = userEncryptedRepository.findAll();
+		assertEquals(user, writeSpringReadSpring2.stream().filter(u -> u.getId().equals(user.getId())).findFirst().get());
+
 		if (cleanAfter) {
 			try {
 				couchbaseTemplate.removeById(UserEncrypted.class).one(user.getId());