PhabricatorFileStorageBlob.php
No OneTemporary
Actions

Subscribers

None

File Metadata

	<?php

	/**
	* Simple blob store DAO for @{class:PhabricatorMySQLFileStorageEngine}.
	*
	* @group file
	*/
	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;

	private $fullData;

	protected function willWriteData(array &$data) {
	parent::willWriteData($data);

	$this->fullData = $data['data'];
	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();
	}

	}