Function UpdateOne

pg_documentdb/src/commands/update.c:2220–2250

* UpdateOne is the top-level function for updates with multi:false. It internally * calls ApiInternalSchemaName.update_one(..) to perform an update or delete of a single * row on a specific shard. If update_one returns a reinsert flag, which indicates * a change of shard_key_value, it additionally reinserts the document. */

 * a change of shard_key_value, it additionally reinserts the document.
 */
void
UpdateOne(MongoCollection *collection, UpdateOneParams *updateOneParams,
		  int64 shardKeyHash, text *transactionId, UpdateOneResult *result,
		  bool forceInlineWrites, ExprEvalState *stateForSchemaValidation)
{
	CallUpdateOne(collection, updateOneParams, shardKeyHash, transactionId, result,
				  forceInlineWrites, stateForSchemaValidation);

	/* check for shard key value changes */
	if (result->reinsertDocument)
	{
		/* compute new shard key hash */
		int64 newShardKeyHash =
			ComputeShardKeyHashForDocument(collection->shardKey, collection->collectionId,
										   result->reinsertDocument);

		/* extract object ID */
		pgbson *objectId = PgbsonGetDocumentId(result->reinsertDocument);

		/* If we have to reinsert the document in a different shard */
		bool queryHasNonIdFilters = false;
		bool isIdFilterCollationAwareIgnore = false;
		pgbson *objectIdFilter = GetObjectIdFilterFromQueryDocumentValue(
			updateOneParams->query, &queryHasNonIdFilters,
			&isIdFilterCollationAwareIgnore);
		bool hasOnlyObjectIdFilter = objectIdFilter != NULL && !queryHasNonIdFilters;

		DoInsertForUpdate(collection, newShardKeyHash, objectId, result->reinsertDocument,
						  hasOnlyObjectIdFilter, updateOneParams->update);
	}
}


static void