doTable( $table ) ) { return true; } /** @var MySQLField $fieldInfo */ $fieldInfo = $this->db->fieldInfo( $table, $field ); if ( $fieldInfo->isBinary() ) { $this->output( "...$table table has correct $field encoding.\n" ); } else { $this->applyPatch( $patchFile, false, "Fixing $field encoding on $table table" ); } } /** * Check whether an index contain a field * * @param string $table Table name * @param string $index Index name to check * @param string $field Field that should be in the index * @return bool */ protected function indexHasField( $table, $index, $field ) { $info = $this->db->indexInfo( $table, $index, __METHOD__ ); if ( $info ) { foreach ( $info as $row ) { if ( $row->Column_name == $field ) { $this->output( "...index $index on table $table includes field $field.\n" ); return true; } } } $this->output( "...index $index on table $table has no field $field; added.\n" ); return false; } protected function doLanguageLinksLengthSync() { $sync = [ [ 'table' => 'l10n_cache', 'field' => 'lc_lang', 'file' => 'patch-l10n_cache-lc_lang-35.sql' ], [ 'table' => 'langlinks', 'field' => 'll_lang', 'file' => 'patch-langlinks-ll_lang-35.sql' ], [ 'table' => 'sites', 'field' => 'site_language', 'file' => 'patch-sites-site_language-35.sql' ], ]; foreach ( $sync as $s ) { $table = $this->db->tableName( $s['table'] ); $field = $s['field']; $res = $this->db->query( "SHOW COLUMNS FROM $table LIKE '$field'", __METHOD__ ); $row = $res->fetchObject(); if ( $row && $row->Type !== "varbinary(35)" ) { $this->applyPatch( $s['file'], false, "Updating length of $field in $table" ); } else { $this->output( "...$field is up-to-date.\n" ); } } } protected function doFixIpbAddressUniqueIndex() { if ( !$this->doTable( 'ipblocks' ) ) { return; } if ( !$this->indexHasField( 'ipblocks', 'ipb_address_unique', 'ipb_anon_only' ) ) { $this->output( "...ipb_address_unique index up-to-date.\n" ); return; } $this->applyPatch( 'patch-ipblocks-fix-ipb_address_unique.sql', false, 'Removing ipb_anon_only column from ipb_address_unique index' ); } protected function doUnsignedSyncronisation() { $sync = [ [ 'table' => 'bot_passwords', 'field' => 'bp_user', 'file' => 'patch-bot_passwords-bp_user-unsigned.sql' ], [ 'table' => 'change_tag', 'field' => 'ct_log_id', 'file' => 'patch-change_tag-ct_log_id-unsigned.sql' ], [ 'table' => 'change_tag', 'field' => 'ct_rev_id', 'file' => 'patch-change_tag-ct_rev_id-unsigned.sql' ], [ 'table' => 'user_newtalk', 'field' => 'user_id', 'file' => 'patch-user_newtalk-user_id-unsigned.sql' ], [ 'table' => 'user_properties', 'field' => 'up_user', 'file' => 'patch-user_properties-up_user-unsigned.sql' ], [ 'table' => 'change_tag', 'field' => 'ct_rc_id', 'file' => 'patch-change_tag-ct_rc_id-unsigned.sql' ] ]; foreach ( $sync as $s ) { if ( !$this->doTable( $s['table'] ) ) { continue; } $info = $this->db->fieldInfo( $s['table'], $s['field'] ); if ( $info === false ) { continue; } $fullName = "{$s['table']}.{$s['field']}"; if ( $info->isUnsigned() ) { $this->output( "...$fullName is already unsigned int.\n" ); continue; } $this->applyPatch( $s['file'], false, "Making $fullName into an unsigned int" ); } return true; } public function getSchemaVars() { global $wgDBTableOptions; $vars = []; $vars['wgDBTableOptions'] = str_replace( 'TYPE', 'ENGINE', $wgDBTableOptions ); $vars['wgDBTableOptions'] = str_replace( 'CHARSET=mysql4', 'CHARSET=binary', $vars['wgDBTableOptions'] ); return $vars; } /** * Drop a default value from a field * * @since 1.36 * @param string $table * @param string $field */ protected function dropDefault( $table, $field ) { $updateKey = "$table-$field-dropDefault"; if ( $this->updateRowExists( $updateKey ) ) { return; } $info = $this->db->fieldInfo( $table, $field ); if ( $info && $info->defaultValue() !== false ) { $this->output( "Removing '$table.$field' default value.\n" ); $table = $this->db->tableName( $table ); $ret = $this->db->query( "ALTER TABLE $table ALTER COLUMN $field DROP DEFAULT", __METHOD__ ); if ( $ret ) { $this->insertUpdateRow( $updateKey ); } } } /** * Set a default value for a field * * @since 1.36 * @param string $table * @param string $field * @param mixed $default */ protected function setDefault( $table, $field, $default ) { $info = $this->db->fieldInfo( $table, $field ); if ( $info && $info->defaultValue() !== $default ) { $this->output( "Changing '$table.$field' default value.\n" ); $table = $this->db->tableName( $table ); $this->db->query( "ALTER TABLE $table ALTER COLUMN $field SET DEFAULT " . $this->db->addQuotes( $default ), __METHOD__ ); } } }