mirror of
https://we.phorge.it/source/phorge.git
synced 2024-11-24 15:52:41 +01:00
f5580c7a08
Summary: Ref T4100. Ref T5595. To support a unified "Projects:" query across all applications, a future diff is going to add a set of "Edge Logic" capabilities to `PolicyAwareQuery` which write the required SELECT, JOIN, WHERE, HAVING and GROUP clauses for you. With the addition of "Edge Logic", we'll have three systems which may need to build components of query claues: ordering/paging, customfields/applicationsearch, and edge logic. For most clauses, queries don't currently call into the parent explicitly to get default components. I want to move more query construction logic up the class tree so it can be shared. For most methods, this isn't a problem, but many subclasses define a `buildWhereClause()`. Make all such definitions protected and consistent. This causes no behavioral changes. Test Plan: Ran `arc unit --everything`, which does a pretty through job of verifying this statically. Reviewers: btrahan Reviewed By: btrahan Subscribers: yelirekim, hach-que, epriestley Maniphest Tasks: T4100, T5595 Differential Revision: https://secure.phabricator.com/D12453
128 lines
3.4 KiB
PHP
128 lines
3.4 KiB
PHP
<?php
|
|
|
|
/**
|
|
* Query class that answers these questions:
|
|
*
|
|
* - Q: What are the conpherences to show when I land on /conpherence/ ?
|
|
* - A:
|
|
*
|
|
* id(new ConpherenceParticipantQuery())
|
|
* ->withParticipantPHIDs(array($my_phid))
|
|
* ->execute();
|
|
*
|
|
* - Q: What are the next set of conpherences as I scroll up (more recent) or
|
|
* down (less recent) this list of conpherences?
|
|
* - A:
|
|
*
|
|
* id(new ConpherenceParticipantQuery())
|
|
* ->withParticipantPHIDs(array($my_phid))
|
|
* ->withParticipantCursor($top_participant)
|
|
* ->setOrder(ConpherenceParticipantQuery::ORDER_NEWER)
|
|
* ->execute();
|
|
*
|
|
* -or-
|
|
*
|
|
* id(new ConpherenceParticipantQuery())
|
|
* ->withParticipantPHIDs(array($my_phid))
|
|
* ->withParticipantCursor($bottom_participant)
|
|
* ->setOrder(ConpherenceParticipantQuery::ORDER_OLDER)
|
|
* ->execute();
|
|
*
|
|
* For counts of read, un-read, or all conpherences by participant, see
|
|
* @{class:ConpherenceParticipantCountQuery}.
|
|
*/
|
|
final class ConpherenceParticipantQuery extends PhabricatorOffsetPagedQuery {
|
|
|
|
const LIMIT = 100;
|
|
const ORDER_NEWER = 'newer';
|
|
const ORDER_OLDER = 'older';
|
|
|
|
private $participantPHIDs;
|
|
private $participantCursor;
|
|
private $order = self::ORDER_OLDER;
|
|
|
|
public function withParticipantPHIDs(array $phids) {
|
|
$this->participantPHIDs = $phids;
|
|
return $this;
|
|
}
|
|
|
|
public function withParticipantCursor(ConpherenceParticipant $participant) {
|
|
$this->participantCursor = $participant;
|
|
return $this;
|
|
}
|
|
|
|
public function setOrder($order) {
|
|
$this->order = $order;
|
|
return $this;
|
|
}
|
|
|
|
public function execute() {
|
|
$table = new ConpherenceParticipant();
|
|
$conn_r = $table->establishConnection('r');
|
|
|
|
$data = queryfx_all(
|
|
$conn_r,
|
|
'SELECT * FROM %T participant %Q %Q %Q',
|
|
$table->getTableName(),
|
|
$this->buildWhereClause($conn_r),
|
|
$this->buildOrderClause($conn_r),
|
|
$this->buildLimitClause($conn_r));
|
|
|
|
$participants = $table->loadAllFromArray($data);
|
|
|
|
$participants = mpull($participants, null, 'getConpherencePHID');
|
|
|
|
if ($this->order == self::ORDER_NEWER) {
|
|
$participants = array_reverse($participants);
|
|
}
|
|
|
|
return $participants;
|
|
}
|
|
|
|
protected function buildWhereClause(AphrontDatabaseConnection $conn_r) {
|
|
$where = array();
|
|
|
|
if ($this->participantPHIDs) {
|
|
$where[] = qsprintf(
|
|
$conn_r,
|
|
'participantPHID IN (%Ls)',
|
|
$this->participantPHIDs);
|
|
}
|
|
|
|
if ($this->participantCursor) {
|
|
$date_touched = $this->participantCursor->getDateTouched();
|
|
$id = $this->participantCursor->getID();
|
|
if ($this->order == self::ORDER_OLDER) {
|
|
$compare_date = '<';
|
|
$compare_id = '<=';
|
|
} else {
|
|
$compare_date = '>';
|
|
$compare_id = '>=';
|
|
}
|
|
$where[] = qsprintf(
|
|
$conn_r,
|
|
'(dateTouched %Q %d OR (dateTouched = %d AND id %Q %d))',
|
|
$compare_date,
|
|
$date_touched,
|
|
$date_touched,
|
|
$compare_id,
|
|
$id);
|
|
}
|
|
|
|
return $this->formatWhereClause($where);
|
|
}
|
|
|
|
private function buildOrderClause(AphrontDatabaseConnection $conn_r) {
|
|
$order_word = ($this->order == self::ORDER_OLDER) ? 'DESC' : 'ASC';
|
|
// if these are different direction we won't get as efficient a query
|
|
// see http://dev.mysql.com/doc/refman/5.5/en/order-by-optimization.html
|
|
$order = qsprintf(
|
|
$conn_r,
|
|
'ORDER BY dateTouched %Q, id %Q',
|
|
$order_word,
|
|
$order_word);
|
|
|
|
return $order;
|
|
}
|
|
|
|
}
|