mirror of
https://github.com/Universal-Omega/DynamicPageList3
synced 2024-11-27 17:40:13 +00:00
d7336b1a67
Also adds a PHPUnit tests for the notuses parameter.
2296 lines
57 KiB
PHP
2296 lines
57 KiB
PHP
<?php
|
|
|
|
namespace MediaWiki\Extension\DynamicPageList3;
|
|
|
|
use DateInterval;
|
|
use DateTime;
|
|
use Exception;
|
|
use ExtensionRegistry;
|
|
use MediaWiki\MediaWikiServices;
|
|
use MediaWiki\User\UserFactory;
|
|
use MWException;
|
|
use PoolCounterWorkViaCallback;
|
|
use WANObjectCache;
|
|
use WikiMap;
|
|
use Wikimedia\Rdbms\Database;
|
|
use Wikimedia\Rdbms\IDatabase;
|
|
|
|
class Query {
|
|
/**
|
|
* Parameters Object
|
|
*
|
|
* @var Parameters
|
|
*/
|
|
private $parameters;
|
|
|
|
/**
|
|
* Mediawiki DB Object
|
|
*
|
|
* @var IDatabase
|
|
*/
|
|
private $dbr;
|
|
|
|
/**
|
|
* Array of prefixed and escaped table names.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $tableNames = [];
|
|
|
|
/**
|
|
* Parameters that have already been processed.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $parametersProcessed = [];
|
|
|
|
/**
|
|
* Select Fields
|
|
*
|
|
* @var array
|
|
*/
|
|
private $select = [];
|
|
|
|
/**
|
|
* The generated SQL Query.
|
|
*
|
|
* @var string
|
|
*/
|
|
private $sqlQuery = '';
|
|
|
|
/**
|
|
* Selected Fields - An array to look up keys against for speed optimization.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $selectedFields = [];
|
|
|
|
/**
|
|
* Prefixed and escaped table names.
|
|
*
|
|
* @var array
|
|
*/
|
|
private $tables = [];
|
|
|
|
/**
|
|
* Where Clauses
|
|
*
|
|
* @var array
|
|
*/
|
|
private $where = [];
|
|
|
|
/**
|
|
* Group By Clauses
|
|
*
|
|
* @var array
|
|
*/
|
|
private $groupBy = [];
|
|
|
|
/**
|
|
* Order By Clauses
|
|
*
|
|
* @var array
|
|
*/
|
|
private $orderBy = [];
|
|
|
|
/**
|
|
* Join Clauses
|
|
*
|
|
* @var array
|
|
*/
|
|
private $join = [];
|
|
|
|
/**
|
|
* Limit
|
|
*
|
|
* @var int|bool
|
|
*/
|
|
private $limit = false;
|
|
|
|
/**
|
|
* Offset
|
|
*
|
|
* @var int|bool
|
|
*/
|
|
private $offset = false;
|
|
|
|
/**
|
|
* Order By Direction
|
|
*
|
|
* @var string
|
|
*/
|
|
private $direction = 'ASC';
|
|
|
|
/**
|
|
* Distinct Results
|
|
*
|
|
* @var bool
|
|
*/
|
|
private $distinct = true;
|
|
|
|
/**
|
|
* Character Set Collation
|
|
*
|
|
* @var string|bool
|
|
*/
|
|
private $collation = false;
|
|
|
|
/**
|
|
* Was the revision auxiliary table select added for firstedit and lastedit?
|
|
*
|
|
* @var bool
|
|
*/
|
|
private $revisionAuxWhereAdded = false;
|
|
|
|
/**
|
|
* UserFactory object
|
|
*
|
|
* @var UserFactory
|
|
*/
|
|
private $userFactory;
|
|
|
|
/**
|
|
* @param Parameters $parameters
|
|
*/
|
|
public function __construct( Parameters $parameters ) {
|
|
$this->parameters = $parameters;
|
|
|
|
$this->tableNames = self::getTableNames();
|
|
|
|
$this->dbr = MediaWikiServices::getInstance()->getDBLoadBalancer()->getConnection( DB_REPLICA, 'dpl' );
|
|
|
|
$this->userFactory = MediaWikiServices::getInstance()->getUserFactory();
|
|
}
|
|
|
|
/**
|
|
* Start a query build. Returns found rows.
|
|
*
|
|
* @param bool $calcRows
|
|
* @param ?int &$foundRows
|
|
* @param string $profilingContext Used to see the origin of a query in the profiling
|
|
* @return array|bool
|
|
*/
|
|
public function buildAndSelect( bool $calcRows = false, ?int &$foundRows = null, $profilingContext = '' ) {
|
|
global $wgNonincludableNamespaces, $wgDebugDumpSql;
|
|
|
|
$options = [];
|
|
|
|
$parameters = $this->parameters->getAllParameters();
|
|
foreach ( $parameters as $parameter => $option ) {
|
|
$function = '_' . $parameter;
|
|
// Some parameters do not modify the query so we check if the function to modify the query exists first.
|
|
$success = true;
|
|
if ( method_exists( $this, $function ) ) {
|
|
$success = $this->$function( $option );
|
|
}
|
|
|
|
if ( $success === false ) {
|
|
throw new MWException( __METHOD__ . ": SQL Build Error returned from {$function} for " . serialize( $option ) . "." );
|
|
}
|
|
|
|
$this->parametersProcessed[$parameter] = true;
|
|
}
|
|
|
|
if ( !$this->parameters->getParameter( 'openreferences' ) ) {
|
|
// Add things that are always part of the query.
|
|
$this->addTable( 'page', $this->tableNames['page'] );
|
|
$this->addSelect(
|
|
[
|
|
'page_namespace' => $this->tableNames['page'] . '.page_namespace',
|
|
'page_id' => $this->tableNames['page'] . '.page_id',
|
|
'page_title' => $this->tableNames['page'] . '.page_title'
|
|
]
|
|
);
|
|
}
|
|
|
|
// Always add nonincludeable namespaces.
|
|
if ( is_array( $wgNonincludableNamespaces ) && count( $wgNonincludableNamespaces ) ) {
|
|
$this->addNotWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_namespace' => $wgNonincludableNamespaces
|
|
]
|
|
);
|
|
}
|
|
|
|
if ( $this->offset !== false ) {
|
|
$options['OFFSET'] = $this->offset;
|
|
}
|
|
|
|
if ( $this->limit !== false ) {
|
|
$options['LIMIT'] = $this->limit;
|
|
} elseif ( $this->offset !== false ) {
|
|
$options['LIMIT'] = $this->parameters->getParameter( 'count' );
|
|
}
|
|
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
if ( count( $this->parameters->getParameter( 'imagecontainer' ) ?? [] ) > 0 ) {
|
|
$this->addSelect(
|
|
[
|
|
'il_to',
|
|
]
|
|
);
|
|
|
|
$tables = [
|
|
'ic' => 'imagelinks'
|
|
];
|
|
} else {
|
|
if ( $this->parameters->getParameter( 'openreferences' ) === 'missing' ) {
|
|
$this->addSelect(
|
|
[
|
|
'page_namespace',
|
|
'page_id',
|
|
'page_title',
|
|
'pl_namespace',
|
|
'pl_title',
|
|
]
|
|
);
|
|
|
|
$this->addWhere(
|
|
[
|
|
'page_namespace' => null,
|
|
]
|
|
);
|
|
|
|
$this->addJoin(
|
|
'page',
|
|
[
|
|
'LEFT JOIN',
|
|
[
|
|
'page_namespace = pl_namespace',
|
|
'page_title = pl_title',
|
|
],
|
|
]
|
|
);
|
|
|
|
$tables = [
|
|
'page',
|
|
'pagelinks',
|
|
];
|
|
} else {
|
|
$this->addSelect(
|
|
[
|
|
'pl_namespace',
|
|
'pl_title',
|
|
]
|
|
);
|
|
|
|
$tables = [
|
|
'pagelinks',
|
|
];
|
|
}
|
|
}
|
|
} else {
|
|
$tables = $this->tables;
|
|
if ( count( $this->groupBy ) ) {
|
|
$options['GROUP BY'] = $this->groupBy;
|
|
}
|
|
if ( count( $this->orderBy ) ) {
|
|
$options['ORDER BY'] = $this->orderBy;
|
|
foreach ( $options['ORDER BY'] as $key => $value ) {
|
|
$options['ORDER BY'][$key] .= ' ' . $this->direction;
|
|
}
|
|
}
|
|
}
|
|
if ( $this->parameters->getParameter( 'goal' ) == 'categories' ) {
|
|
$categoriesGoal = true;
|
|
$fields = [
|
|
$this->tableNames['page'] . '.page_id'
|
|
];
|
|
|
|
$options[] = 'DISTINCT';
|
|
} else {
|
|
if ( $calcRows ) {
|
|
$options[] = 'SQL_CALC_FOUND_ROWS';
|
|
}
|
|
|
|
if ( $this->distinct ) {
|
|
$options[] = 'DISTINCT';
|
|
}
|
|
|
|
$categoriesGoal = false;
|
|
$fields = $this->select;
|
|
}
|
|
|
|
$queryError = false;
|
|
try {
|
|
if ( $categoriesGoal ) {
|
|
$res = $this->dbr->select(
|
|
$tables,
|
|
$fields,
|
|
$this->where,
|
|
__METHOD__,
|
|
$options,
|
|
$this->join
|
|
);
|
|
|
|
$pageIds = [];
|
|
|
|
foreach ( $res as $row ) {
|
|
$pageIds[] = $row->page_id;
|
|
}
|
|
|
|
$query = $this->dbr->selectSQLText(
|
|
[
|
|
'clgoal' => 'categorylinks'
|
|
],
|
|
[
|
|
'clgoal.cl_to'
|
|
],
|
|
[
|
|
'clgoal.cl_from' => $pageIds
|
|
],
|
|
__METHOD__,
|
|
[
|
|
'ORDER BY' => 'clgoal.cl_to ' . $this->direction
|
|
]
|
|
);
|
|
} else {
|
|
$query = $this->dbr->selectSQLText(
|
|
$tables,
|
|
$fields,
|
|
$this->where,
|
|
__METHOD__,
|
|
$options,
|
|
$this->join
|
|
);
|
|
}
|
|
|
|
if ( Hooks::getDebugLevel() >= 4 && $wgDebugDumpSql ) {
|
|
$this->sqlQuery = $query;
|
|
}
|
|
} catch ( Exception $e ) {
|
|
throw new MWException( __METHOD__ . ': ' . wfMessage( 'dpl_query_error', Hooks::getVersion(), $this->dbr->lastError() )->text() );
|
|
}
|
|
|
|
// Partially taken from intersection
|
|
$queryCacheTime = Config::getSetting( 'queryCacheTime' );
|
|
$maxQueryTime = Config::getSetting( 'maxQueryTime' );
|
|
|
|
if ( $maxQueryTime ) {
|
|
$options['MAX_EXECUTION_TIME'] = $maxQueryTime;
|
|
}
|
|
|
|
$qname = __METHOD__;
|
|
if ( !empty( $profilingContext ) ) {
|
|
$qname .= ' - ' . $profilingContext;
|
|
}
|
|
$where = $this->where;
|
|
$join = $this->join;
|
|
$db = $this->dbr;
|
|
|
|
$doQuery = static function () use ( $qname, $db, $tables, $fields, $where, $options, $join, $calcRows, &$foundRows ) {
|
|
$res = $db->select( $tables, $fields, $where, $qname, $options, $join );
|
|
|
|
if ( $calcRows ) {
|
|
$calcRowsResult = $db->query( 'SELECT FOUND_ROWS() AS count;', $qname );
|
|
$total = $calcRowsResult->fetchRow();
|
|
|
|
$foundRows = (int)$total['count'];
|
|
}
|
|
|
|
return iterator_to_array( $res );
|
|
};
|
|
|
|
$poolCounterKey = 'nowait:dpl3-query:' . WikiMap::getCurrentWikiId();
|
|
$worker = new PoolCounterWorkViaCallback( 'DPL3', $poolCounterKey, [
|
|
'doWork' => $doQuery,
|
|
] );
|
|
|
|
if ( $queryCacheTime <= 0 ) {
|
|
return $worker->execute();
|
|
}
|
|
|
|
$cache = MediaWikiServices::getInstance()->getMainWANObjectCache();
|
|
|
|
return $cache->getWithSetCallback(
|
|
$cache->makeKey( 'DPL3Query', hash( 'sha256', $query ) ),
|
|
$queryCacheTime,
|
|
static function ( $oldVal, &$ttl, &$setOpts ) use ( $worker, $db ){
|
|
$setOpts += Database::getCacheSetOptions( $db );
|
|
$res = $worker->execute();
|
|
if ( $res === false ) {
|
|
// Do not cache errors.
|
|
$ttl = WANObjectCache::TTL_UNCACHEABLE;
|
|
// If we have oldVal, prefer it to error
|
|
if ( is_array( $oldVal ) ) {
|
|
return $oldVal;
|
|
}
|
|
}
|
|
return $res;
|
|
},
|
|
[
|
|
'lowTTL' => min( $cache::TTL_MINUTE, floor( $queryCacheTime * 0.75 ) ),
|
|
'pcTTL' => min( $cache::TTL_PROC_LONG, $queryCacheTime )
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Returns the generated SQL Query
|
|
*
|
|
* @return string
|
|
*/
|
|
public function getSqlQuery() {
|
|
return $this->sqlQuery;
|
|
}
|
|
|
|
/**
|
|
* Return prefixed and quoted tables that are needed.
|
|
*
|
|
* @return array
|
|
*/
|
|
public static function getTableNames() {
|
|
$dbr = MediaWikiServices::getInstance()->getDBLoadBalancer()->getConnection( DB_REPLICA, 'dpl' );
|
|
|
|
$tables = [
|
|
'categorylinks',
|
|
'dpl_clview',
|
|
'externallinks',
|
|
'flaggedpages',
|
|
'imagelinks',
|
|
'linktarget',
|
|
'page',
|
|
'pagelinks',
|
|
'recentchanges',
|
|
'revision',
|
|
'templatelinks'
|
|
];
|
|
|
|
$tableNames = [];
|
|
foreach ( $tables as $table ) {
|
|
$tableNames[$table] = $dbr->tableName( $table );
|
|
}
|
|
|
|
return $tableNames;
|
|
}
|
|
|
|
/**
|
|
* Add a table to the output.
|
|
*
|
|
* @param string $table
|
|
* @param string $alias
|
|
* @return bool
|
|
*/
|
|
public function addTable( $table, $alias ) {
|
|
if ( empty( $table ) ) {
|
|
throw new MWException( __METHOD__ . ': An empty table name was passed.' );
|
|
}
|
|
|
|
if ( empty( $alias ) || is_numeric( $alias ) ) {
|
|
throw new MWException( __METHOD__ . ': An empty or numeric table alias was passed.' );
|
|
}
|
|
|
|
if ( !isset( $this->tables[$alias] ) ) {
|
|
$this->tables[$alias] = $this->dbr->tableName( $table );
|
|
|
|
return true;
|
|
} else {
|
|
return false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Add multiple tables to the output.
|
|
*
|
|
* @param array $tablesByAlias [ table => alias ]
|
|
*/
|
|
public function addTables( array $tablesByAlias ) {
|
|
foreach ( $tablesByAlias as $table => $alias ) {
|
|
$this->addTable( $table, $alias );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Add a where clause to the output.
|
|
* Where clauses get imploded together with AND at the end. Any custom where clauses should be preformed before placed into here.
|
|
*
|
|
* @param array|string $where
|
|
* @return bool
|
|
*/
|
|
public function addWhere( $where ) {
|
|
if ( empty( $where ) ) {
|
|
throw new MWException( __METHOD__ . ': An empty where clause was passed.' );
|
|
}
|
|
|
|
if ( is_string( $where ) ) {
|
|
$this->where[] = $where;
|
|
} elseif ( is_array( $where ) ) {
|
|
$this->where = array_merge( $this->where, $where );
|
|
} else {
|
|
throw new MWException( __METHOD__ . ': An invalid where clause was passed.' );
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Add a where clause to the output that uses NOT IN or !=.
|
|
*
|
|
* @param array $where
|
|
* @return bool
|
|
*/
|
|
public function addNotWhere( $where ) {
|
|
if ( empty( $where ) ) {
|
|
throw new MWException( __METHOD__ . ': An empty not where clause was passed.' );
|
|
}
|
|
|
|
if ( is_array( $where ) ) {
|
|
foreach ( $where as $field => $values ) {
|
|
$this->where[] = $field . ( count( $values ) > 1 ? ' NOT IN(' . $this->dbr->makeList( $values ) . ')' : ' != ' . $this->dbr->addQuotes( current( $values ) ) );
|
|
}
|
|
} else {
|
|
throw new MWException( __METHOD__ . ': An invalid NOT WHERE clause was passed.' );
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Add a field to select.
|
|
* Will ignore duplicate values if the exact same alias and exact same field are passed.
|
|
*
|
|
* @param array $fields
|
|
* @return bool
|
|
*/
|
|
public function addSelect( $fields ) {
|
|
if ( !is_array( $fields ) ) {
|
|
throw new MWException( __METHOD__ . ': A non-array was passed.' );
|
|
}
|
|
|
|
foreach ( $fields as $alias => $field ) {
|
|
if ( !is_numeric( $alias ) && array_key_exists( $alias, $this->select ) && $this->select[$alias] != $field ) {
|
|
// In case of a code bug that is overwriting an existing field alias throw an exception.
|
|
throw new MWException( __METHOD__ . ": Attempted to overwrite existing field alias `{$this->select[$alias]}` AS `{$alias}` with `{$field}` AS `{$alias}`." );
|
|
}
|
|
|
|
// String alias and does not exist already.
|
|
if ( !is_numeric( $alias ) && !array_key_exists( $alias, $this->select ) ) {
|
|
$this->select[$alias] = $field;
|
|
}
|
|
|
|
// Speed up by not using in_array() or array_key_exists(). Toss the field names into their own array as keys => true to exploit a speedy look up with isset().
|
|
if ( is_numeric( $alias ) && !isset( $this->selectedFields[$field] ) ) {
|
|
$this->select[] = $field;
|
|
$this->selectedFields[$field] = true;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Add a GROUP BY clause to the output.
|
|
*
|
|
* @param string $groupBy
|
|
* @return bool
|
|
*/
|
|
public function addGroupBy( $groupBy ) {
|
|
if ( empty( $groupBy ) ) {
|
|
throw new MWException( __METHOD__ . ': An empty GROUP BY clause was passed.' );
|
|
}
|
|
|
|
$this->groupBy[] = $groupBy;
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Add a ORDER BY clause to the output.
|
|
*
|
|
* @param string $orderBy
|
|
* @return bool
|
|
*/
|
|
public function addOrderBy( $orderBy ) {
|
|
if ( empty( $orderBy ) ) {
|
|
throw new MWException( __METHOD__ . ': An empty ORDER BY clause was passed.' );
|
|
}
|
|
|
|
$this->orderBy[] = $orderBy;
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Add a JOIN clause to the output.
|
|
*
|
|
* @param string $tableAlias
|
|
* @param array $joinConditions
|
|
* @return bool
|
|
*/
|
|
public function addJoin( $tableAlias, $joinConditions ) {
|
|
if ( empty( $tableAlias ) || empty( $joinConditions ) ) {
|
|
throw new MWException( __METHOD__ . ': An empty JOIN clause was passed.' );
|
|
}
|
|
|
|
if ( isset( $this->join[$tableAlias] ) ) {
|
|
throw new MWException( __METHOD__ . ': Attempted to overwrite existing JOIN clause.' );
|
|
}
|
|
|
|
$this->join[$tableAlias] = $joinConditions;
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* @param array $joins
|
|
*/
|
|
public function addJoins( array $joins ) {
|
|
foreach ( $joins as $alias => $conds ) {
|
|
$this->addJoin( $alias, $conds );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set the limit.
|
|
*
|
|
* @param mixed $limit
|
|
* @return bool
|
|
*/
|
|
public function setLimit( $limit ) {
|
|
if ( is_numeric( $limit ) ) {
|
|
$this->limit = (int)$limit;
|
|
} else {
|
|
$this->limit = false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Set the offset.
|
|
*
|
|
* @param mixed $offset
|
|
* @return bool
|
|
*/
|
|
public function setOffset( $offset ) {
|
|
if ( is_numeric( $offset ) ) {
|
|
$this->offset = (int)$offset;
|
|
} else {
|
|
$this->offset = false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Set the ORDER BY direction
|
|
*
|
|
* @param string $direction
|
|
* @return bool
|
|
*/
|
|
public function setOrderDir( $direction ) {
|
|
$this->direction = $direction;
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Set the character set collation.
|
|
*
|
|
* @param string $collation
|
|
*/
|
|
public function setCollation( $collation ) {
|
|
$this->collation = $collation;
|
|
}
|
|
|
|
/**
|
|
* Return SQL prefixed collation.
|
|
*
|
|
* @return string|null
|
|
*/
|
|
public function getCollateSQL() {
|
|
return ( $this->collation !== false ? 'COLLATE ' . $this->collation : null );
|
|
}
|
|
|
|
/**
|
|
* Recursively get and return an array of subcategories.
|
|
*
|
|
* @param string $categoryName
|
|
* @param int $depth
|
|
* @return array
|
|
*/
|
|
public static function getSubcategories( $categoryName, $depth = 1 ) {
|
|
$dbr = MediaWikiServices::getInstance()->getDBLoadBalancer()->getConnection( DB_REPLICA, 'dpl' );
|
|
|
|
if ( $depth > 2 ) {
|
|
// Hard constrain depth because lots of recursion is bad.
|
|
$depth = 2;
|
|
}
|
|
|
|
$categories = [];
|
|
$res = $dbr->select(
|
|
[ 'page', 'categorylinks' ],
|
|
[ 'page_title' ],
|
|
[
|
|
'page_namespace' => NS_CATEGORY,
|
|
'cl_to' => str_replace( ' ', '_', $categoryName )
|
|
],
|
|
__METHOD__,
|
|
[ 'DISTINCT' ],
|
|
[
|
|
'categorylinks' => [
|
|
'INNER JOIN',
|
|
'page_id = cl_from'
|
|
]
|
|
]
|
|
);
|
|
|
|
foreach ( $res as $row ) {
|
|
$categories[] = $row->page_title;
|
|
if ( $depth > 1 ) {
|
|
$categories = array_merge( $categories, self::getSubcategories( $row->page_title, $depth - 1 ) );
|
|
}
|
|
}
|
|
|
|
$categories = array_unique( $categories );
|
|
$res->free();
|
|
|
|
return $categories;
|
|
}
|
|
|
|
/**
|
|
* Helper method to handle relative timestamps.
|
|
*
|
|
* @param mixed $inputDate
|
|
* @return int|string
|
|
*/
|
|
private function convertTimestamp( $inputDate ) {
|
|
$timestamp = $inputDate;
|
|
switch ( $inputDate ) {
|
|
case 'today':
|
|
$timestamp = date( 'YmdHis' );
|
|
break;
|
|
case 'last hour':
|
|
$date = new DateTime();
|
|
$date->sub( new DateInterval( 'P1H' ) );
|
|
$timestamp = $date->format( 'YmdHis' );
|
|
break;
|
|
case 'last day':
|
|
$date = new DateTime();
|
|
$date->sub( new DateInterval( 'P1D' ) );
|
|
$timestamp = $date->format( 'YmdHis' );
|
|
break;
|
|
case 'last week':
|
|
$date = new DateTime();
|
|
$date->sub( new DateInterval( 'P7D' ) );
|
|
$timestamp = $date->format( 'YmdHis' );
|
|
break;
|
|
case 'last month':
|
|
$date = new DateTime();
|
|
$date->sub( new DateInterval( 'P1M' ) );
|
|
$timestamp = $date->format( 'YmdHis' );
|
|
break;
|
|
case 'last year':
|
|
$date = new DateTime();
|
|
$date->sub( new DateInterval( 'P1Y' ) );
|
|
$timestamp = $date->format( 'YmdHis' );
|
|
break;
|
|
}
|
|
|
|
if ( is_numeric( $timestamp ) ) {
|
|
return $this->dbr->addQuotes( $timestamp );
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addauthor' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addauthor( $option ) {
|
|
// Addauthor can not be used with addlasteditor.
|
|
if ( !isset( $this->parametersProcessed['addlasteditor'] ) || !$this->parametersProcessed['addlasteditor'] ) {
|
|
$this->addTable( 'revision', 'rev' );
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp = (SELECT MIN(rev_aux_min.rev_timestamp) FROM ' . $this->tableNames['revision'] . ' AS rev_aux_min WHERE rev_aux_min.rev_page = rev.rev_page)'
|
|
]
|
|
);
|
|
|
|
$this->_adduser( null, 'rev' );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addcategories' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addcategories( $option ) {
|
|
$this->addTable( 'categorylinks', 'cl_gc' );
|
|
$this->addSelect(
|
|
[
|
|
'cats' => "GROUP_CONCAT(DISTINCT cl_gc.cl_to ORDER BY cl_gc.cl_to ASC SEPARATOR ' | ')"
|
|
]
|
|
);
|
|
|
|
$this->addJoin(
|
|
'cl_gc',
|
|
[
|
|
'LEFT OUTER JOIN',
|
|
'page_id = cl_gc.cl_from'
|
|
]
|
|
);
|
|
|
|
$this->addGroupBy( $this->tableNames['page'] . '.page_id' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addcontribution' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addcontribution( $option ) {
|
|
$this->addTable( 'recentchanges', 'rc' );
|
|
|
|
$this->addSelect(
|
|
[
|
|
'contribution' => 'SUM(ABS(rc.rc_new_len - rc.rc_old_len))',
|
|
'contributor' => 'rc.rc_actor'
|
|
]
|
|
);
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rc.rc_cur_id'
|
|
]
|
|
);
|
|
|
|
$this->addGroupBy( 'rc.rc_cur_id' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addeditdate' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addeditdate( $option ) {
|
|
$this->addTable( 'revision', 'rev' );
|
|
$this->addSelect( [ 'rev.rev_timestamp' ] );
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addfirstcategorydate' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addfirstcategorydate( $option ) {
|
|
// @TODO: This should be programmatically determining which categorylink table to use instead of assuming the first one.
|
|
$this->addSelect(
|
|
[
|
|
'cl_timestamp' => "DATE_FORMAT(cl1.cl_timestamp, '%Y%m%d%H%i%s')"
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addlasteditor' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addlasteditor( $option ) {
|
|
// Addlasteditor can not be used with addauthor.
|
|
if ( !isset( $this->parametersProcessed['addauthor'] ) || !$this->parametersProcessed['addauthor'] ) {
|
|
$this->addTable( 'revision', 'rev' );
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp = (SELECT MAX(rev_aux_max.rev_timestamp) FROM ' . $this->tableNames['revision'] . ' AS rev_aux_max WHERE rev_aux_max.rev_page = rev.rev_page)'
|
|
]
|
|
);
|
|
|
|
$this->_adduser( null, 'rev' );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addpagecounter' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addpagecounter( $option ) {
|
|
if ( ExtensionRegistry::getInstance()->isLoaded( 'HitCounters' ) ) {
|
|
$this->addTable( 'hit_counter', 'hit_counter' );
|
|
$this->addSelect(
|
|
[
|
|
'page_counter' => 'hit_counter.page_counter'
|
|
]
|
|
);
|
|
|
|
if ( !isset( $this->join['hit_counter'] ) ) {
|
|
$this->addJoin(
|
|
'hit_counter',
|
|
[
|
|
'LEFT JOIN',
|
|
'hit_counter.page_id = ' . $this->tableNames['page'] . '.page_id'
|
|
]
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addpagesize' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addpagesize( $option ) {
|
|
$this->addSelect(
|
|
[
|
|
'page_len' => "{$this->tableNames['page']}.page_len"
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'addpagetoucheddate' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _addpagetoucheddate( $option ) {
|
|
$this->addSelect(
|
|
[
|
|
'page_touched' => "{$this->tableNames['page']}.page_touched"
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'adduser' parameter.
|
|
*
|
|
* @param mixed $option
|
|
* @param string $tableAlias
|
|
*/
|
|
private function _adduser( $option, $tableAlias = '' ) {
|
|
$tableAlias = ( !empty( $tableAlias ) ? $tableAlias . '.' : '' );
|
|
|
|
$this->addSelect(
|
|
[
|
|
$tableAlias . 'rev_actor',
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'allrevisionsbefore' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _allrevisionsbefore( $option ) {
|
|
$this->addTable( 'revision', 'rev' );
|
|
$this->addSelect(
|
|
[
|
|
'rev.rev_id',
|
|
'rev.rev_timestamp'
|
|
]
|
|
);
|
|
|
|
$this->addOrderBy( 'rev.rev_id' );
|
|
$this->setOrderDir( 'DESC' );
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp < ' . $this->convertTimestamp( $option )
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'allrevisionssince' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _allrevisionssince( $option ) {
|
|
$this->addTable( 'revision', 'rev' );
|
|
$this->addSelect(
|
|
[
|
|
'rev.rev_id',
|
|
'rev.rev_timestamp'
|
|
]
|
|
);
|
|
|
|
$this->addOrderBy( 'rev.rev_id' );
|
|
$this->setOrderDir( 'DESC' );
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp >= ' . $this->convertTimestamp( $option )
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'articlecategory' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _articlecategory( $option ) {
|
|
$this->addWhere( "{$this->tableNames['page']}.page_title IN (SELECT p2.page_title FROM {$this->tableNames['page']} p2 INNER JOIN {$this->tableNames['categorylinks']} clstc ON (clstc.cl_from = p2.page_id AND clstc.cl_to = " . $this->dbr->addQuotes( $option ) . ") WHERE p2.page_namespace = 0)" );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'categoriesminmax' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _categoriesminmax( $option ) {
|
|
if ( is_numeric( $option[0] ) ) {
|
|
$this->addWhere( (int)$option[0] . ' <= (SELECT count(*) FROM ' . $this->tableNames['categorylinks'] . ' WHERE ' . $this->tableNames['categorylinks'] . '.cl_from=page_id)' );
|
|
}
|
|
|
|
if ( isset( $option[1] ) && is_numeric( $option[1] ) ) {
|
|
$this->addWhere( (int)$option[1] . ' >= (SELECT count(*) FROM ' . $this->tableNames['categorylinks'] . ' WHERE ' . $this->tableNames['categorylinks'] . '.cl_from=page_id)' );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'category' parameter. This includes 'category', 'categorymatch', and 'categoryregexp'.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _category( $option ) {
|
|
$i = 0;
|
|
|
|
foreach ( $option as $comparisonType => $operatorTypes ) {
|
|
foreach ( $operatorTypes as $operatorType => $categoryGroups ) {
|
|
foreach ( $categoryGroups as $categories ) {
|
|
if ( !is_array( $categories ) ) {
|
|
continue;
|
|
}
|
|
|
|
$tableName = ( in_array( '', $categories ) ? 'dpl_clview' : 'categorylinks' );
|
|
if ( $operatorType == 'AND' ) {
|
|
foreach ( $categories as $category ) {
|
|
$i++;
|
|
$tableAlias = "cl{$i}";
|
|
$this->addTable( $tableName, $tableAlias );
|
|
$this->addJoin(
|
|
$tableAlias,
|
|
[
|
|
'INNER JOIN',
|
|
"{$this->tableNames['page']}.page_id = {$tableAlias}.cl_from AND $tableAlias.cl_to {$comparisonType} " . $this->dbr->addQuotes( str_replace( ' ', '_', $category ) )
|
|
]
|
|
);
|
|
}
|
|
} elseif ( $operatorType == 'OR' ) {
|
|
$i++;
|
|
$tableAlias = "cl{$i}";
|
|
$this->addTable( $tableName, $tableAlias );
|
|
|
|
$joinOn = "{$this->tableNames['page']}.page_id = {$tableAlias}.cl_from AND (";
|
|
$ors = [];
|
|
|
|
foreach ( $categories as $category ) {
|
|
$ors[] = "{$tableAlias}.cl_to {$comparisonType} " . $this->dbr->addQuotes( str_replace( ' ', '_', $category ) );
|
|
}
|
|
|
|
$joinOn .= implode( " {$operatorType} ", $ors );
|
|
$joinOn .= ')';
|
|
|
|
$this->addJoin(
|
|
$tableAlias,
|
|
[
|
|
'INNER JOIN',
|
|
$joinOn
|
|
]
|
|
);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notcategory' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notcategory( $option ) {
|
|
$i = 0;
|
|
foreach ( $option as $operatorType => $categories ) {
|
|
foreach ( $categories as $category ) {
|
|
$i++;
|
|
|
|
$tableAlias = "ecl{$i}";
|
|
$this->addTable( 'categorylinks', $tableAlias );
|
|
|
|
$this->addJoin(
|
|
$tableAlias,
|
|
[
|
|
'LEFT OUTER JOIN',
|
|
"{$this->tableNames['page']}.page_id = {$tableAlias}.cl_from AND {$tableAlias}.cl_to {$operatorType}" . $this->dbr->addQuotes( str_replace( ' ', '_', $category ) )
|
|
]
|
|
);
|
|
|
|
$this->addWhere(
|
|
[
|
|
"{$tableAlias}.cl_to" => null
|
|
]
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'createdby' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _createdby( $option ) {
|
|
$this->addTable( 'revision', 'creation_rev' );
|
|
$this->_adduser( null, 'creation_rev' );
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->dbr->addQuotes( $this->userFactory->newFromName( $option )->getActorId() ) . ' = creation_rev.rev_actor',
|
|
'creation_rev.rev_page = page_id',
|
|
'creation_rev.rev_parent_id = 0'
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'distinct' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _distinct( $option ) {
|
|
if ( $option == 'strict' || $option === true ) {
|
|
$this->distinct = true;
|
|
} else {
|
|
$this->distinct = false;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'firstrevisionsince' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _firstrevisionsince( $option ) {
|
|
$this->addTable( 'revision', 'rev' );
|
|
$this->addSelect(
|
|
[
|
|
'rev.rev_id',
|
|
'rev.rev_timestamp'
|
|
]
|
|
);
|
|
|
|
// tell the query optimizer not to look at rows that the following subquery will filter out anyway
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp >= ' . $this->dbr->addQuotes( $option )
|
|
]
|
|
);
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp = (SELECT MIN(rev_aux_snc.rev_timestamp) FROM ' . $this->tableNames['revision'] . ' AS rev_aux_snc WHERE rev_aux_snc.rev_page=rev.rev_page AND rev_aux_snc.rev_timestamp >= ' . $this->convertTimestamp( $option ) . ')'
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'goal' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _goal( $option ) {
|
|
if ( $option == 'categories' ) {
|
|
$this->setLimit( false );
|
|
$this->setOffset( false );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'hiddencategories' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _hiddencategories( $option ) {
|
|
// @TODO: Unfinished functionality! Never implemented by original author.
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'imagecontainer' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _imagecontainer( $option ) {
|
|
$where = [];
|
|
|
|
$this->addTable( 'imagelinks', 'ic' );
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => 'ic.il_to'
|
|
]
|
|
);
|
|
|
|
if ( !$this->parameters->getParameter( 'openreferences' ) ) {
|
|
$where = [
|
|
"{$this->tableNames['page']}.page_namespace = " . NS_FILE,
|
|
"{$this->tableNames['page']}.page_title = ic.il_to"
|
|
];
|
|
}
|
|
|
|
$ors = [];
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$ors[] = 'LOWER(CAST(ic.il_from AS char) = LOWER(' . $this->dbr->addQuotes( $link->getArticleID() ) . ')';
|
|
} else {
|
|
$ors[] = 'ic.il_from = ' . $this->dbr->addQuotes( $link->getArticleID() );
|
|
}
|
|
}
|
|
}
|
|
|
|
$where[] = '(' . implode( ' OR ', $ors ) . ')';
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'imageused' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _imageused( $option ) {
|
|
$where = [];
|
|
|
|
if ( $this->parameters->getParameter( 'distinct' ) == 'strict' ) {
|
|
$this->addGroupBy( 'page_title' );
|
|
}
|
|
|
|
$this->addTable( 'imagelinks', 'il' );
|
|
$this->addSelect(
|
|
[
|
|
'image_sel_title' => 'il.il_to'
|
|
]
|
|
);
|
|
|
|
$where[] = $this->tableNames['page'] . '.page_id = il.il_from';
|
|
$ors = [];
|
|
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$ors[] = 'LOWER(CAST(il.il_to AS char)) = LOWER(' . $this->dbr->addQuotes( $link->getDBkey() ) . ')';
|
|
} else {
|
|
$ors[] = 'il.il_to = ' . $this->dbr->addQuotes( $link->getDBkey() );
|
|
}
|
|
}
|
|
}
|
|
|
|
$where[] = '(' . implode( ' OR ', $ors ) . ')';
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'lastmodifiedby' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _lastmodifiedby( $option ) {
|
|
$this->addWhere( $this->dbr->addQuotes( $this->userFactory->newFromName( $option )->getActorId() ) . ' = (SELECT rev_actor FROM ' . $this->tableNames['revision'] . ' WHERE ' . $this->tableNames['revision'] . '.rev_page=page_id ORDER BY ' . $this->tableNames['revision'] . '.rev_timestamp DESC LIMIT 1)' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'lastrevisionbefore' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _lastrevisionbefore( $option ) {
|
|
$this->addTable( 'revision', 'rev' );
|
|
$this->addSelect( [ 'rev.rev_id', 'rev.rev_timestamp' ] );
|
|
|
|
// tell the query optimizer not to look at rows that the following subquery will filter out anyway
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp < ' . $this->convertTimestamp( $option )
|
|
]
|
|
);
|
|
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_id = rev.rev_page',
|
|
'rev.rev_timestamp = (SELECT MAX(rev_aux_bef.rev_timestamp) FROM ' . $this->tableNames['revision'] . ' AS rev_aux_bef WHERE rev_aux_bef.rev_page=rev.rev_page AND rev_aux_bef.rev_timestamp < ' . $this->convertTimestamp( $option ) . ')'
|
|
]
|
|
);
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'linksfrom' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _linksfrom( $option ) {
|
|
$where = [];
|
|
|
|
if ( $this->parameters->getParameter( 'distinct' ) == 'strict' ) {
|
|
$this->addGroupBy( 'page_title' );
|
|
}
|
|
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$ors = [];
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$ors[] = '(pl_from = ' . $link->getArticleID() . ')';
|
|
}
|
|
}
|
|
|
|
$where[] = '(' . implode( ' OR ', $ors ) . ')';
|
|
} else {
|
|
$this->addTable( 'pagelinks', 'plf' );
|
|
$this->addTable( 'page', 'pagesrc' );
|
|
$this->addSelect(
|
|
[
|
|
'sel_title' => 'pagesrc.page_title',
|
|
'sel_ns' => 'pagesrc.page_namespace'
|
|
]
|
|
);
|
|
|
|
$where = [
|
|
$this->tableNames['page'] . '.page_namespace = plf.pl_namespace',
|
|
$this->tableNames['page'] . '.page_title = plf.pl_title',
|
|
'pagesrc.page_id = plf.pl_from'
|
|
];
|
|
|
|
$ors = [];
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$ors[] = 'plf.pl_from = ' . $link->getArticleID();
|
|
}
|
|
}
|
|
|
|
$where[] = '(' . implode( ' OR ', $ors ) . ')';
|
|
}
|
|
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'linksto' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _linksto( $option ) {
|
|
if ( $this->parameters->getParameter( 'distinct' ) == 'strict' ) {
|
|
$this->addGroupBy( 'page_title' );
|
|
}
|
|
|
|
if ( count( $option ) > 0 ) {
|
|
$this->addTable( 'pagelinks', 'pl' );
|
|
$this->addSelect( [ 'sel_title' => 'pl.pl_title', 'sel_ns' => 'pl.pl_namespace' ] );
|
|
|
|
foreach ( $option as $index => $linkGroup ) {
|
|
if ( $index == 0 ) {
|
|
$where = $this->tableNames['page'] . '.page_id=pl.pl_from AND ';
|
|
$ors = [];
|
|
|
|
foreach ( $linkGroup as $link ) {
|
|
$_or = '(pl.pl_namespace=' . (int)$link->getNamespace();
|
|
if ( strpos( $link->getDBkey(), '%' ) >= 0 ) {
|
|
$operator = 'LIKE';
|
|
} else {
|
|
$operator = '=';
|
|
}
|
|
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or .= ' AND LOWER(CAST(pl.pl_title AS char)) ' . $operator . ' LOWER(' . $this->dbr->addQuotes( $link->getDBkey() ) . ')';
|
|
} else {
|
|
$_or .= ' AND pl.pl_title ' . $operator . ' ' . $this->dbr->addQuotes( $link->getDBkey() );
|
|
}
|
|
|
|
$_or .= ')';
|
|
$ors[] = $_or;
|
|
}
|
|
|
|
$where .= '(' . implode( ' OR ', $ors ) . ')';
|
|
} else {
|
|
$where = 'EXISTS(select pl_from FROM ' . $this->tableNames['pagelinks'] . ' WHERE (' . $this->tableNames['pagelinks'] . '.pl_from=page_id AND ';
|
|
$ors = [];
|
|
|
|
foreach ( $linkGroup as $link ) {
|
|
$_or = '(' . $this->tableNames['pagelinks'] . '.pl_namespace=' . (int)$link->getNamespace();
|
|
if ( strpos( $link->getDBkey(), '%' ) >= 0 ) {
|
|
$operator = 'LIKE';
|
|
} else {
|
|
$operator = '=';
|
|
}
|
|
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or .= ' AND LOWER(CAST(' . $this->tableNames['pagelinks'] . '.pl_title AS char)) ' . $operator . ' LOWER(' . $this->dbr->addQuotes( $link->getDBkey() ) . ')';
|
|
} else {
|
|
$_or .= ' AND ' . $this->tableNames['pagelinks'] . '.pl_title ' . $operator . ' ' . $this->dbr->addQuotes( $link->getDBkey() );
|
|
}
|
|
|
|
$_or .= ')';
|
|
$ors[] = $_or;
|
|
}
|
|
|
|
$where .= '(' . implode( ' OR ', $ors ) . ')';
|
|
$where .= '))';
|
|
}
|
|
|
|
$this->addWhere( $where );
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notlinksfrom' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notlinksfrom( $option ) {
|
|
if ( $this->parameters->getParameter( 'distinct' ) == 'strict' ) {
|
|
$this->addGroupBy( 'page_title' );
|
|
}
|
|
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$ands = [];
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$ands[] = 'pl_from <> ' . (int)$link->getArticleID() . ' ';
|
|
}
|
|
}
|
|
|
|
$where = '(' . implode( ' AND ', $ands ) . ')';
|
|
} else {
|
|
$where = 'CONCAT(page_namespace,page_title) NOT IN (SELECT CONCAT(' . $this->tableNames['pagelinks'] . '.pl_namespace,' . $this->tableNames['pagelinks'] . '.pl_title) FROM ' . $this->tableNames['pagelinks'] . ' WHERE ';
|
|
$ors = [];
|
|
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$ors[] = $this->tableNames['pagelinks'] . '.pl_from = ' . (int)$link->getArticleID();
|
|
}
|
|
}
|
|
|
|
$where .= implode( ' OR ', $ors ) . ')';
|
|
}
|
|
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notlinksto' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notlinksto( $option ) {
|
|
if ( $this->parameters->getParameter( 'distinct' ) == 'strict' ) {
|
|
$this->addGroupBy( 'page_title' );
|
|
}
|
|
|
|
if ( count( $option ) ) {
|
|
$where = $this->tableNames['page'] . '.page_id NOT IN (SELECT ' . $this->tableNames['pagelinks'] . '.pl_from FROM ' . $this->tableNames['pagelinks'] . ' WHERE ';
|
|
$ors = [];
|
|
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$_or = '(' . $this->tableNames['pagelinks'] . '.pl_namespace=' . (int)$link->getNamespace();
|
|
if ( strpos( $link->getDBkey(), '%' ) >= 0 ) {
|
|
$operator = 'LIKE';
|
|
} else {
|
|
$operator = '=';
|
|
}
|
|
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or .= ' AND LOWER(CAST(' . $this->tableNames['pagelinks'] . '.pl_title AS char)) ' . $operator . ' LOWER(' . $this->dbr->addQuotes( $link->getDBkey() ) . '))';
|
|
} else {
|
|
$_or .= ' AND ' . $this->tableNames['pagelinks'] . '.pl_title ' . $operator . ' ' . $this->dbr->addQuotes( $link->getDBkey() ) . ')';
|
|
}
|
|
|
|
$ors[] = $_or;
|
|
}
|
|
}
|
|
|
|
$where .= '(' . implode( ' OR ', $ors ) . '))';
|
|
}
|
|
|
|
$this->addWhere( $where ?? '' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'linkstoexternal' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _linkstoexternal( $option ) {
|
|
if ( $this->parameters->getParameter( 'distinct' ) == 'strict' ) {
|
|
$this->addGroupBy( 'page_title' );
|
|
}
|
|
|
|
if ( count( $option ) > 0 ) {
|
|
$this->addTable( 'externallinks', 'el' );
|
|
$this->addSelect( [ 'el_to' => 'el.el_to' ] );
|
|
|
|
foreach ( $option as $index => $linkGroup ) {
|
|
if ( $index == 0 ) {
|
|
$where = $this->tableNames['page'] . '.page_id=el.el_from AND ';
|
|
$ors = [];
|
|
|
|
foreach ( $linkGroup as $link ) {
|
|
$ors[] = 'el.el_to LIKE ' . $this->dbr->addQuotes( $link );
|
|
}
|
|
|
|
$where .= '(' . implode( ' OR ', $ors ) . ')';
|
|
} else {
|
|
$where = 'EXISTS(SELECT el_from FROM ' . $this->tableNames['externallinks'] . ' WHERE (' . $this->tableNames['externallinks'] . '.el_from=page_id AND ';
|
|
$ors = [];
|
|
|
|
foreach ( $linkGroup as $link ) {
|
|
$ors[] = $this->tableNames['externallinks'] . '.el_to LIKE ' . $this->dbr->addQuotes( $link );
|
|
}
|
|
|
|
$where .= '(' . implode( ' OR ', $ors ) . ')';
|
|
$where .= '))';
|
|
}
|
|
|
|
$this->addWhere( $where );
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'maxrevisions' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _maxrevisions( $option ) {
|
|
$this->addWhere( "((SELECT count(rev_aux3.rev_page) FROM {$this->tableNames['revision']} AS rev_aux3 WHERE rev_aux3.rev_page = {$this->tableNames['page']}.page_id) <= {$option})" );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'minoredits' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _minoredits( $option ) {
|
|
if ( isset( $option ) && $option == 'exclude' ) {
|
|
$this->addTable( 'revision', 'revision' );
|
|
$this->addWhere( 'revision.rev_minor_edit = 0' );
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'minrevisions' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _minrevisions( $option ) {
|
|
$this->addWhere( "((SELECT count(rev_aux2.rev_page) FROM {$this->tableNames['revision']} AS rev_aux2 WHERE rev_aux2.rev_page = {$this->tableNames['page']}.page_id) >= {$option})" );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'modifiedby' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _modifiedby( $option ) {
|
|
$this->addTable( 'revision', 'change_rev' );
|
|
|
|
$this->addWhere( $this->dbr->addQuotes( $this->userFactory->newFromName( $option )->getActorId() ) . ' = change_rev.rev_actor AND change_rev.rev_page = page_id' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'namespace' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _namespace( $option ) {
|
|
if ( is_array( $option ) && count( $option ) ) {
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$this->addWhere(
|
|
[
|
|
"{$this->tableNames['pagelinks']}.pl_namespace" => $option
|
|
]
|
|
);
|
|
} else {
|
|
$this->addWhere(
|
|
[
|
|
"{$this->tableNames['page']}.page_namespace" => $option
|
|
]
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notcreatedby' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notcreatedby( $option ) {
|
|
$this->addTable( 'revision', 'no_creation_rev' );
|
|
|
|
$this->addWhere( $this->dbr->addQuotes( $this->userFactory->newFromName( $option )->getActorId() ) . ' != no_creation_rev.rev_actor AND no_creation_rev.rev_page = page_id AND no_creation_rev.rev_parent_id = 0' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notlastmodifiedby' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notlastmodifiedby( $option ) {
|
|
$this->addWhere( $this->dbr->addQuotes( $this->userFactory->newFromName( $option )->getActorId() ) . ' != (SELECT rev_actor FROM ' . $this->tableNames['revision'] . ' WHERE ' . $this->tableNames['revision'] . '.rev_page=page_id ORDER BY ' . $this->tableNames['revision'] . '.rev_timestamp DESC LIMIT 1)' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notmodifiedby' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notmodifiedby( $option ) {
|
|
$this->addWhere( 'NOT EXISTS (SELECT 1 FROM ' . $this->tableNames['revision'] . ' WHERE ' . $this->tableNames['revision'] . '.rev_page=page_id AND ' . $this->tableNames['revision'] . '.rev_actor = ' . $this->dbr->addQuotes( $this->userFactory->newFromName( $option )->getActorId() ) . ' LIMIT 1)' );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notnamespace' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notnamespace( $option ) {
|
|
if ( is_array( $option ) && count( $option ) ) {
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$this->addNotWhere(
|
|
[
|
|
"{$this->tableNames['pagelinks']}.pl_namespace" => $option
|
|
]
|
|
);
|
|
} else {
|
|
$this->addNotWhere(
|
|
[
|
|
"{$this->tableNames['page']}.page_namespace" => $option
|
|
]
|
|
);
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'count' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _count( $option ) {
|
|
$this->setLimit( $option );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'offset' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _offset( $option ) {
|
|
$this->setOffset( $option );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'order' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _order( $option ) {
|
|
$orderMethod = $this->parameters->getParameter( 'ordermethod' );
|
|
|
|
if ( !empty( $orderMethod ) && is_array( $orderMethod ) && $orderMethod[0] !== 'none' ) {
|
|
if ( $option === 'descending' || $option === 'desc' ) {
|
|
$this->setOrderDir( 'DESC' );
|
|
} else {
|
|
$this->setOrderDir( 'ASC' );
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'ordercollation' parameter.
|
|
*
|
|
* @param mixed $option
|
|
* @return bool
|
|
*/
|
|
private function _ordercollation( $option ) {
|
|
$option = mb_strtolower( $option );
|
|
|
|
$res = $this->dbr->query( 'SHOW CHARACTER SET' );
|
|
if ( !$res ) {
|
|
return false;
|
|
}
|
|
|
|
foreach ( $res as $row ) {
|
|
if ( $option == $row->{'Default collation'} ) {
|
|
$this->setCollation( $option );
|
|
break;
|
|
}
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'ordermethod' parameter.
|
|
*
|
|
* @param mixed $option
|
|
* @return bool
|
|
*/
|
|
private function _ordermethod( $option ) {
|
|
if ( $this->parameters->getParameter( 'goal' ) == 'categories' ) {
|
|
// No order methods for returning categories.
|
|
return true;
|
|
}
|
|
|
|
$services = MediaWikiServices::getInstance();
|
|
$namespaces = $services->getContentLanguage()->getNamespaces();
|
|
|
|
// $aStrictNs = array_slice( (array)Config::getSetting( 'allowedNamespaces' ), 1, count( Config::getSetting( 'allowedNamespaces' ) ), true );
|
|
|
|
$namespaces = array_slice( $namespaces, 3, count( $namespaces ), true );
|
|
$_namespaceIdToText = "CASE {$this->tableNames['page']}.page_namespace";
|
|
|
|
foreach ( $namespaces as $id => $name ) {
|
|
$_namespaceIdToText .= ' WHEN ' . (int)$id . ' THEN ' . $this->dbr->addQuotes( $name . ':' );
|
|
}
|
|
|
|
$_namespaceIdToText .= ' END';
|
|
|
|
$option = (array)$option;
|
|
|
|
foreach ( $option as $orderMethod ) {
|
|
switch ( $orderMethod ) {
|
|
case 'category':
|
|
$this->addOrderBy( 'cl_head.cl_to' );
|
|
$this->addSelect( [ 'cl_head.cl_to' ] );
|
|
|
|
if ( ( is_array( $this->parameters->getParameter( 'catheadings' ) ) && in_array( '', $this->parameters->getParameter( 'catheadings' ) ) ) || ( is_array( $this->parameters->getParameter( 'catnotheadings' ) ) && in_array( '', $this->parameters->getParameter( 'catnotheadings' ) ) ) ) {
|
|
$_clTableName = 'dpl_clview';
|
|
$_clTableAlias = $_clTableName;
|
|
} else {
|
|
$_clTableName = 'categorylinks';
|
|
$_clTableAlias = 'cl_head';
|
|
}
|
|
|
|
$this->addTable( $_clTableName, $_clTableAlias );
|
|
$this->addJoin(
|
|
$_clTableAlias,
|
|
[
|
|
'LEFT OUTER JOIN',
|
|
'page_id = cl_head.cl_from'
|
|
]
|
|
);
|
|
|
|
if ( is_array( $this->parameters->getParameter( 'catheadings' ) ) && count( $this->parameters->getParameter( 'catheadings' ) ) ) {
|
|
$this->addWhere(
|
|
[
|
|
'cl_head.cl_to' => $this->parameters->getParameter( 'catheadings' )
|
|
]
|
|
);
|
|
}
|
|
|
|
if ( is_array( $this->parameters->getParameter( 'catnotheadings' ) ) && count( $this->parameters->getParameter( 'catnotheadings' ) ) ) {
|
|
$this->addNotWhere(
|
|
[
|
|
'cl_head.cl_to' => $this->parameters->getParameter( 'catnotheadings' )
|
|
]
|
|
);
|
|
}
|
|
break;
|
|
case 'categoryadd':
|
|
// @TODO: See TODO in __addfirstcategorydate().
|
|
$this->addOrderBy( 'cl1.cl_timestamp' );
|
|
break;
|
|
case 'counter':
|
|
if ( ExtensionRegistry::getInstance()->isLoaded( 'HitCounters' ) ) {
|
|
// If the "addpagecounter" parameter was not used the table and join need to be added now.
|
|
if ( !array_key_exists( 'hit_counter', $this->tables ) ) {
|
|
$this->addTable( 'hit_counter', 'hit_counter' );
|
|
|
|
if ( !isset( $this->join['hit_counter'] ) ) {
|
|
$this->addJoin(
|
|
'hit_counter',
|
|
[
|
|
'LEFT JOIN',
|
|
'hit_counter.page_id = ' . $this->tableNames['page'] . '.page_id'
|
|
]
|
|
);
|
|
}
|
|
}
|
|
|
|
$this->addOrderBy( 'hit_counter.page_counter' );
|
|
}
|
|
break;
|
|
case 'firstedit':
|
|
$this->addOrderBy( 'rev.rev_timestamp' );
|
|
$this->addTable( 'revision', 'rev' );
|
|
|
|
$this->addSelect(
|
|
[
|
|
'rev.rev_timestamp'
|
|
]
|
|
);
|
|
|
|
if ( !$this->revisionAuxWhereAdded ) {
|
|
$this->addWhere(
|
|
[
|
|
"{$this->tableNames['page']}.page_id = rev.rev_page",
|
|
"rev.rev_timestamp = (SELECT MIN(rev_aux.rev_timestamp) FROM {$this->tableNames['revision']} AS rev_aux WHERE rev_aux.rev_page=rev.rev_page)"
|
|
]
|
|
);
|
|
}
|
|
|
|
$this->revisionAuxWhereAdded = true;
|
|
break;
|
|
case 'lastedit':
|
|
if ( Hooks::isLikeIntersection() ) {
|
|
$this->addOrderBy( 'page_touched' );
|
|
$this->addSelect(
|
|
[
|
|
'page_touched' => "{$this->tableNames['page']}.page_touched"
|
|
]
|
|
);
|
|
} else {
|
|
$this->addOrderBy( 'rev.rev_timestamp' );
|
|
$this->addTable( 'revision', 'rev' );
|
|
$this->addSelect( [ 'rev.rev_timestamp' ] );
|
|
|
|
if ( !$this->revisionAuxWhereAdded ) {
|
|
$this->addWhere(
|
|
[
|
|
"{$this->tableNames['page']}.page_id = rev.rev_page",
|
|
"rev.rev_timestamp = (SELECT MAX(rev_aux.rev_timestamp) FROM {$this->tableNames['revision']} AS rev_aux WHERE rev_aux.rev_page = rev.rev_page)"
|
|
]
|
|
);
|
|
}
|
|
|
|
$this->revisionAuxWhereAdded = true;
|
|
}
|
|
break;
|
|
case 'pagesel':
|
|
$this->addOrderBy( 'sortkey' );
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => 'CONCAT(pl.pl_namespace, pl.pl_title) ' . $this->getCollateSQL()
|
|
]
|
|
);
|
|
break;
|
|
case 'pagetouched':
|
|
$this->addOrderBy( 'page_touched' );
|
|
$this->addSelect(
|
|
[
|
|
'page_touched' => "{$this->tableNames['page']}.page_touched"
|
|
]
|
|
);
|
|
break;
|
|
case 'size':
|
|
$this->addOrderBy( 'page_len' );
|
|
break;
|
|
case 'sortkey':
|
|
$this->addOrderBy( 'sortkey' );
|
|
|
|
// If cl_sortkey is null (uncategorized page), generate a sortkey in the usual way (full page name, underscores replaced with spaces).
|
|
// UTF-8 created problems with non-utf-8 MySQL databases
|
|
$replaceConcat = "REPLACE(CONCAT({$_namespaceIdToText}, " . $this->tableNames['page'] . ".page_title), '_', ' ')";
|
|
|
|
$category = (array)$this->parameters->getParameter( 'category' );
|
|
$notCategory = (array)$this->parameters->getParameter( 'notcategory' );
|
|
if ( count( $category ) + count( $notCategory ) > 0 ) {
|
|
if ( in_array( 'category', $this->parameters->getParameter( 'ordermethod' ) ) ) {
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => "IFNULL(cl_head.cl_sortkey, {$replaceConcat}) " . $this->getCollateSQL()
|
|
]
|
|
);
|
|
} else {
|
|
// This runs on the assumption that at least one category parameter was used and that numbering starts at 1.
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => "IFNULL(cl1.cl_sortkey, {$replaceConcat}) " . $this->getCollateSQL()
|
|
]
|
|
);
|
|
}
|
|
} else {
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => $replaceConcat . $this->getCollateSQL()
|
|
]
|
|
);
|
|
}
|
|
break;
|
|
case 'titlewithoutnamespace':
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$this->addOrderBy( 'pl_title' );
|
|
} else {
|
|
$this->addOrderBy( 'page_title' );
|
|
}
|
|
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => "{$this->tableNames['page']}.page_title " . $this->getCollateSQL()
|
|
]
|
|
);
|
|
break;
|
|
case 'title':
|
|
$this->addOrderBy( 'sortkey' );
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => "REPLACE(CONCAT(IF(pl_namespace =0, '', CONCAT(" . $_namespaceIdToText . ", ':')), pl_title), '_', ' ') " . $this->getCollateSQL()
|
|
]
|
|
);
|
|
} else {
|
|
// Generate sortkey like for category links. UTF-8 created problems with non-utf-8 MySQL databases.
|
|
$this->addSelect(
|
|
[
|
|
'sortkey' => "REPLACE(CONCAT(IF(" . $this->tableNames['page'] . ".page_namespace = 0, '', CONCAT(" . $_namespaceIdToText . ", ':')), " . $this->tableNames['page'] . ".page_title), '_', ' ') " . $this->getCollateSQL()
|
|
]
|
|
);
|
|
}
|
|
break;
|
|
case 'user':
|
|
$this->addOrderBy( 'rev.rev_actor' );
|
|
$this->addTable( 'revision', 'rev' );
|
|
|
|
$this->_adduser( null, 'rev' );
|
|
break;
|
|
case 'none':
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'redirects' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _redirects( $option ) {
|
|
if ( !$this->parameters->getParameter( 'openreferences' ) ) {
|
|
switch ( $option ) {
|
|
case 'only':
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_is_redirect' => 1
|
|
]
|
|
);
|
|
break;
|
|
case 'exclude':
|
|
$this->addWhere(
|
|
[
|
|
$this->tableNames['page'] . '.page_is_redirect' => 0
|
|
]
|
|
);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'stablepages' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _stablepages( $option ) {
|
|
if ( function_exists( 'efLoadFlaggedRevs' ) ) {
|
|
// Do not add this again if 'qualitypages' has already added it.
|
|
if ( !$this->parametersProcessed['qualitypages'] ) {
|
|
$this->addJoin(
|
|
'flaggedpages',
|
|
[
|
|
'LEFT JOIN',
|
|
'page_id = fp_page_id'
|
|
]
|
|
);
|
|
}
|
|
|
|
switch ( $option ) {
|
|
case 'only':
|
|
$this->addWhere(
|
|
[
|
|
'fp_stable IS NOT NULL'
|
|
]
|
|
);
|
|
break;
|
|
case 'exclude':
|
|
$this->addWhere(
|
|
[
|
|
'fp_stable' => null
|
|
]
|
|
);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'qualitypages' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _qualitypages( $option ) {
|
|
if ( function_exists( 'efLoadFlaggedRevs' ) ) {
|
|
// Do not add this again if 'stablepages' has already added it.
|
|
if ( !$this->parametersProcessed['stablepages'] ) {
|
|
$this->addJoin(
|
|
'flaggedpages',
|
|
[
|
|
'LEFT JOIN',
|
|
'page_id = fp_page_id'
|
|
]
|
|
);
|
|
}
|
|
|
|
switch ( $option ) {
|
|
case 'only':
|
|
$this->addWhere( 'fp_quality >= 1' );
|
|
break;
|
|
case 'exclude':
|
|
$this->addWhere( 'fp_quality = 0' );
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'title' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _title( $option ) {
|
|
$ors = [];
|
|
|
|
foreach ( $option as $comparisonType => $titles ) {
|
|
foreach ( $titles as $title ) {
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or = "LOWER(CAST(pl_title AS char)) {$comparisonType}" . strtolower( $this->dbr->addQuotes( $title ) );
|
|
} else {
|
|
$_or = "pl_title {$comparisonType} " . $this->dbr->addQuotes( $title );
|
|
}
|
|
} else {
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or = "LOWER(CAST({$this->tableNames['page']}.page_title AS char)) {$comparisonType}" . strtolower( $this->dbr->addQuotes( $title ) );
|
|
} else {
|
|
$_or = "{$this->tableNames['page']}.page_title {$comparisonType}" . $this->dbr->addQuotes( $title );
|
|
}
|
|
}
|
|
|
|
$ors[] = $_or;
|
|
}
|
|
}
|
|
|
|
$where = '(' . implode( ' OR ', $ors ) . ')';
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'nottitle' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _nottitle( $option ) {
|
|
$ors = [];
|
|
|
|
foreach ( $option as $comparisonType => $titles ) {
|
|
foreach ( $titles as $title ) {
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or = "LOWER(CAST(pl_title AS char)) {$comparisonType}" . strtolower( $this->dbr->addQuotes( $title ) );
|
|
} else {
|
|
$_or = "pl_title {$comparisonType} " . $this->dbr->addQuotes( $title );
|
|
}
|
|
} else {
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or = "LOWER(CAST({$this->tableNames['page']}.page_title AS char)) {$comparisonType}" . strtolower( $this->dbr->addQuotes( $title ) );
|
|
} else {
|
|
$_or = "{$this->tableNames['page']}.page_title {$comparisonType}" . $this->dbr->addQuotes( $title );
|
|
}
|
|
}
|
|
|
|
$ors[] = $_or;
|
|
}
|
|
}
|
|
|
|
$where = 'NOT (' . implode( ' OR ', $ors ) . ')';
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'titlegt' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _titlegt( $option ) {
|
|
$operator = '>';
|
|
if ( substr( $option, 0, 2 ) === '=_' ) {
|
|
$option = substr( $option, 2 );
|
|
$operator = '>=';
|
|
}
|
|
|
|
if ( $option === '' ) {
|
|
$operator = 'LIKE';
|
|
$option = '%';
|
|
}
|
|
|
|
$option = $this->dbr->addQuotes( $option );
|
|
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$where = "(pl_title {$operator} {$option})";
|
|
} else {
|
|
$where = "({$this->tableNames['page']}.page_title {$operator} {$option})";
|
|
}
|
|
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'titlelt' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _titlelt( $option ) {
|
|
$operator = '<';
|
|
if ( substr( $option, 0, 2 ) === '=_' ) {
|
|
$option = substr( $option, 2 );
|
|
$operator = '<=';
|
|
}
|
|
|
|
if ( $option === '' ) {
|
|
$operator = 'LIKE';
|
|
$option = '%';
|
|
}
|
|
|
|
$option = $this->dbr->addQuotes( $option );
|
|
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$where = "(pl_title {$operator} {$option})";
|
|
} else {
|
|
$where = "({$this->tableNames['page']}.page_title {$operator} {$option})";
|
|
}
|
|
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'usedby' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _usedby( $option ) {
|
|
if ( $this->parameters->getParameter( 'openreferences' ) ) {
|
|
$ors = [];
|
|
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$ors[] = 'tpl_from = ' . (int)$link->getArticleID();
|
|
}
|
|
}
|
|
|
|
$where = '(' . implode( ' OR ', $ors ) . ')';
|
|
} else {
|
|
$this->addTables( [
|
|
'linktarget' => 'lt',
|
|
'page' => 'tplsrc',
|
|
'templatelinks' => 'tpl',
|
|
] );
|
|
|
|
$linksMigration = MediaWikiServices::getInstance()->getLinksMigration();
|
|
list( $nsField, $titleField ) = $linksMigration->getTitleFields( 'templatelinks' );
|
|
|
|
$this->addSelect( [ 'tpl_sel_title' => 'tplsrc.page_title', 'tpl_sel_ns' => 'tplsrc.page_namespace' ] );
|
|
$where = $this->tableNames['page'] . '.page_namespace = lt.' . $nsField . ' AND ' .
|
|
$this->tableNames['page'] . '.page_title = lt.' . $titleField . ' AND tplsrc.page_id = tpl.tl_from AND ';
|
|
$ors = [];
|
|
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$ors[] = 'tpl.tl_from = ' . (int)$link->getArticleID();
|
|
}
|
|
}
|
|
|
|
$where .= '(' . implode( ' OR ', $ors ) . ')';
|
|
}
|
|
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'uses' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _uses( $option ) {
|
|
$this->addTables( [
|
|
'linktarget' => 'lt',
|
|
'templatelinks' => 'tl',
|
|
] );
|
|
|
|
$where = $this->tableNames['page'] . '.page_id=tl.tl_from AND lt.lt_id = tl.tl_target_id AND (';
|
|
$ors = [];
|
|
|
|
$linksMigration = MediaWikiServices::getInstance()->getLinksMigration();
|
|
list( $nsField, $titleField ) = $linksMigration->getTitleFields( 'templatelinks' );
|
|
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$_or = '(lt.' . $nsField . '=' . (int)$link->getNamespace();
|
|
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or .= ' AND LOWER(CAST(lt.' . $titleField . ' AS char)) = LOWER(' . $this->dbr->addQuotes( $link->getDBkey() ) . '))';
|
|
} else {
|
|
$_or .= ' AND ' . $titleField . ' = ' . $this->dbr->addQuotes( $link->getDBkey() ) . ')';
|
|
}
|
|
|
|
$ors[] = $_or;
|
|
}
|
|
}
|
|
|
|
$where .= implode( ' OR ', $ors ) . ')';
|
|
$this->addWhere( $where );
|
|
}
|
|
|
|
/**
|
|
* Set SQL for 'notuses' parameter.
|
|
*
|
|
* @param mixed $option
|
|
*/
|
|
private function _notuses( $option ) {
|
|
if ( count( $option ) > 0 ) {
|
|
$where = $this->tableNames['page'] . '.page_id NOT IN (SELECT ' . $this->tableNames['templatelinks'] . '.tl_from FROM ' . $this->tableNames['templatelinks'] . ' INNER JOIN ' . $this->tableNames['linktarget'] . ' ON ' . $this->tableNames['linktarget'] . '.lt_id = ' . $this->tableNames['templatelinks'] . '.tl_target_id WHERE (';
|
|
$ors = [];
|
|
|
|
$linksMigration = MediaWikiServices::getInstance()->getLinksMigration();
|
|
list( $nsField, $titleField ) = $linksMigration->getTitleFields( 'templatelinks' );
|
|
|
|
foreach ( $option as $linkGroup ) {
|
|
foreach ( $linkGroup as $link ) {
|
|
$_or = '(' . $this->tableNames['linktarget'] . '.' . $nsField . '=' . (int)$link->getNamespace();
|
|
|
|
if ( $this->parameters->getParameter( 'ignorecase' ) ) {
|
|
$_or .= ' AND LOWER(CAST(' . $this->tableNames['linktarget'] . '.' . $titleField . ' AS char)) = LOWER(' . $this->dbr->addQuotes( $link->getDBkey() ) . '))';
|
|
} else {
|
|
$_or .= ' AND ' . $this->tableNames['linktarget'] . '.' . $titleField . ' = ' . $this->dbr->addQuotes( $link->getDBkey() ) . ')';
|
|
}
|
|
$ors[] = $_or;
|
|
}
|
|
}
|
|
|
|
$where .= implode( ' OR ', $ors ) . '))';
|
|
}
|
|
|
|
$this->addWhere( $where ?? '' );
|
|
}
|
|
}
|