Function command_validate

pg_documentdb/src/commands/validate.c:86–195

* command_validate is the implementation of the internal logic for * 'validate' database diagnostic command. */

 * 'validate' database diagnostic command.
 */
Datum
command_validate(PG_FUNCTION_ARGS)
{
	ValidateSpec validateSpec = { 0 };

	if (PG_ARGISNULL(1))
	{
		ereport(ERROR, (errmsg("The provided namespace value is not valid.")));
	}

	pgbson *validationBsonSpec = PG_GETARG_PGBSON(1);
	Datum databaseNameDatum = PG_ARGISNULL(0) ? (Datum) 0 : PG_GETARG_DATUM(0);

	bson_iter_t validateIter;
	PgbsonInitIterator(validationBsonSpec, &validateIter);

	while (bson_iter_next(&validateIter))
	{
		StringView keyView = bson_iter_key_string_view(&validateIter);
		const bson_value_t *value = bson_iter_value(&validateIter);

		if (StringViewEqualsCString(&keyView, "validate"))
		{
			if (bson_iter_type(&validateIter) == BSON_TYPE_DOCUMENT)
			{
				ereport(ERROR, (errcode(ERRCODE_DOCUMENTDB_INVALIDNAMESPACE),
								errmsg(
									"Collection name contains an invalid object type")));
			}
			EnsureTopLevelFieldType("validate", &validateIter, BSON_TYPE_UTF8);
			validateSpec.collectionName = value->value.v_utf8.str;
		}
		else if (StringViewEqualsCString(&keyView, "$db"))
		{
			ValidateOrExtractDatabaseNameFromSpec(&validateIter, &databaseNameDatum);
		}
		else if (StringViewEqualsCString(&keyView, "full"))
		{
			validateSpec.full = BsonValueAsBool(value);
		}
		else if (StringViewEqualsCString(&keyView, "repair"))
		{
			validateSpec.repair = BsonValueAsBool(value);
		}
		else if (StringViewEqualsCString(&keyView, "metadata"))
		{
			validateSpec.metadata = BsonValueAsBool(value);
		}
	}

	if (databaseNameDatum == (Datum) 0)
	{
		ereport(ERROR, (errmsg("Database name must not be NULL")));
	}
	validateSpec.databaseName = TextDatumGetCString(databaseNameDatum);

	if (validateSpec.collectionName == NULL || strlen(validateSpec.collectionName) == 0)
	{