Function DetectMongoCollection

pg_documentdb/src/commands/current_op.c:1141–1177

* Looks at the "raw" Mongo collection and extracts the * actual Mongo database/collection. */

 * actual Mongo database/collection.
 */
static void
DetectMongoCollection(SingleWorkerActivity *activity)
{
	activity->processedMongoDatabase = "";
	activity->processedMongoCollection = "";
	if (activity->rawMongoTable == NULL &&
		(strstr(activity->query, "CREATE INDEX") != NULL))
	{
		/* Get Index Spec for sharded create index query, for this activity->rawMongoTable could be null */
		IndexSpec *spec = GetIndexSpecForShardedCreateIndexQuery(activity);
		if (spec != NULL)
		{
			activity->indexSpec = spec;
		}
	}

	/* No raw collection found */
	if (activity->rawMongoTable == NULL ||
		strlen(activity->rawMongoTable) < 11 ||
		strncmp(activity->rawMongoTable, "documents_", 10) != 0)
	{
		return;
	}

	uint64 collectionId = (uint64) atoll(&activity->rawMongoTable[10]);
	if (collectionId == 0)
	{
		return;
	}

	const MongoCollection *collection = GetMongoCollectionByColId(collectionId, NoLock);
	if (collection != NULL)
	{
		activity->processedMongoDatabase = collection->name.databaseName;
		activity->processedMongoCollection = collection->name.collectionName;
	}
}


/*