From 7966aba1e07f04efa16dd62be92f1062c1de0465 Mon Sep 17 00:00:00 2001 From: Thomas Risberg Date: Fri, 27 Aug 2010 20:48:53 -0400 Subject: [PATCH] some more refactoring --- .../datastore/document/mongodb/MongoTemplate.java | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/springframework/datastore/document/mongodb/MongoTemplate.java b/src/main/java/org/springframework/datastore/document/mongodb/MongoTemplate.java index 7bd096c94..1482d3ad3 100644 --- a/src/main/java/org/springframework/datastore/document/mongodb/MongoTemplate.java +++ b/src/main/java/org/springframework/datastore/document/mongodb/MongoTemplate.java @@ -58,12 +58,25 @@ public class MongoTemplate extends AbstractDocumentStoreTemplate { return connectionFactory; } + public void execute(String command) { + DB db = getDocumentStoreConnectionFactory().getConnection(); + CommandResult cr = db.command(command); + String err = cr.getErrorMessage(); + if (err != null) { + throw new InvalidDataAccessApiUsageException("Command execution of " + + command + " failed: " + err); + } + } public void execute(DocumentSource command) { CommandResult cr = getDocumentStoreConnectionFactory() .getConnection() .command(command.getDocument()); - System.out.println("! " + cr.getErrorMessage()); + String err = cr.getErrorMessage(); + if (err != null) { + throw new InvalidDataAccessApiUsageException("Command execution of " + + command.getDocument().toString() + " failed: " + err); + } } public void createCollection(String collectionName, DocumentSource documentSource) {