3 * Replication-safe online upgrade script for log_id/log_deleted
6 * @ingroup MaintenanceArchive
9 require( dirname(__FILE__
).'/../commandLine.inc' );
13 var $batchSize = 1000;
17 $this->dbw
= wfGetDB( DB_MASTER
);
18 $logging = $this->dbw
->tableName( 'logging' );
19 $logging_1_10 = $this->dbw
->tableName( 'logging_1_10' );
20 $logging_pre_1_10 = $this->dbw
->tableName( 'logging_pre_1_10' );
22 if ( $this->dbw
->tableExists( 'logging_pre_1_10' ) && !$this->dbw
->tableExists( 'logging' ) ) {
23 # Fix previous aborted run
24 echo "Cleaning up from previous aborted run\n";
25 $this->dbw
->query( "RENAME TABLE $logging_pre_1_10 TO $logging", __METHOD__
);
28 if ( $this->dbw
->tableExists( 'logging_pre_1_10' ) ) {
29 echo "This script has already been run to completion\n";
33 # Create the target table
34 if ( !$this->dbw
->tableExists( 'logging_1_10' ) ) {
35 global $wgDBTableOptions;
38 CREATE TABLE $logging_1_10 (
39 -- Log ID, for referring to this specific log entry, probably for deletion and such.
40 log_id int unsigned NOT NULL auto_increment,
42 -- Symbolic keys for the general log type and the action type
43 -- within the log. The output format will be controlled by the
44 -- action field, but only the type controls categorization.
45 log_type varbinary(10) NOT NULL default '',
46 log_action varbinary(10) NOT NULL default '',
49 log_timestamp binary(14) NOT NULL default '19700101000000',
51 -- The user who performed this action; key to user_id
52 log_user int unsigned NOT NULL default 0,
54 -- Key to the page affected. Where a user is the target,
55 -- this will point to the user page.
56 log_namespace int NOT NULL default 0,
57 log_title varchar(255) binary NOT NULL default '',
59 -- Freeform text. Interpreted as edit history comments.
60 log_comment varchar(255) NOT NULL default '',
62 -- LF separated list of miscellaneous parameters
63 log_params blob NOT NULL,
65 -- rev_deleted for logs
66 log_deleted tinyint unsigned NOT NULL default '0',
68 PRIMARY KEY log_id (log_id),
69 KEY type_time (log_type, log_timestamp),
70 KEY user_time (log_user, log_timestamp),
71 KEY page_time (log_namespace, log_title, log_timestamp),
72 KEY times (log_timestamp)
76 echo "Creating table logging_1_10\n";
77 $this->dbw
->query( $sql, __METHOD__
);
80 # Synchronise the tables
81 echo "Doing initial sync...\n";
82 $this->sync( 'logging', 'logging_1_10' );
85 # Rename the old table away
86 echo "Renaming the old table to $logging_pre_1_10\n";
87 $this->dbw
->query( "RENAME TABLE $logging TO $logging_pre_1_10", __METHOD__
);
89 # Copy remaining old rows
90 # Done before the new table is active so that $copyPos is accurate
91 echo "Doing final sync...\n";
92 $this->sync( 'logging_pre_1_10', 'logging_1_10' );
94 # Move the new table in
95 echo "Moving the new table in...\n";
96 $this->dbw
->query( "RENAME TABLE $logging_1_10 TO $logging", __METHOD__
);
101 * Copy all rows from $srcTable to $dstTable
103 function sync( $srcTable, $dstTable ) {
105 $minTs = $this->dbw
->selectField( $srcTable, 'MIN(log_timestamp)', false, __METHOD__
);
106 $minTsUnix = wfTimestamp( TS_UNIX
, $minTs );
110 $maxTs = $this->dbw
->selectField( $srcTable, 'MAX(log_timestamp)', false, __METHOD__
);
111 $copyPos = $this->dbw
->selectField( $dstTable, 'MAX(log_timestamp)', false, __METHOD__
);
112 $maxTsUnix = wfTimestamp( TS_UNIX
, $maxTs );
113 $copyPosUnix = wfTimestamp( TS_UNIX
, $copyPos );
115 if ( $copyPos === null ) {
118 $percent = ( $copyPosUnix - $minTsUnix ) / ( $maxTsUnix - $minTsUnix ) * 100;
120 printf( "%s %.2f%%\n", $copyPos, $percent );
122 # Handle all entries with timestamp equal to $copyPos
123 if ( $copyPos !== null ) {
124 $numRowsCopied +
= $this->copyExactMatch( $srcTable, $dstTable, $copyPos );
127 # Now copy a batch of rows
128 if ( $copyPos === null ) {
131 $conds = array( 'log_timestamp > ' . $this->dbw
->addQuotes( $copyPos ) );
133 $srcRes = $this->dbw
->select( $srcTable, '*', $conds, __METHOD__
,
134 array( 'LIMIT' => $batchSize, 'ORDER BY' => 'log_timestamp' ) );
136 if ( ! $srcRes->numRows() ) {
142 foreach ( $srcRes as $srcRow ) {
143 $batch[] = (array)$srcRow;
145 $this->dbw
->insert( $dstTable, $batch, __METHOD__
);
146 $numRowsCopied +
= count( $batch );
148 wfWaitForSlaves( 5 );
150 echo "Copied $numRowsCopied rows\n";
153 function copyExactMatch( $srcTable, $dstTable, $copyPos ) {
155 $srcRes = $this->dbw
->select( $srcTable, '*', array( 'log_timestamp' => $copyPos ), __METHOD__
);
156 $dstRes = $this->dbw
->select( $dstTable, '*', array( 'log_timestamp' => $copyPos ), __METHOD__
);
158 if ( $srcRes->numRows() ) {
159 $srcRow = $srcRes->fetchObject();
160 $srcFields = array_keys( (array)$srcRow );
162 $dstRowsSeen = array();
164 # Make a hashtable of rows that already exist in the destination
165 foreach ( $dstRes as $dstRow ) {
166 $reducedDstRow = array();
167 foreach ( $srcFields as $field ) {
168 $reducedDstRow[$field] = $dstRow->$field;
170 $hash = md5( serialize( $reducedDstRow ) );
171 $dstRowsSeen[$hash] = true;
174 # Copy all the source rows that aren't already in the destination
175 foreach ( $srcRes as $srcRow ) {
176 $hash = md5( serialize( (array)$srcRow ) );
177 if ( !isset( $dstRowsSeen[$hash] ) ) {
178 $this->dbw
->insert( $dstTable, (array)$srcRow, __METHOD__
);
183 return $numRowsCopied;
187 $ul = new UpdateLogging
;