mindol1004/spring-data-mongodb
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

DATADOC-16 added updateMulti and updateFirst methods

Browse Source
This commit is contained in:
Thomas Risberg
2010-12-02 16:24:51 -05:00
parent 69dfe329a6
commit 885e9575f2
1 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
spring-data-mongodb/src/main/java/org/springframework/data/document/mongodb/MongoTemplate.java
View File

@@ -237,11 +237,11 @@ public class MongoTemplate implements InitializingBean {
} }
} }
public void update(DBObject queryDoc, DBObject updateDoc) { public void updateFirst(DBObject queryDoc, DBObject updateDoc) {
update(getRequiredDefaultCollectionName(), queryDoc, updateDoc); updateFirst(getRequiredDefaultCollectionName(), queryDoc, updateDoc);
} }
public void update(String collectionName, DBObject queryDoc, DBObject updateDoc) { public void updateFirst(String collectionName, DBObject queryDoc, DBObject updateDoc) {
WriteResult wr = null; WriteResult wr = null;
try { try {
wr = getDb().getCollection(collectionName).update(queryDoc, updateDoc); wr = getDb().getCollection(collectionName).update(queryDoc, updateDoc);
@@ -250,6 +250,19 @@ public class MongoTemplate implements InitializingBean {
} }
} }
public void updateMulti(DBObject queryDoc, DBObject updateDoc) {
updateMulti(getRequiredDefaultCollectionName(), queryDoc, updateDoc);
}
public void updateMulti(String collectionName, DBObject queryDoc, DBObject updateDoc) {
WriteResult wr = null;
try {
wr = getDb().getCollection(collectionName).updateMulti(queryDoc, updateDoc);
} catch (MongoException e) {
throw new DataRetrievalFailureException("Error during updateMulti using " + queryDoc + ", " + updateDoc + ": " + wr.getLastError().getErrorMessage(), e);
}
}
public void remove(DBObject queryDoc) { public void remove(DBObject queryDoc) {
remove(getRequiredDefaultCollectionName(), queryDoc); remove(getRequiredDefaultCollectionName(), queryDoc);
} }