22 #include <bsoncxx/builder/basic/array.hpp> 23 #include <bsoncxx/builder/basic/document.hpp> 24 #include <bsoncxx/builder/basic/kvp.hpp> 25 #include <bsoncxx/builder/concatenate.hpp> 26 #include <bsoncxx/document/view_or_value.hpp> 27 #include <bsoncxx/oid.hpp> 28 #include <bsoncxx/stdx/optional.hpp> 29 #include <bsoncxx/string/view_or_value.hpp> 30 #include <mongocxx/bulk_write.hpp> 31 #include <mongocxx/change_stream.hpp> 32 #include <mongocxx/client_session.hpp> 33 #include <mongocxx/cursor.hpp> 34 #include <mongocxx/index_view.hpp> 35 #include <mongocxx/model/insert_one.hpp> 36 #include <mongocxx/options/aggregate.hpp> 37 #include <mongocxx/options/bulk_write.hpp> 38 #include <mongocxx/options/change_stream.hpp> 39 #include <mongocxx/options/count.hpp> 40 #include <mongocxx/options/delete.hpp> 41 #include <mongocxx/options/distinct.hpp> 42 #include <mongocxx/options/find.hpp> 43 #include <mongocxx/options/find_one_and_delete.hpp> 44 #include <mongocxx/options/find_one_and_replace.hpp> 45 #include <mongocxx/options/find_one_and_update.hpp> 46 #include <mongocxx/options/index.hpp> 47 #include <mongocxx/options/index_view.hpp> 48 #include <mongocxx/options/insert.hpp> 49 #include <mongocxx/options/update.hpp> 50 #include <mongocxx/read_concern.hpp> 51 #include <mongocxx/read_preference.hpp> 52 #include <mongocxx/result/bulk_write.hpp> 53 #include <mongocxx/result/delete.hpp> 54 #include <mongocxx/result/insert_many.hpp> 55 #include <mongocxx/result/insert_one.hpp> 56 #include <mongocxx/result/replace_one.hpp> 57 #include <mongocxx/result/update.hpp> 58 #include <mongocxx/write_concern.hpp> 60 #include <mongocxx/config/prelude.hpp> 63 MONGOCXX_INLINE_NAMESPACE_BEGIN
65 using bsoncxx::builder::basic::kvp;
66 using bsoncxx::builder::basic::make_document;
67 using bsoncxx::builder::concatenate;
126 explicit operator bool()
const noexcept;
174 const pipeline& pipeline,
206 class bulk_write create_bulk_write(const client_session& session,
234 MONGOCXX_INLINE stdx::optional<result::bulk_write> write(
259 MONGOCXX_INLINE stdx::optional<result::bulk_write> write(
260 const client_session& session,
290 template <
typename container_type>
291 MONGOCXX_INLINE stdx::optional<result::bulk_write>
bulk_write(
317 template <
typename container_type>
318 MONGOCXX_INLINE stdx::optional<result::bulk_write> bulk_write(
319 const client_session& session,
320 const container_type& writes,
350 template <
typename write_model_iterator_type>
351 MONGOCXX_INLINE stdx::optional<result::bulk_write> bulk_write(
352 write_model_iterator_type begin,
353 write_model_iterator_type end,
380 template <
typename write_model_iterator_type>
381 MONGOCXX_INLINE stdx::optional<result::bulk_write> bulk_write(
382 const client_session& session,
383 write_model_iterator_type begin,
384 write_model_iterator_type end,
404 MONGOCXX_DEPRECATED stdx::optional<result::bulk_write> bulk_write(
405 const class bulk_write& bulk_write);
406 stdx::optional<result::bulk_write> bulk_write_deprecated(
const class bulk_write& bulk_write);
443 std::int64_t count(
const client_session& session,
499 const client_session& session,
526 stdx::optional<result::delete_result> delete_many(
548 stdx::optional<result::delete_result> delete_many(
549 const client_session& session,
575 stdx::optional<result::delete_result> delete_one(
597 stdx::optional<result::delete_result> delete_one(
598 const client_session& session,
646 cursor distinct(
const client_session& session,
673 void drop(
const bsoncxx::stdx::optional<mongocxx::write_concern>&
write_concern = {});
693 void drop(
const client_session& session,
694 const bsoncxx::stdx::optional<mongocxx::write_concern>&
write_concern = {});
741 cursor find(
const client_session& session,
761 stdx::optional<bsoncxx::document::value> find_one(
780 stdx::optional<bsoncxx::document::value> find_one(
781 const client_session& session,
808 stdx::optional<bsoncxx::document::value> find_one_and_delete(
831 stdx::optional<bsoncxx::document::value> find_one_and_delete(
832 const client_session& session,
862 stdx::optional<bsoncxx::document::value> find_one_and_replace(
889 stdx::optional<bsoncxx::document::value> find_one_and_replace(
890 const client_session& session,
921 stdx::optional<bsoncxx::document::value> find_one_and_update(
948 stdx::optional<bsoncxx::document::value> find_one_and_update(
949 const client_session& session,
992 stdx::optional<result::insert_one> insert_one(
const client_session& session,
1024 template <
typename container_type>
1025 MONGOCXX_INLINE stdx::optional<result::insert_many> insert_many(
1049 template <
typename container_type>
1050 MONGOCXX_INLINE stdx::optional<result::insert_many> insert_many(
1051 const client_session& session,
1052 const container_type& container,
1080 template <
typename document_view_iterator_type>
1081 MONGOCXX_INLINE stdx::optional<result::insert_many> insert_many(
1082 document_view_iterator_type begin,
1083 document_view_iterator_type end,
1107 template <
typename document_view_iterator_type>
1108 MONGOCXX_INLINE stdx::optional<result::insert_many> insert_many(
1109 const client_session& session,
1110 document_view_iterator_type begin,
1111 document_view_iterator_type end,
1128 cursor list_indexes()
const;
1142 cursor list_indexes(
const client_session& session)
const;
1154 stdx::string_view name()
const;
1176 bool drop_target_before_rename =
false,
1177 const bsoncxx::stdx::optional<write_concern>&
write_concern = {});
1200 void rename(
const client_session& session,
1202 bool drop_target_before_rename =
false,
1203 const bsoncxx::stdx::optional<write_concern>&
write_concern = {});
1228 class read_concern read_concern() const;
1248 class read_preference read_preference() const;
1272 stdx::optional<result::replace_one> replace_one(
1299 stdx::optional<result::replace_one> replace_one(
1300 const client_session& session,
1357 stdx::optional<result::update> update_many(
const client_session& session,
1414 stdx::optional<result::update> update_one(
const client_session& session,
1437 class write_concern write_concern() const;
1506 const pipeline& pipe,
1514 friend class bulk_write;
1520 MONGOCXX_PRIVATE collection(
const database& database,
void* collection);
1522 MONGOCXX_PRIVATE
cursor _aggregate(
const client_session* session,
1523 const pipeline& pipeline,
1526 MONGOCXX_PRIVATE std::int64_t _count(
const client_session* session,
1531 const client_session* session,
1536 MONGOCXX_PRIVATE stdx::optional<result::delete_result> _delete_many(
1537 const client_session* session,
1541 MONGOCXX_PRIVATE stdx::optional<result::delete_result> _delete_one(
1542 const client_session* session,
1546 MONGOCXX_PRIVATE
cursor _distinct(
const client_session* session,
1551 MONGOCXX_PRIVATE
void _drop(
1552 const client_session* session,
1553 const bsoncxx::stdx::optional<mongocxx::write_concern>& write_concern);
1555 MONGOCXX_PRIVATE
cursor _find(
const client_session* session,
1559 MONGOCXX_PRIVATE stdx::optional<bsoncxx::document::value> _find_one(
1560 const client_session* session,
1564 MONGOCXX_PRIVATE stdx::optional<bsoncxx::document::value> _find_one_and_delete(
1565 const client_session* session,
1569 MONGOCXX_PRIVATE stdx::optional<bsoncxx::document::value> _find_one_and_replace(
1570 const client_session* session,
1575 MONGOCXX_PRIVATE stdx::optional<bsoncxx::document::value> _find_one_and_update(
1576 const client_session* session,
1581 MONGOCXX_PRIVATE stdx::optional<result::insert_one> _insert_one(
1582 const client_session* session,
1586 MONGOCXX_PRIVATE
void _rename(
1587 const client_session* session,
1589 bool drop_target_before_rename,
1590 const bsoncxx::stdx::optional<class write_concern>& write_concern);
1592 MONGOCXX_PRIVATE stdx::optional<result::replace_one> _replace_one(
1593 const client_session* session,
1598 MONGOCXX_PRIVATE stdx::optional<result::update> _update_one(
1599 const client_session* session,
1604 MONGOCXX_PRIVATE stdx::optional<result::update> _update_many(
1605 const client_session* session,
1610 MONGOCXX_PRIVATE
change_stream _watch(
const client_session* session,
1611 const pipeline& pipe,
1615 class bulk_write _init_insert_many(const options::insert& options,
1616 const client_session* session);
1618 void _insert_many_doc_handler(class bulk_write& writes,
1619 bsoncxx::builder::basic::array& inserted_ids,
1620 bsoncxx::document::view doc) const;
1622 stdx::optional<result::insert_many> _exec_insert_many(
1623 class bulk_write& writes, bsoncxx::builder::basic::array& inserted_ids);
1625 template <typename document_view_iterator_type>
1626 MONGOCXX_PRIVATE stdx::optional<result::insert_many> _insert_many(
1627 const client_session* session,
1628 document_view_iterator_type begin,
1629 document_view_iterator_type end,
1630 const options::insert& options);
1632 class MONGOCXX_PRIVATE impl;
1634 MONGOCXX_PRIVATE impl& _get_impl();
1635 MONGOCXX_PRIVATE const impl& _get_impl() const;
1637 std::unique_ptr<impl> _impl;
1641 const model::write& write, const options::bulk_write& options) {
1647 return create_bulk_write(session, options).
append(write).
execute();
1650 template <
typename container_type>
1651 MONGOCXX_INLINE stdx::optional<result::bulk_write> collection::bulk_write(
1653 return bulk_write(requests.begin(), requests.end(), options);
1656 template <
typename container_type>
1657 MONGOCXX_INLINE stdx::optional<result::bulk_write> collection::bulk_write(
1658 const client_session& session,
1659 const container_type& requests,
1661 return bulk_write(session, requests.begin(), requests.end(), options);
1664 template <
typename write_model_iterator_type>
1665 MONGOCXX_INLINE stdx::optional<result::bulk_write> collection::bulk_write(
1666 write_model_iterator_type begin,
1667 write_model_iterator_type end,
1669 auto writes = create_bulk_write(options);
1670 std::for_each(begin, end, [&](
const model::write& current) { writes.append(current); });
1671 return writes.execute();
1674 template <
typename write_model_iterator_type>
1675 MONGOCXX_INLINE stdx::optional<result::bulk_write> collection::bulk_write(
1676 const client_session& session,
1677 write_model_iterator_type begin,
1678 write_model_iterator_type end,
1680 auto writes = create_bulk_write(session, options);
1681 std::for_each(begin, end, [&](
const model::write& current) { writes.append(current); });
1682 return writes.execute();
1685 template <
typename container_type>
1688 return insert_many(container.begin(), container.end(), options);
1691 template <
typename container_type>
1693 const client_session& session,
1694 const container_type& container,
1696 return insert_many(session, container.begin(), container.end(), options);
1699 template <
typename document_view_iterator_type>
1700 MONGOCXX_INLINE stdx::optional<result::insert_many> collection::_insert_many(
1702 const client_session* session,
1703 document_view_iterator_type begin,
1704 document_view_iterator_type end,
1707 auto writes = _init_insert_many(options, session);
1709 _insert_many_doc_handler(writes, inserted_ids, doc);
1711 return _exec_insert_many(writes, inserted_ids);
1714 template <
typename document_view_iterator_type>
1716 document_view_iterator_type begin,
1717 document_view_iterator_type end,
1719 return _insert_many(
nullptr, begin, end, options);
1722 template <
typename document_view_iterator_type>
1724 const client_session& session,
1725 document_view_iterator_type begin,
1726 document_view_iterator_type end,
1728 return _insert_many(&session, begin, end, options);
1731 MONGOCXX_INLINE_NAMESPACE_END
1734 #include <mongocxx/config/postlude.hpp> Top level namespace for the MongoDB C++ driver.
Definition: bulk_write.hpp:24
A read-only BSON document that owns its underlying buffer.
Definition: value.hpp:33
Class representing the optional arguments to a MongoDB query.
Definition: find.hpp:36
A read-only, non-owning view of a BSON document.
Definition: view.hpp:33
Class representing a pointer to the result set of a query on a MongoDB server.
Definition: cursor.hpp:36
Class representing the optional arguments to a MongoDB distinct command.
Definition: distinct.hpp:34
Class representing the optional arguments to a MongoDB bulk write.
Definition: bulk_write.hpp:29
Class representing the optional arguments to a MongoDB insert operation.
Definition: insert.hpp:31
Use a session for a sequence of operations, optionally with causal consistency.
Definition: client_session.hpp:38
Class representing a MongoDB database.
Definition: database.hpp:47
stdx::optional< result::bulk_write > write(const model::write &write, const options::bulk_write &options=options::bulk_write())
Sends a write to the server as a bulk write operation.
Definition: collection.hpp:1640
Class representing the optional arguments to a MongoDB update operation.
Definition: update.hpp:32
Class representing a batch of write operations that can be sent to the server as a group...
Definition: bulk_write.hpp:43
Definition: change_stream.hpp:29
Class representing the optional arguments to a MongoDB delete operation.
Definition: delete.hpp:30
A traditional builder-style interface for constructing a BSON array.
Definition: array.hpp:35
Class representing a MongoDB aggregation pipeline.
Definition: pipeline.hpp:35
bulk_write & append(const model::write &operation)
Appends a single write to the bulk write operation.
Class representing a preference for how the driver routes read operations to members of a replica set...
Definition: read_preference.hpp:57
Class representing the optional arguments to a MongoDB aggregation operation.
Definition: aggregate.hpp:36
Definition: change_stream.hpp:29
Class representing a view-or-value variant type for strings.
Definition: view_or_value.hpp:36
Models a single write operation within a .
Definition: write.hpp:37
stdx::optional< result::bulk_write > execute() const
Executes a bulk write.
Definition: index_view.hpp:32
Class representing optional arguments to IndexView operations.
Definition: index_view.hpp:31
A class to represent the read concern.
Definition: read_concern.hpp:52
Class representing the optional arguments to a MongoDB find_and_modify replace operation.
Definition: find_one_and_replace.hpp:35
stdx::optional< result::insert_many > insert_many(const container_type &container, const options::insert &options=options::insert())
Inserts multiple documents into the collection.
Definition: collection.hpp:1686
Class representing the optional arguments to a MongoDB find_and_modify delete operation.
Definition: find_one_and_delete.hpp:33
Class representing the server-side requirement for reporting the success of a write operation...
Definition: write_concern.hpp:55
Class representing the optional arguments to a MongoDB count command.
Definition: count.hpp:36
Class representing the optional arguments to a MongoDB find_and_modify update operation.
Definition: find_one_and_update.hpp:36
Class representing server side document groupings within a MongoDB database.
Definition: collection.hpp:87