Rename query() method to selector()

This commit is contained in:
fbraem
2013-02-20 22:20:55 +01:00
parent e04dca0e13
commit e79f75d9fe
5 changed files with 17 additions and 17 deletions

View File

@@ -105,12 +105,12 @@ public:
/// Sets the number to return (limit) /// Sets the number to return (limit)
Document& query(); Document& selector();
/// Returns the query document /// Returns the selector document
Document& returnFieldSelector(); Document& returnFieldSelector();
/// Returns the selector document /// Returns the field selector document
protected: protected:
@@ -128,7 +128,7 @@ private:
Int32 _numberToReturn; Int32 _numberToReturn;
Document _query; Document _selector;
Document _returnFieldSelector; Document _returnFieldSelector;
}; };
@@ -152,9 +152,9 @@ inline std::string QueryRequest::fullCollectionName() const
} }
inline Document& QueryRequest::query() inline Document& QueryRequest::selector()
{ {
return _query; return _selector;
} }

View File

@@ -75,7 +75,7 @@ Document::Ptr Database::getLastErrorDoc(Connection& connection) const
Poco::SharedPtr<Poco::MongoDB::QueryRequest> request = createQueryRequest("$cmd"); Poco::SharedPtr<Poco::MongoDB::QueryRequest> request = createQueryRequest("$cmd");
request->setNumberToReturn(1); request->setNumberToReturn(1);
request->query().add("getLastError", 1); request->selector().add("getLastError", 1);
Poco::MongoDB::ResponseMessage response; Poco::MongoDB::ResponseMessage response;
connection.sendRequest(*request, response); connection.sendRequest(*request, response);
@@ -110,7 +110,7 @@ Poco::SharedPtr<Poco::MongoDB::QueryRequest> Database::createCountRequest(const
{ {
Poco::SharedPtr<Poco::MongoDB::QueryRequest> request = createQueryRequest("$cmd"); Poco::SharedPtr<Poco::MongoDB::QueryRequest> request = createQueryRequest("$cmd");
request->setNumberToReturn(1); request->setNumberToReturn(1);
request->query().add("count", collectionName); request->selector().add("count", collectionName);
return request; return request;
} }

View File

@@ -49,7 +49,7 @@ QueryRequest::QueryRequest(const std::string& collectionName, QueryRequest::Flag
_fullCollectionName(collectionName), _fullCollectionName(collectionName),
_numberToSkip(0), _numberToSkip(0),
_numberToReturn(100), _numberToReturn(100),
_query(), _selector(),
_returnFieldSelector() _returnFieldSelector()
{ {
} }
@@ -65,7 +65,7 @@ void QueryRequest::buildRequest(BinaryWriter& writer)
BSONWriter(writer).writeCString(_fullCollectionName); BSONWriter(writer).writeCString(_fullCollectionName);
writer << _numberToSkip; writer << _numberToSkip;
writer << _numberToReturn; writer << _numberToReturn;
_query.write(writer); _selector.write(writer);
if ( ! _returnFieldSelector.empty() ) if ( ! _returnFieldSelector.empty() )
{ {

View File

@@ -78,7 +78,7 @@ Connection::Ptr ReplicaSet::isMaster(const Net::SocketAddress& address)
QueryRequest request("admin.$cmd"); QueryRequest request("admin.$cmd");
request.setNumberToReturn(1); request.setNumberToReturn(1);
request.query().add("isMaster", 1); request.selector().add("isMaster", 1);
ResponseMessage response; ResponseMessage response;
conn->sendRequest(request, response); conn->sendRequest(request, response);

View File

@@ -124,7 +124,7 @@ void MongoDBTest::testQueryRequest()
} }
Poco::MongoDB::QueryRequest request("team.players"); Poco::MongoDB::QueryRequest request("team.players");
request.query().add("lastname" , std::string("Braem")); request.selector().add("lastname" , std::string("Braem"));
request.setNumberToReturn(1); request.setNumberToReturn(1);
Poco::MongoDB::ResponseMessage response; Poco::MongoDB::ResponseMessage response;
@@ -173,7 +173,7 @@ void MongoDBTest::testDBQueryRequest()
Database db("team"); Database db("team");
Poco::SharedPtr<Poco::MongoDB::QueryRequest> request = db.createQueryRequest("players"); Poco::SharedPtr<Poco::MongoDB::QueryRequest> request = db.createQueryRequest("players");
request->query().add("lastname" , std::string("Braem")); request->selector().add("lastname" , std::string("Braem"));
Poco::MongoDB::ResponseMessage response; Poco::MongoDB::ResponseMessage response;
_mongo.sendRequest(*request, response); _mongo.sendRequest(*request, response);
@@ -219,7 +219,7 @@ void MongoDBTest::testCountCommand()
Poco::MongoDB::QueryRequest request("team.$cmd"); Poco::MongoDB::QueryRequest request("team.$cmd");
request.setNumberToReturn(1); request.setNumberToReturn(1);
request.query().add("count", std::string("players")); request.selector().add("count", std::string("players"));
Poco::MongoDB::ResponseMessage response; Poco::MongoDB::ResponseMessage response;
@@ -331,7 +331,7 @@ void MongoDBTest::testCursorRequest()
Poco::MongoDB::QueryRequest drop("team.$cmd"); Poco::MongoDB::QueryRequest drop("team.$cmd");
drop.setNumberToReturn(1); drop.setNumberToReturn(1);
drop.query().add("drop", std::string("numbers")); drop.selector().add("drop", std::string("numbers"));
Poco::MongoDB::ResponseMessage responseDrop; Poco::MongoDB::ResponseMessage responseDrop;
_mongo.sendRequest(drop, responseDrop); _mongo.sendRequest(drop, responseDrop);
@@ -353,7 +353,7 @@ void MongoDBTest::testBuildInfo()
Poco::MongoDB::QueryRequest request("team.$cmd"); Poco::MongoDB::QueryRequest request("team.$cmd");
request.setNumberToReturn(1); request.setNumberToReturn(1);
request.query().add("buildInfo", 1); request.selector().add("buildInfo", 1);
Poco::MongoDB::ResponseMessage response; Poco::MongoDB::ResponseMessage response;
@@ -388,7 +388,7 @@ void MongoDBTest::testConnectionPool()
Poco::MongoDB::QueryRequest request("team.$cmd"); Poco::MongoDB::QueryRequest request("team.$cmd");
request.setNumberToReturn(1); request.setNumberToReturn(1);
request.query().add("count", std::string("players")); request.selector().add("count", std::string("players"));
Poco::MongoDB::ResponseMessage response; Poco::MongoDB::ResponseMessage response;
((Connection::Ptr) pooledConnection)->sendRequest(request, response); ((Connection::Ptr) pooledConnection)->sendRequest(request, response);