/** * Copyright (C) 2013 10gen Inc. * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License, version 3, * as published by the Free Software Foundation. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see . * * As a special exception, the copyright holders give permission to link the * code of portions of this program with the OpenSSL library under certain * conditions as described in each individual source file and distribute * linked combinations including the program with the OpenSSL library. You * must comply with the GNU Affero General Public License in all respects for * all of the code used other than as permitted herein. If you modify file(s) * with this exception, you may extend this exception to your version of the * file(s), but you are not obligated to do so. If you do not wish to do so, * delete this exception statement from your version. If you delete this * exception statement from all source files in the program, then also delete * it in the license file. */ #pragma once #include "mongo/db/jsobj.h" #include "mongo/db/curop.h" #include "mongo/db/namespace_string.h" #include "mongo/db/query/explain.h" #include "mongo/util/mongoutils/str.h" namespace mongo { namespace str = mongoutils::str; class FieldRef; class UpdateLifecycle; class UpdateRequest { public: enum ReturnDocOption { // Return no document. RETURN_NONE, // Return the document as it was before the update. If the update results in an insert, // no document will be returned. RETURN_OLD, // Return the document as it is after the update. RETURN_NEW }; inline UpdateRequest(const NamespaceString& nsString) : _nsString(nsString), _god(false), _upsert(false), _multi(false), _fromMigration(false), _lifecycle(NULL), _isExplain(false), _returnDocs(ReturnDocOption::RETURN_NONE), _yieldPolicy(PlanExecutor::YIELD_MANUAL) {} const NamespaceString& getNamespaceString() const { return _nsString; } inline void setQuery(const BSONObj& query) { _query = query; } inline const BSONObj& getQuery() const { return _query; } inline void setProj(const BSONObj& proj) { _proj = proj; } inline const BSONObj& getProj() const { return _proj; } inline void setSort(const BSONObj& sort) { _sort = sort; } inline const BSONObj& getSort() const { return _sort; } inline void setUpdates(const BSONObj& updates) { _updates = updates; } inline const BSONObj& getUpdates() const { return _updates; } // Please see documentation on the private members matching these names for // explanations of the following fields. inline void setGod(bool value = true) { _god = value; } bool isGod() const { return _god; } inline void setUpsert(bool value = true) { _upsert = value; } bool isUpsert() const { return _upsert; } inline void setMulti(bool value = true) { _multi = value; } bool isMulti() const { return _multi; } inline void setFromMigration(bool value = true) { _fromMigration = value; } bool isFromMigration() const { return _fromMigration; } inline void setLifecycle(UpdateLifecycle* value) { _lifecycle = value; } inline UpdateLifecycle* getLifecycle() const { return _lifecycle; } inline void setExplain(bool value = true) { _isExplain = value; } inline bool isExplain() const { return _isExplain; } inline void setReturnDocs(ReturnDocOption value) { _returnDocs = value; } inline bool shouldReturnOldDocs() const { return _returnDocs == ReturnDocOption::RETURN_OLD; } inline bool shouldReturnNewDocs() const { return _returnDocs == ReturnDocOption::RETURN_NEW; } inline bool shouldReturnAnyDocs() const { return shouldReturnOldDocs() || shouldReturnNewDocs(); } inline void setYieldPolicy(PlanExecutor::YieldPolicy yieldPolicy) { _yieldPolicy = yieldPolicy; } inline PlanExecutor::YieldPolicy getYieldPolicy() const { return _yieldPolicy; } const std::string toString() const { return str::stream() << " query: " << _query << " projection: " << _proj << " sort: " << _sort << " updated: " << _updates << " god: " << _god << " upsert: " << _upsert << " multi: " << _multi << " fromMigration: " << _fromMigration << " isExplain: " << _isExplain; } private: const NamespaceString& _nsString; // Contains the query that selects documents to update. BSONObj _query; // Contains the projection information. BSONObj _proj; // Contains the sort order information. BSONObj _sort; // Contains the modifiers to apply to matched objects, or a replacement document. BSONObj _updates; // Flags controlling the update. // God bypasses _id checking and index generation. It is only used on behalf of system // updates, never user updates. bool _god; // True if this should insert if no matching document is found. bool _upsert; // True if this update is allowed to affect more than one document. bool _multi; // True if this update is on behalf of a chunk migration. bool _fromMigration; // The lifecycle data, and events used during the update request. UpdateLifecycle* _lifecycle; // Whether or not we are requesting an explained update. Explained updates are read-only. bool _isExplain; // Specifies which version of the documents to return, if any. // // RETURN_NONE (default): Never return any documents, old or new. // RETURN_OLD: Return ADVANCED when a matching document is encountered, and the value of // the document before it was updated. If there were no matches, return // IS_EOF instead (even in case of an upsert). // RETURN_NEW: Return ADVANCED when a matching document is encountered, and the value of // the document after being updated. If an upsert was specified and it // resulted in an insert, return the inserted document. // // This allows findAndModify to execute an update and retrieve the resulting document // without another query before or after the update. ReturnDocOption _returnDocs; // Whether or not the update should yield. Defaults to YIELD_MANUAL. PlanExecutor::YieldPolicy _yieldPolicy; }; } // namespace mongo