LinksMigration.php

Go to the documentation of this file.

<?php
namespace MediaWiki\Linker;
 
use InvalidArgumentException;
use MediaWiki\Config\Config;
use MediaWiki\MainConfigNames;
 
class LinksMigration {
 
    private $config;
 
    private $linkTargetLookup;
 
    public static $mapping = [
        'templatelinks' => [
            'config' => MainConfigNames::TemplateLinksSchemaMigrationStage,
            'page_id' => 'tl_from',
            'ns' => 'tl_namespace',
            'title' => 'tl_title',
            'target_id' => 'tl_target_id',
            'deprecated_configs' => [ SCHEMA_COMPAT_OLD ],
        ],
        'pagelinks' => [
            'config' => MainConfigNames::PageLinksSchemaMigrationStage,
            'page_id' => 'pl_from',
            'ns' => 'pl_namespace',
            'title' => 'pl_title',
            'target_id' => 'pl_target_id',
            'deprecated_configs' => [],
        ],
    ];
 
    public static $prefixToTableMapping = [
        'tl' => 'templatelinks',
        'pl' => 'pagelinks',
    ];
 
    public function __construct( Config $config, LinkTargetLookup $linktargetLookup ) {
        $this->config = $config;
        $this->linkTargetLookup = $linktargetLookup;
    }
 
    public function getLinksConditions( string $table, LinkTarget $linkTarget ): array {
        $this->assertMapping( $table );
        if ( $this->config->get( self::$mapping[$table]['config'] ) & SCHEMA_COMPAT_READ_NEW ) {
            $targetId = $this->linkTargetLookup->getLinkTargetId( $linkTarget );
            // Not found, it shouldn't pick anything
            if ( !$targetId ) {
                return [ '1=0' ];
            }
            return [
                self::$mapping[$table]['target_id'] => $targetId,
            ];
        } else {
            return [
                self::$mapping[$table]['ns'] => $linkTarget->getNamespace(),
                self::$mapping[$table]['title'] => $linkTarget->getDBkey(),
            ];
        }
    }
 
    public function getQueryInfo( string $table, string $joinTable = 'linktarget', string $joinType = 'JOIN' ) {
        $this->assertMapping( $table );
        if ( $this->config->get( self::$mapping[$table]['config'] ) & SCHEMA_COMPAT_READ_NEW ) {
            $targetId = self::$mapping[$table]['target_id'];
            if ( $joinTable === 'linktarget' ) {
                $tables = [ $table, 'linktarget' ];
            } else {
                $tables = [ 'linktarget', $table ];
            }
            return [
                'tables' => $tables,
                'fields' => [
                    $targetId,
                    'lt_namespace',
                    'lt_title'
                ],
                'joins' => [ $joinTable => [
                    $joinType,
                    [ "$targetId=lt_id" ]
                ] ],
            ];
        } else {
            return [
                'fields' => [
                    self::$mapping[$table]['ns'],
                    self::$mapping[$table]['title']
                ],
                'tables' => [ $table ],
                'joins' => [],
            ];
        }
    }
 
    public function getTitleFields( $table ) {
        $this->assertMapping( $table );
 
        if ( $this->config->get( self::$mapping[$table]['config'] ) & SCHEMA_COMPAT_READ_NEW ) {
            return [ 'lt_namespace', 'lt_title' ];
        } else {
            return [ self::$mapping[$table]['ns'], self::$mapping[$table]['title'] ];
        }
    }
 
    private function assertMapping( string $table ) {
        if ( !isset( self::$mapping[$table] ) ) {
            throw new InvalidArgumentException(
                "LinksMigration doesn't support the $table table yet"
            );
        }
 
        $config = $this->config->get( self::$mapping[$table]['config'] );
        if ( in_array( $config, self::$mapping[$table]['deprecated_configs'] ) ) {
            throw new InvalidArgumentException(
                "LinksMigration config $config on $table table is not supported anymore"
            );
        }
    }
}