*/
require_once __DIR__ . '/backup.inc';
+require_once __DIR__ . '/7zip.inc';
require_once __DIR__ . '/../includes/export/WikiExporter.php';
+use Wikimedia\Rdbms\IMaintainableDatabase;
+
/**
* @ingroup Maintenance
*/
class TextPassDumper extends BackupDumper {
+ /** @var BaseDump */
public $prefetch = null;
+ /** @var string|bool */
+ private $thisPage;
+ /** @var string|bool */
+ private $thisRev;
// when we spend more than maxTimeAllowed seconds on this run, we continue
// processing until we write out the next complete page, then save output file(s),
*/
protected $spawnErr = false;
+ /**
+ * @var bool|XmlDumpWriter
+ */
protected $xmlwriterobj = false;
protected $timeExceeded = false;
protected $firstPageWritten = false;
protected $lastPageWritten = false;
protected $checkpointJustWritten = false;
- protected $checkpointFiles = array();
+ protected $checkpointFiles = [];
/**
- * @var DatabaseBase
+ * @var IMaintainableDatabase
*/
protected $db;
// We do /not/ retry upon failure, but delegate to encapsulating logic, to avoid
// individually retrying at different layers of code.
- // 1. The LoadBalancer.
try {
$this->lb = wfGetLBFactory()->newMainLB();
} catch ( Exception $e ) {
. " rotating DB failed to obtain new load balancer (" . $e->getMessage() . ")" );
}
- // 2. The Connection, through the load balancer.
try {
- $this->db = $this->lb->getConnection( DB_SLAVE, 'dump' );
+ $this->db = $this->lb->getConnection( DB_REPLICA, 'dump' );
} catch ( Exception $e ) {
throw new MWException( __METHOD__
. " rotating DB failed to obtain new database (" . $e->getMessage() . ")" );
xml_set_element_handler(
$parser,
- array( $this, 'startElement' ),
- array( $this, 'endElement' )
+ [ $this, 'startElement' ],
+ [ $this, 'endElement' ]
);
- xml_set_character_data_handler( $parser, array( $this, 'characterData' ) );
+ xml_set_character_data_handler( $parser, [ $this, 'characterData' ] );
$offset = 0; // for context extraction on error reporting
do {
$filenameList = (array)$this->egress->getFilenames();
// we wrote some stuff after last checkpoint that needs renamed
if ( file_exists( $filenameList[0] ) ) {
- $newFilenames = array();
+ $newFilenames = [];
# we might have just written the header and footer and had no
# pages or revisions written... perhaps they were all deleted
# there's no pageID 0 so we use that. the caller is responsible
if ( $model === null && $wgContentHandlerUseDB ) {
$row = $this->db->selectRow(
'revision',
- array( 'rev_content_model', 'rev_content_format' ),
- array( 'rev_id' => $this->thisRev ),
+ [ 'rev_content_model', 'rev_content_format' ],
+ [ 'rev_id' => $this->thisRev ],
__METHOD__
);
}
while ( $failures < $this->maxFailures ) {
-
// As soon as we found a good text for the $id, we will return immediately.
// Hence, if we make it past the try catch block, we know that we did not
// find a good text.
if ( $text === false && isset( $this->prefetch ) && $prefetchNotTried ) {
$prefetchNotTried = false;
$tryIsPrefetch = true;
- $text = $this->prefetch->prefetch( intval( $this->thisPage ),
- intval( $this->thisRev ) );
+ $text = $this->prefetch->prefetch( (int)$this->thisPage, (int)$this->thisRev );
if ( $text === null ) {
$text = false;
if ( $model !== CONTENT_MODEL_WIKITEXT ) {
$revLength = strlen( $text );
} else {
- $revLength = $this->db->selectField( 'revision', 'rev_len', array( 'rev_id' => $revID ) );
+ $revLength = $this->db->selectField( 'revision', 'rev_len', [ 'rev_id' => $revID ] );
}
if ( strlen( $text ) == $revLength ) {
throw new MWException( __METHOD__ . "No database available" );
}
$row = $this->db->selectRow( 'text',
- array( 'old_text', 'old_flags' ),
- array( 'old_id' => $id ),
+ [ 'old_text', 'old_flags' ],
+ [ 'old_id' => $id ],
__METHOD__ );
$text = Revision::getRevisionText( $row );
if ( $text === false ) {
if ( file_exists( "$IP/../multiversion/MWScript.php" ) ) {
$cmd = implode( " ",
array_map( 'wfEscapeShellArg',
- array(
+ [
$this->php,
"$IP/../multiversion/MWScript.php",
"fetchText.php",
- '--wiki', wfWikiID() ) ) );
+ '--wiki', wfWikiID() ] ) );
} else {
$cmd = implode( " ",
array_map( 'wfEscapeShellArg',
- array(
+ [
$this->php,
"$IP/maintenance/fetchText.php",
- '--wiki', wfWikiID() ) ) );
+ '--wiki', wfWikiID() ] ) );
}
- $spec = array(
- 0 => array( "pipe", "r" ),
- 1 => array( "pipe", "w" ),
- 2 => array( "file", "/dev/null", "a" ) );
- $pipes = array();
+ $spec = [
+ 0 => [ "pipe", "r" ],
+ 1 => [ "pipe", "w" ],
+ 2 => [ "file", "/dev/null", "a" ] ];
+ $pipes = [];
$this->progress( "Spawning database subprocess: $cmd" );
$this->spawnProc = proc_open( $cmd, $spec, $pipes );
$format = $format === '' ? null : $format;
$text = $this->getText( $id, $model, $format );
- $this->openElement = array( $name, array( 'xml:space' => 'preserve' ) );
+ $this->openElement = [ $name, [ 'xml:space' => 'preserve' ] ];
if ( strlen( $text ) > 0 ) {
$this->characterData( $parser, $text );
}
} else {
- $this->openElement = array( $name, $attribs );
+ $this->openElement = [ $name, $attribs ];
}
}
// this could be more than one file if we had more than one output arg
$filenameList = (array)$this->egress->getFilenames();
- $newFilenames = array();
+ $newFilenames = [];
$firstPageID = str_pad( $this->firstPageWritten, 9, "0", STR_PAD_LEFT );
$lastPageID = str_pad( $this->lastPageWritten, 9, "0", STR_PAD_LEFT );
$filenamesCount = count( $filenameList );
dépôts / lhc / web / wiklou.git / blobdiff