PhabricatorFileQuery.php
View Options

	<?php

	final class PhabricatorFileQuery
	extends PhabricatorCursorPagedPolicyAwareQuery {

	private $ids;
	private $phids;
	private $authorPHIDs;
	private $explicitUploads;
	private $transforms;

	public function withIDs(array $ids) {
	$this->ids = $ids;
	return $this;
	}

	public function withPHIDs(array $phids) {
	$this->phids = $phids;
	return $this;
	}

	public function withAuthorPHIDs(array $phids) {
	$this->authorPHIDs = $phids;
	return $this;
	}

	public function withTransforms(array $specs) {
	foreach ($specs as $spec) {
	if (!is_array($spec) \|\|
	empty($spec['originalPHID']) \|\|
	empty($spec['transform'])) {
	throw new Exception(
	"Transform specification must be a dictionary with keys ".
	"'originalPHID' and 'transform'!");
	}
	}

	$this->transforms = $specs;
	return $this;
	}

	public function showOnlyExplicitUploads($explicit_uploads) {
	$this->explicitUploads = $explicit_uploads;
	return $this;
	}

	protected function loadPage() {
	$table = new PhabricatorFile();
	$conn_r = $table->establishConnection('r');

	$data = queryfx_all(
	$conn_r,
	'SELECT * FROM %T f %Q %Q %Q %Q',
	$table->getTableName(),
	$this->buildJoinClause($conn_r),
	$this->buildWhereClause($conn_r),
	$this->buildOrderClause($conn_r),
	$this->buildLimitClause($conn_r));

	return $table->loadAllFromArray($data);
	}

	private function buildJoinClause(AphrontDatabaseConnection $conn_r) {
	$joins = array();

	if ($this->transforms) {
	$joins[] = qsprintf(
	$conn_r,
	'JOIN %T t ON t.transformedPHID = f.phid',
	id(new PhabricatorTransformedFile())->getTableName());
	}

	return implode(' ', $joins);
	}

	private function buildWhereClause(AphrontDatabaseConnection $conn_r) {
	$where = array();

	$where[] = $this->buildPagingClause($conn_r);

	if ($this->ids) {
	$where[] = qsprintf(
	$conn_r,
	'f.id IN (%Ld)',
	$this->ids);
	}

	if ($this->phids) {
	$where[] = qsprintf(
	$conn_r,
	'f.phid IN (%Ls)',
	$this->phids);
	}

	if ($this->authorPHIDs) {
	$where[] = qsprintf(
	$conn_r,
	'f.authorPHID IN (%Ls)',
	$this->authorPHIDs);
	}

	if ($this->explicitUploads) {
	$where[] = qsprintf(
	$conn_r,
	'f.isExplicitUpload = true');
	}

	if ($this->transforms) {
	$clauses = array();
	foreach ($this->transforms as $transform) {
	$clauses[] = qsprintf(
	$conn_r,
	'(t.originalPHID = %s AND t.transform = %s)',
	$transform['originalPHID'],
	$transform['transform']);
	}
	$where[] = qsprintf($conn_r, '(%Q)', implode(') OR (', $clauses));
	}

	return $this->formatWhereClause($where);
	}

	protected function getPagingColumn() {
	return 'f.id';
	}

	}

File Metadata

Mime Type: text/x-php
Expires: Sun, Jan 19, 20:17 (1 w, 5 d ago)
Storage Engine: blob
Storage Format: Raw Data
Storage Handle: 1128374
Default Alt Text: PhabricatorFileQuery.php (2 KB)

PhabricatorFileQuery.php
No OneTemporary
Actions

PhabricatorFileQuery.php
View Options

File Metadata

Event Timeline

PhabricatorFileQuery.phpNo OneTemporaryActions

PhabricatorFileQuery.phpView Options

File Metadata

Event Timeline

PhabricatorFileQuery.php
No OneTemporary
Actions

PhabricatorFileQuery.php
View Options