Differential D8316 Diff 19768 src/applications/files/storage/PhabricatorFileStorageBlob.php

Changeset View

Standalone View

	<?php			<?php

	/**			/**
	* Simple blob store DAO for @{class:PhabricatorMySQLFileStorageEngine}.			* Simple blob store DAO for @{class:PhabricatorMySQLFileStorageEngine}.
	*
	* @group file
	*/			*/
	final class PhabricatorFileStorageBlob extends PhabricatorFileDAO {			final class PhabricatorFileStorageBlob extends PhabricatorFileDAO {
	// max_allowed_packet defaults to 1 MiB, escaping can make the data twice
	// longer, query fits in the rest.
	const CHUNK_SIZE = 5e5;

	protected $data;			protected $data;

	private $fullData;			public function getConfiguration() {
				return array(
	protected function willWriteData(array &$data) {			self::CONFIG_BINARY => array(
	parent::willWriteData($data);			'data' => true,
				),
	$this->fullData = $data['data'];			) + parent::getConfiguration();
	if (strlen($data['data']) > self::CHUNK_SIZE) {
	$data['data'] = substr($data['data'], 0, self::CHUNK_SIZE);
	$this->openTransaction();
	}
	}

	protected function didWriteData() {
	$size = self::CHUNK_SIZE;
	$length = strlen($this->fullData);
	if ($length > $size) {
	$conn = $this->establishConnection('w');
	for ($offset = $size; $offset < $length; $offset += $size) {
	queryfx(
	$conn,
	'UPDATE %T SET data = CONCAT(data, %s) WHERE %C = %d',
	$this->getTableName(),
	substr($this->fullData, $offset, $size),
	$this->getIDKeyForUse(),
	$this->getID());
	}
	$this->saveTransaction();
	}

	parent::didWriteData();
	epriestleyAuthorUnsubmitted Not Done Inline Actions This never worked, see discussion in D3392. epriestley: This never worked, see discussion in D3392.
	}			}

	}			}