phabricator/src/applications/files/storage/PhabricatorFileStorageBlob.php

<?php

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

}