Function UpsertDocument

pg_documentdb/src/commands/update.c:3897–3928

* UpsertDocument performs an insert when an update did not match any rows * and returns the inserted object ID. */

 * and returns the inserted object ID.
 */
static pgbson *
UpsertDocument(MongoCollection *collection, const bson_value_t *update,
			   const bson_value_t *query, const bson_value_t *arrayFilters,
			   ExprEvalState *stateForSchemaValidation,
			   bool hasOnlyObjectIdFilter, const bson_value_t *variableSpec)
{
	pgbson *emptyDocument = PgbsonInitEmpty();

	/*
	 * Perform regular bson update document because this is an upsert case without
	 * update change tracking
	 */
	pgbson *newDoc = BsonUpdateDocument(emptyDocument, update, query, arrayFilters,
										variableSpec);

	int64 newShardKeyHash =
		ComputeShardKeyHashForDocument(collection->shardKey, collection->collectionId,
									   newDoc);

	pgbson *objectId = PgbsonGetDocumentId(newDoc);

	if (EnableSchemaValidation && stateForSchemaValidation != NULL)
	{
		bson_value_t newDocValue = ConvertPgbsonToBsonValue(newDoc);
		ValidateSchemaOnDocumentInsert(stateForSchemaValidation, &newDocValue,
									   FAILED_VALIDATION_ERROR_MSG);
	}

	DoInsertForUpdate(collection, newShardKeyHash, objectId, newDoc,
					  hasOnlyObjectIdFilter, update);
	return objectId;
}


/*