diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/document/mongodb/MongoTemplate.java b/spring-data-mongodb/src/main/java/org/springframework/data/document/mongodb/MongoTemplate.java index 3375135f5..cdbb1351e 100644 --- a/spring-data-mongodb/src/main/java/org/springframework/data/document/mongodb/MongoTemplate.java +++ b/spring-data-mongodb/src/main/java/org/springframework/data/document/mongodb/MongoTemplate.java @@ -28,8 +28,6 @@ import org.springframework.beans.PropertyAccessorFactory; import org.springframework.beans.factory.InitializingBean; import org.springframework.dao.DataRetrievalFailureException; import org.springframework.dao.InvalidDataAccessApiUsageException; -import org.springframework.data.document.AbstractDocumentStoreTemplate; -import org.springframework.data.document.mongodb.query.Query; import com.mongodb.BasicDBObject; import com.mongodb.CommandResult; @@ -239,6 +237,20 @@ public class MongoTemplate implements InitializingBean { } } + public void update(DBObject queryDoc, DBObject updateDoc) { + update(getRequiredDefaultCollectionName(), queryDoc, updateDoc); + } + + public void update(String collectionName, DBObject queryDoc, DBObject updateDoc) { + WriteResult wr = null; + try { + wr = getDb().getCollection(collectionName).update(queryDoc, updateDoc); + } catch (MongoException e) { + throw new DataRetrievalFailureException(wr.getLastError().getErrorMessage(), e); + } + } + + public List getCollection(Class targetClass) { List results = new ArrayList();