X-Git-Url: https://git.heureux-cyclage.org/?a=blobdiff_plain;f=includes%2FQueryPage.php;h=0b5875080316e33e5479c3b6c5910fff6c1295cc;hb=56c2036f1e780e4ede9e83f803fdf57929daacfb;hp=925083e0d0c356e63a2e088f9b6f7bd5609e008a;hpb=4b279acd46437f7e01e6e876c777dbb32a6908dc;p=lhc%2Fweb%2Fwiklou.git diff --git a/includes/QueryPage.php b/includes/QueryPage.php index 925083e0d0..0b58750803 100644 --- a/includes/QueryPage.php +++ b/includes/QueryPage.php @@ -1,47 +1,89 @@ listoutput; + * + * @param bool $bool + */ + function setListoutput( $bool ) { + $this->listoutput = $bool; + } /** * Subclasses return their name here. Make sure the name is also @@ -52,6 +94,15 @@ class QueryPage { return ''; } + /** + * Return title object representing this page + * + * @return Title + */ + function getTitle() { + return SpecialPage::getTitleFor( $this->getName() ); + } + /** * Subclasses return an SQL query here. * @@ -93,6 +144,18 @@ class QueryPage { return $wgDisableQueryPages; } + /** + * Whether or not the output of the page in question is retrived from + * the database cache. + * + * @return bool + */ + function isCached() { + global $wgMiserMode; + + return $this->isExpensive() && $wgMiserMode; + } + /** * Sometime we dont want to build rss / atom feeds. */ @@ -112,11 +175,21 @@ class QueryPage { /** * The content returned by this function will be output before any result - */ + */ function getPageHeader( ) { return ''; } - + + /** + * If using extra form wheely-dealies, return a set of parameters here + * as an associative array. They will be encoded and added to the paging + * links (prev/next/lengths). + * @return array + */ + function linkParameters() { + return array(); + } + /** * Some special pages (for example SpecialListusers) might not return the * current object formatted, but return the previous one instead. @@ -127,143 +200,271 @@ class QueryPage { return false; } + /** + * Clear the cache and save new results + */ + function recache( $limit, $ignoreErrors = true ) { + $fname = get_class($this) . '::recache'; + $dbw = wfGetDB( DB_MASTER ); + $dbr = wfGetDB( DB_SLAVE, array( $this->getName(), 'QueryPage::recache', 'vslow' ) ); + if ( !$dbw || !$dbr ) { + return false; + } + + $querycache = $dbr->tableName( 'querycache' ); + + if ( $ignoreErrors ) { + $ignoreW = $dbw->ignoreErrors( true ); + $ignoreR = $dbr->ignoreErrors( true ); + } + + # Clear out any old cached data + $dbw->delete( 'querycache', array( 'qc_type' => $this->getName() ), $fname ); + # Do query + $sql = $this->getSQL() . $this->getOrder(); + if ($limit !== false) + $sql = $dbr->limitResult($sql, $limit, 0); + $res = $dbr->query($sql, $fname); + $num = false; + if ( $res ) { + $num = $dbr->numRows( $res ); + # Fetch results + $insertSql = "INSERT INTO $querycache (qc_type,qc_namespace,qc_title,qc_value) VALUES "; + $first = true; + while ( $res && $row = $dbr->fetchObject( $res ) ) { + if ( $first ) { + $first = false; + } else { + $insertSql .= ','; + } + if ( isset( $row->value ) ) { + $value = $row->value; + } else { + $value = 0; + } + + $insertSql .= '(' . + $dbw->addQuotes( $row->type ) . ',' . + $dbw->addQuotes( $row->namespace ) . ',' . + $dbw->addQuotes( $row->title ) . ',' . + $dbw->addQuotes( $value ) . ')'; + } + + # Save results into the querycache table on the master + if ( !$first ) { + if ( !$dbw->query( $insertSql, $fname ) ) { + // Set result to false to indicate error + $dbr->freeResult( $res ); + $res = false; + } + } + if ( $res ) { + $dbr->freeResult( $res ); + } + if ( $ignoreErrors ) { + $dbw->ignoreErrors( $ignoreW ); + $dbr->ignoreErrors( $ignoreR ); + } + + # Update the querycache_info record for the page + $dbw->delete( 'querycache_info', array( 'qci_type' => $this->getName() ), $fname ); + $dbw->insert( 'querycache_info', array( 'qci_type' => $this->getName(), 'qci_timestamp' => $dbw->timestamp() ), $fname ); + + } + return $num; + } + /** * This is the actual workhorse. It does everything needed to make a * real, honest-to-gosh query page. * * @param $offset database query offset * @param $limit database query limit + * @param $shownavigation show navigation like "next 200"? */ - function doQuery( $offset, $limit, $recache = false ) { - global $wgUser, $wgOut, $wgLang, $wgRequest, $wgContLang; - global $wgMiserMode; + function doQuery( $offset, $limit, $shownavigation=true ) { + global $wgUser, $wgOut, $wgLang, $wgContLang; + + $this->offset = $offset; + $this->limit = $limit; $sname = $this->getName(); $fname = get_class($this) . '::doQuery'; - $sql = $this->getSQL(); - $dbr =& wfGetDB( DB_SLAVE ); - $dbw =& wfGetDB( DB_MASTER ); - $querycache = $dbr->tableName( 'querycache' ); + $dbr = wfGetDB( DB_SLAVE ); $wgOut->setSyndicated( $this->isSyndicated() ); - $res = false; - - if ( $this->isExpensive() ) { - // Disabled recache parameter due to retry problems -- TS - // $recache = $wgRequest->getBool( 'recache' ); - - if( $recache ) { - # Clear out any old cached data - $dbw->delete( 'querycache', array( 'qc_type' => $sname ), $fname ); - - # Do query on the (possibly out of date) slave server - $slowDB =& wfGetDB( DB_SLAVE, array( $this->getName(), 'QueryPage-recache', 'vslow' ) ); - $maxstored = 1000; - $res = $slowDB->query( $sql . $this->getOrder() . $dbr->limitResult( $maxstored,0 ), $fname ); - - # Fetch results - $insertSql = "INSERT INTO $querycache (qc_type,qc_namespace,qc_title,qc_value) VALUES "; - $first = true; - while ( $row = $dbr->fetchObject( $res ) ) { - if ( $first ) { - $first = false; - } else { - $insertSql .= ','; - } - if ( isset( $row->value ) ) { - $value = $row->value; - } else { - $value = ''; - } - - $insertSql .= '(' . - $dbw->addQuotes( $row->type ) . ',' . - $dbw->addQuotes( $row->namespace ) . ',' . - $dbw->addQuotes( $row->title ) . ',' . - $dbw->addQuotes( $value ) . ')'; - } - # Save results into the querycache table on the master - if ( !$first ) { - $dbw->query( $insertSql, $fname ); + if ( !$this->isCached() ) { + $sql = $this->getSQL(); + } else { + # Get the cached result + $querycache = $dbr->tableName( 'querycache' ); + $type = $dbr->strencode( $sname ); + $sql = + "SELECT qc_type as type, qc_namespace as namespace,qc_title as title, qc_value as value + FROM $querycache WHERE qc_type='$type'"; + + if( !$this->listoutput ) { + + # Fetch the timestamp of this update + $tRes = $dbr->select( 'querycache_info', array( 'qci_timestamp' ), array( 'qci_type' => $type ), $fname ); + $tRow = $dbr->fetchObject( $tRes ); + + if( $tRow ) { + $updated = $wgLang->timeAndDate( $tRow->qci_timestamp, true, true ); + $wgOut->addMeta( 'Data-Cache-Time', $tRow->qci_timestamp ); + $wgOut->addInlineScript( "var dataCacheTime = '{$tRow->qci_timestamp}';" ); + $wgOut->addWikiMsg( 'perfcachedts', $updated ); + } else { + $wgOut->addWikiMsg( 'perfcached' ); } - # Set result pointer to allow reading for display - $numRows = $dbr->numRows( $res ); - if ( $numRows <= $offset ) { - $num = 0; - } else { - $dbr->dataSeek( $res, $offset ); - $num = max( $limit, $numRows - $offset ); + # If updates on this page have been disabled, let the user know + # that the data set won't be refreshed for now + global $wgDisableQueryPageUpdate; + if( is_array( $wgDisableQueryPageUpdate ) && in_array( $this->getName(), $wgDisableQueryPageUpdate ) ) { + $wgOut->addWikiMsg( 'querypage-no-updates' ); } + } - if( $wgMiserMode || $recache ) { - $type = $dbr->strencode( $sname ); - $sql = - "SELECT qc_type as type, qc_namespace as namespace,qc_title as title, qc_value as value - FROM $querycache WHERE qc_type='$type'"; - } - if( $wgMiserMode ) { - $wgOut->addWikiText( wfMsg( 'perfcached' ) ); - } - } - if ( $res === false ) { - $res = $dbr->query( $sql . $this->getOrder() . - $dbr->limitResult( $limit,$offset ), $fname ); - $num = $dbr->numRows($res); + } - $sk = $wgUser->getSkin( ); + $sql .= $this->getOrder(); + $sql = $dbr->limitResult($sql, $limit, $offset); + $res = $dbr->query( $sql ); + $num = $dbr->numRows($res); - $wgOut->addHTML( $this->getPageHeader() ); + $this->preprocessResults( $dbr, $res ); - $top = wfShowingResults( $offset, $num); - $wgOut->addHTML( "
{$top}\n" ); + $wgOut->addHTML( XML::openElement( 'div', array('class' => 'mw-spcontent') ) ); - # often disable 'next' link when we reach the end - if($num < $limit) { $atend = true; } else { $atend = false; } + # Top header and navigation + if( $shownavigation ) { + $wgOut->addHTML( $this->getPageHeader() ); + if( $num > 0 ) { + $wgOut->addHTML( '
' . wfShowingResults( $offset, $num ) . '
' ); + # Disable the "next" link when we reach the end + $paging = wfViewPrevNext( $offset, $limit, $wgContLang->specialPage( $sname ), + wfArrayToCGI( $this->linkParameters() ), ( $num < $limit ) ); + $wgOut->addHTML( '' . $paging . '
' ); + } else { + # No results to show, so don't bother with "showing X of Y" etc. + # -- just let the user know and give up now + $wgOut->addHTML( '' . wfMsgHtml( 'specialpage-empty' ) . '
' ); + $wgOut->addHTML( XML::closeElement( 'div' ) ); + return; + } + } - $sl = wfViewPrevNext( $offset, $limit , $wgContLang->specialPage( $sname ), "" ,$atend ); - $wgOut->addHTML( "' . $paging . '
' ); + } + + $wgOut->addHTML( XML::closeElement( 'div' ) ); + + return $num; + } - if ( $num > 0 ) { - $s = "{$sl}
\n" ); - return $num; + } + + function openList( $offset ) { + return "\n