42f4f1a97378a65357ef384f4d6958180cea69e5
3 * Version of FileJournal that logs to a DB table.
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License along
16 * with this program; if not, write to the Free Software Foundation, Inc.,
17 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
18 * http://www.gnu.org/copyleft/gpl.html
21 * @ingroup FileJournal
22 * @author Aaron Schulz
26 * Version of FileJournal that logs to a DB table
29 class DBFileJournal
extends FileJournal
{
30 /** @var DatabaseBase */
33 protected $wiki = false; // string; wiki DB name
36 * Construct a new instance from configuration.
38 * 'wiki' : wiki name to use for LoadBalancer
40 * @param $config Array
42 protected function __construct( array $config ) {
43 parent
::__construct( $config );
45 $this->wiki
= $config['wiki'];
49 * @see FileJournal::logChangeBatch()
52 protected function doLogChangeBatch( array $entries, $batchId ) {
53 $status = Status
::newGood();
56 $dbw = $this->getMasterDB();
57 } catch ( DBError
$e ) {
58 $status->fatal( 'filejournal-fail-dbconnect', $this->backend
);
63 $now = wfTimestamp( TS_UNIX
);
66 foreach ( $entries as $entry ) {
68 'fj_batch_uuid' => $batchId,
69 'fj_backend' => $this->backend
,
70 'fj_op' => $entry['op'],
71 'fj_path' => $entry['path'],
72 'fj_new_sha1' => $entry['newSha1'],
73 'fj_timestamp' => $dbw->timestamp( $now )
78 $dbw->insert( 'filejournal', $data, __METHOD__
);
79 if ( mt_rand( 0, 99 ) == 0 ) {
80 $this->purgeOldLogs(); // occasionally delete old logs
82 } catch ( DBError
$e ) {
83 $status->fatal( 'filejournal-fail-dbquery', $this->backend
);
92 * @see FileJournal::doGetCurrentPosition()
93 * @return integer|false
95 protected function doGetCurrentPosition() {
96 $dbw = $this->getMasterDB();
98 return $dbw->selectField( 'filejournal', 'MAX(fj_id)',
99 array( 'fj_backend' => $this->backend
),
105 * @see FileJournal::doGetPositionAtTime()
106 * @param $time integer|string timestamp
107 * @return integer|false
109 protected function doGetPositionAtTime( $time ) {
110 $dbw = $this->getMasterDB();
112 $encTimestamp = $dbw->addQuotes( $dbw->timestamp( $time ) );
114 return $dbw->selectField( 'filejournal', 'fj_id',
115 array( 'fj_backend' => $this->backend
, "fj_timestamp <= $encTimestamp" ),
117 array( 'ORDER BY' => 'fj_timestamp DESC' )
122 * @see FileJournal::doGetChangeEntries()
126 protected function doGetChangeEntries( $start, $limit ) {
127 $dbw = $this->getMasterDB();
129 $res = $dbw->select( 'filejournal', '*',
131 'fj_backend' => $this->backend
,
132 'fj_id >= ' . $dbw->addQuotes( (int)$start ) ), // $start may be 0
134 array_merge( array( 'ORDER BY' => 'fj_id ASC' ),
135 $limit ?
array( 'LIMIT' => $limit ) : array() )
139 foreach ( $res as $row ) {
141 foreach ( (array)$row as $key => $value ) {
142 $item[substr( $key, 3 )] = $value; // "fj_op" => "op"
151 * @see FileJournal::purgeOldLogs()
155 protected function doPurgeOldLogs() {
156 $status = Status
::newGood();
157 if ( $this->ttlDays
<= 0 ) {
158 return $status; // nothing to do
161 $dbw = $this->getMasterDB();
162 $dbCutoff = $dbw->timestamp( time() - 86400 * $this->ttlDays
);
164 $dbw->delete( 'filejournal',
165 array( 'fj_timestamp < ' . $dbw->addQuotes( $dbCutoff ) ),
173 * Get a master connection to the logging DB
175 * @return DatabaseBase
178 protected function getMasterDB() {
180 // Get a separate connection in autocommit mode
181 $lb = wfGetLBFactory()->newMainLB();
182 $this->dbw
= $lb->getConnection( DB_MASTER
, array(), $this->wiki
);
183 $this->dbw
->clearFlag( DBO_TRX
);