- $row = $dbw->selectRow( 'job', '*', array( 'job_cmd' => $type ), __METHOD__,
- array( 'LIMIT' => 1 ));
-
- if ($row === false) {
+ if ( $row === false ) {
$dbw->delete( 'job', array( 'job_id' => $row->job_id ), __METHOD__ );
$affected = $dbw->affectedRows();
$dbw->delete( 'job', array( 'job_id' => $row->job_id ), __METHOD__ );
$affected = $dbw->affectedRows();
$job = Job::factory( $row->job_cmd, $title, Job::extractBlob( $row->job_params ), $row->job_id );
$dbw->delete( 'job', $job->insertFields(), __METHOD__ );
$job = Job::factory( $row->job_cmd, $title, Job::extractBlob( $row->job_params ), $row->job_id );
$dbw->delete( 'job', $job->insertFields(), __METHOD__ );
*/
$row = $dbr->selectRow( 'job', '*', "job_id >= ${offset}", __METHOD__,
*/
$row = $dbr->selectRow( 'job', '*', "job_id >= ${offset}", __METHOD__,
// Refetching without offset is needed as some of job IDs could have had delayed commits
// and have lower IDs than jobs already executed, blame concurrency :)
//
// Refetching without offset is needed as some of job IDs could have had delayed commits
// and have lower IDs than jobs already executed, blame concurrency :)
//
$row = $dbr->selectRow( 'job', '*', '', __METHOD__,
$row = $dbr->selectRow( 'job', '*', '', __METHOD__,
$dbw = wfGetDB( DB_MASTER );
$dbw->delete( 'job', array( 'job_id' => $row->job_id ), __METHOD__ );
$affected = $dbw->affectedRows();
$dbw = wfGetDB( DB_MASTER );
$dbw->delete( 'job', array( 'job_id' => $row->job_id ), __METHOD__ );
$affected = $dbw->affectedRows();
// Delete the random row
$dbw->delete( 'job', array( 'job_id' => $row->job_id ), __METHOD__ );
$affected = $dbw->affectedRows();
// Delete the random row
$dbw->delete( 'job', array( 'job_id' => $row->job_id ), __METHOD__ );
$affected = $dbw->affectedRows();
$dbw->insert( 'job', $fields, __METHOD__ );
}
protected function insertFields() {
$dbw->insert( 'job', $fields, __METHOD__ );
}
protected function insertFields() {
'job_cmd' => $this->command,
'job_namespace' => $this->title->getNamespace(),
'job_title' => $this->title->getDBkey(),
'job_cmd' => $this->command,
'job_namespace' => $this->title->getNamespace(),
'job_title' => $this->title->getDBkey(),