mirror of
https://gerrit.wikimedia.org/r/mediawiki/extensions/Echo
synced 2024-12-11 23:46:53 +00:00
69 lines
1.4 KiB
PHP
69 lines
1.4 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Cache class that maps revision id to Revision object
|
||
|
|
*/
|
||
|
|
class EchoRevisionLocalCache extends EchoLocalCache {
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @var EchoRevisionLocalCache
|
||
|
|
*/
|
||
|
|
private static $instance;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* The current wiki id
|
||
|
|
* @var string|null
|
||
|
|
*/
|
||
|
|
private static $wiki;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Create a EchoRevisionLocalCache object
|
||
|
|
* @return EchoRevisionLocalCache
|
||
|
|
*/
|
||
|
|
public static function create() {
|
||
|
|
// A job queue may run against multiple wikis,
|
||
|
|
// initialize a new one for the current wiki
|
||
|
|
if ( wfWikiId() != self::$wiki ) {
|
||
|
|
self::$instance = null;
|
||
|
|
self::$wiki = wfWikiId();
|
||
|
|
}
|
||
|
|
if ( !self::$instance ) {
|
||
|
|
self::$instance = new EchoRevisionLocalCache();
|
||
|
|
}
|
||
|
|
return self::$instance;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritDoc}
|
||
|
|
*/
|
||
|
|
protected function resolve() {
|
||
|
|
if ( $this->lookups ) {
|
||
|
|
// @Todo Add newFromIds() to Revision
|
||
|
|
$dbr = wfGetDB( DB_SLAVE );
|
||
|
|
$fields = array_merge(
|
||
|
|
Revision::selectFields(),
|
||
|
|
Revision::selectPageFields(),
|
||
|
|
Revision::selectUserFields()
|
||
|
|
);
|
||
|
|
$res = $dbr->select(
|
||
|
|
array( 'revision', 'page', 'user' ),
|
||
|
|
$fields,
|
||
|
|
array( 'rev_id' => $this->lookups ),
|
||
|
|
__METHOD__,
|
||
|
|
array(),
|
||
|
|
array(
|
||
|
|
'page' => Revision::pageJoinCond(),
|
||
|
|
'user' => Revision::userJoinCond()
|
||
|
|
)
|
||
|
|
);
|
||
|
|
if ( $res ) {
|
||
|
|
foreach ( $res as $row ) {
|
||
|
|
$this->targets->set( $row->rev_id, new Revision( $row ) );
|
||
|
|
}
|
||
|
|
$this->lookups = array();
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|