Class ExtOperatorUpsert

src/ExtMsg.actor.cpp:1395–1423

};

struct ExtOperatorUpsert : ConcreteInsertOp<ExtOperatorUpsert> {
	bson::BSONObj selector;
	bson::BSONObj update;

	ExtOperatorUpsert(bson::BSONObj selector, bson::BSONObj update) : selector(selector), update(update) {}

	ACTOR static Future<Reference<IReadWriteContext>> upsertActor(ExtOperatorUpsert* self,
	                                                              Reference<CollectionContext> cx) {
		Optional<IdInfo> encodedIds = extractEncodedIds(self->selector);
		if (!encodedIds.present())
			encodedIds = extractEncodedIdsFromUpdate(self->update);
		int selectorOperators = hasOperatorFieldnames(self->selector, -1, 0);
		bson::BSONObj thingToInsert;
		if (!selectorOperators) {
			thingToInsert = self->selector;
		} else {
			thingToInsert = transformOperatorQueryToUpdatableDocument(self->selector);
		}
		state Reference<IReadWriteContext> dcx = wait(insertDocument(cx, thingToInsert, encodedIds));
		wait(updateDocument(dcx, self->update, true, dcx->getKeyEncodedId()));
		return dcx;
	}

	Future<Reference<IReadWriteContext>> insert(Reference<CollectionContext> cx) override {
		return upsertActor(this, cx);
	}

	std::string describe() override { return "OperatorUpsert(" + selector.toString() + "," + update.toString() + ")"; }
};

struct ExtSimpleUpsert : ConcreteInsertOp<ExtSimpleUpsert> {
	bson::BSONObj selector;