(An Untitled Masterwork)
ActivePublic
Actions

Authored by Tarrow on Mar 28 2021, 9:12 PM.

Tags

None

Referenced Files

	F34195019: raw-paste-data.txt
	Mar 28 2021, 9:12 PM

Subscribers

None

	diff --git a/includes/Storage/SqlBlobStore.php b/includes/Storage/SqlBlobStore.php
	index d865cfda32..0b14b4eb39 100644
	--- a/includes/Storage/SqlBlobStore.php
	+++ b/includes/Storage/SqlBlobStore.php
	@@ -35,6 +35,7 @@ use InvalidArgumentException;
	use MWException;
	use StatusValue;
	use WANObjectCache;
	+use Wikibase\Repo\WikibaseRepo;
	use Wikimedia\Assert\Assert;
	use Wikimedia\AtEase\AtEase;
	use Wikimedia\Rdbms\IDatabase;
	@@ -224,6 +225,13 @@ class SqlBlobStore implements IDBAccessObject, BlobStore {
	try {
	$flags = $this->compressData( $data );

	+ if ( $hints[BlobStore::MODEL_HINT] === "wikibase-item" ) {
	+ $mongoEntityCollection = WikibaseRepo::getDefaultInstance()->getMongoEntityCollection();
	+ $insertOneResult = $mongoEntityCollection->insertOne(
	+ json_decode($data, true)
	+ );
	+ return "mongo:" . $insertOneResult->getInsertedId();
	+ }
	# Write to external storage if required
	if ( $this->useExternalStore ) {
	// Store and get the URL
	@@ -374,6 +382,8 @@ class SqlBlobStore implements IDBAccessObject, BlobStore {
	}

	$textIdToBlobAddress[$textId] = $blobAddress;
	+ } elseif ( $schema === 'mongo' ) {
	+ $textIdToBlobAddress[$id] = $blobAddress;
	} else {
	$errors[$blobAddress] = "Unknown blob address schema: $schema."
	. ' Use findBadBlobs.php to remedy.';
	@@ -386,6 +396,11 @@ class SqlBlobStore implements IDBAccessObject, BlobStore {
	if ( !$textIds ) {
	return [ $result, $errors ];
	}
	+
	+ if ( $schema === 'mongo' ) {
	+
	+ }
	+
	// Callers doing updates will pass in READ_LATEST as usual. Since the text/blob tables
	// do not normally get rows changed around, set READ_LATEST_IMMUTABLE in those cases.
	$queryFlags \|= DBAccessObjectUtils::hasFlags( $queryFlags, self::READ_LATEST )

Event Timeline

Tarrow created this paste.Mar 28 2021, 9:12 PM

(An Untitled Masterwork)ActivePublicActions

Event Timeline

(An Untitled Masterwork)
ActivePublic
Actions