LinksDeletionUpdate.php

Go to the documentation of this file.

<?php
class LinksDeletionUpdate extends SqlDataUpdate implements EnqueueableDataUpdate {
    protected $page;
    protected $pageId;
    protected $timestamp;

    function __construct( WikiPage $page, $pageId = null, $timestamp = null ) {
        parent::__construct( false ); // no implicit transaction

        $this->page = $page;
        if ( $pageId ) {
            $this->pageId = $pageId; // page ID at time of deletion
        } elseif ( $page->exists() ) {
            $this->pageId = $page->getId();
        } else {
            throw new MWException( "Page ID not known, perhaps the page doesn't exist?" );
        }

        $this->timestamp = $timestamp ?: wfTimestampNow();
    }

    public function doUpdate() {
        # Page may already be deleted, so don't just getId()
        $id = $this->pageId;

        # Delete restrictions for it
        $this->mDb->delete( 'page_restrictions', [ 'pr_page' => $id ], __METHOD__ );

        # Fix category table counts
        $cats = $this->mDb->selectFieldValues(
            'categorylinks',
            'cl_to',
            [ 'cl_from' => $id ],
            __METHOD__
        );
        $this->page->updateCategoryCounts( [], $cats );

        # If using cascading deletes, we can skip some explicit deletes
        if ( !$this->mDb->cascadingDeletes() ) {
            # Delete outgoing links
            $this->mDb->delete( 'pagelinks', [ 'pl_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'imagelinks', [ 'il_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'categorylinks', [ 'cl_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'templatelinks', [ 'tl_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'externallinks', [ 'el_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'langlinks', [ 'll_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'iwlinks', [ 'iwl_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'redirect', [ 'rd_from' => $id ], __METHOD__ );
            $this->mDb->delete( 'page_props', [ 'pp_page' => $id ], __METHOD__ );
        }

        # If using cleanup triggers, we can skip some manual deletes
        if ( !$this->mDb->cleanupTriggers() ) {
            $title = $this->page->getTitle();
            # Find recentchanges entries to clean up...
            $rcIdsForTitle = $this->mDb->selectFieldValues( 'recentchanges',
                'rc_id',
                [
                    'rc_type != ' . RC_LOG,
                    'rc_namespace' => $title->getNamespace(),
                    'rc_title' => $title->getDBkey(),
                    'rc_timestamp < ' .
                        $this->mDb->addQuotes( $this->mDb->timestamp( $this->timestamp ) )
                ],
                __METHOD__
            );
            $rcIdsForPage = $this->mDb->selectFieldValues( 'recentchanges',
                'rc_id',
                [ 'rc_type != ' . RC_LOG, 'rc_cur_id' => $id ],
                __METHOD__
            );

            # T98706: delete PK to avoid lock contention with RC delete log insertions
            $rcIds = array_merge( $rcIdsForTitle, $rcIdsForPage );
            if ( $rcIds ) {
                $this->mDb->delete( 'recentchanges', [ 'rc_id' => $rcIds ], __METHOD__ );
            }
        }
    }

    public function getAsJobSpecification() {
        return [
            'wiki' => $this->mDb->getWikiID(),
            'job'  => new JobSpecification(
                'deleteLinks',
                [ 'pageId' => $this->pageId, 'timestamp' => $this->timestamp ],
                [ 'removeDuplicates' => true ],
                $this->page->getTitle()
            )
        ];
    }
}