Spring/spring-data-mongodb
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

cleaned up warnings; modified insert/save debug logging

Browse Source
This commit is contained in:
Thomas Risberg
2011-04-08 18:51:27 -04:00
parent afee3abb10
commit 104fca18a4
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -17,7 +17,6 @@
package org.springframework.data.document.mongodb;
import static org.springframework.data.document.mongodb.query.Criteria.whereId;
import static org.springframework.data.document.mongodb.query.Query.query;
import java.beans.IntrospectionException;
import java.beans.PropertyDescriptor;
@@ -614,7 +613,8 @@ public class MongoTemplate implements InitializingBean, MongoOperations, Applica
for (Object o : listToSave) {
PersistentEntity<?> entity = mappingContext.getPersistentEntity(o.getClass());
if (null != entity && entity instanceof MongoPersistentEntity) {
String coll = ((MongoPersistentEntity) entity).getCollection();
@SuppressWarnings("unchecked")
String coll = ((MongoPersistentEntity<T>) entity).getCollection();
List<Object> objList = objs.get(coll);
if (null == objList) {
objList = new ArrayList<Object>();
@@ -715,7 +715,7 @@ public class MongoTemplate implements InitializingBean, MongoOperations, Applica
}
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("insert DBObject: " + dbDoc);
LOGGER.debug("insert DBObject containing fields: " + dbDoc.keySet());
}
return execute(collectionName, new CollectionCallback<Object>() {
public Object doInCollection(DBCollection collection) throws MongoException, DataAccessException {
@@ -746,6 +746,9 @@ public class MongoTemplate implements InitializingBean, MongoOperations, Applica
}
}
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("insert list of DBObjects containing " + dbDocList.size() + " items");
}
execute(collectionName, new CollectionCallback<Void>() {
public Void doInCollection(DBCollection collection) throws MongoException, DataAccessException {
if (writeConcern == null) {
@@ -786,7 +789,7 @@ public class MongoTemplate implements InitializingBean, MongoOperations, Applica
}
}
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("save DBObject: " + dbDoc);
LOGGER.debug("save DBObject containing fields: " + dbDoc.keySet());
}
return execute(collectionName, new CollectionCallback<Object>() {
public Object doInCollection(DBCollection collection) throws MongoException, DataAccessException {
@@ -1285,7 +1288,7 @@ public class MongoTemplate implements InitializingBean, MongoOperations, Applica
entity = mappingContext.addPersistentEntity(clazz);
}
if (null != entity && entity instanceof MongoPersistentEntity) {
return ((MongoPersistentEntity) entity).getCollection();
return ((MongoPersistentEntity<T>) entity).getCollection();
}
}
// Otherwise, return the default for this template.