Function command_update_bulk

pg_documentdb/src/commands/update.c:413–459

* A wire protocol bulk update on a collection (non-transactional) * this is same as command_update but using procedure */

 * this is same as command_update but using procedure
 */
Datum
command_update_bulk(PG_FUNCTION_ARGS)
{
	if (PG_ARGISNULL(1))
	{
		ereport(ERROR, (errmsg("update document cannot be NULL")));
	}

	Datum databaseNameDatum = PG_ARGISNULL(0) ? (Datum) 0 : PG_GETARG_DATUM(0);
	pgbson *updateSpec = PG_GETARG_PGBSON(1);
	pgbsonsequence *updateDocs = PG_GETARG_MAYBE_NULL_PGBSON_SEQUENCE(2);

	text *transactionId = NULL;
	if (!PG_ARGISNULL(3))
	{
		transactionId = PG_GETARG_TEXT_P(3);
	}

	bool isTopLevel = true;
	if (IsInTransactionBlock(isTopLevel))
	{
		ereport(ERROR, (errcode(ERRCODE_DOCUMENTDB_OPERATIONNOTSUPPORTEDINTRANSACTION),
						errmsg("the bulk update procedure cannot be used in transactions."
							   " Please use the update function instead")));
	}

	ReportFeatureUsage(FEATURE_COMMAND_UPDATE_BULK);

	/* fetch TupleDesc for return value, not interested in resultTypeId */
	Oid *resultTypeId = NULL;
	TupleDesc resultTupDesc;
	TypeFuncClass resultTypeClass =
		get_call_result_type(fcinfo, resultTypeId, &resultTupDesc);

	if (resultTypeClass != TYPEFUNC_COMPOSITE)
	{
		ereport(ERROR, (errmsg("return type must be a row type")));
	}

	/* For results we need a stable memory context across transactions */
	MemoryContext stableContext = fcinfo->flinfo->fn_mcxt;

	HeapTuple resultTuple = PerformUpdateCore(&databaseNameDatum, updateSpec, updateDocs,
											  transactionId, resultTupDesc,
											  WriteMode_Bulk_Proc, stableContext);
	PG_RETURN_DATUM(HeapTupleGetDatum(resultTuple));
}


/*