BulkWriteResult.h

Go to the documentation of this file.

 
#pragma once
#include <mongocxx/result/bulk_write.hpp>
 
namespace catapult { namespace mongo {
 
    struct BulkWriteResult {
    public:
        BulkWriteResult()
                : NumInserted(0)
                , NumMatched(0)
                , NumModified(0)
                , NumDeleted(0)
                , NumUpserted(0)
        {}
 
        explicit BulkWriteResult(const mongocxx::result::bulk_write& result)
                : NumInserted(result.inserted_count())
                , NumMatched(result.matched_count())
                , NumModified(result.modified_count())
                , NumDeleted(result.deleted_count())
                , NumUpserted(result.upserted_count())
        {}
 
    public:
        static BulkWriteResult Aggregate(const std::vector<BulkWriteResult>& results) {
            BulkWriteResult aggregate;
            for (const auto& result : results) {
                aggregate.NumInserted += result.NumInserted;
                aggregate.NumMatched += result.NumMatched;
                aggregate.NumModified += result.NumModified;
                aggregate.NumDeleted += result.NumDeleted;
                aggregate.NumUpserted += result.NumUpserted;
            }
 
            return aggregate;
        }
 
    public:
        int32_t NumInserted;
 
        int32_t NumMatched;
 
        int32_t NumModified;
 
        int32_t NumDeleted;
 
        int32_t NumUpserted;
    };
}}