1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
|
<?php
/**
* Replication-safe online upgrade script for log_id/log_deleted
*
* @file
* @ingroup MaintenanceArchive
*/
require( dirname(__FILE__).'/../commandLine.inc' );
class UpdateLogging {
var $dbw;
var $batchSize = 1000;
var $minTs = false;
function execute() {
$this->dbw = wfGetDB( DB_MASTER );
$logging = $this->dbw->tableName( 'logging' );
$logging_1_10 = $this->dbw->tableName( 'logging_1_10' );
$logging_pre_1_10 = $this->dbw->tableName( 'logging_pre_1_10' );
if ( $this->dbw->tableExists( 'logging_pre_1_10' ) && !$this->dbw->tableExists( 'logging' ) ) {
# Fix previous aborted run
echo "Cleaning up from previous aborted run\n";
$this->dbw->query( "RENAME TABLE $logging_pre_1_10 TO $logging", __METHOD__ );
}
if ( $this->dbw->tableExists( 'logging_pre_1_10' ) ) {
echo "This script has already been run to completion\n";
return;
}
# Create the target table
if ( !$this->dbw->tableExists( 'logging_1_10' ) ) {
global $wgDBTableOptions;
$sql = <<<EOT
CREATE TABLE $logging_1_10 (
-- Log ID, for referring to this specific log entry, probably for deletion and such.
log_id int unsigned NOT NULL auto_increment,
-- Symbolic keys for the general log type and the action type
-- within the log. The output format will be controlled by the
-- action field, but only the type controls categorization.
log_type varbinary(10) NOT NULL default '',
log_action varbinary(10) NOT NULL default '',
-- Timestamp. Duh.
log_timestamp binary(14) NOT NULL default '19700101000000',
-- The user who performed this action; key to user_id
log_user int unsigned NOT NULL default 0,
-- Key to the page affected. Where a user is the target,
-- this will point to the user page.
log_namespace int NOT NULL default 0,
log_title varchar(255) binary NOT NULL default '',
-- Freeform text. Interpreted as edit history comments.
log_comment varchar(255) NOT NULL default '',
-- LF separated list of miscellaneous parameters
log_params blob NOT NULL,
-- rev_deleted for logs
log_deleted tinyint unsigned NOT NULL default '0',
PRIMARY KEY log_id (log_id),
KEY type_time (log_type, log_timestamp),
KEY user_time (log_user, log_timestamp),
KEY page_time (log_namespace, log_title, log_timestamp),
KEY times (log_timestamp)
) $wgDBTableOptions
EOT;
echo "Creating table logging_1_10\n";
$this->dbw->query( $sql, __METHOD__ );
}
# Synchronise the tables
echo "Doing initial sync...\n";
$this->sync( 'logging', 'logging_1_10' );
echo "Sync done\n\n";
# Rename the old table away
echo "Renaming the old table to $logging_pre_1_10\n";
$this->dbw->query( "RENAME TABLE $logging TO $logging_pre_1_10", __METHOD__ );
# Copy remaining old rows
# Done before the new table is active so that $copyPos is accurate
echo "Doing final sync...\n";
$this->sync( 'logging_pre_1_10', 'logging_1_10' );
# Move the new table in
echo "Moving the new table in...\n";
$this->dbw->query( "RENAME TABLE $logging_1_10 TO $logging", __METHOD__ );
echo "Finished.\n";
}
/**
* Copy all rows from $srcTable to $dstTable
*/
function sync( $srcTable, $dstTable ) {
$batchSize = 1000;
$minTs = $this->dbw->selectField( $srcTable, 'MIN(log_timestamp)', false, __METHOD__ );
$minTsUnix = wfTimestamp( TS_UNIX, $minTs );
$numRowsCopied = 0;
while ( true ) {
$maxTs = $this->dbw->selectField( $srcTable, 'MAX(log_timestamp)', false, __METHOD__ );
$copyPos = $this->dbw->selectField( $dstTable, 'MAX(log_timestamp)', false, __METHOD__ );
$maxTsUnix = wfTimestamp( TS_UNIX, $maxTs );
$copyPosUnix = wfTimestamp( TS_UNIX, $copyPos );
if ( $copyPos === null ) {
$percent = 0;
} else {
$percent = ( $copyPosUnix - $minTsUnix ) / ( $maxTsUnix - $minTsUnix ) * 100;
}
printf( "%s %.2f%%\n", $copyPos, $percent );
# Handle all entries with timestamp equal to $copyPos
if ( $copyPos !== null ) {
$numRowsCopied += $this->copyExactMatch( $srcTable, $dstTable, $copyPos );
}
# Now copy a batch of rows
if ( $copyPos === null ) {
$conds = false;
} else {
$conds = array( 'log_timestamp > ' . $this->dbw->addQuotes( $copyPos ) );
}
$srcRes = $this->dbw->select( $srcTable, '*', $conds, __METHOD__,
array( 'LIMIT' => $batchSize, 'ORDER BY' => 'log_timestamp' ) );
if ( ! $srcRes->numRows() ) {
# All done
break;
}
$batch = array();
foreach ( $srcRes as $srcRow ) {
$batch[] = (array)$srcRow;
}
$this->dbw->insert( $dstTable, $batch, __METHOD__ );
$numRowsCopied += count( $batch );
wfWaitForSlaves( 5 );
}
echo "Copied $numRowsCopied rows\n";
}
function copyExactMatch( $srcTable, $dstTable, $copyPos ) {
$numRowsCopied = 0;
$srcRes = $this->dbw->select( $srcTable, '*', array( 'log_timestamp' => $copyPos ), __METHOD__ );
$dstRes = $this->dbw->select( $dstTable, '*', array( 'log_timestamp' => $copyPos ), __METHOD__ );
if ( $srcRes->numRows() ) {
$srcRow = $srcRes->fetchObject();
$srcFields = array_keys( (array)$srcRow );
$srcRes->seek( 0 );
$dstRowsSeen = array();
# Make a hashtable of rows that already exist in the destination
foreach ( $dstRes as $dstRow ) {
$reducedDstRow = array();
foreach ( $srcFields as $field ) {
$reducedDstRow[$field] = $dstRow->$field;
}
$hash = md5( serialize( $reducedDstRow ) );
$dstRowsSeen[$hash] = true;
}
# Copy all the source rows that aren't already in the destination
foreach ( $srcRes as $srcRow ) {
$hash = md5( serialize( (array)$srcRow ) );
if ( !isset( $dstRowsSeen[$hash] ) ) {
$this->dbw->insert( $dstTable, (array)$srcRow, __METHOD__ );
$numRowsCopied++;
}
}
}
return $numRowsCopied;
}
}
$ul = new UpdateLogging;
$ul->execute();
|
