From 79c1edbdfb670e81e83cb54386b19f77b04545c9 Mon Sep 17 00:00:00 2001
From: fbraem <franky.braem@gmail.com>
Date: Tue, 19 Feb 2013 22:32:11 +0100
Subject: [PATCH] Add getLastErrorDoc and getLastError

---
 MongoDB/include/Poco/MongoDB/Database.h |  8 +++++++
 MongoDB/src/Database.cpp                | 31 +++++++++++++++++++++++++
 2 files changed, 39 insertions(+)

diff --git a/MongoDB/include/Poco/MongoDB/Database.h b/MongoDB/include/Poco/MongoDB/Database.h
index d16248b1c..9f4a21c5b 100644
--- a/MongoDB/include/Poco/MongoDB/Database.h
+++ b/MongoDB/include/Poco/MongoDB/Database.h
@@ -80,6 +80,14 @@ public:
 		/// The collectionname must not contain the database name!
 
 
+	Document::Ptr getLastErrorDoc(Connection& connection) const;
+		/// Sends the getLastError command to the database and returns the document
+
+
+	std::string getLastError(Connection& connection) const;
+		/// Sends the getLastError command to the database and returns the err element
+		/// from the error document. When err is null, an empty string is returned.
+
 private:
 	std::string _dbname;
 };
diff --git a/MongoDB/src/Database.cpp b/MongoDB/src/Database.cpp
index b43ebb694..e5be810f6 100644
--- a/MongoDB/src/Database.cpp
+++ b/MongoDB/src/Database.cpp
@@ -69,6 +69,37 @@ double Database::count(Connection& connection, const std::string& collectionName
 }
 
 
+Document::Ptr Database::getLastErrorDoc(Connection& connection) const
+{
+	Document::Ptr errorDoc;
+
+	Poco::SharedPtr<Poco::MongoDB::QueryRequest> request = createQueryRequest("$cmd");
+	request->setNumberToReturn(1);
+	request->query().add("getLastError", 1);
+
+	Poco::MongoDB::ResponseMessage response;
+	connection.sendRequest(*request, response);
+
+	if ( response.documents().size() > 0 )
+	{
+		errorDoc = response.documents()[0];
+	}
+
+	return errorDoc;
+}
+
+std::string Database::getLastError(Connection& connection) const
+{
+	Document::Ptr errorDoc = getLastErrorDoc(connection);
+	if ( !errorDoc.isNull() && errorDoc->isType<std::string>("err") )
+	{
+		return errorDoc->get<std::string>("err");
+	}
+
+	return "";
+}
+
+
 Poco::SharedPtr<Poco::MongoDB::QueryRequest> Database::createQueryRequest(const std::string& collectionName) const
 {
 	return new Poco::MongoDB::QueryRequest(_dbname + '.' + collectionName);