DATADOC-48 adding checks not to overwrite existing keys in changeset

spring-data-mongodb-cross-store/src/main/java/org/springframework/data/persistence/document/mongo/MongoChangeSetPersister.java

@@ -6,7 +6,6 @@ import com.mongodb.DBObject;
 import com.mongodb.MongoException;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.DataAccessException;
 import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.data.document.mongodb.CollectionCallback;
@@ -43,28 +42,33 @@ public class MongoChangeSetPersister implements ChangeSetPersister<Object> {
     final DBObject dbk = new BasicDBObject();
     dbk.put(ENTITY_ID, id);
     dbk.put(ENTITY_CLASS, entityClass.getName());
+    if (log.isDebugEnabled()) {
+      log.debug("Loading MongoDB data for " + dbk);
+    }
     mongoTemplate.execute(collName, new CollectionCallback<Object>() {
       @Override
       public Object doInCollection(DBCollection collection)
           throws MongoException, DataAccessException {
         for (DBObject dbo : collection.find(dbk)) {
           String key = (String) dbo.get(ENTITY_FIELD_NAME);
+          if (log.isDebugEnabled()) {
+            log.debug("Processing key: " + key);
+          }
+          if (!changeSet.getValues().containsKey(key)) {
             String className = (String) dbo.get(ENTITY_FIELD_CLASS);
             if (className == null) {
               throw new DataIntegrityViolationException(
                   "Unble to convert property " + key
                       + ": Invalid metadata, " + ENTITY_FIELD_CLASS + " not available");
             }
-          Class<?> clazz = null;
+            Class<?> clazz = ClassUtils.resolveClassName(className, ClassUtils.getDefaultClassLoader());
-          try {
-            clazz = Class.forName(className);
-          } catch (ClassNotFoundException e) {
-            throw new DataIntegrityViolationException(
-                "Unble to convert property " + key + " of type " + className, e);
-          }
             Object value = mongoTemplate.getConverter().read(clazz, dbo);
+            if (log.isDebugEnabled()) {
+              log.debug("Adding to ChangeSet: " + key);
+            }
             changeSet.set(key, value);
           }
+        }
         return null;
       }
     });