diff --git a/spring-data-mongodb/pom.xml b/spring-data-mongodb/pom.xml
index b808ccf76..9754e8545 100644
--- a/spring-data-mongodb/pom.xml
+++ b/spring-data-mongodb/pom.xml
@@ -18,7 +18,7 @@
1.3
1.5
- 3.2.2
+ 3.3.0
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/BulkOperations.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/BulkOperations.java
index 95fd16283..c5be41fb3 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/BulkOperations.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/BulkOperations.java
@@ -21,6 +21,8 @@ import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.data.util.Pair;
+import com.mongodb.bulk.BulkWriteResult;
+
/**
* Bulk operations for insert/update/remove actions on a collection. These bulks operation are available since MongoDB
* 2.6 and make use of low level bulk commands on the protocol level. This interface defines a fluent API to add
@@ -36,7 +38,7 @@ public interface BulkOperations {
/**
* Mode for bulk operation.
**/
- public enum BulkMode {
+ enum BulkMode {
/** Perform bulk operations in sequence. The first error will cancel processing. */
ORDERED,
@@ -139,5 +141,5 @@ public interface BulkOperations {
* @return Result of the bulk operation providing counters for inserts/updates etc.
* @throws {@link BulkOperationException} if an error occurred during bulk processing.
*/
- com.mongodb.bulk.BulkWriteResult execute();
+ BulkWriteResult execute();
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CollectionCallback.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CollectionCallback.java
index 3b7fd11a3..28167e53b 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CollectionCallback.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CollectionCallback.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2010-2011 the original author or authors.
+ * Copyright 2010-2016 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.
@@ -21,8 +21,24 @@ import org.springframework.dao.DataAccessException;
import com.mongodb.MongoException;
import com.mongodb.client.MongoCollection;
+/**
+ * Callback interface for executing actions against a {@link MongoCollection}
+ *
+ * @author Mark Pollak
+ * @author Grame Rocher
+ * @author Oliver Gierke
+ * @author John Brisbin
+ * @auhtor Christoph Strobl
+ * @since 1.0
+ */
public interface CollectionCallback {
+ /**
+ * @param collection never {@literal null}.
+ * @return
+ * @throws MongoException
+ * @throws DataAccessException
+ */
T doInCollection(MongoCollection collection) throws MongoException, DataAccessException;
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CursorPreparer.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CursorPreparer.java
index 0262b9b03..6c28d186e 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CursorPreparer.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/CursorPreparer.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2002-2010 the original author or authors.
+ * Copyright 2002-2016 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.
@@ -17,13 +17,13 @@ package org.springframework.data.mongodb.core;
import org.bson.Document;
-import com.mongodb.DBCursor;
import com.mongodb.client.FindIterable;
/**
- * Simple callback interface to allow customization of a {@link DBCursor}.
+ * Simple callback interface to allow customization of a {@link FindIterable}.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
*/
interface CursorPreparer {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DbCallback.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DbCallback.java
index c019b86b1..a8a32040c 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DbCallback.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DbCallback.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2010-2011 the original author or authors.
+ * Copyright 2010-2016 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.
@@ -20,6 +20,10 @@ import org.springframework.dao.DataAccessException;
import com.mongodb.MongoException;
import com.mongodb.client.MongoDatabase;
+/**
+ *
+ * @param
+ */
public interface DbCallback {
T doInDB(MongoDatabase db) throws MongoException, DataAccessException;
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultBulkOperations.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultBulkOperations.java
index b14304891..bca4e5536 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultBulkOperations.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultBulkOperations.java
@@ -43,6 +43,7 @@ import com.mongodb.client.model.WriteModel;
*
* @author Tobias Trelle
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.9
*/
class DefaultBulkOperations implements BulkOperations {
@@ -50,7 +51,6 @@ class DefaultBulkOperations implements BulkOperations {
private final MongoOperations mongoOperations;
private final BulkMode bulkMode;
private final String collectionName;
- private final Class> entityType;
private PersistenceExceptionTranslator exceptionTranslator;
private WriteConcernResolver writeConcernResolver;
@@ -79,7 +79,6 @@ class DefaultBulkOperations implements BulkOperations {
this.mongoOperations = mongoOperations;
this.bulkMode = bulkMode;
this.collectionName = collectionName;
- this.entityType = entityType;
this.exceptionTranslator = new MongoExceptionTranslator();
this.writeConcernResolver = DefaultWriteConcernResolver.INSTANCE;
@@ -237,8 +236,6 @@ class DefaultBulkOperations implements BulkOperations {
Assert.notNull(query, "Query must not be null!");
models.add(new DeleteManyModel(query.getQueryObject()));
- // bulk.find(query.getQueryObject()).remove();
-
return this;
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultIndexOperations.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultIndexOperations.java
index 402fcd4bb..e9b3c501f 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultIndexOperations.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DefaultIndexOperations.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2011-2015 the original author or authors.
+ * Copyright 2011-2016 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.
@@ -86,9 +86,6 @@ public class DefaultIndexOperations implements IndexOperations {
if (indexOptions.containsKey("unique")) {
ops = ops.unique((Boolean) indexOptions.get("unique"));
}
- // if(indexOptions.containsField("dropDuplicates")) {
- // ops = ops.((boolean)indexOptions.get("dropDuplicates"));
- // }
if (indexOptions.containsKey("sparse")) {
ops = ops.sparse((Boolean) indexOptions.get("sparse"));
}
@@ -151,22 +148,6 @@ public class DefaultIndexOperations implements IndexOperations {
dropIndex("*");
}
- /*
- * (non-Javadoc)
- * @see org.springframework.data.mongodb.core.IndexOperations#resetIndexCache()
- */
- @Deprecated
- public void resetIndexCache() {
- mongoOperations.execute(collectionName, new CollectionCallback() {
- public Void doInCollection(MongoCollection collection) throws MongoException, DataAccessException {
-
- // TODO remove this one
- // ReflectiveDBCollectionInvoker.resetIndexCache(collection);
- return null;
- }
- });
- }
-
/*
* (non-Javadoc)
* @see org.springframework.data.mongodb.core.IndexOperations#getIndexInfo()
@@ -177,25 +158,25 @@ public class DefaultIndexOperations implements IndexOperations {
public List doInCollection(MongoCollection collection)
throws MongoException, DataAccessException {
- MongoCursor dbObjectList = collection.listIndexes(Document.class).iterator();
- return getIndexData(dbObjectList);
+ MongoCursor cursor = collection.listIndexes(Document.class).iterator();
+ return getIndexData(cursor);
}
- private List getIndexData(MongoCursor dbObjectList) {
+ private List getIndexData(MongoCursor cursor) {
List indexInfoList = new ArrayList();
- while (dbObjectList.hasNext()) {
+ while (cursor.hasNext()) {
- Document ix = dbObjectList.next();
- Document keyDbObject = (Document) ix.get("key");
- int numberOfElements = keyDbObject.keySet().size();
+ Document ix = cursor.next();
+ Document keyDocument = (Document) ix.get("key");
+ int numberOfElements = keyDocument.keySet().size();
List indexFields = new ArrayList(numberOfElements);
- for (String key : keyDbObject.keySet()) {
+ for (String key : keyDocument.keySet()) {
- Object value = keyDbObject.get(key);
+ Object value = keyDocument.get(key);
if (TWO_D_IDENTIFIERS.contains(value)) {
indexFields.add(IndexField.geo(key));
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DocumentCallbackHandler.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DocumentCallbackHandler.java
index 15756f2e2..64088a6c0 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DocumentCallbackHandler.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/DocumentCallbackHandler.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2010-2011 the original author or authors.
+ * Copyright 2010-2016 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.
@@ -28,8 +28,13 @@ import com.mongodb.MongoException;
* later inspection.
*
* @author Mark Pollack
+ * @author Grame Rocher
+ * @author Oliver Gierke
+ * @author John Brisbin
+ * @author Christoph Strobl
+ * @since 1.0
*/
public interface DocumentCallbackHandler {
- void processDocument(Document dbObject) throws MongoException, DataAccessException;
+ void processDocument(Document document) throws MongoException, DataAccessException;
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/GeoCommandStatistics.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/GeoCommandStatistics.java
index 75649c0dd..420ea5554 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/GeoCommandStatistics.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/GeoCommandStatistics.java
@@ -22,7 +22,9 @@ import org.springframework.util.Assert;
* Value object to mitigate different representations of geo command execution results in MongoDB.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
* @soundtrack Fruitcake - Jeff Coffin (The Inside of the Outside)
+ * @since 1.9
*/
class GeoCommandStatistics {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/IndexOperations.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/IndexOperations.java
index cc97d7bfb..3ea8cb6e6 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/IndexOperations.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/IndexOperations.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2011-2015 the original author or authors.
+ * Copyright 2011-2016 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.
@@ -49,15 +49,6 @@ public interface IndexOperations {
*/
void dropAllIndexes();
- /**
- * Clears all indices that have not yet been applied to this collection.
- *
- * @deprecated since 1.7. The MongoDB Java driver version 3.0 does no longer support reseting the index cache.
- * @throws {@link UnsupportedOperationException} when used with MongoDB Java driver version 3.0.
- */
- @Deprecated
- void resetIndexCache();
-
/**
* Returns the index information on the collection.
*
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoAction.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoAction.java
index e1f498928..6af857eca 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoAction.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoAction.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2011-2012 the original author or authors.
+ * Copyright 2011-2016 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.
@@ -31,6 +31,7 @@ import com.mongodb.WriteConcern;
*
* @author Mark Pollack
* @author Oliver Gierke
+ * @author Christoph Strobl
*/
public class MongoAction {
@@ -72,14 +73,6 @@ public class MongoAction {
return defaultWriteConcern;
}
- /**
- * @deprecated use {@link #getEntityType()} instead.
- */
- @Deprecated
- public Class> getEntityClass() {
- return entityType;
- }
-
public Class> getEntityType() {
return entityType;
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoExceptionTranslator.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoExceptionTranslator.java
index dbbcf173a..0be5bb968 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoExceptionTranslator.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoExceptionTranslator.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2010-2015 the original author or authors.
+ * Copyright 2010-2016 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.
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoOperations.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoOperations.java
index 0e771c6d8..fad14684b 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoOperations.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoOperations.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2011-2015 the original author or authors.
+ * Copyright 2011-2016 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.
@@ -84,18 +84,6 @@ public interface MongoOperations {
*/
Document executeCommand(Document command);
- /**
- * Execute a MongoDB command. Any errors that result from executing this command will be converted into Spring's DAO
- * exception hierarchy.
- *
- * @param command a MongoDB command
- * @param options query options to use
- * @deprecated since 1.7. Please use {@link #executeCommand(Document, ReadPreference)}, as the MongoDB Java driver
- * version 3 no longer supports this operation.
- */
- @Deprecated
- Document executeCommand(Document command, int options);
-
/**
* Execute a MongoDB command. Any errors that result from executing this command will be converted into Spring's data
* access exception hierarchy.
@@ -152,22 +140,6 @@ public interface MongoOperations {
*/
T execute(String collectionName, CollectionCallback action);
- /**
- * Executes the given {@link DbCallback} within the same connection to the database so as to ensure consistency in a
- * write heavy environment where you may read the data that you wrote. See the comments on {@see Java Driver Concurrency }
- *
- * Allows for returning a result object, that is a domain object or a collection of domain objects.
- *
- * @param return type
- * @param action callback that specified the MongoDB actions to perform on the DB instance
- * @return a result object returned by the action or null
- * @deprecated since 1.7 as the MongoDB Java driver version 3 does not longer support request boundaries via
- * {@link DB#requestStart()} and {@link DB#requestDone()}.
- */
- @Deprecated
- T executeInSession(DbCallback action);
-
/**
* Executes the given {@link Query} on the entity collection of the specified {@code entityType} backed by a Mongo DB
* {@link Cursor}.
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoTemplate.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoTemplate.java
index 40f9225c2..6426baea3 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoTemplate.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/MongoTemplate.java
@@ -361,7 +361,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
FindIterable cursor = collection.find(mappedQuery).projection(mappedFields);
QueryCursorPreparer cursorPreparer = new QueryCursorPreparer(query, entityType);
- ReadDbObjectCallback readCallback = new ReadDbObjectCallback(mongoConverter, entityType,
+ ReadDocumentCallback readCallback = new ReadDocumentCallback(mongoConverter, entityType,
collectionName);
return new CloseableIterableCursorAdapter(cursorPreparer.prepare(cursor), exceptionTranslator, readCallback);
@@ -393,16 +393,6 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
return result;
}
- /*
- * (non-Javadoc)
- * @see org.springframework.data.mongodb.core.MongoOperations#executeCommand(com.mongodb.Document, int)
- */
- @Deprecated
- public Document executeCommand(final Document command, final int options) {
- return executeCommand(command,
- (options & Bytes.QUERYOPTION_SLAVEOK) != 0 ? ReadPreference.secondaryPreferred() : ReadPreference.primary());
- }
-
/*
* (non-Javadoc)
* @see org.springframework.data.mongodb.core.MongoOperations#executeCommand(com.mongodb.Document, com.mongodb.ReadPreference)
@@ -490,20 +480,6 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
}
- /*
- * (non-Javadoc)
- * @see org.springframework.data.mongodb.core.MongoOperations#executeInSession(org.springframework.data.mongodb.core.DbCallback)
- */
- @Deprecated
- public T executeInSession(final DbCallback action) {
-
- return execute(new DbCallback() {
- public T doInDB(MongoDatabase db) throws MongoException, DataAccessException {
- return action.doInDB(db);
- }
- });
- }
-
public MongoCollection createCollection(Class entityClass) {
return createCollection(determineCollectionName(entityClass));
}
@@ -518,7 +494,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
public MongoCollection createCollection(final String collectionName,
final CollectionOptions collectionOptions) {
- return doCreateCollection(collectionName, convertToDbObject(collectionOptions));
+ return doCreateCollection(collectionName, convertToDocument(collectionOptions));
}
public MongoCollection getCollection(final String collectionName) {
@@ -697,8 +673,8 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
List results = (List) commandResult.get("results");
results = results == null ? Collections.emptyList() : results;
- DbObjectCallback> callback = new GeoNearResultDbObjectCallback(
- new ReadDbObjectCallback(mongoConverter, entityClass, collectionName), near.getMetric());
+ DocumentCallback> callback = new GeoNearResultDocumentCallback(
+ new ReadDocumentCallback(mongoConverter, entityClass, collectionName), near.getMetric());
List> result = new ArrayList>(results.size());
int index = 0;
@@ -774,13 +750,13 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
public long count(Query query, Class> entityClass, String collectionName) {
Assert.hasText(collectionName);
- final Document dbObject = query == null ? null
+ final Document document = query == null ? null
: queryMapper.getMappedObject(query.getQueryObject(),
entityClass == null ? null : mappingContext.getPersistentEntity(entityClass));
return execute(collectionName, new CollectionCallback() {
public Long doInCollection(MongoCollection collection) throws MongoException, DataAccessException {
- return collection.count(dbObject);
+ return collection.count(document);
}
});
}
@@ -860,7 +836,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
maybeEmitEvent(new BeforeConvertEvent(objectToSave, collectionName));
- Document dbDoc = toDbObject(objectToSave, writer);
+ Document dbDoc = toDocument(objectToSave, writer);
maybeEmitEvent(new BeforeSaveEvent(objectToSave, dbDoc, collectionName));
Object id = insertDocument(collectionName, dbDoc, objectToSave.getClass());
@@ -874,7 +850,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
* @param writer
* @return
*/
- private Document toDbObject(T objectToSave, MongoWriter writer) {
+ private Document toDocument(T objectToSave, MongoWriter writer) {
if (objectToSave instanceof Document) {
return (Document) objectToSave;
@@ -958,7 +934,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
Assert.notNull(writer);
- List dbObjectList = new ArrayList();
+ List documentList = new ArrayList();
for (T o : batchToSave) {
initializeVersionProperty(o);
@@ -968,16 +944,16 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
writer.write(o, dbDoc);
maybeEmitEvent(new BeforeSaveEvent(o, dbDoc, collectionName));
- dbObjectList.add(dbDoc);
+ documentList.add(dbDoc);
}
- List ids = consolidateIdentifiers(insertDBObjectList(collectionName, dbObjectList), dbObjectList);
+ List ids = consolidateIdentifiers(insertDocumentList(collectionName, documentList), documentList);
int i = 0;
for (T obj : batchToSave) {
if (i < ids.size()) {
populateIdIfNecessary(obj, ids.get(i));
- maybeEmitEvent(new AfterSaveEvent(obj, dbObjectList.get(i), collectionName));
+ maybeEmitEvent(new AfterSaveEvent(obj, documentList.get(i), collectionName));
}
i++;
}
@@ -1030,13 +1006,13 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
// Bump version number
convertingAccessor.setProperty(versionProperty, versionNumber.longValue() + 1);
- Document dbObject = new Document();
+ Document document = new Document();
maybeEmitEvent(new BeforeConvertEvent(objectToSave, collectionName));
- this.mongoConverter.write(objectToSave, dbObject);
+ this.mongoConverter.write(objectToSave, document);
- maybeEmitEvent(new BeforeSaveEvent(objectToSave, dbObject, collectionName));
- Update update = Update.fromDocument(dbObject, ID_FIELD);
+ maybeEmitEvent(new BeforeSaveEvent(objectToSave, document, collectionName));
+ Update update = Update.fromDocument(document, ID_FIELD);
UpdateResult result = doUpdate(collectionName, query, update, objectToSave.getClass(), false, false);
@@ -1045,7 +1021,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
String.format("Cannot save entity %s with version %s to collection %s. Has it been modified meanwhile?", id,
versionNumber, collectionName));
}
- maybeEmitEvent(new AfterSaveEvent(objectToSave, dbObject, collectionName));
+ maybeEmitEvent(new AfterSaveEvent(objectToSave, document, collectionName));
}
}
@@ -1055,7 +1031,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
maybeEmitEvent(new BeforeConvertEvent(objectToSave, collectionName));
- Document dbDoc = toDbObject(objectToSave, writer);
+ Document dbDoc = toDocument(objectToSave, writer);
maybeEmitEvent(new BeforeSaveEvent(objectToSave, dbDoc, collectionName));
Object id = saveDocument(collectionName, dbDoc, objectToSave.getClass());
@@ -1064,31 +1040,30 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
maybeEmitEvent(new AfterSaveEvent(objectToSave, dbDoc, collectionName));
}
- protected Object insertDocument(final String collectionName, final Document dbDoc, final Class> entityClass) {
+ protected Object insertDocument(final String collectionName, final Document document, final Class> entityClass) {
if (LOGGER.isDebugEnabled()) {
- LOGGER.debug("Inserting Document containing fields: {} in collection: {}", dbDoc.keySet(), collectionName);
+ LOGGER.debug("Inserting Document containing fields: {} in collection: {}", document.keySet(), collectionName);
}
return execute(collectionName, new CollectionCallback() {
public Object doInCollection(MongoCollection collection) throws MongoException, DataAccessException {
MongoAction mongoAction = new MongoAction(writeConcern, MongoActionOperation.INSERT, collectionName,
- entityClass, dbDoc, null);
+ entityClass, document, null);
WriteConcern writeConcernToUse = prepareWriteConcern(mongoAction);
if (writeConcernToUse == null) {
- collection.insertOne(dbDoc);
+ collection.insertOne(document);
} else {
- collection.withWriteConcern(writeConcernToUse).insertOne(dbDoc);
+ collection.withWriteConcern(writeConcernToUse).insertOne(document);
}
- // handleAnyWriteResultErrors(writeResult, dbDoc, MongoActionOperation.INSERT);
- return dbDoc.get(ID_FIELD);
+ return document.get(ID_FIELD);
}
});
}
// TODO: 2.0 - Change method signature to return List and return all identifiers (DATAMONGO-1513,
// DATAMONGO-1519)
- protected List insertDBObjectList(final String collectionName, final List documents) {
+ protected List insertDocumentList(final String collectionName, final List documents) {
if (documents.isEmpty()) {
return Collections.emptyList();
}
@@ -1109,9 +1084,6 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
collection.withWriteConcern(writeConcernToUse).insertMany(documents);
}
- // WriteResult writeResult = writeConcernToUse == null ? collection.insert(dbDocList)
- // : collection.insert(dbDocList.toArray((Document[]) new Document[dbDocList.size()]), writeConcernToUse);
- // handleAnyWriteResultErrors(writeResult, null, MongoActionOperation.INSERT_LIST);
return null;
}
});
@@ -1155,7 +1127,6 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
collection.withWriteConcern(writeConcernToUse).replaceOne(Filters.eq(ID_FIELD, dbDoc.get(ID_FIELD)), dbDoc,
new UpdateOptions().upsert(true));
}
- // handleAnyWriteResultErrors(writeResult, dbDoc, MongoActionOperation.SAVE);
return dbDoc.get(ID_FIELD);
}
});
@@ -1250,13 +1221,13 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
}
- private boolean dbObjectContainsVersionProperty(Document dbObject, MongoPersistentEntity> persistentEntity) {
+ private boolean documentContainsVersionProperty(Document document, MongoPersistentEntity> persistentEntity) {
if (persistentEntity == null || !persistentEntity.hasVersionProperty()) {
return false;
}
- return dbObject.containsKey(persistentEntity.getVersionProperty().getFieldName());
+ return document.containsKey(persistentEntity.getVersionProperty().getFieldName());
}
public DeleteResult remove(Object object) {
@@ -1389,7 +1360,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
maybeEmitEvent(new BeforeDeleteEvent(queryObject, entityClass, collectionName));
- Document dboq = queryMapper.getMappedObject(queryObject, entity);
+ Document mappedQuery = queryMapper.getMappedObject(queryObject, entity);
MongoAction mongoAction = new MongoAction(writeConcern, MongoActionOperation.REMOVE, collectionName,
entityClass, null, queryObject);
@@ -1398,13 +1369,13 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
DeleteResult dr = null;
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Remove using query: {} in collection: {}.",
- new Object[] { serializeToJsonSafely(dboq), collectionName });
+ new Object[] { serializeToJsonSafely(mappedQuery), collectionName });
}
if (writeConcernToUse == null) {
- dr = collection.deleteMany(dboq);
+ dr = collection.deleteMany(mappedQuery);
} else {
- dr = collection.withWriteConcern(writeConcernToUse).deleteMany(dboq);
+ dr = collection.withWriteConcern(writeConcernToUse).deleteMany(mappedQuery);
}
maybeEmitEvent(new AfterDeleteEvent(queryObject, entityClass, collectionName));
@@ -1420,7 +1391,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
public List findAll(Class entityClass, String collectionName) {
return executeFindMultiInternal(new FindCallback(null), null,
- new ReadDbObjectCallback(mongoConverter, entityClass, collectionName), collectionName);
+ new ReadDocumentCallback(mongoConverter, entityClass, collectionName), collectionName);
}
public MapReduceResults mapReduce(String inputCollectionName, String mapFunction, String reduceFunction,
@@ -1448,7 +1419,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
MongoCollection inputCollection = getCollection(inputCollectionName);
// MapReduceOp
- MapReduceIterable result = inputCollection.mapReduce(mapFunction, reduceFunction);
+ MapReduceIterable result = inputCollection.mapReduce(mapFunc, reduceFunc);
if (query != null && result != null) {
if (query.getLimit() > 0 && mapReduceOptions.getLimit() == null) {
@@ -1485,10 +1456,10 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
}
List mappedResults = new ArrayList();
- DbObjectCallback callback = new ReadDbObjectCallback(mongoConverter, entityClass, inputCollectionName);
+ DocumentCallback callback = new ReadDocumentCallback(mongoConverter, entityClass, inputCollectionName);
- for (Document dbObject : result) {
- mappedResults.add(callback.doWith(dbObject));
+ for (Document document : result) {
+ mappedResults.add(callback.doWith(document));
}
return new MapReduceResults(mappedResults, new Document());
@@ -1501,36 +1472,36 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
public GroupByResults group(Criteria criteria, String inputCollectionName, GroupBy groupBy,
Class entityClass) {
- Document dbo = groupBy.getGroupByObject();
- dbo.put("ns", inputCollectionName);
+ Document document = groupBy.getGroupByObject();
+ document.put("ns", inputCollectionName);
if (criteria == null) {
- dbo.put("cond", null);
+ document.put("cond", null);
} else {
- dbo.put("cond", queryMapper.getMappedObject(criteria.getCriteriaObject(), null));
+ document.put("cond", queryMapper.getMappedObject(criteria.getCriteriaObject(), null));
}
// If initial document was a JavaScript string, potentially loaded by Spring's Resource abstraction, load it and
// convert to Document
- if (dbo.containsKey("initial")) {
- Object initialObj = dbo.get("initial");
+ if (document.containsKey("initial")) {
+ Object initialObj = document.get("initial");
if (initialObj instanceof String) {
String initialAsString = replaceWithResourceIfNecessary((String) initialObj);
- dbo.put("initial", Document.parse(initialAsString));
+ document.put("initial", Document.parse(initialAsString));
}
}
- if (dbo.containsKey("$reduce")) {
- dbo.put("$reduce", replaceWithResourceIfNecessary(dbo.get("$reduce").toString()));
+ if (document.containsKey("$reduce")) {
+ document.put("$reduce", replaceWithResourceIfNecessary(document.get("$reduce").toString()));
}
- if (dbo.containsKey("$keyf")) {
- dbo.put("$keyf", replaceWithResourceIfNecessary(dbo.get("$keyf").toString()));
+ if (document.containsKey("$keyf")) {
+ document.put("$keyf", replaceWithResourceIfNecessary(document.get("$keyf").toString()));
}
- if (dbo.containsKey("finalize")) {
- dbo.put("finalize", replaceWithResourceIfNecessary(dbo.get("finalize").toString()));
+ if (document.containsKey("finalize")) {
+ document.put("finalize", replaceWithResourceIfNecessary(document.get("finalize").toString()));
}
- Document commandObject = new Document("group", dbo);
+ Document commandObject = new Document("group", document);
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Executing Group with Document [{}]", serializeToJsonSafely(commandObject));
@@ -1545,10 +1516,10 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
@SuppressWarnings("unchecked")
Iterable resultSet = (Iterable) commandResult.get("retval");
List mappedResults = new ArrayList();
- DbObjectCallback callback = new ReadDbObjectCallback(mongoConverter, entityClass, inputCollectionName);
+ DocumentCallback callback = new ReadDocumentCallback(mongoConverter, entityClass, inputCollectionName);
- for (Document dbObject : resultSet) {
- mappedResults.add(callback.doWith(dbObject));
+ for (Document resultDocument : resultSet) {
+ mappedResults.add(callback.doWith(resultDocument));
}
return new GroupByResults(mappedResults, commandResult);
@@ -1638,7 +1609,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
Assert.notNull(outputType, "Output type must not be null!");
AggregationOperationContext rootContext = context == null ? Aggregation.DEFAULT_CONTEXT : context;
- Document command = aggregation.toDbObject(collectionName, rootContext);
+ Document command = aggregation.toDocument(collectionName, rootContext);
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Executing aggregation: {}", serializeToJsonSafely(command));
@@ -1666,11 +1637,11 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
return Collections.emptyList();
}
- DbObjectCallback callback = new UnwrapAndReadDbObjectCallback(mongoConverter, outputType, collectionName);
+ DocumentCallback callback = new UnwrapAndReadDocumentCallback(mongoConverter, outputType, collectionName);
List mappedResults = new ArrayList();
- for (Document dbObject : resultSet) {
- mappedResults.add(callback.doWith(dbObject));
+ for (Document document : resultSet) {
+ mappedResults.add(callback.doWith(document));
}
return mappedResults;
@@ -1785,7 +1756,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
return executeFindOneInternal(new FindOneCallback(mappedQuery, mappedFields),
- new ReadDbObjectCallback(this.mongoConverter, entityClass, collectionName), collectionName);
+ new ReadDocumentCallback(this.mongoConverter, entityClass, collectionName), collectionName);
}
/**
@@ -1800,7 +1771,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
*/
protected List doFind(String collectionName, Document query, Document fields, Class entityClass) {
return doFind(collectionName, query, fields, entityClass, null,
- new ReadDbObjectCallback(this.mongoConverter, entityClass, collectionName));
+ new ReadDocumentCallback(this.mongoConverter, entityClass, collectionName));
}
/**
@@ -1819,11 +1790,11 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
protected List doFind(String collectionName, Document query, Document fields, Class entityClass,
CursorPreparer preparer) {
return doFind(collectionName, query, fields, entityClass, preparer,
- new ReadDbObjectCallback(mongoConverter, entityClass, collectionName));
+ new ReadDocumentCallback(mongoConverter, entityClass, collectionName));
}
protected List doFind(String collectionName, Document query, Document fields, Class entityClass,
- CursorPreparer preparer, DbObjectCallback objectCallback) {
+ CursorPreparer preparer, DocumentCallback objectCallback) {
MongoPersistentEntity> entity = mappingContext.getPersistentEntity(entityClass);
@@ -1839,20 +1810,20 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
collectionName);
}
- protected Document convertToDbObject(CollectionOptions collectionOptions) {
- Document dbo = new Document();
+ protected Document convertToDocument(CollectionOptions collectionOptions) {
+ Document document = new Document();
if (collectionOptions != null) {
if (collectionOptions.getCapped() != null) {
- dbo.put("capped", collectionOptions.getCapped().booleanValue());
+ document.put("capped", collectionOptions.getCapped().booleanValue());
}
if (collectionOptions.getSize() != null) {
- dbo.put("size", collectionOptions.getSize().intValue());
+ document.put("size", collectionOptions.getSize().intValue());
}
if (collectionOptions.getMaxDocuments() != null) {
- dbo.put("max", collectionOptions.getMaxDocuments().intValue());
+ document.put("max", collectionOptions.getMaxDocuments().intValue());
}
}
- return dbo;
+ return document;
}
/**
@@ -1879,7 +1850,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
MongoPersistentEntity> entity = mappingContext.getPersistentEntity(entityClass);
return executeFindOneInternal(new FindAndRemoveCallback(queryMapper.getMappedObject(query, entity), fields, sort),
- new ReadDbObjectCallback(readerToUse, entityClass, collectionName), collectionName);
+ new ReadDocumentCallback(readerToUse, entityClass, collectionName), collectionName);
}
protected T doFindAndModify(String collectionName, Document query, Document fields, Document sort,
@@ -1906,7 +1877,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
return executeFindOneInternal(new FindAndModifyCallback(mappedQuery, fields, sort, mappedUpdate, options),
- new ReadDbObjectCallback(readerToUse, entityClass, collectionName), collectionName);
+ new ReadDocumentCallback(readerToUse, entityClass, collectionName), collectionName);
}
/**
@@ -1922,8 +1893,8 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
if (savedObject instanceof Document) {
- Document dbObject = (Document) savedObject;
- dbObject.put(ID_FIELD, id);
+ Document document = (Document) savedObject;
+ document.put(ID_FIELD, id);
return;
}
@@ -1959,17 +1930,17 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
* collection of objects. It will take the following steps
*
* Execute the given {@link ConnectionCallback} for a {@link Document}.
- * Apply the given {@link DbObjectCallback} to each of the {@link Document}s to obtain the result.
+ * Apply the given {@link DocumentCallback} to each of the {@link Document}s to obtain the result.
*
*
* @param
* @param collectionCallback the callback to retrieve the {@link Document} with
- * @param objectCallback the {@link DbObjectCallback} to transform {@link Document}s into the actual domain type
+ * @param objectCallback the {@link DocumentCallback} to transform {@link Document}s into the actual domain type
* @param collectionName the collection to be queried
* @return
*/
private T executeFindOneInternal(CollectionCallback collectionCallback,
- DbObjectCallback objectCallback, String collectionName) {
+ DocumentCallback objectCallback, String collectionName) {
try {
T result = objectCallback
@@ -1987,19 +1958,19 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
* Execute the given {@link ConnectionCallback} for a {@link DBCursor}.
* Prepare that {@link DBCursor} with the given {@link CursorPreparer} (will be skipped if {@link CursorPreparer}
* is {@literal null}
- * Iterate over the {@link DBCursor} and applies the given {@link DbObjectCallback} to each of the
+ * Iterate over the {@link DBCursor} and applies the given {@link DocumentCallback} to each of the
* {@link Document}s collecting the actual result {@link List}.
*
*
* @param
* @param collectionCallback the callback to retrieve the {@link DBCursor} with
* @param preparer the {@link CursorPreparer} to potentially modify the {@link DBCursor} before ireating over it
- * @param objectCallback the {@link DbObjectCallback} to transform {@link Document}s into the actual domain type
+ * @param objectCallback the {@link DocumentCallback} to transform {@link Document}s into the actual domain type
* @param collectionName the collection to be queried
* @return
*/
private List executeFindMultiInternal(CollectionCallback> collectionCallback,
- CursorPreparer preparer, DbObjectCallback objectCallback, String collectionName) {
+ CursorPreparer preparer, DocumentCallback objectCallback, String collectionName) {
try {
@@ -2054,8 +2025,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
cursor = iterable.iterator();
while (cursor.hasNext()) {
- Document dbobject = cursor.next();
- callbackHandler.processDocument(dbobject);
+ callbackHandler.processDocument(cursor.next());
}
} finally {
@@ -2355,25 +2325,25 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
* @author Thomas Darimont
*/
- interface DbObjectCallback {
+ interface DocumentCallback {
T doWith(Document object);
}
/**
- * Simple {@link DbObjectCallback} that will transform {@link Document} into the given target type using the given
+ * Simple {@link DocumentCallback} that will transform {@link Document} into the given target type using the given
* {@link MongoReader}.
*
* @author Oliver Gierke
* @author Christoph Strobl
*/
- private class ReadDbObjectCallback implements DbObjectCallback {
+ private class ReadDocumentCallback implements DocumentCallback {
private final EntityReader super T, Bson> reader;
private final Class type;
private final String collectionName;
- public ReadDbObjectCallback(EntityReader super T, Bson> reader, Class type, String collectionName) {
+ public ReadDocumentCallback(EntityReader super T, Bson> reader, Class type, String collectionName) {
Assert.notNull(reader);
Assert.notNull(type);
@@ -2394,9 +2364,9 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
}
- class UnwrapAndReadDbObjectCallback extends ReadDbObjectCallback {
+ class UnwrapAndReadDocumentCallback extends ReadDocumentCallback {
- public UnwrapAndReadDbObjectCallback(EntityReader super T, Bson> reader, Class type, String collectionName) {
+ public UnwrapAndReadDocumentCallback(EntityReader super T, Bson> reader, Class type, String collectionName) {
super(reader, type, collectionName);
}
@@ -2459,8 +2429,8 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
cursorToUse = cursorToUse.limit(query.getLimit());
}
if (query.getSortObject() != null) {
- Document sortDbo = type != null ? getMappedSortObject(query, type) : query.getSortObject();
- cursorToUse = cursorToUse.sort(sortDbo);
+ Document sort = type != null ? getMappedSortObject(query, type) : query.getSortObject();
+ cursorToUse = cursorToUse.sort(sort);
}
Document meta = new Document();
@@ -2501,23 +2471,23 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
}
/**
- * {@link DbObjectCallback} that assumes a {@link GeoResult} to be created, delegates actual content unmarshalling to
+ * {@link DocumentCallback} that assumes a {@link GeoResult} to be created, delegates actual content unmarshalling to
* a delegate and creates a {@link GeoResult} from the result.
*
* @author Oliver Gierke
*/
- static class GeoNearResultDbObjectCallback implements DbObjectCallback> {
+ static class GeoNearResultDocumentCallback implements DocumentCallback> {
- private final DbObjectCallback delegate;
+ private final DocumentCallback delegate;
private final Metric metric;
/**
- * Creates a new {@link GeoNearResultDbObjectCallback} using the given {@link DbObjectCallback} delegate for
+ * Creates a new {@link GeoNearResultDocumentCallback} using the given {@link DocumentCallback} delegate for
* {@link GeoResult} content unmarshalling.
*
* @param delegate must not be {@literal null}.
*/
- public GeoNearResultDbObjectCallback(DbObjectCallback delegate, Metric metric) {
+ public GeoNearResultDocumentCallback(DocumentCallback delegate, Metric metric) {
Assert.notNull(delegate);
this.delegate = delegate;
this.metric = metric;
@@ -2544,10 +2514,10 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
private volatile MongoCursor cursor;
private PersistenceExceptionTranslator exceptionTranslator;
- private DbObjectCallback objectReadCallback;
+ private DocumentCallback objectReadCallback;
CloseableIterableCursorAdapter(MongoCursor cursor, PersistenceExceptionTranslator exceptionTranslator,
- DbObjectCallback objectReadCallback) {
+ DocumentCallback objectReadCallback) {
this.cursor = cursor;
this.exceptionTranslator = exceptionTranslator;
this.objectReadCallback = objectReadCallback;
@@ -2561,7 +2531,7 @@ public class MongoTemplate implements MongoOperations, ApplicationContextAware {
* @param objectReadCallback
*/
public CloseableIterableCursorAdapter(FindIterable cursor,
- PersistenceExceptionTranslator exceptionTranslator, DbObjectCallback objectReadCallback) {
+ PersistenceExceptionTranslator exceptionTranslator, DocumentCallback objectReadCallback) {
this.cursor = cursor.iterator();
this.exceptionTranslator = exceptionTranslator;
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReflectiveDbInvoker.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReflectiveDbInvoker.java
index 5abe74c0a..9a2280812 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReflectiveDbInvoker.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/ReflectiveDbInvoker.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2015 the original author or authors.
+ * Copyright 2015-2016 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.
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/SimpleMongoDbFactory.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/SimpleMongoDbFactory.java
index 841b25235..53583e9bc 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/SimpleMongoDbFactory.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/SimpleMongoDbFactory.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2011-2015 the original author or authors.
+ * Copyright 2011-2016 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.
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/Aggregation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/Aggregation.java
index 73efa71d8..eeed1f5ac 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/Aggregation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/Aggregation.java
@@ -494,7 +494,7 @@ public class Aggregation {
* @param inputCollectionName the name of the input collection
* @return the {@code Document} representing this aggregation
*/
- public Document toDbObject(String inputCollectionName, AggregationOperationContext rootContext) {
+ public Document toDocument(String inputCollectionName, AggregationOperationContext rootContext) {
AggregationOperationContext context = rootContext;
List operationDocuments = new ArrayList(operations.size());
@@ -530,7 +530,7 @@ public class Aggregation {
@Override
public String toString() {
return SerializationUtils
- .serializeToJsonSafely(toDbObject("__collection__", new NoOpAggregationOperationContext()));
+ .serializeToJsonSafely(toDocument("__collection__", new NoOpAggregationOperationContext()));
}
/**
@@ -545,8 +545,8 @@ public class Aggregation {
* @see org.springframework.data.mongodb.core.aggregation.AggregationOperationContext#getMappedObject(com.mongodb.Document)
*/
@Override
- public Document getMappedObject(Document dbObject) {
- return dbObject;
+ public Document getMappedObject(Document document) {
+ return document;
}
/*
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpression.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpression.java
index 176923d40..95747a11d 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpression.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpression.java
@@ -34,5 +34,5 @@ public interface AggregationExpression {
* @param context
* @return
*/
- Document toDbObject(AggregationOperationContext context);
+ Document toDocument(AggregationOperationContext context);
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressionTransformer.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressionTransformer.java
index 720388f76..ee08f35db 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressionTransformer.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationExpressionTransformer.java
@@ -28,6 +28,8 @@ import org.springframework.util.Assert;
* {@link AggregationExpressionTransformationContext}.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
+ * @since 1.4
*/
interface AggregationExpressionTransformer
extends ExpressionTransformer> {
@@ -38,7 +40,7 @@ interface AggregationExpressionTransformer
* @author Oliver Gierke
* @author Thomas Darimont
*/
- public static class AggregationExpressionTransformationContext
+ class AggregationExpressionTransformationContext
extends ExpressionTransformationContextSupport {
private final AggregationOperationContext aggregationContext;
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationFunctionExpressions.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationFunctionExpressions.java
index d50b5ebe0..e6f9f5bb5 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationFunctionExpressions.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationFunctionExpressions.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2015 the original author or authors.
+ * Copyright 2015-2016 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.
@@ -27,7 +27,8 @@ import org.springframework.util.Assert;
*
* @author Thomas Darimont
* @author Oliver Gierke
- * @since 1.10
+ * @author Christoph Strobl
+ * @since 1.7
*/
public enum AggregationFunctionExpressions {
@@ -77,7 +78,7 @@ public enum AggregationFunctionExpressions {
* @see org.springframework.data.mongodb.core.aggregation.Expression#toDbObject(org.springframework.data.mongodb.core.aggregation.AggregationOperationContext)
*/
@Override
- public Document toDbObject(AggregationOperationContext context) {
+ public Document toDocument(AggregationOperationContext context) {
List args = new ArrayList(values.size());
@@ -91,7 +92,7 @@ public enum AggregationFunctionExpressions {
private static Object unpack(Object value, AggregationOperationContext context) {
if (value instanceof AggregationExpression) {
- return ((AggregationExpression) value).toDbObject(context);
+ return ((AggregationExpression) value).toDocument(context);
}
if (value instanceof Field) {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperation.java
index a46973408..ae15ab36a 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperation.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -23,6 +23,7 @@ import org.bson.Document;
* @author Sebastian Herold
* @author Thomas Darimont
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.3
*/
public interface AggregationOperation {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperationContext.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperationContext.java
index ac6097ff5..aed2c9926 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperationContext.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOperationContext.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -22,6 +22,7 @@ import org.springframework.data.mongodb.core.aggregation.ExposedFields.FieldRefe
* The context for an {@link AggregationOperation}.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.3
*/
public interface AggregationOperationContext {
@@ -29,10 +30,10 @@ public interface AggregationOperationContext {
/**
* Returns the mapped {@link Document}, potentially converting the source considering mapping metadata etc.
*
- * @param dbObject will never be {@literal null}.
+ * @param document will never be {@literal null}.
* @return must not be {@literal null}.
*/
- Document getMappedObject(Document dbObject);
+ Document getMappedObject(Document document);
/**
* Returns a {@link FieldReference} for the given field or {@literal null} if the context does not expose the given
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOptions.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOptions.java
index 591a5f28c..2625d912a 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOptions.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationOptions.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2014 the original author or authors.
+ * Copyright 2014-2016 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.
@@ -24,6 +24,7 @@ import org.bson.Document;
*
* @author Thomas Darimont
* @author Oliver Gierke
+ * @author Christoph Strobl
* @see Aggregation#withOptions(AggregationOptions)
* @see TypedAggregation#withOptions(AggregationOptions)
* @since 1.6
@@ -111,14 +112,14 @@ public class AggregationOptions {
*
* @return
*/
- public Document toDbObject() {
+ public Document toDocument() {
- Document dbo = new Document();
- dbo.put(ALLOW_DISK_USE, allowDiskUse);
- dbo.put(EXPLAIN, explain);
- dbo.put(CURSOR, cursor);
+ Document document = new Document();
+ document.put(ALLOW_DISK_USE, allowDiskUse);
+ document.put(EXPLAIN, explain);
+ document.put(CURSOR, cursor);
- return dbo;
+ return document;
}
/* (non-Javadoc)
@@ -126,7 +127,7 @@ public class AggregationOptions {
*/
@Override
public String toString() {
- return toDbObject().toJson();
+ return toDocument().toJson();
}
/**
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationResults.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationResults.java
index 49fd2dc12..dec351601 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationResults.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/AggregationResults.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013-2014 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -28,6 +28,7 @@ import org.springframework.util.Assert;
* @author Tobias Trelle
* @author Oliver Gierke
* @author Thomas Darimont
+ * @author Christoph Strobl
* @param The class in which the results are mapped onto.
* @since 1.3
*/
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ConditionalOperator.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ConditionalOperator.java
index a3204f68b..c3b29e269 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ConditionalOperator.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ConditionalOperator.java
@@ -75,7 +75,7 @@ public class ConditionalOperator implements AggregationExpression {
* @param thenValue must not be {@literal null}.
* @param otherwiseValue must not be {@literal null}.
*/
- public ConditionalOperator(DBObject condition, Object thenValue, Object otherwiseValue) {
+ public ConditionalOperator(Document condition, Object thenValue, Object otherwiseValue) {
this((Object) condition, thenValue, otherwiseValue);
}
@@ -99,7 +99,7 @@ public class ConditionalOperator implements AggregationExpression {
* @see org.springframework.data.mongodb.core.aggregation.AggregationExpression#toDbObject(org.springframework.data.mongodb.core.aggregation.AggregationOperationContext)
*/
@Override
- public Document toDbObject(AggregationOperationContext context) {
+ public Document toDocument(AggregationOperationContext context) {
Document condObject = new Document();
@@ -117,7 +117,7 @@ public class ConditionalOperator implements AggregationExpression {
}
if (value instanceof ConditionalOperator) {
- return ((ConditionalOperator) value).toDbObject(context);
+ return ((ConditionalOperator) value).toDocument(context);
}
return context.getMappedObject(new Document("$set", value)).get("$set");
@@ -244,7 +244,7 @@ public class ConditionalOperator implements AggregationExpression {
* @param booleanExpression expression that yields in a boolean result, must not be {@literal null}.
* @return the {@link ThenBuilder}
*/
- ThenBuilder when(DBObject booleanExpression);
+ ThenBuilder when(Document booleanExpression);
/**
* @param booleanField reference to a field holding a boolean value, must not be {@literal null}.
@@ -320,7 +320,7 @@ public class ConditionalOperator implements AggregationExpression {
* @see org.springframework.data.mongodb.core.aggregation.ConditionalOperator.WhenBuilder#when(com.mongodb.DBObject)
*/
@Override
- public ConditionalExpressionBuilder when(DBObject booleanExpression) {
+ public ConditionalExpressionBuilder when(Document booleanExpression) {
Assert.notNull(booleanExpression, "'Boolean expression' must not be null!");
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ExposedFieldsAggregationOperationContext.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ExposedFieldsAggregationOperationContext.java
index 72c2d60ea..923ae847f 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ExposedFieldsAggregationOperationContext.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ExposedFieldsAggregationOperationContext.java
@@ -27,6 +27,7 @@ import org.springframework.util.Assert;
* @author Thomas Darimont
* @author Oliver Gierke
* @author Mark Paluch
+ * @author Christoph Strobl
* @since 1.4
*/
class ExposedFieldsAggregationOperationContext implements AggregationOperationContext {
@@ -56,8 +57,8 @@ class ExposedFieldsAggregationOperationContext implements AggregationOperationCo
* @see org.springframework.data.mongodb.core.aggregation.AggregationOperationContext#getMappedObject(com.mongodb.Document)
*/
@Override
- public Document getMappedObject(Document dbObject) {
- return rootContext.getMappedObject(dbObject);
+ public Document getMappedObject(Document document) {
+ return rootContext.getMappedObject(document);
}
/*
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GeoNearOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GeoNearOperation.java
index 7c8a2de66..1be716b85 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GeoNearOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GeoNearOperation.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013-2015 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -26,6 +26,7 @@ import org.springframework.util.Assert;
* instances of this class directly.
*
* @author Thomas Darimont
+ * @author Christoph Strobl
* @since 1.3
*/
public class GeoNearOperation implements AggregationOperation {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GroupOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GroupOperation.java
index 62e28054a..0aa7a7134 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GroupOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/GroupOperation.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013-2015 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -37,6 +37,7 @@ import org.springframework.util.StringUtils;
* @author Sebastian Herold
* @author Thomas Darimont
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.3
*/
public class GroupOperation implements FieldsExposingAggregationOperation {
@@ -424,7 +425,7 @@ public class GroupOperation implements FieldsExposingAggregationOperation {
if (reference == null) {
if (value instanceof AggregationExpression) {
- return ((AggregationExpression) value).toDbObject(context);
+ return ((AggregationExpression) value).toDocument(context);
}
return value;
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/IfNullOperator.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/IfNullOperator.java
index f46860ec3..130abe69b 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/IfNullOperator.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/IfNullOperator.java
@@ -31,6 +31,7 @@ import com.mongodb.DBObject;
*
* @see http://docs.mongodb.com/manual/reference/operator/aggregation/ifNull/
* @author Mark Paluch
+ * @author Christoph Strobl
* @since 1.10
*/
public class IfNullOperator implements AggregationExpression {
@@ -58,7 +59,7 @@ public class IfNullOperator implements AggregationExpression {
* @see org.springframework.data.mongodb.core.aggregation.AggregationExpression#toDbObject(org.springframework.data.mongodb.core.aggregation.AggregationOperationContext)
*/
@Override
- public Document toDbObject(AggregationOperationContext context) {
+ public Document toDocument(AggregationOperationContext context) {
List list = new ArrayList();
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/LimitOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/LimitOperation.java
index 4ae0ee877..353b6866b 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/LimitOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/LimitOperation.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013-2015 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -27,6 +27,7 @@ import org.springframework.util.Assert;
* @see http://docs.mongodb.org/manual/reference/aggregation/limit/
* @author Thomas Darimont
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.3
*/
public class LimitOperation implements AggregationOperation {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/OutOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/OutOperation.java
index 7c5593b96..edc678c78 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/OutOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/OutOperation.java
@@ -15,9 +15,6 @@
*/
package org.springframework.data.mongodb.core.aggregation;
-import com.mongodb.BasicDBObject;
-import com.mongodb.DBObject;
-
import org.bson.Document;
import org.springframework.util.Assert;
@@ -29,6 +26,7 @@ import org.springframework.util.Assert;
*
* @see http://docs.mongodb.org/manual/reference/aggregation/out/
* @author Nikolay Bogdanov
+ * @author Christoph Strobl
*/
public class OutOperation implements AggregationOperation {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ProjectionOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ProjectionOperation.java
index 8f60d700c..2e3abf033 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ProjectionOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/ProjectionOperation.java
@@ -1065,7 +1065,7 @@ public class ProjectionOperation implements FieldsExposingAggregationOperation {
@Override
public Document toDocument(AggregationOperationContext context) {
- return new Document(field.getName(), expression.toDbObject(context));
+ return new Document(field.getName(), expression.toDocument(context));
}
}
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SkipOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SkipOperation.java
index 1a75a6097..00142222c 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SkipOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SkipOperation.java
@@ -27,6 +27,7 @@ import org.springframework.util.Assert;
* @see http://docs.mongodb.org/manual/reference/aggregation/skip/
* @author Thomas Darimont
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.3
*/
public class SkipOperation implements AggregationOperation {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SortOperation.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SortOperation.java
index d740b4f1f..345ba71fc 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SortOperation.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SortOperation.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013-2015 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -31,6 +31,7 @@ import org.springframework.util.Assert;
* @see http://docs.mongodb.org/manual/reference/aggregation/sort/#pipe._S_sort
* @author Thomas Darimont
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.3
*/
public class SortOperation implements AggregationOperation {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SpelExpressionTransformer.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SpelExpressionTransformer.java
index 4b73f7c31..1e78c94d5 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SpelExpressionTransformer.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/SpelExpressionTransformer.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013-2014 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -248,23 +248,23 @@ class SpelExpressionTransformer implements AggregationExpressionTransformer {
private Document createOperationObjectAndAddToPreviousArgumentsIfNecessary(
AggregationExpressionTransformationContext context, OperatorNode currentNode) {
- Document nextDbObject = new Document(currentNode.getMongoOperator(), new ArrayList());
+ Document nextDocument = new Document(currentNode.getMongoOperator(), new ArrayList());
if (!context.hasPreviousOperation()) {
- return nextDbObject;
+ return nextDocument;
}
if (context.parentIsSameOperation()) {
// same operator applied in a row e.g. 1 + 2 + 3 carry on with the operation and render as $add: [1, 2 ,3]
- nextDbObject = context.getPreviousOperationObject();
+ nextDocument = context.getPreviousOperationObject();
} else if (!currentNode.isUnaryOperator()) {
// different operator -> add context object for next level to list if arguments of previous expression
- context.addToPreviousOperation(nextDbObject);
+ context.addToPreviousOperation(nextDocument);
}
- return nextDbObject;
+ return nextDocument;
}
private Object convertUnaryMinusOp(ExpressionTransformationContextSupport context,
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/TypeBasedAggregationOperationContext.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/TypeBasedAggregationOperationContext.java
index c7d32a616..8d46ebf55 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/TypeBasedAggregationOperationContext.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/aggregation/TypeBasedAggregationOperationContext.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -33,6 +33,7 @@ import org.springframework.util.Assert;
* property references into document field names.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
* @since 1.3
*/
public class TypeBasedAggregationOperationContext implements AggregationOperationContext {
@@ -66,8 +67,8 @@ public class TypeBasedAggregationOperationContext implements AggregationOperatio
* @see org.springframework.data.mongodb.core.aggregation.AggregationOperationContext#getMappedObject(com.mongodb.Document)
*/
@Override
- public Document getMappedObject(Document dbObject) {
- return mapper.getMappedObject(dbObject, mappingContext.getPersistentEntity(type));
+ public Document getMappedObject(Document document) {
+ return mapper.getMappedObject(document, mappingContext.getPersistentEntity(type));
}
/*
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectAccessor.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectAccessor.java
index e96907598..e2b60e1b7 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectAccessor.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectAccessor.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2013-2015 the original author or authors.
+ * Copyright 2013-2016 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.
@@ -29,11 +29,12 @@ import com.mongodb.BasicDBObject;
import com.mongodb.DBObject;
/**
- * Wrapper value object for a {@link BasicDocument} to be able to access raw values by {@link MongoPersistentProperty}
+ * Wrapper value object for a {@link Document} to be able to access raw values by {@link MongoPersistentProperty}
* references. The accessors will transparently resolve nested document values that a {@link MongoPersistentProperty}
* might refer to through a path expression in field names.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
*/
class DocumentAccessor {
@@ -42,7 +43,7 @@ class DocumentAccessor {
/**
* Creates a new {@link DocumentAccessor} for the given {@link Document}.
*
- * @param dbObject must be a {@link BasicDocument} effectively, must not be {@literal null}.
+ * @param dbObject must be a {@link Document} effectively, must not be {@literal null}.
*/
public DocumentAccessor(Bson dbObject) {
@@ -169,7 +170,7 @@ class DocumentAccessor {
}
/**
- * Returns the given source object as map, i.e. {@link BasicDocument}s and maps as is or {@literal null} otherwise.
+ * Returns the given source object as map, i.e. {@link Document}s and maps as is or {@literal null} otherwise.
*
* @param source can be {@literal null}.
* @return
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectPropertyAccessor.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectPropertyAccessor.java
index c10f9f793..8a875e17a 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectPropertyAccessor.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DBObjectPropertyAccessor.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2012-2014 the original author or authors.
+ * Copyright 2012-2016 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.
@@ -27,6 +27,7 @@ import org.springframework.expression.TypedValue;
* {@link PropertyAccessor} to allow entity based field access to {@link Document}s.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
*/
class DocumentPropertyAccessor extends MapAccessor {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefProxyHandler.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefProxyHandler.java
index 5e9adaa2d..1f86a3511 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefProxyHandler.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefProxyHandler.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2014 the original author or authors.
+ * Copyright 2014-2016 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.
@@ -28,6 +28,7 @@ import com.mongodb.DBRef;
/**
* @author Oliver Gierke
+ * @author Christoph Strobl
*/
class DefaultDbRefProxyHandler implements DbRefProxyHandler {
@@ -37,8 +38,8 @@ class DefaultDbRefProxyHandler implements DbRefProxyHandler {
/**
* @param spELContext must not be {@literal null}.
- * @param conversionService must not be {@literal null}.
* @param mappingContext must not be {@literal null}.
+ * @param resolver must not be {@literal null}.
*/
public DefaultDbRefProxyHandler(SpELContext spELContext,
MappingContext extends MongoPersistentEntity>, MongoPersistentProperty> mappingContext,
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolver.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolver.java
index 6f32aae24..25c6c4e82 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolver.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolver.java
@@ -27,11 +27,6 @@ import java.util.Collections;
import java.util.Comparator;
import java.util.List;
-import com.mongodb.BasicDBObject;
-import com.mongodb.BasicDBObjectBuilder;
-import com.mongodb.DB;
-import com.mongodb.DBObject;
-import com.mongodb.client.MongoDatabase;
import org.aopalliance.intercept.MethodInterceptor;
import org.aopalliance.intercept.MethodInvocation;
import org.bson.Document;
@@ -51,7 +46,9 @@ import org.springframework.objenesis.ObjenesisStd;
import org.springframework.util.Assert;
import org.springframework.util.ReflectionUtils;
+import com.mongodb.DBObject;
import com.mongodb.DBRef;
+import com.mongodb.client.MongoDatabase;
/**
* A {@link DbRefResolver} that resolves {@link org.springframework.data.mongodb.core.mapping.DBRef}s by delegating to a
@@ -148,8 +145,7 @@ public class DefaultDbRefResolver implements DbRefResolver {
MongoDatabase db = mongoDbFactory.getDb();
List result = new ArrayList<>();
- db.getCollection(collection)
- .find(new Document("_id", new Document("$in", ids))).into(result);
+ db.getCollection(collection).find(new Document("_id", new Document("$in", ids))).into(result);
Collections.sort(result, new DbRefByReferencePositionComparator(ids));
return result;
}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolverCallback.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolverCallback.java
index c1094557a..423aacd4e 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolverCallback.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultDbRefResolverCallback.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2014 the original author or authors.
+ * Copyright 2014-2016 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.
@@ -24,6 +24,7 @@ import org.springframework.data.mongodb.core.mapping.MongoPersistentProperty;
* Default implementation of {@link DbRefResolverCallback}.
*
* @author Oliver Gierke
+ * @author Christoph Strobl
*/
class DefaultDbRefResolverCallback implements DbRefResolverCallback {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultMongoTypeMapper.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultMongoTypeMapper.java
index 1fb4b97b5..79493de39 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultMongoTypeMapper.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/DefaultMongoTypeMapper.java
@@ -42,6 +42,7 @@ import com.mongodb.DBObject;
*
* @author Oliver Gierke
* @author Thomas Darimont
+ * @author Christoph Strobl
*/
public class DefaultMongoTypeMapper extends DefaultTypeMapper implements MongoTypeMapper {
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/GeoConverters.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/GeoConverters.java
index c4dc2843d..9f5ecc007 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/GeoConverters.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/GeoConverters.java
@@ -69,27 +69,27 @@ abstract class GeoConverters {
@SuppressWarnings("unchecked")
public static Collection extends Object> getConvertersToRegister() {
return Arrays.asList( //
- BoxToDbObjectConverter.INSTANCE //
- , PolygonToDbObjectConverter.INSTANCE //
- , CircleToDbObjectConverter.INSTANCE //
- , SphereToDbObjectConverter.INSTANCE //
- , DbObjectToBoxConverter.INSTANCE //
- , DbObjectToPolygonConverter.INSTANCE //
- , DbObjectToCircleConverter.INSTANCE //
- , DbObjectToSphereConverter.INSTANCE //
- , DbObjectToPointConverter.INSTANCE //
- , PointToDbObjectConverter.INSTANCE //
- , GeoCommandToDbObjectConverter.INSTANCE //
- , GeoJsonToDbObjectConverter.INSTANCE //
- , GeoJsonPointToDbObjectConverter.INSTANCE //
- , GeoJsonPolygonToDbObjectConverter.INSTANCE //
- , DbObjectToGeoJsonPointConverter.INSTANCE //
- , DbObjectToGeoJsonPolygonConverter.INSTANCE //
- , DbObjectToGeoJsonLineStringConverter.INSTANCE //
- , DbObjectToGeoJsonMultiLineStringConverter.INSTANCE //
- , DbObjectToGeoJsonMultiPointConverter.INSTANCE //
- , DbObjectToGeoJsonMultiPolygonConverter.INSTANCE //
- , DbObjectToGeoJsonGeometryCollectionConverter.INSTANCE);
+ BoxToDocumentConverter.INSTANCE //
+ , PolygonToDocumentConverter.INSTANCE //
+ , CircleToDocumentConverter.INSTANCE //
+ , SphereToDocumentConverter.INSTANCE //
+ , DocumentToBoxConverter.INSTANCE //
+ , DocumentToPolygonConverter.INSTANCE //
+ , DocumentToCircleConverter.INSTANCE //
+ , DocumentToSphereConverter.INSTANCE //
+ , DocumentToPointConverter.INSTANCE //
+ , PointToDocumentConverter.INSTANCE //
+ , GeoCommandToDocumentConverter.INSTANCE //
+ , GeoJsonToDocumentConverter.INSTANCE //
+ , GeoJsonPointToDocumentConverter.INSTANCE //
+ , GeoJsonPolygonToDocumentConverter.INSTANCE //
+ , DocumentToGeoJsonPointConverter.INSTANCE //
+ , DocumentToGeoJsonPolygonConverter.INSTANCE //
+ , DocumentToGeoJsonLineStringConverter.INSTANCE //
+ , DocumentToGeoJsonMultiLineStringConverter.INSTANCE //
+ , DocumentToGeoJsonMultiPointConverter.INSTANCE //
+ , DocumentToGeoJsonMultiPolygonConverter.INSTANCE //
+ , DocumentToGeoJsonGeometryCollectionConverter.INSTANCE);
}
/**
@@ -99,7 +99,7 @@ abstract class GeoConverters {
* @since 1.5
*/
@ReadingConverter
- static enum DbObjectToPointConverter implements Converter {
+ static enum DocumentToPointConverter implements Converter {
INSTANCE;
@@ -117,7 +117,7 @@ abstract class GeoConverters {
Assert.isTrue(source.keySet().size() == 2, "Source must contain 2 elements");
if (source.containsKey("type")) {
- return DbObjectToGeoJsonPointConverter.INSTANCE.convert(source);
+ return DocumentToGeoJsonPointConverter.INSTANCE.convert(source);
}
return new Point((Double) source.get("x"), (Double) source.get("y"));
@@ -130,7 +130,7 @@ abstract class GeoConverters {
* @author Thomas Darimont
* @since 1.5
*/
- static enum PointToDbObjectConverter implements Converter {
+ static enum PointToDocumentConverter implements Converter {
INSTANCE;
@@ -151,7 +151,7 @@ abstract class GeoConverters {
* @since 1.5
*/
@WritingConverter
- static enum BoxToDbObjectConverter implements Converter {
+ static enum BoxToDocumentConverter implements Converter {
INSTANCE;
@@ -167,8 +167,8 @@ abstract class GeoConverters {
}
Document result = new Document();
- result.put("first", PointToDbObjectConverter.INSTANCE.convert(source.getFirst()));
- result.put("second", PointToDbObjectConverter.INSTANCE.convert(source.getSecond()));
+ result.put("first", PointToDocumentConverter.INSTANCE.convert(source.getFirst()));
+ result.put("second", PointToDocumentConverter.INSTANCE.convert(source.getSecond()));
return result;
}
}
@@ -180,7 +180,7 @@ abstract class GeoConverters {
* @since 1.5
*/
@ReadingConverter
- static enum DbObjectToBoxConverter implements Converter {
+ static enum DocumentToBoxConverter implements Converter {
INSTANCE;
@@ -195,8 +195,8 @@ abstract class GeoConverters {
return null;
}
- Point first = DbObjectToPointConverter.INSTANCE.convert((Document) source.get("first"));
- Point second = DbObjectToPointConverter.INSTANCE.convert((Document) source.get("second"));
+ Point first = DocumentToPointConverter.INSTANCE.convert((Document) source.get("first"));
+ Point second = DocumentToPointConverter.INSTANCE.convert((Document) source.get("second"));
return new Box(first, second);
}
@@ -208,7 +208,7 @@ abstract class GeoConverters {
* @author Thomas Darimont
* @since 1.5
*/
- static enum CircleToDbObjectConverter implements Converter {
+ static enum CircleToDocumentConverter implements Converter {
INSTANCE;
@@ -224,7 +224,7 @@ abstract class GeoConverters {
}
Document result = new Document();
- result.put("center", PointToDbObjectConverter.INSTANCE.convert(source.getCenter()));
+ result.put("center", PointToDocumentConverter.INSTANCE.convert(source.getCenter()));
result.put("radius", source.getRadius().getNormalizedValue());
result.put("metric", source.getRadius().getMetric().toString());
return result;
@@ -238,7 +238,7 @@ abstract class GeoConverters {
* @since 1.5
*/
@ReadingConverter
- static enum DbObjectToCircleConverter implements Converter {
+ static enum DocumentToCircleConverter implements Converter {
INSTANCE;
@@ -269,7 +269,7 @@ abstract class GeoConverters {
Assert.notNull(center, "Center must not be null!");
Assert.notNull(radius, "Radius must not be null!");
- return new Circle(DbObjectToPointConverter.INSTANCE.convert(center), distance);
+ return new Circle(DocumentToPointConverter.INSTANCE.convert(center), distance);
}
}
@@ -279,7 +279,7 @@ abstract class GeoConverters {
* @author Thomas Darimont
* @since 1.5
*/
- static enum SphereToDbObjectConverter implements Converter {
+ static enum SphereToDocumentConverter implements Converter {
INSTANCE;
@@ -295,7 +295,7 @@ abstract class GeoConverters {
}
Document result = new Document();
- result.put("center", PointToDbObjectConverter.INSTANCE.convert(source.getCenter()));
+ result.put("center", PointToDocumentConverter.INSTANCE.convert(source.getCenter()));
result.put("radius", source.getRadius().getNormalizedValue());
result.put("metric", source.getRadius().getMetric().toString());
return result;
@@ -309,7 +309,7 @@ abstract class GeoConverters {
* @since 1.5
*/
@ReadingConverter
- static enum DbObjectToSphereConverter implements Converter {
+ static enum DocumentToSphereConverter implements Converter {
INSTANCE;
@@ -340,7 +340,7 @@ abstract class GeoConverters {
Assert.notNull(center, "Center must not be null!");
Assert.notNull(radius, "Radius must not be null!");
- return new Sphere(DbObjectToPointConverter.INSTANCE.convert(center), distance);
+ return new Sphere(DocumentToPointConverter.INSTANCE.convert(center), distance);
}
}
@@ -350,7 +350,7 @@ abstract class GeoConverters {
* @author Thomas Darimont
* @since 1.5
*/
- static enum PolygonToDbObjectConverter implements Converter {
+ static enum PolygonToDocumentConverter implements Converter {
INSTANCE;
@@ -369,7 +369,7 @@ abstract class GeoConverters {
List pointTuples = new ArrayList(points.size());
for (Point point : points) {
- pointTuples.add(PointToDbObjectConverter.INSTANCE.convert(point));
+ pointTuples.add(PointToDocumentConverter.INSTANCE.convert(point));
}
Document result = new Document();
@@ -385,7 +385,7 @@ abstract class GeoConverters {
* @since 1.5
*/
@ReadingConverter
- static enum DbObjectToPolygonConverter implements Converter {
+ static enum DocumentToPolygonConverter implements Converter {
INSTANCE;
@@ -407,7 +407,7 @@ abstract class GeoConverters {
for (Document element : points) {
Assert.notNull(element, "Point elements of polygon must not be null!");
- newPoints.add(DbObjectToPointConverter.INSTANCE.convert(element));
+ newPoints.add(DocumentToPointConverter.INSTANCE.convert(element));
}
return new Polygon(newPoints);
@@ -420,7 +420,7 @@ abstract class GeoConverters {
* @author Thomas Darimont
* @since 1.5
*/
- static enum GeoCommandToDbObjectConverter implements Converter {
+ static enum GeoCommandToDocumentConverter implements Converter {
INSTANCE;
@@ -441,7 +441,7 @@ abstract class GeoConverters {
Shape shape = source.getShape();
if (shape instanceof GeoJson) {
- return GeoJsonToDbObjectConverter.INSTANCE.convert((GeoJson) shape);
+ return GeoJsonToDocumentConverter.INSTANCE.convert((GeoJson) shape);
}
if (shape instanceof Box) {
@@ -480,7 +480,7 @@ abstract class GeoConverters {
* @since 1.7
*/
@SuppressWarnings("rawtypes")
- static enum GeoJsonToDbObjectConverter implements Converter {
+ static enum GeoJsonToDocumentConverter implements Converter {
INSTANCE;
@@ -543,7 +543,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum GeoJsonPointToDbObjectConverter implements Converter {
+ static enum GeoJsonPointToDocumentConverter implements Converter {
INSTANCE;
@@ -553,7 +553,7 @@ abstract class GeoConverters {
*/
@Override
public Document convert(GeoJsonPoint source) {
- return GeoJsonToDbObjectConverter.INSTANCE.convert(source);
+ return GeoJsonToDocumentConverter.INSTANCE.convert(source);
}
}
@@ -561,7 +561,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum GeoJsonPolygonToDbObjectConverter implements Converter {
+ static enum GeoJsonPolygonToDocumentConverter implements Converter {
INSTANCE;
@@ -571,7 +571,7 @@ abstract class GeoConverters {
*/
@Override
public Document convert(GeoJsonPolygon source) {
- return GeoJsonToDbObjectConverter.INSTANCE.convert(source);
+ return GeoJsonToDocumentConverter.INSTANCE.convert(source);
}
}
@@ -579,7 +579,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum DbObjectToGeoJsonPointConverter implements Converter {
+ static enum DocumentToGeoJsonPointConverter implements Converter {
INSTANCE;
@@ -607,7 +607,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum DbObjectToGeoJsonPolygonConverter implements Converter {
+ static enum DocumentToGeoJsonPolygonConverter implements Converter {
INSTANCE;
@@ -633,7 +633,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum DbObjectToGeoJsonMultiPolygonConverter implements Converter {
+ static enum DocumentToGeoJsonMultiPolygonConverter implements Converter {
INSTANCE;
@@ -666,7 +666,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum DbObjectToGeoJsonLineStringConverter implements Converter {
+ static enum DocumentToGeoJsonLineStringConverter implements Converter {
INSTANCE;
@@ -694,7 +694,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum DbObjectToGeoJsonMultiPointConverter implements Converter {
+ static enum DocumentToGeoJsonMultiPointConverter implements Converter {
INSTANCE;
@@ -722,7 +722,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum DbObjectToGeoJsonMultiLineStringConverter implements Converter {
+ static enum DocumentToGeoJsonMultiLineStringConverter implements Converter {
INSTANCE;
@@ -754,7 +754,7 @@ abstract class GeoConverters {
* @author Christoph Strobl
* @since 1.7
*/
- static enum DbObjectToGeoJsonGeometryCollectionConverter implements Converter {
+ static enum DocumentToGeoJsonGeometryCollectionConverter implements Converter {
INSTANCE;
@@ -785,26 +785,26 @@ abstract class GeoConverters {
Object type = source.get("type");
if (ObjectUtils.nullSafeEquals(type, "Point")) {
- return DbObjectToGeoJsonPointConverter.INSTANCE.convert(source);
+ return DocumentToGeoJsonPointConverter.INSTANCE.convert(source);
}
if (ObjectUtils.nullSafeEquals(type, "MultiPoint")) {
- return DbObjectToGeoJsonMultiPointConverter.INSTANCE.convert(source);
+ return DocumentToGeoJsonMultiPointConverter.INSTANCE.convert(source);
}
if (ObjectUtils.nullSafeEquals(type, "LineString")) {
- return DbObjectToGeoJsonLineStringConverter.INSTANCE.convert(source);
+ return DocumentToGeoJsonLineStringConverter.INSTANCE.convert(source);
}
if (ObjectUtils.nullSafeEquals(type, "MultiLineString")) {
- return DbObjectToGeoJsonMultiLineStringConverter.INSTANCE.convert(source);
+ return DocumentToGeoJsonMultiLineStringConverter.INSTANCE.convert(source);
}
if (ObjectUtils.nullSafeEquals(type, "Polygon")) {
- return DbObjectToGeoJsonPolygonConverter.INSTANCE.convert(source);
+ return DocumentToGeoJsonPolygonConverter.INSTANCE.convert(source);
}
if (ObjectUtils.nullSafeEquals(type, "MultiPolygon")) {
- return DbObjectToGeoJsonMultiPolygonConverter.INSTANCE.convert(source);
+ return DocumentToGeoJsonMultiPolygonConverter.INSTANCE.convert(source);
}
throw new IllegalArgumentException(String.format("Cannot convert unknown GeoJson type %s", type));
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/MappingMongoConverter.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/MappingMongoConverter.java
index 44fafb120..5f1dd3f9f 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/MappingMongoConverter.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/core/convert/MappingMongoConverter.java
@@ -104,7 +104,7 @@ public class MappingMongoConverter extends AbstractMongoConverter implements App
/**
* Creates a new {@link MappingMongoConverter} given the new {@link DbRefResolver} and {@link MappingContext}.
*
- * @param mongoDbFactory must not be {@literal null}.
+ * @param dbRefResolver must not be {@literal null}.
* @param mappingContext must not be {@literal null}.
*/
public MappingMongoConverter(DbRefResolver dbRefResolver,
@@ -192,50 +192,50 @@ public class MappingMongoConverter extends AbstractMongoConverter implements App
* (non-Javadoc)
* @see org.springframework.data.mongodb.core.core.MongoReader#read(java.lang.Class, com.mongodb.Document)
*/
- public S read(Class clazz, final Bson dbo) {
- return read(ClassTypeInformation.from(clazz), dbo);
+ public S read(Class clazz, final Bson bson) {
+ return read(ClassTypeInformation.from(clazz), bson);
}
- protected S read(TypeInformation type, Bson dbo) {
- return read(type, dbo, ObjectPath.ROOT);
+ protected S read(TypeInformation