Function DoSingleUpdate

pg_documentdb/src/commands/update.c:1282–1328

* Updates a single update and rollback on failures. * Applicable only for update invoked via a procedure. */

 * Applicable only for update invoked via a procedure.
 */
static bool
DoSingleUpdate(MongoCollection *collection, UpdateSpec *updateSpec, text *transactionId,
			   BatchUpdateResult *batchResult, int updateIndex, bool forceInlineWrites,
			   ExprEvalState *volatile stateForSchemaValidation)
{
	/* declared volatile because of the longjmp in PG_CATCH */
	volatile bool isSuccess = false;

	UpdateResult updateResult;
	memset(&updateResult, 0, sizeof(updateResult));

	PG_TRY();
	{
		ProcessUpdate(collection, updateSpec, transactionId, &updateResult,
					  forceInlineWrites, stateForSchemaValidation);
		UpdateResultInBatch(batchResult, &updateResult,
							batchResult->resultMemoryContext, updateIndex);
		isSuccess = true;
	}
	PG_CATCH();
	{
		MemoryContext oldContext = MemoryContextSwitchTo(
			batchResult->resultMemoryContext);
		ErrorData *errorData = CopyErrorDataAndFlush();
		MemoryContextSwitchTo(oldContext);

		if (IsOperatorInterventionError(errorData))
		{
			ReThrowError(errorData);
		}

		PopAllActiveSnapshots();
		AbortCurrentTransaction();
		StartTransactionCommand();

		oldContext = MemoryContextSwitchTo(batchResult->resultMemoryContext);
		batchResult->writeErrors = lappend(batchResult->writeErrors,
										   GetWriteErrorFromErrorData(errorData,
																	  updateIndex));
		MemoryContextSwitchTo(oldContext);
		FreeErrorData(errorData);
		isSuccess = false;
	}
	PG_END_TRY();

	return isSuccess;
}


/*