MediaWiki REL1_31
PostgresUpdater.php
Go to the documentation of this file.
1<?php
25
33
37 protected $db;
38
44 protected function getCoreUpdateList() {
45 return [
46 # rename tables 1.7.3
47 # r15791 Change reserved word table names "user" and "text"
48 [ 'renameTable', 'user', 'mwuser' ],
49 [ 'renameTable', 'text', 'pagecontent' ],
50 [ 'renameIndex', 'mwuser', 'user_pkey', 'mwuser_pkey' ],
51 [ 'renameIndex', 'mwuser', 'user_user_name_key', 'mwuser_user_name_key' ],
52 [ 'renameIndex', 'pagecontent', 'text_pkey', 'pagecontent_pkey' ],
53
54 # renamed sequences
55 [ 'renameSequence', 'ipblocks_ipb_id_val', 'ipblocks_ipb_id_seq' ],
56 [ 'renameSequence', 'rev_rev_id_val', 'revision_rev_id_seq' ],
57 [ 'renameSequence', 'text_old_id_val', 'text_old_id_seq' ],
58 [ 'renameSequence', 'rc_rc_id_seq', 'recentchanges_rc_id_seq' ],
59 [ 'renameSequence', 'log_log_id_seq', 'logging_log_id_seq' ],
60 [ 'renameSequence', 'pr_id_val', 'page_restrictions_pr_id_seq' ],
61 [ 'renameSequence', 'us_id_seq', 'uploadstash_us_id_seq' ],
62
63 # since r58263
64 [ 'renameSequence', 'category_id_seq', 'category_cat_id_seq' ],
65
66 # new sequences if not renamed above
67 [ 'addSequence', 'logging', false, 'logging_log_id_seq' ],
68 [ 'addSequence', 'page_restrictions', false, 'page_restrictions_pr_id_seq' ],
69 [ 'addSequence', 'filearchive', 'fa_id', 'filearchive_fa_id_seq' ],
70 [ 'addSequence', 'archive', false, 'archive_ar_id_seq' ],
71 [ 'addSequence', 'externallinks', false, 'externallinks_el_id_seq' ],
72 [ 'addSequence', 'watchlist', false, 'watchlist_wl_id_seq' ],
73 [ 'addSequence', 'change_tag', false, 'change_tag_ct_id_seq' ],
74 [ 'addSequence', 'tag_summary', false, 'tag_summary_ts_id_seq' ],
75
76 # new tables
77 [ 'addTable', 'category', 'patch-category.sql' ],
78 [ 'addTable', 'page', 'patch-page.sql' ],
79 [ 'addTable', 'querycachetwo', 'patch-querycachetwo.sql' ],
80 [ 'addTable', 'page_props', 'patch-page_props.sql' ],
81 [ 'addTable', 'page_restrictions', 'patch-page_restrictions.sql' ],
82 [ 'addTable', 'profiling', 'patch-profiling.sql' ],
83 [ 'addTable', 'protected_titles', 'patch-protected_titles.sql' ],
84 [ 'addTable', 'redirect', 'patch-redirect.sql' ],
85 [ 'addTable', 'updatelog', 'patch-updatelog.sql' ],
86 [ 'addTable', 'change_tag', 'patch-change_tag.sql' ],
87 [ 'addTable', 'tag_summary', 'patch-tag_summary.sql' ],
88 [ 'addTable', 'valid_tag', 'patch-valid_tag.sql' ],
89 [ 'addTable', 'user_properties', 'patch-user_properties.sql' ],
90 [ 'addTable', 'log_search', 'patch-log_search.sql' ],
91 [ 'addTable', 'l10n_cache', 'patch-l10n_cache.sql' ],
92 [ 'addTable', 'iwlinks', 'patch-iwlinks.sql' ],
93 [ 'addTable', 'module_deps', 'patch-module_deps.sql' ],
94 [ 'addTable', 'uploadstash', 'patch-uploadstash.sql' ],
95 [ 'addTable', 'user_former_groups', 'patch-user_former_groups.sql' ],
96 [ 'addTable', 'sites', 'patch-sites.sql' ],
97 [ 'addTable', 'bot_passwords', 'patch-bot_passwords.sql' ],
98
99 # Needed before new field
100 [ 'convertArchive2' ],
101
102 # new fields
103 [ 'addPgField', 'updatelog', 'ul_value', 'TEXT' ],
104 [ 'addPgField', 'archive', 'ar_deleted', 'SMALLINT NOT NULL DEFAULT 0' ],
105 [ 'addPgField', 'archive', 'ar_len', 'INTEGER' ],
106 [ 'addPgField', 'archive', 'ar_page_id', 'INTEGER' ],
107 [ 'addPgField', 'archive', 'ar_parent_id', 'INTEGER' ],
108 [ 'addPgField', 'archive', 'ar_content_model', 'TEXT' ],
109 [ 'addPgField', 'archive', 'ar_content_format', 'TEXT' ],
110 [ 'addPgField', 'categorylinks', 'cl_sortkey_prefix', "TEXT NOT NULL DEFAULT ''" ],
111 [ 'addPgField', 'categorylinks', 'cl_collation', "TEXT NOT NULL DEFAULT 0" ],
112 [ 'addPgField', 'categorylinks', 'cl_type', "TEXT NOT NULL DEFAULT 'page'" ],
113 [ 'addPgField', 'image', 'img_sha1', "TEXT NOT NULL DEFAULT ''" ],
114 [ 'addPgField', 'ipblocks', 'ipb_allow_usertalk', 'SMALLINT NOT NULL DEFAULT 0' ],
115 [ 'addPgField', 'ipblocks', 'ipb_anon_only', 'SMALLINT NOT NULL DEFAULT 0' ],
116 [ 'addPgField', 'ipblocks', 'ipb_by_text', "TEXT NOT NULL DEFAULT ''" ],
117 [ 'addPgField', 'ipblocks', 'ipb_block_email', 'SMALLINT NOT NULL DEFAULT 0' ],
118 [ 'addPgField', 'ipblocks', 'ipb_create_account', 'SMALLINT NOT NULL DEFAULT 1' ],
119 [ 'addPgField', 'ipblocks', 'ipb_deleted', 'SMALLINT NOT NULL DEFAULT 0' ],
120 [ 'addPgField', 'ipblocks', 'ipb_enable_autoblock', 'SMALLINT NOT NULL DEFAULT 1' ],
121 [ 'addPgField', 'ipblocks', 'ipb_parent_block_id',
122 'INTEGER DEFAULT NULL REFERENCES ipblocks(ipb_id) ' .
123 'ON DELETE SET NULL DEFERRABLE INITIALLY DEFERRED' ],
124 [ 'addPgField', 'filearchive', 'fa_deleted', 'SMALLINT NOT NULL DEFAULT 0' ],
125 [ 'addPgField', 'filearchive', 'fa_sha1', "TEXT NOT NULL DEFAULT ''" ],
126 [ 'addPgField', 'logging', 'log_deleted', 'SMALLINT NOT NULL DEFAULT 0' ],
127 [ 'addPgField', 'logging', 'log_id',
128 "INTEGER NOT NULL PRIMARY KEY DEFAULT nextval('logging_log_id_seq')" ],
129 [ 'addPgField', 'logging', 'log_params', 'TEXT' ],
130 [ 'addPgField', 'mwuser', 'user_editcount', 'INTEGER' ],
131 [ 'addPgField', 'mwuser', 'user_newpass_time', 'TIMESTAMPTZ' ],
132 [ 'addPgField', 'oldimage', 'oi_deleted', 'SMALLINT NOT NULL DEFAULT 0' ],
133 [ 'addPgField', 'oldimage', 'oi_major_mime', "TEXT NOT NULL DEFAULT 'unknown'" ],
134 [ 'addPgField', 'oldimage', 'oi_media_type', 'TEXT' ],
135 [ 'addPgField', 'oldimage', 'oi_metadata', "BYTEA NOT NULL DEFAULT ''" ],
136 [ 'addPgField', 'oldimage', 'oi_minor_mime', "TEXT NOT NULL DEFAULT 'unknown'" ],
137 [ 'addPgField', 'oldimage', 'oi_sha1', "TEXT NOT NULL DEFAULT ''" ],
138 [ 'addPgField', 'page', 'page_content_model', 'TEXT' ],
139 [ 'addPgField', 'page_restrictions', 'pr_id',
140 "INTEGER NOT NULL UNIQUE DEFAULT nextval('page_restrictions_pr_id_seq')" ],
141 [ 'addPgField', 'profiling', 'pf_memory', 'NUMERIC(18,10) NOT NULL DEFAULT 0' ],
142 [ 'addPgField', 'recentchanges', 'rc_deleted', 'SMALLINT NOT NULL DEFAULT 0' ],
143 [ 'addPgField', 'recentchanges', 'rc_log_action', 'TEXT' ],
144 [ 'addPgField', 'recentchanges', 'rc_log_type', 'TEXT' ],
145 [ 'addPgField', 'recentchanges', 'rc_logid', 'INTEGER NOT NULL DEFAULT 0' ],
146 [ 'addPgField', 'recentchanges', 'rc_new_len', 'INTEGER' ],
147 [ 'addPgField', 'recentchanges', 'rc_old_len', 'INTEGER' ],
148 [ 'addPgField', 'recentchanges', 'rc_params', 'TEXT' ],
149 [ 'addPgField', 'redirect', 'rd_interwiki', 'TEXT NULL' ],
150 [ 'addPgField', 'redirect', 'rd_fragment', 'TEXT NULL' ],
151 [ 'addPgField', 'revision', 'rev_deleted', 'SMALLINT NOT NULL DEFAULT 0' ],
152 [ 'addPgField', 'revision', 'rev_len', 'INTEGER' ],
153 [ 'addPgField', 'revision', 'rev_parent_id', 'INTEGER DEFAULT NULL' ],
154 [ 'addPgField', 'revision', 'rev_content_model', 'TEXT' ],
155 [ 'addPgField', 'revision', 'rev_content_format', 'TEXT' ],
156 [ 'addPgField', 'site_stats', 'ss_active_users', "INTEGER DEFAULT '-1'" ],
157 [ 'addPgField', 'user_newtalk', 'user_last_timestamp', 'TIMESTAMPTZ' ],
158 [ 'addPgField', 'logging', 'log_user_text', "TEXT NOT NULL DEFAULT ''" ],
159 [ 'addPgField', 'logging', 'log_page', 'INTEGER' ],
160 [ 'addPgField', 'interwiki', 'iw_api', "TEXT NOT NULL DEFAULT ''" ],
161 [ 'addPgField', 'interwiki', 'iw_wikiid', "TEXT NOT NULL DEFAULT ''" ],
162 [ 'addPgField', 'revision', 'rev_sha1', "TEXT NOT NULL DEFAULT ''" ],
163 [ 'addPgField', 'archive', 'ar_sha1', "TEXT NOT NULL DEFAULT ''" ],
164 [ 'addPgField', 'uploadstash', 'us_chunk_inx', "INTEGER NULL" ],
165 [ 'addPgField', 'job', 'job_timestamp', "TIMESTAMPTZ" ],
166 [ 'addPgField', 'job', 'job_random', "INTEGER NOT NULL DEFAULT 0" ],
167 [ 'addPgField', 'job', 'job_attempts', "INTEGER NOT NULL DEFAULT 0" ],
168 [ 'addPgField', 'job', 'job_token', "TEXT NOT NULL DEFAULT ''" ],
169 [ 'addPgField', 'job', 'job_token_timestamp', "TIMESTAMPTZ" ],
170 [ 'addPgField', 'job', 'job_sha1', "TEXT NOT NULL DEFAULT ''" ],
171 [ 'addPgField', 'archive', 'ar_id',
172 "INTEGER NOT NULL PRIMARY KEY DEFAULT nextval('archive_ar_id_seq')" ],
173 [ 'addPgField', 'externallinks', 'el_id',
174 "INTEGER NOT NULL PRIMARY KEY DEFAULT nextval('externallinks_el_id_seq')" ],
175 [ 'addPgField', 'uploadstash', 'us_props', "BYTEA" ],
176
177 # type changes
178 [ 'changeField', 'archive', 'ar_deleted', 'smallint', '' ],
179 [ 'changeField', 'archive', 'ar_minor_edit', 'smallint',
180 'ar_minor_edit::smallint DEFAULT 0' ],
181 [ 'changeField', 'filearchive', 'fa_deleted', 'smallint', '' ],
182 [ 'changeField', 'filearchive', 'fa_height', 'integer', '' ],
183 [ 'changeField', 'filearchive', 'fa_metadata', 'bytea', "decode(fa_metadata,'escape')" ],
184 [ 'changeField', 'filearchive', 'fa_size', 'integer', '' ],
185 [ 'changeField', 'filearchive', 'fa_width', 'integer', '' ],
186 [ 'changeField', 'filearchive', 'fa_storage_group', 'text', '' ],
187 [ 'changeField', 'filearchive', 'fa_storage_key', 'text', '' ],
188 [ 'changeField', 'image', 'img_metadata', 'bytea', "decode(img_metadata,'escape')" ],
189 [ 'changeField', 'image', 'img_size', 'integer', '' ],
190 [ 'changeField', 'image', 'img_width', 'integer', '' ],
191 [ 'changeField', 'image', 'img_height', 'integer', '' ],
192 [ 'changeField', 'interwiki', 'iw_local', 'smallint', 'iw_local::smallint' ],
193 [ 'changeField', 'interwiki', 'iw_trans', 'smallint', 'iw_trans::smallint DEFAULT 0' ],
194 [ 'changeField', 'ipblocks', 'ipb_auto', 'smallint', 'ipb_auto::smallint DEFAULT 0' ],
195 [ 'changeField', 'ipblocks', 'ipb_anon_only', 'smallint',
196 "CASE WHEN ipb_anon_only=' ' THEN 0 ELSE ipb_anon_only::smallint END DEFAULT 0" ],
197 [ 'changeField', 'ipblocks', 'ipb_create_account', 'smallint',
198 "CASE WHEN ipb_create_account=' ' THEN 0 ELSE ipb_create_account::smallint END DEFAULT 1" ],
199 [ 'changeField', 'ipblocks', 'ipb_enable_autoblock', 'smallint',
200 "CASE WHEN ipb_enable_autoblock=' ' THEN 0 ELSE ipb_enable_autoblock::smallint END DEFAULT 1" ],
201 [ 'changeField', 'ipblocks', 'ipb_block_email', 'smallint',
202 "CASE WHEN ipb_block_email=' ' THEN 0 ELSE ipb_block_email::smallint END DEFAULT 0" ],
203 [ 'changeField', 'ipblocks', 'ipb_address', 'text', 'ipb_address::text' ],
204 [ 'changeField', 'ipblocks', 'ipb_deleted', 'smallint', 'ipb_deleted::smallint DEFAULT 0' ],
205 [ 'changeField', 'mwuser', 'user_token', 'text', '' ],
206 [ 'changeField', 'mwuser', 'user_email_token', 'text', '' ],
207 [ 'changeField', 'objectcache', 'keyname', 'text', '' ],
208 [ 'changeField', 'oldimage', 'oi_height', 'integer', '' ],
209 [ 'changeField', 'oldimage', 'oi_metadata', 'bytea', "decode(img_metadata,'escape')" ],
210 [ 'changeField', 'oldimage', 'oi_size', 'integer', '' ],
211 [ 'changeField', 'oldimage', 'oi_width', 'integer', '' ],
212 [ 'changeField', 'page', 'page_is_redirect', 'smallint',
213 'page_is_redirect::smallint DEFAULT 0' ],
214 [ 'changeField', 'page', 'page_is_new', 'smallint', 'page_is_new::smallint DEFAULT 0' ],
215 [ 'changeField', 'querycache', 'qc_value', 'integer', '' ],
216 [ 'changeField', 'querycachetwo', 'qcc_value', 'integer', '' ],
217 [ 'changeField', 'recentchanges', 'rc_bot', 'smallint', 'rc_bot::smallint DEFAULT 0' ],
218 [ 'changeField', 'recentchanges', 'rc_deleted', 'smallint', '' ],
219 [ 'changeField', 'recentchanges', 'rc_minor', 'smallint', 'rc_minor::smallint DEFAULT 0' ],
220 [ 'changeField', 'recentchanges', 'rc_new', 'smallint', 'rc_new::smallint DEFAULT 0' ],
221 [ 'changeField', 'recentchanges', 'rc_type', 'smallint', 'rc_type::smallint DEFAULT 0' ],
222 [ 'changeField', 'recentchanges', 'rc_patrolled', 'smallint',
223 'rc_patrolled::smallint DEFAULT 0' ],
224 [ 'changeField', 'revision', 'rev_deleted', 'smallint', 'rev_deleted::smallint DEFAULT 0' ],
225 [ 'changeField', 'revision', 'rev_minor_edit', 'smallint',
226 'rev_minor_edit::smallint DEFAULT 0' ],
227 [ 'changeField', 'templatelinks', 'tl_namespace', 'smallint', 'tl_namespace::smallint' ],
228 [ 'changeField', 'user_newtalk', 'user_ip', 'text', 'host(user_ip)' ],
229 [ 'changeField', 'uploadstash', 'us_image_bits', 'smallint', '' ],
230 [ 'changeField', 'profiling', 'pf_time', 'float', '' ],
231 [ 'changeField', 'profiling', 'pf_memory', 'float', '' ],
232
233 # null changes
234 [ 'changeNullableField', 'oldimage', 'oi_bits', 'NULL' ],
235 [ 'changeNullableField', 'oldimage', 'oi_timestamp', 'NULL' ],
236 [ 'changeNullableField', 'oldimage', 'oi_major_mime', 'NULL' ],
237 [ 'changeNullableField', 'oldimage', 'oi_minor_mime', 'NULL' ],
238 [ 'changeNullableField', 'image', 'img_metadata', 'NOT NULL' ],
239 [ 'changeNullableField', 'filearchive', 'fa_metadata', 'NOT NULL' ],
240 [ 'changeNullableField', 'recentchanges', 'rc_cur_id', 'NULL' ],
241 [ 'changeNullableField', 'recentchanges', 'rc_cur_time', 'NULL' ],
242
243 [ 'checkOiDeleted' ],
244
245 # New indexes
246 [ 'addPgIndex', 'archive', 'archive_user_text', '(ar_user_text)' ],
247 [ 'addPgIndex', 'image', 'img_sha1', '(img_sha1)' ],
248 [ 'addPgIndex', 'ipblocks', 'ipb_parent_block_id', '(ipb_parent_block_id)' ],
249 [ 'addPgIndex', 'oldimage', 'oi_sha1', '(oi_sha1)' ],
250 [ 'addPgIndex', 'page', 'page_mediawiki_title', '(page_title) WHERE page_namespace = 8' ],
251 [ 'addPgIndex', 'pagelinks', 'pagelinks_title', '(pl_title)' ],
252 [ 'addPgIndex', 'page_props', 'pp_propname_page', '(pp_propname, pp_page)' ],
253 [ 'addPgIndex', 'revision', 'rev_text_id_idx', '(rev_text_id)' ],
254 [ 'addPgIndex', 'recentchanges', 'rc_timestamp_bot', '(rc_timestamp) WHERE rc_bot = 0' ],
255 [ 'addPgIndex', 'templatelinks', 'templatelinks_from', '(tl_from)' ],
256 [ 'addPgIndex', 'watchlist', 'wl_user', '(wl_user)' ],
257 [ 'addPgIndex', 'watchlist', 'wl_user_notificationtimestamp',
258 '(wl_user, wl_notificationtimestamp)' ],
259 [ 'addPgIndex', 'logging', 'logging_user_type_time',
260 '(log_user, log_type, log_timestamp)' ],
261 [ 'addPgIndex', 'logging', 'logging_page_id_time', '(log_page,log_timestamp)' ],
262 [ 'addPgIndex', 'iwlinks', 'iwl_prefix_from_title', '(iwl_prefix, iwl_from, iwl_title)' ],
263 [ 'addPgIndex', 'iwlinks', 'iwl_prefix_title_from', '(iwl_prefix, iwl_title, iwl_from)' ],
264 [ 'addPgIndex', 'job', 'job_timestamp_idx', '(job_timestamp)' ],
265 [ 'addPgIndex', 'job', 'job_sha1', '(job_sha1)' ],
266 [ 'addPgIndex', 'job', 'job_cmd_token', '(job_cmd, job_token, job_random)' ],
267 [ 'addPgIndex', 'job', 'job_cmd_token_id', '(job_cmd, job_token, job_id)' ],
268 [ 'addPgIndex', 'filearchive', 'fa_sha1', '(fa_sha1)' ],
269 [ 'addPgIndex', 'logging', 'logging_user_text_type_time',
270 '(log_user_text, log_type, log_timestamp)' ],
271 [ 'addPgIndex', 'logging', 'logging_user_text_time', '(log_user_text, log_timestamp)' ],
272
273 [ 'checkIndex', 'pagelink_unique', [
274 [ 'pl_from', 'int4_ops', 'btree', 0 ],
275 [ 'pl_namespace', 'int2_ops', 'btree', 0 ],
276 [ 'pl_title', 'text_ops', 'btree', 0 ],
277 ],
278 'CREATE UNIQUE INDEX pagelink_unique ON pagelinks (pl_from,pl_namespace,pl_title)' ],
279 [ 'checkIndex', 'cl_sortkey', [
280 [ 'cl_to', 'text_ops', 'btree', 0 ],
281 [ 'cl_sortkey', 'text_ops', 'btree', 0 ],
282 [ 'cl_from', 'int4_ops', 'btree', 0 ],
283 ],
284 'CREATE INDEX cl_sortkey ON "categorylinks" ' .
285 'USING "btree" ("cl_to", "cl_sortkey", "cl_from")' ],
286 [ 'checkIndex', 'iwl_prefix_title_from', [
287 [ 'iwl_prefix', 'text_ops', 'btree', 0 ],
288 [ 'iwl_title', 'text_ops', 'btree', 0 ],
289 [ 'iwl_from', 'int4_ops', 'btree', 0 ],
290 ],
291 'CREATE INDEX iwl_prefix_title_from ON "iwlinks" ' .
292 'USING "btree" ("iwl_prefix", "iwl_title", "iwl_from")' ],
293 [ 'checkIndex', 'logging_times', [
294 [ 'log_timestamp', 'timestamptz_ops', 'btree', 0 ],
295 ],
296 'CREATE INDEX "logging_times" ON "logging" USING "btree" ("log_timestamp")' ],
297 [ 'dropPgIndex', 'oldimage', 'oi_name' ],
298 [ 'checkIndex', 'oi_name_archive_name', [
299 [ 'oi_name', 'text_ops', 'btree', 0 ],
300 [ 'oi_archive_name', 'text_ops', 'btree', 0 ],
301 ],
302 'CREATE INDEX "oi_name_archive_name" ON "oldimage" ' .
303 'USING "btree" ("oi_name", "oi_archive_name")' ],
304 [ 'checkIndex', 'oi_name_timestamp', [
305 [ 'oi_name', 'text_ops', 'btree', 0 ],
306 [ 'oi_timestamp', 'timestamptz_ops', 'btree', 0 ],
307 ],
308 'CREATE INDEX "oi_name_timestamp" ON "oldimage" ' .
309 'USING "btree" ("oi_name", "oi_timestamp")' ],
310 [ 'checkIndex', 'page_main_title', [
311 [ 'page_title', 'text_pattern_ops', 'btree', 0 ],
312 ],
313 'CREATE INDEX "page_main_title" ON "page" ' .
314 'USING "btree" ("page_title" "text_pattern_ops") WHERE ("page_namespace" = 0)' ],
315 [ 'checkIndex', 'page_mediawiki_title', [
316 [ 'page_title', 'text_pattern_ops', 'btree', 0 ],
317 ],
318 'CREATE INDEX "page_mediawiki_title" ON "page" ' .
319 'USING "btree" ("page_title" "text_pattern_ops") WHERE ("page_namespace" = 8)' ],
320 [ 'checkIndex', 'page_project_title', [
321 [ 'page_title', 'text_pattern_ops', 'btree', 0 ],
322 ],
323 'CREATE INDEX "page_project_title" ON "page" ' .
324 'USING "btree" ("page_title" "text_pattern_ops") ' .
325 'WHERE ("page_namespace" = 4)' ],
326 [ 'checkIndex', 'page_talk_title', [
327 [ 'page_title', 'text_pattern_ops', 'btree', 0 ],
328 ],
329 'CREATE INDEX "page_talk_title" ON "page" ' .
330 'USING "btree" ("page_title" "text_pattern_ops") ' .
331 'WHERE ("page_namespace" = 1)' ],
332 [ 'checkIndex', 'page_user_title', [
333 [ 'page_title', 'text_pattern_ops', 'btree', 0 ],
334 ],
335 'CREATE INDEX "page_user_title" ON "page" ' .
336 'USING "btree" ("page_title" "text_pattern_ops") WHERE ' .
337 '("page_namespace" = 2)' ],
338 [ 'checkIndex', 'page_utalk_title', [
339 [ 'page_title', 'text_pattern_ops', 'btree', 0 ],
340 ],
341 'CREATE INDEX "page_utalk_title" ON "page" ' .
342 'USING "btree" ("page_title" "text_pattern_ops") ' .
343 'WHERE ("page_namespace" = 3)' ],
344 [ 'checkIndex', 'ts2_page_text', [
345 [ 'textvector', 'tsvector_ops', 'gist', 0 ],
346 ],
347 'CREATE INDEX "ts2_page_text" ON "pagecontent" USING "gist" ("textvector")' ],
348 [ 'checkIndex', 'ts2_page_title', [
349 [ 'titlevector', 'tsvector_ops', 'gist', 0 ],
350 ],
351 'CREATE INDEX "ts2_page_title" ON "page" USING "gist" ("titlevector")' ],
352
353 [ 'checkOiNameConstraint' ],
354 [ 'checkPageDeletedTrigger' ],
355 [ 'checkRevUserFkey' ],
356 [ 'dropPgIndex', 'ipblocks', 'ipb_address' ],
357 [ 'checkIndex', 'ipb_address_unique', [
358 [ 'ipb_address', 'text_ops', 'btree', 0 ],
359 [ 'ipb_user', 'int4_ops', 'btree', 0 ],
360 [ 'ipb_auto', 'int2_ops', 'btree', 0 ],
361 [ 'ipb_anon_only', 'int2_ops', 'btree', 0 ],
362 ],
363 'CREATE UNIQUE INDEX ipb_address_unique ' .
364 'ON ipblocks (ipb_address,ipb_user,ipb_auto,ipb_anon_only)' ],
365
366 [ 'checkIwlPrefix' ],
367
368 # All FK columns should be deferred
369 [ 'changeFkeyDeferrable', 'archive', 'ar_user', 'mwuser(user_id) ON DELETE SET NULL' ],
370 [ 'changeFkeyDeferrable', 'categorylinks', 'cl_from', 'page(page_id) ON DELETE CASCADE' ],
371 [ 'changeFkeyDeferrable', 'externallinks', 'el_from', 'page(page_id) ON DELETE CASCADE' ],
372 [ 'changeFkeyDeferrable', 'filearchive', 'fa_deleted_user',
373 'mwuser(user_id) ON DELETE SET NULL' ],
374 [ 'changeFkeyDeferrable', 'filearchive', 'fa_user', 'mwuser(user_id) ON DELETE SET NULL' ],
375 [ 'changeFkeyDeferrable', 'image', 'img_user', 'mwuser(user_id) ON DELETE SET NULL' ],
376 [ 'changeFkeyDeferrable', 'imagelinks', 'il_from', 'page(page_id) ON DELETE CASCADE' ],
377 [ 'changeFkeyDeferrable', 'ipblocks', 'ipb_by', 'mwuser(user_id) ON DELETE CASCADE' ],
378 [ 'changeFkeyDeferrable', 'ipblocks', 'ipb_user', 'mwuser(user_id) ON DELETE SET NULL' ],
379 [ 'changeFkeyDeferrable', 'ipblocks', 'ipb_parent_block_id',
380 'ipblocks(ipb_id) ON DELETE SET NULL' ],
381 [ 'changeFkeyDeferrable', 'langlinks', 'll_from', 'page(page_id) ON DELETE CASCADE' ],
382 [ 'changeFkeyDeferrable', 'logging', 'log_user', 'mwuser(user_id) ON DELETE SET NULL' ],
383 [ 'changeFkeyDeferrable', 'oldimage', 'oi_name',
384 'image(img_name) ON DELETE CASCADE ON UPDATE CASCADE' ],
385 [ 'changeFkeyDeferrable', 'oldimage', 'oi_user', 'mwuser(user_id) ON DELETE SET NULL' ],
386 [ 'changeFkeyDeferrable', 'pagelinks', 'pl_from', 'page(page_id) ON DELETE CASCADE' ],
387 [ 'changeFkeyDeferrable', 'page_props', 'pp_page', 'page (page_id) ON DELETE CASCADE' ],
388 [ 'changeFkeyDeferrable', 'page_restrictions', 'pr_page',
389 'page(page_id) ON DELETE CASCADE' ],
390 [ 'changeFkeyDeferrable', 'protected_titles', 'pt_user',
391 'mwuser(user_id) ON DELETE SET NULL' ],
392 [ 'changeFkeyDeferrable', 'recentchanges', 'rc_user',
393 'mwuser(user_id) ON DELETE SET NULL' ],
394 [ 'changeFkeyDeferrable', 'redirect', 'rd_from', 'page(page_id) ON DELETE CASCADE' ],
395 [ 'changeFkeyDeferrable', 'revision', 'rev_page', 'page (page_id) ON DELETE CASCADE' ],
396 [ 'changeFkeyDeferrable', 'revision', 'rev_user', 'mwuser(user_id) ON DELETE RESTRICT' ],
397 [ 'changeFkeyDeferrable', 'templatelinks', 'tl_from', 'page(page_id) ON DELETE CASCADE' ],
398 [ 'changeFkeyDeferrable', 'user_groups', 'ug_user', 'mwuser(user_id) ON DELETE CASCADE' ],
399 [ 'changeFkeyDeferrable', 'user_newtalk', 'user_id', 'mwuser(user_id) ON DELETE CASCADE' ],
400 [ 'changeFkeyDeferrable', 'user_properties', 'up_user',
401 'mwuser(user_id) ON DELETE CASCADE' ],
402 [ 'changeFkeyDeferrable', 'watchlist', 'wl_user', 'mwuser(user_id) ON DELETE CASCADE' ],
403
404 # r81574
405 [ 'addInterwikiType' ],
406 # end
407 [ 'tsearchFixes' ],
408
409 // 1.23
410 [ 'addPgField', 'recentchanges', 'rc_source', "TEXT NOT NULL DEFAULT ''" ],
411 [ 'addPgField', 'page', 'page_links_updated', "TIMESTAMPTZ NULL" ],
412 [ 'addPgField', 'mwuser', 'user_password_expires', 'TIMESTAMPTZ NULL' ],
413 [ 'changeFieldPurgeTable', 'l10n_cache', 'lc_value', 'bytea',
414 "replace(lc_value,'\','\\\\')::bytea" ],
415 // 1.23.9
416 [ 'rebuildTextSearch' ],
417
418 // 1.24
419 [ 'addPgField', 'page_props', 'pp_sortkey', 'float NULL' ],
420 [ 'addPgIndex', 'page_props', 'pp_propname_sortkey_page',
421 '( pp_propname, pp_sortkey, pp_page ) WHERE ( pp_sortkey IS NOT NULL )' ],
422 [ 'addPgField', 'page', 'page_lang', 'TEXT default NULL' ],
423 [ 'addPgField', 'pagelinks', 'pl_from_namespace', 'INTEGER NOT NULL DEFAULT 0' ],
424 [ 'addPgField', 'templatelinks', 'tl_from_namespace', 'INTEGER NOT NULL DEFAULT 0' ],
425 [ 'addPgField', 'imagelinks', 'il_from_namespace', 'INTEGER NOT NULL DEFAULT 0' ],
426
427 // 1.25
428 [ 'dropTable', 'hitcounter' ],
429 [ 'dropField', 'site_stats', 'ss_total_views', 'patch-drop-ss_total_views.sql' ],
430 [ 'dropField', 'page', 'page_counter', 'patch-drop-page_counter.sql' ],
431 [ 'dropFkey', 'recentchanges', 'rc_cur_id' ],
432
433 // 1.27
434 [ 'dropTable', 'msg_resource_links' ],
435 [ 'dropTable', 'msg_resource' ],
436 [
437 'addPgField', 'watchlist', 'wl_id',
438 "INTEGER NOT NULL PRIMARY KEY DEFAULT nextval('watchlist_wl_id_seq')"
439 ],
440
441 // 1.28
442 [ 'addPgIndex', 'recentchanges', 'rc_name_type_patrolled_timestamp',
443 '( rc_namespace, rc_type, rc_patrolled, rc_timestamp )' ],
444 [ 'addPgField', 'change_tag', 'ct_id',
445 "INTEGER NOT NULL PRIMARY KEY DEFAULT nextval('change_tag_ct_id_seq')" ],
446 [ 'addPgField', 'tag_summary', 'ts_id',
447 "INTEGER NOT NULL PRIMARY KEY DEFAULT nextval('tag_summary_ts_id_seq')" ],
448
449 // 1.29
450 [ 'addPgField', 'externallinks', 'el_index_60', "BYTEA NOT NULL DEFAULT ''" ],
451 [ 'addPgIndex', 'externallinks', 'el_index_60', '( el_index_60, el_id )' ],
452 [ 'addPgIndex', 'externallinks', 'el_from_index_60', '( el_from, el_index_60, el_id )' ],
453 [ 'addPgField', 'user_groups', 'ug_expiry', "TIMESTAMPTZ NULL" ],
454 [ 'addPgIndex', 'user_groups', 'user_groups_expiry', '( ug_expiry )' ],
455
456 // 1.30
457 [ 'addPgEnumValue', 'media_type', '3D' ],
458 [ 'setDefault', 'revision', 'rev_comment', '' ],
459 [ 'changeNullableField', 'revision', 'rev_comment', 'NOT NULL', true ],
460 [ 'setDefault', 'archive', 'ar_comment', '' ],
461 [ 'changeNullableField', 'archive', 'ar_comment', 'NOT NULL', true ],
462 [ 'addPgField', 'archive', 'ar_comment_id', 'INTEGER NOT NULL DEFAULT 0' ],
463 [ 'setDefault', 'ipblocks', 'ipb_reason', '' ],
464 [ 'addPgField', 'ipblocks', 'ipb_reason_id', 'INTEGER NOT NULL DEFAULT 0' ],
465 [ 'setDefault', 'image', 'img_description', '' ],
466 [ 'setDefault', 'oldimage', 'oi_description', '' ],
467 [ 'changeNullableField', 'oldimage', 'oi_description', 'NOT NULL', true ],
468 [ 'addPgField', 'oldimage', 'oi_description_id', 'INTEGER NOT NULL DEFAULT 0' ],
469 [ 'setDefault', 'filearchive', 'fa_deleted_reason', '' ],
470 [ 'changeNullableField', 'filearchive', 'fa_deleted_reason', 'NOT NULL', true ],
471 [ 'addPgField', 'filearchive', 'fa_deleted_reason_id', 'INTEGER NOT NULL DEFAULT 0' ],
472 [ 'setDefault', 'filearchive', 'fa_description', '' ],
473 [ 'addPgField', 'filearchive', 'fa_description_id', 'INTEGER NOT NULL DEFAULT 0' ],
474 [ 'setDefault', 'recentchanges', 'rc_comment', '' ],
475 [ 'changeNullableField', 'recentchanges', 'rc_comment', 'NOT NULL', true ],
476 [ 'addPgField', 'recentchanges', 'rc_comment_id', 'INTEGER NOT NULL DEFAULT 0' ],
477 [ 'setDefault', 'logging', 'log_comment', '' ],
478 [ 'changeNullableField', 'logging', 'log_comment', 'NOT NULL', true ],
479 [ 'addPgField', 'logging', 'log_comment_id', 'INTEGER NOT NULL DEFAULT 0' ],
480 [ 'setDefault', 'protected_titles', 'pt_reason', '' ],
481 [ 'changeNullableField', 'protected_titles', 'pt_reason', 'NOT NULL', true ],
482 [ 'addPgField', 'protected_titles', 'pt_reason_id', 'INTEGER NOT NULL DEFAULT 0' ],
483 [ 'addTable', 'comment', 'patch-comment-table.sql' ],
484 [ 'addTable', 'revision_comment_temp', 'patch-revision_comment_temp-table.sql' ],
485 // image_comment_temp is no longer needed when upgrading to MW 1.31 or newer,
486 // as it is dropped later in the update process as part of 'migrateImageCommentTemp'.
487 // File kept on disk and the updater entry here for historical purposes.
488 // [ 'addTable', 'image_comment_temp', 'patch-image_comment_temp-table.sql' ],
489
490 // This field was added in 1.31, but is put here so it can be used by 'migrateComments'
491 [ 'addPgField', 'image', 'img_description_id', 'INTEGER NOT NULL DEFAULT 0' ],
492
493 [ 'migrateComments' ],
494 [ 'addIndex', 'site_stats', 'site_stats_pkey', 'patch-site_stats-pk.sql' ],
495 [ 'addTable', 'ip_changes', 'patch-ip_changes.sql' ],
496
497 // 1.31
498 [ 'addTable', 'slots', 'patch-slots-table.sql' ],
499 [ 'dropPgIndex', 'slots', 'slot_role_inherited' ],
500 [ 'dropPgField', 'slots', 'slot_inherited' ],
501 [ 'addPgField', 'slots', 'slot_origin', 'INTEGER NOT NULL' ],
502 [
503 'addPgIndex',
504 'slots',
505 'slot_revision_origin_role',
506 '( slot_revision_id, slot_origin, slot_role_id )',
507 ],
508 [ 'addTable', 'content', 'patch-content-table.sql' ],
509 [ 'addTable', 'content_models', 'patch-content_models-table.sql' ],
510 [ 'addTable', 'slot_roles', 'patch-slot_roles-table.sql' ],
511 [ 'migrateArchiveText' ],
512 [ 'addTable', 'actor', 'patch-actor-table.sql' ],
513 [ 'addTable', 'revision_actor_temp', 'patch-revision_actor_temp-table.sql' ],
514 [ 'setDefault', 'revision', 'rev_user', 0 ],
515 [ 'setDefault', 'revision', 'rev_user_text', '' ],
516 [ 'setDefault', 'archive', 'ar_user', 0 ],
517 [ 'changeNullableField', 'archive', 'ar_user', 'NOT NULL', true ],
518 [ 'setDefault', 'archive', 'ar_user_text', '' ],
519 [ 'addPgField', 'archive', 'ar_actor', 'INTEGER NOT NULL DEFAULT 0' ],
520 [ 'addPgIndex', 'archive', 'archive_actor', '( ar_actor )' ],
521 [ 'setDefault', 'ipblocks', 'ipb_by', 0 ],
522 [ 'addPgField', 'ipblocks', 'ipb_by_actor', 'INTEGER NOT NULL DEFAULT 0' ],
523 [ 'setDefault', 'image', 'img_user', 0 ],
524 [ 'changeNullableField', 'image', 'img_user', 'NOT NULL', true ],
525 [ 'setDefault', 'image', 'img_user_text', '' ],
526 [ 'addPgField', 'image', 'img_actor', 'INTEGER NOT NULL DEFAULT 0' ],
527 [ 'setDefault', 'oldimage', 'oi_user', 0 ],
528 [ 'changeNullableField', 'oldimage', 'oi_user', 'NOT NULL', true ],
529 [ 'setDefault', 'oldimage', 'oi_user_text', '' ],
530 [ 'addPgField', 'oldimage', 'oi_actor', 'INTEGER NOT NULL DEFAULT 0' ],
531 [ 'setDefault', 'filearchive', 'fa_user', 0 ],
532 [ 'changeNullableField', 'filearchive', 'fa_user', 'NOT NULL', true ],
533 [ 'setDefault', 'filearchive', 'fa_user_text', '' ],
534 [ 'addPgField', 'filearchive', 'fa_actor', 'INTEGER NOT NULL DEFAULT 0' ],
535 [ 'setDefault', 'recentchanges', 'rc_user', 0 ],
536 [ 'changeNullableField', 'recentchanges', 'rc_user', 'NOT NULL', true ],
537 [ 'setDefault', 'recentchanges', 'rc_user_text', '' ],
538 [ 'addPgField', 'recentchanges', 'rc_actor', 'INTEGER NOT NULL DEFAULT 0' ],
539 [ 'setDefault', 'logging', 'log_user', 0 ],
540 [ 'changeNullableField', 'logging', 'log_user', 'NOT NULL', true ],
541 [ 'addPgField', 'logging', 'log_actor', 'INTEGER NOT NULL DEFAULT 0' ],
542 [ 'addPgIndex', 'logging', 'logging_actor_time_backwards', '( log_timestamp, log_actor )' ],
543 [ 'addPgIndex', 'logging', 'logging_actor_type_time', '( log_actor, log_type, log_timestamp )' ],
544 [ 'addPgIndex', 'logging', 'logging_actor_time', '( log_actor, log_timestamp )' ],
545 [ 'migrateActors' ],
546 [ 'modifyTable', 'site_stats', 'patch-site_stats-modify.sql' ],
547 [ 'populateArchiveRevId' ],
548 [ 'dropPgIndex', 'recentchanges', 'rc_namespace_title' ],
549 [
550 'addPgIndex',
551 'recentchanges',
552 'rc_namespace_title_timestamp', '( rc_namespace, rc_title, rc_timestamp )'
553 ],
554 [ 'setSequenceOwner', 'mwuser', 'user_id', 'user_user_id_seq' ],
555 [ 'setSequenceOwner', 'actor', 'actor_id', 'actor_actor_id_seq' ],
556 [ 'setSequenceOwner', 'page', 'page_id', 'page_page_id_seq' ],
557 [ 'setSequenceOwner', 'revision', 'rev_id', 'revision_rev_id_seq' ],
558 [ 'setSequenceOwner', 'ip_changes', 'ipc_rev_id', 'ip_changes_ipc_rev_id_seq' ],
559 [ 'setSequenceOwner', 'pagecontent', 'old_id', 'text_old_id_seq' ],
560 [ 'setSequenceOwner', 'comment', 'comment_id', 'comment_comment_id_seq' ],
561 [ 'setSequenceOwner', 'page_restrictions', 'pr_id', 'page_restrictions_pr_id_seq' ],
562 [ 'setSequenceOwner', 'archive', 'ar_id', 'archive_ar_id_seq' ],
563 [ 'setSequenceOwner', 'content', 'content_id', 'content_content_id_seq' ],
564 [ 'setSequenceOwner', 'slot_roles', 'role_id', 'slot_roles_role_id_seq' ],
565 [ 'setSequenceOwner', 'content_models', 'model_id', 'content_models_model_id_seq' ],
566 [ 'setSequenceOwner', 'externallinks', 'el_id', 'externallinks_el_id_seq' ],
567 [ 'setSequenceOwner', 'ipblocks', 'ipb_id', 'ipblocks_ipb_id_seq' ],
568 [ 'setSequenceOwner', 'filearchive', 'fa_id', 'filearchive_fa_id_seq' ],
569 [ 'setSequenceOwner', 'uploadstash', 'us_id', 'uploadstash_us_id_seq' ],
570 [ 'setSequenceOwner', 'recentchanges', 'rc_id', 'recentchanges_rc_id_seq' ],
571 [ 'setSequenceOwner', 'watchlist', 'wl_id', 'watchlist_wl_id_seq' ],
572 [ 'setSequenceOwner', 'logging', 'log_id', 'logging_log_id_seq' ],
573 [ 'setSequenceOwner', 'job', 'job_id', 'job_job_id_seq' ],
574 [ 'setSequenceOwner', 'category', 'cat_id', 'category_cat_id_seq' ],
575 [ 'setSequenceOwner', 'change_tag', 'ct_id', 'change_tag_ct_id_seq' ],
576 [ 'setSequenceOwner', 'tag_summary', 'ts_id', 'tag_summary_ts_id_seq' ],
577 [ 'setSequenceOwner', 'sites', 'site_id', 'sites_site_id_seq' ],
578 ];
579 }
580
581 protected function getOldGlobalUpdates() {
582 global $wgExtNewTables, $wgExtPGNewFields, $wgExtPGAlteredFields, $wgExtNewIndexes;
583
584 $updates = [];
585
586 # Add missing extension tables
587 foreach ( $wgExtNewTables as $tableRecord ) {
588 $updates[] = [
589 'addTable', $tableRecord[0], $tableRecord[1], true
590 ];
591 }
592
593 # Add missing extension fields
594 foreach ( $wgExtPGNewFields as $fieldRecord ) {
595 $updates[] = [
596 'addPgField', $fieldRecord[0], $fieldRecord[1],
597 $fieldRecord[2]
598 ];
599 }
600
601 # Change altered columns
602 foreach ( $wgExtPGAlteredFields as $fieldRecord ) {
603 $updates[] = [
604 'changeField', $fieldRecord[0], $fieldRecord[1],
605 $fieldRecord[2]
606 ];
607 }
608
609 # Add missing extension indexes
610 foreach ( $wgExtNewIndexes as $fieldRecord ) {
611 $updates[] = [
612 'addPgExtIndex', $fieldRecord[0], $fieldRecord[1],
613 $fieldRecord[2]
614 ];
615 }
616
617 return $updates;
618 }
619
620 protected function describeTable( $table ) {
621 $q = <<<END
622SELECT attname, attnum FROM pg_namespace, pg_class, pg_attribute
623 WHERE pg_class.relnamespace = pg_namespace.oid
624 AND attrelid=pg_class.oid AND attnum > 0
625 AND relname=%s AND nspname=%s
626END;
627 $res = $this->db->query( sprintf( $q,
628 $this->db->addQuotes( $table ),
629 $this->db->addQuotes( $this->db->getCoreSchema() ) ) );
630 if ( !$res ) {
631 return null;
632 }
633
634 $cols = [];
635 foreach ( $res as $r ) {
636 $cols[] = [
637 "name" => $r[0],
638 "ord" => $r[1],
639 ];
640 }
641
642 return $cols;
643 }
644
645 function describeIndex( $idx ) {
646 // first fetch the key (which is a list of columns ords) and
647 // the table the index applies to (an oid)
648 $q = <<<END
649SELECT indkey, indrelid FROM pg_namespace, pg_class, pg_index
650 WHERE nspname=%s
651 AND pg_class.relnamespace = pg_namespace.oid
652 AND relname=%s
653 AND indexrelid=pg_class.oid
654END;
655 $res = $this->db->query(
656 sprintf(
657 $q,
658 $this->db->addQuotes( $this->db->getCoreSchema() ),
659 $this->db->addQuotes( $idx )
660 )
661 );
662 if ( !$res ) {
663 return null;
664 }
665 $r = $this->db->fetchRow( $res );
666 if ( !$r ) {
667 return null;
668 }
669
670 $indkey = $r[0];
671 $relid = intval( $r[1] );
672 $indkeys = explode( ' ', $indkey );
673
674 $colnames = [];
675 foreach ( $indkeys as $rid ) {
676 $query = <<<END
677SELECT attname FROM pg_class, pg_attribute
678 WHERE attrelid=$relid
679 AND attnum=%d
680 AND attrelid=pg_class.oid
681END;
682 $r2 = $this->db->query( sprintf( $query, $rid ) );
683 if ( !$r2 ) {
684 return null;
685 }
686 $row2 = $this->db->fetchRow( $r2 );
687 if ( !$row2 ) {
688 return null;
689 }
690 $colnames[] = $row2[0];
691 }
692
693 return $colnames;
694 }
695
696 function fkeyDeltype( $fkey ) {
697 $q = <<<END
698SELECT confdeltype FROM pg_constraint, pg_namespace
699 WHERE connamespace=pg_namespace.oid
700 AND nspname=%s
701 AND conname=%s;
702END;
703 $r = $this->db->query(
704 sprintf(
705 $q,
706 $this->db->addQuotes( $this->db->getCoreSchema() ),
707 $this->db->addQuotes( $fkey )
708 )
709 );
710 $row = $this->db->fetchRow( $r );
711 if ( !$row ) {
712 return null;
713 }
714
715 return $row[0];
716 }
717
718 function ruleDef( $table, $rule ) {
719 $q = <<<END
720SELECT definition FROM pg_rules
721 WHERE schemaname = %s
722 AND tablename = %s
723 AND rulename = %s
724END;
725 $r = $this->db->query(
726 sprintf(
727 $q,
728 $this->db->addQuotes( $this->db->getCoreSchema() ),
729 $this->db->addQuotes( $table ),
730 $this->db->addQuotes( $rule )
731 )
732 );
733 $row = $this->db->fetchRow( $r );
734 if ( !$row ) {
735 return null;
736 }
737 $d = $row[0];
738
739 return $d;
740 }
741
742 protected function addSequence( $table, $pkey, $ns ) {
743 if ( !$this->db->sequenceExists( $ns ) ) {
744 $this->output( "Creating sequence $ns\n" );
745 if ( $pkey !== false ) {
746 $this->db->query( "CREATE SEQUENCE $ns OWNED BY $table.$pkey" );
747 $this->setDefault( $table, $pkey, '"nextval"(\'"' . $ns . '"\'::"regclass")' );
748 } else {
749 $this->db->query( "CREATE SEQUENCE $ns" );
750 }
751 }
752 }
753
754 protected function dropSequence( $table, $ns ) {
755 if ( $this->db->sequenceExists( $ns ) ) {
756 $this->output( "Dropping sequence $ns\n" );
757 $this->db->query( "DROP SEQUENCE $ns CASCADE" );
758 }
759 }
760
761 protected function renameSequence( $old, $new ) {
762 if ( $this->db->sequenceExists( $new ) ) {
763 $this->output( "...sequence $new already exists.\n" );
764
765 return;
766 }
767 if ( $this->db->sequenceExists( $old ) ) {
768 $this->output( "Renaming sequence $old to $new\n" );
769 $this->db->query( "ALTER SEQUENCE $old RENAME TO $new" );
770 }
771 }
772
773 protected function setSequenceOwner( $table, $pkey, $seq ) {
774 if ( $this->db->sequenceExists( $seq ) ) {
775 $this->output( "Setting sequence $seq owner to $table.$pkey\n" );
776 $this->db->query( "ALTER SEQUENCE $seq OWNED BY $table.$pkey" );
777 }
778 }
779
780 protected function renameTable( $old, $new, $patch = false ) {
781 if ( $this->db->tableExists( $old ) ) {
782 $this->output( "Renaming table $old to $new\n" );
783 $old = $this->db->realTableName( $old, "quoted" );
784 $new = $this->db->realTableName( $new, "quoted" );
785 $this->db->query( "ALTER TABLE $old RENAME TO $new" );
786 if ( $patch !== false ) {
787 $this->applyPatch( $patch );
788 }
789 }
790 }
791
792 protected function renameIndex(
793 $table, $old, $new, $skipBothIndexExistWarning = false, $a = false, $b = false
794 ) {
795 // First requirement: the table must exist
796 if ( !$this->db->tableExists( $table, __METHOD__ ) ) {
797 $this->output( "...skipping: '$table' table doesn't exist yet.\n" );
798
799 return;
800 }
801
802 // Second requirement: the new index must be missing
803 if ( $this->db->indexExists( $table, $new, __METHOD__ ) ) {
804 $this->output( "...index $new already set on $table table.\n" );
805 if ( !$skipBothIndexExistWarning
806 && $this->db->indexExists( $table, $old, __METHOD__ )
807 ) {
808 $this->output( "...WARNING: $old still exists, despite it has been " .
809 "renamed into $new (which also exists).\n" .
810 " $old should be manually removed if not needed anymore.\n" );
811 }
812
813 return;
814 }
815
816 // Third requirement: the old index must exist
817 if ( !$this->db->indexExists( $table, $old, __METHOD__ ) ) {
818 $this->output( "...skipping: index $old doesn't exist.\n" );
819
820 return;
821 }
822
823 $this->db->query( "ALTER INDEX $old RENAME TO $new" );
824 }
825
826 protected function dropPgField( $table, $field ) {
827 $fi = $this->db->fieldInfo( $table, $field );
828 if ( is_null( $fi ) ) {
829 $this->output( "...$table table does not contain $field field.\n" );
830
831 return;
832 } else {
833 $this->output( "Dropping column '$table.$field'\n" );
834 $this->db->query( "ALTER TABLE $table DROP COLUMN $field" );
835 }
836 }
837
838 protected function addPgField( $table, $field, $type ) {
839 $fi = $this->db->fieldInfo( $table, $field );
840 if ( !is_null( $fi ) ) {
841 $this->output( "...column '$table.$field' already exists\n" );
842
843 return;
844 } else {
845 $this->output( "Adding column '$table.$field'\n" );
846 $this->db->query( "ALTER TABLE $table ADD $field $type" );
847 }
848 }
849
850 protected function changeField( $table, $field, $newtype, $default ) {
851 $fi = $this->db->fieldInfo( $table, $field );
852 if ( is_null( $fi ) ) {
853 $this->output( "...ERROR: expected column $table.$field to exist\n" );
854 exit( 1 );
855 }
856
857 if ( $fi->type() === $newtype ) {
858 $this->output( "...column '$table.$field' is already of type '$newtype'\n" );
859 } else {
860 $this->output( "Changing column type of '$table.$field' from '{$fi->type()}' to '$newtype'\n" );
861 $sql = "ALTER TABLE $table ALTER $field TYPE $newtype";
862 if ( strlen( $default ) ) {
863 $res = [];
864 if ( preg_match( '/DEFAULT (.+)/', $default, $res ) ) {
865 $sqldef = "ALTER TABLE $table ALTER $field SET DEFAULT $res[1]";
866 $this->db->query( $sqldef );
867 $default = preg_replace( '/\s*DEFAULT .+/', '', $default );
868 }
869 $sql .= " USING $default";
870 }
871 $this->db->query( $sql );
872 }
873 }
874
875 protected function changeFieldPurgeTable( $table, $field, $newtype, $default ) {
876 # # For a cache table, empty it if the field needs to be changed, because the old contents
877 # # may be corrupted. If the column is already the desired type, refrain from purging.
878 $fi = $this->db->fieldInfo( $table, $field );
879 if ( is_null( $fi ) ) {
880 $this->output( "...ERROR: expected column $table.$field to exist\n" );
881 exit( 1 );
882 }
883
884 if ( $fi->type() === $newtype ) {
885 $this->output( "...column '$table.$field' is already of type '$newtype'\n" );
886 } else {
887 $this->output( "Purging data from cache table '$table'\n" );
888 $this->db->query( "DELETE from $table" );
889 $this->output( "Changing column type of '$table.$field' from '{$fi->type()}' to '$newtype'\n" );
890 $sql = "ALTER TABLE $table ALTER $field TYPE $newtype";
891 if ( strlen( $default ) ) {
892 $res = [];
893 if ( preg_match( '/DEFAULT (.+)/', $default, $res ) ) {
894 $sqldef = "ALTER TABLE $table ALTER $field SET DEFAULT $res[1]";
895 $this->db->query( $sqldef );
896 $default = preg_replace( '/\s*DEFAULT .+/', '', $default );
897 }
898 $sql .= " USING $default";
899 }
900 $this->db->query( $sql );
901 }
902 }
903
904 protected function setDefault( $table, $field, $default ) {
905 $info = $this->db->fieldInfo( $table, $field );
906 if ( $info->defaultValue() !== $default ) {
907 $this->output( "Changing '$table.$field' default value\n" );
908 $this->db->query( "ALTER TABLE $table ALTER $field SET DEFAULT "
909 . $this->db->addQuotes( $default ) );
910 }
911 }
912
913 protected function changeNullableField( $table, $field, $null, $update = false ) {
914 $fi = $this->db->fieldInfo( $table, $field );
915 if ( is_null( $fi ) ) {
916 $this->output( "...ERROR: expected column $table.$field to exist\n" );
917 exit( 1 );
918 }
919 if ( $fi->isNullable() ) {
920 # # It's NULL - does it need to be NOT NULL?
921 if ( 'NOT NULL' === $null ) {
922 $this->output( "Changing '$table.$field' to not allow NULLs\n" );
923 if ( $update ) {
924 $this->db->query( "UPDATE $table SET $field = DEFAULT WHERE $field IS NULL" );
925 }
926 $this->db->query( "ALTER TABLE $table ALTER $field SET NOT NULL" );
927 } else {
928 $this->output( "...column '$table.$field' is already set as NULL\n" );
929 }
930 } else {
931 # # It's NOT NULL - does it need to be NULL?
932 if ( 'NULL' === $null ) {
933 $this->output( "Changing '$table.$field' to allow NULLs\n" );
934 $this->db->query( "ALTER TABLE $table ALTER $field DROP NOT NULL" );
935 } else {
936 $this->output( "...column '$table.$field' is already set as NOT NULL\n" );
937 }
938 }
939 }
940
941 public function addPgIndex( $table, $index, $type ) {
942 if ( $this->db->indexExists( $table, $index ) ) {
943 $this->output( "...index '$index' on table '$table' already exists\n" );
944 } else {
945 $this->output( "Creating index '$index' on table '$table' $type\n" );
946 $this->db->query( "CREATE INDEX $index ON $table $type" );
947 }
948 }
949
950 public function addPgExtIndex( $table, $index, $type ) {
951 if ( $this->db->indexExists( $table, $index ) ) {
952 $this->output( "...index '$index' on table '$table' already exists\n" );
953 } else {
954 if ( preg_match( '/^\‍(/', $type ) ) {
955 $this->output( "Creating index '$index' on table '$table'\n" );
956 $this->db->query( "CREATE INDEX $index ON $table $type" );
957 } else {
958 $this->applyPatch( $type, true, "Creating index '$index' on table '$table'" );
959 }
960 }
961 }
962
969 public function addPgEnumValue( $type, $value ) {
970 $row = $this->db->selectRow(
971 [
972 't' => 'pg_catalog.pg_type',
973 'n' => 'pg_catalog.pg_namespace',
974 'e' => 'pg_catalog.pg_enum',
975 ],
976 [ 't.typname', 't.typtype', 'e.enumlabel' ],
977 [
978 't.typname' => $type,
979 'n.nspname' => $this->db->getCoreSchema(),
980 ],
981 __METHOD__,
982 [],
983 [
984 'n' => [ 'JOIN', 't.typnamespace = n.oid' ],
985 'e' => [ 'LEFT JOIN', [ 'e.enumtypid = t.oid', 'e.enumlabel' => $value ] ],
986 ]
987 );
988
989 if ( !$row ) {
990 $this->output( "...Type $type does not exist, skipping modify enum.\n" );
991 } elseif ( $row->typtype !== 'e' ) {
992 $this->output( "...Type $type does not seem to be an enum, skipping modify enum.\n" );
993 } elseif ( $row->enumlabel === $value ) {
994 $this->output( "...Enum type $type already contains value '$value'.\n" );
995 } else {
996 $this->output( "...Adding value '$value' to enum type $type.\n" );
997 $etype = $this->db->addIdentifierQuotes( $type );
998 $evalue = $this->db->addQuotes( $value );
999 $this->db->query( "ALTER TYPE $etype ADD VALUE $evalue" );
1000 }
1001 }
1002
1003 protected function dropFkey( $table, $field ) {
1004 $fi = $this->db->fieldInfo( $table, $field );
1005 if ( is_null( $fi ) ) {
1006 $this->output( "WARNING! Column '$table.$field' does not exist but it should! " .
1007 "Please report this.\n" );
1008 return;
1009 }
1010 $conname = $fi->conname();
1011 if ( $fi->conname() ) {
1012 $this->output( "Dropping foreign key constraint on '$table.$field'\n" );
1013 $conclause = "CONSTRAINT \"$conname\"";
1014 $command = "ALTER TABLE $table DROP CONSTRAINT $conname";
1015 $this->db->query( $command );
1016 } else {
1017 $this->output( "...foreign key constraint on '$table.$field' already does not exist\n" );
1018 };
1019 }
1020
1021 protected function changeFkeyDeferrable( $table, $field, $clause ) {
1022 $fi = $this->db->fieldInfo( $table, $field );
1023 if ( is_null( $fi ) ) {
1024 $this->output( "WARNING! Column '$table.$field' does not exist but it should! " .
1025 "Please report this.\n" );
1026
1027 return;
1028 }
1029 if ( $fi->is_deferred() && $fi->is_deferrable() ) {
1030 return;
1031 }
1032 $this->output( "Altering column '$table.$field' to be DEFERRABLE INITIALLY DEFERRED\n" );
1033 $conname = $fi->conname();
1034 if ( $fi->conname() ) {
1035 $conclause = "CONSTRAINT \"$conname\"";
1036 $command = "ALTER TABLE $table DROP CONSTRAINT $conname";
1037 $this->db->query( $command );
1038 } else {
1039 $this->output( "Column '$table.$field' does not have a foreign key " .
1040 "constraint, will be added\n" );
1041 $conclause = "";
1042 }
1043 $command =
1044 "ALTER TABLE $table ADD $conclause " .
1045 "FOREIGN KEY ($field) REFERENCES $clause DEFERRABLE INITIALLY DEFERRED";
1046 $this->db->query( $command );
1047 }
1048
1049 protected function convertArchive2() {
1050 if ( $this->db->tableExists( "archive2" ) ) {
1051 if ( $this->db->ruleExists( 'archive', 'archive_insert' ) ) {
1052 $this->output( "Dropping rule 'archive_insert'\n" );
1053 $this->db->query( 'DROP RULE archive_insert ON archive' );
1054 }
1055 if ( $this->db->ruleExists( 'archive', 'archive_delete' ) ) {
1056 $this->output( "Dropping rule 'archive_delete'\n" );
1057 $this->db->query( 'DROP RULE archive_delete ON archive' );
1058 }
1059 $this->applyPatch(
1060 'patch-remove-archive2.sql',
1061 false,
1062 "Converting 'archive2' back to normal archive table"
1063 );
1064 } else {
1065 $this->output( "...obsolete table 'archive2' does not exist\n" );
1066 }
1067 }
1068
1069 protected function checkOiDeleted() {
1070 if ( $this->db->fieldInfo( 'oldimage', 'oi_deleted' )->type() !== 'smallint' ) {
1071 $this->output( "Changing 'oldimage.oi_deleted' to type 'smallint'\n" );
1072 $this->db->query( "ALTER TABLE oldimage ALTER oi_deleted DROP DEFAULT" );
1073 $this->db->query(
1074 "ALTER TABLE oldimage ALTER oi_deleted TYPE SMALLINT USING (oi_deleted::smallint)" );
1075 $this->db->query( "ALTER TABLE oldimage ALTER oi_deleted SET DEFAULT 0" );
1076 } else {
1077 $this->output( "...column 'oldimage.oi_deleted' is already of type 'smallint'\n" );
1078 }
1079 }
1080
1081 protected function checkOiNameConstraint() {
1082 if ( $this->db->hasConstraint( "oldimage_oi_name_fkey_cascaded" ) ) {
1083 $this->output( "...table 'oldimage' has correct cascading delete/update " .
1084 "foreign key to image\n" );
1085 } else {
1086 if ( $this->db->hasConstraint( "oldimage_oi_name_fkey" ) ) {
1087 $this->db->query(
1088 "ALTER TABLE oldimage DROP CONSTRAINT oldimage_oi_name_fkey" );
1089 }
1090 if ( $this->db->hasConstraint( "oldimage_oi_name_fkey_cascade" ) ) {
1091 $this->db->query(
1092 "ALTER TABLE oldimage DROP CONSTRAINT oldimage_oi_name_fkey_cascade" );
1093 }
1094 $this->output( "Making foreign key on table 'oldimage' (to image) a cascade delete/update\n" );
1095 $this->db->query(
1096 "ALTER TABLE oldimage ADD CONSTRAINT oldimage_oi_name_fkey_cascaded " .
1097 "FOREIGN KEY (oi_name) REFERENCES image(img_name) " .
1098 "ON DELETE CASCADE ON UPDATE CASCADE" );
1099 }
1100 }
1101
1102 protected function checkPageDeletedTrigger() {
1103 if ( !$this->db->triggerExists( 'page', 'page_deleted' ) ) {
1104 $this->applyPatch(
1105 'patch-page_deleted.sql',
1106 false,
1107 "Adding function and trigger 'page_deleted' to table 'page'"
1108 );
1109 } else {
1110 $this->output( "...table 'page' has 'page_deleted' trigger\n" );
1111 }
1112 }
1113
1114 protected function dropPgIndex( $table, $index ) {
1115 if ( $this->db->indexExists( $table, $index ) ) {
1116 $this->output( "Dropping obsolete index '$index'\n" );
1117 $this->db->query( "DROP INDEX \"" . $index . "\"" );
1118 }
1119 }
1120
1121 protected function checkIndex( $index, $should_be, $good_def ) {
1122 $pu = $this->db->indexAttributes( $index );
1123 if ( !empty( $pu ) && $pu != $should_be ) {
1124 $this->output( "Dropping obsolete version of index '$index'\n" );
1125 $this->db->query( "DROP INDEX \"" . $index . "\"" );
1126 $pu = [];
1127 } else {
1128 $this->output( "...no need to drop index '$index'\n" );
1129 }
1130
1131 if ( empty( $pu ) ) {
1132 $this->output( "Creating index '$index'\n" );
1133 $this->db->query( $good_def );
1134 } else {
1135 $this->output( "...index '$index' exists\n" );
1136 }
1137 }
1138
1139 protected function checkRevUserFkey() {
1140 if ( $this->fkeyDeltype( 'revision_rev_user_fkey' ) == 'r' ) {
1141 $this->output( "...constraint 'revision_rev_user_fkey' is ON DELETE RESTRICT\n" );
1142 } else {
1143 $this->applyPatch(
1144 'patch-revision_rev_user_fkey.sql',
1145 false,
1146 "Changing constraint 'revision_rev_user_fkey' to ON DELETE RESTRICT"
1147 );
1148 }
1149 }
1150
1151 protected function checkIwlPrefix() {
1152 if ( $this->db->indexExists( 'iwlinks', 'iwl_prefix' ) ) {
1153 $this->applyPatch(
1154 'patch-rename-iwl_prefix.sql',
1155 false,
1156 "Replacing index 'iwl_prefix' with 'iwl_prefix_title_from'"
1157 );
1158 }
1159 }
1160
1161 protected function addInterwikiType() {
1162 $this->applyPatch( 'patch-add_interwiki.sql', false, "Refreshing add_interwiki()" );
1163 }
1164
1165 protected function tsearchFixes() {
1166 # Tweak the page_title tsearch2 trigger to filter out slashes
1167 # This is create or replace, so harmless to call if not needed
1168 $this->applyPatch( 'patch-ts2pagetitle.sql', false, "Refreshing ts2_page_title()" );
1169
1170 # If the server is 8.3 or higher, rewrite the tsearch2 triggers
1171 # in case they have the old 'default' versions
1172 # Gather version numbers in case we need them
1173 if ( $this->db->getServerVersion() >= 8.3 ) {
1174 $this->applyPatch( 'patch-tsearch2funcs.sql', false, "Rewriting tsearch2 triggers" );
1175 }
1176 }
1177
1178 protected function rebuildTextSearch() {
1179 if ( $this->updateRowExists( 'patch-textsearch_bug66650.sql' ) ) {
1180 $this->output( "...T68650 already fixed or not applicable.\n" );
1181 return;
1182 };
1183 $this->applyPatch( 'patch-textsearch_bug66650.sql', false,
1184 'Rebuilding text search for T68650' );
1185 }
1186}
Apache License January AND DISTRIBUTION Definitions License shall mean the terms and conditions for and distribution as defined by Sections through of this document Licensor shall mean the copyright owner or entity authorized by the copyright owner that is granting the License Legal Entity shall mean the union of the acting entity and all other entities that control are controlled by or are under common control with that entity For the purposes of this definition control direct or to cause the direction or management of such whether by contract or including but not limited to software source documentation and configuration files Object form shall mean any form resulting from mechanical transformation or translation of a Source including but not limited to compiled object generated and conversions to other media types Work shall mean the work of whether in Source or Object made available under the as indicated by a copyright notice that is included in or attached to the whether in Source or Object that is based or other modifications as a an original work of authorship For the purposes of this Derivative Works shall not include works that remain separable or merely the Work and Derivative Works thereof Contribution shall mean any work of including the original version of the Work and any modifications or additions to that Work or Derivative Works that is intentionally submitted to Licensor for inclusion in the Work by the copyright owner or by an individual or Legal Entity authorized to submit on behalf of the copyright owner For the purposes of this definition
as see the revision history and available at free of to any person obtaining a copy of this software and associated documentation to deal in the Software without including without limitation the rights to and or sell copies of the and to permit persons to whom the Software is furnished to do subject to the following WITHOUT WARRANTY OF ANY EXPRESS OR INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY DAMAGES OR OTHER WHETHER IN AN ACTION OF TORT OR ARISING FROM
$command
Definition cdb.php:65
Class for handling database updates.
array $updates
Array of updates to perform on the database.
updateRowExists( $key)
Helper function: check if the given key is present in the updatelog table.
applyPatch( $path, $isFullPath=false, $msg=null)
Applies a SQL patch.
Class for handling updates to Postgres databases.
changeNullableField( $table, $field, $null, $update=false)
changeField( $table, $field, $newtype, $default)
renameTable( $old, $new, $patch=false)
renameIndex( $table, $old, $new, $skipBothIndexExistWarning=false, $a=false, $b=false)
Rename an index from an existing table.
ruleDef( $table, $rule)
dropSequence( $table, $ns)
addPgExtIndex( $table, $index, $type)
addSequence( $table, $pkey, $ns)
addPgEnumValue( $type, $value)
Add a value to an existing PostgreSQL enum type.
getOldGlobalUpdates()
Before 1.17, we used to handle updates via stuff like $wgExtNewTables/Fields/Indexes.
dropPgField( $table, $field)
renameSequence( $old, $new)
dropPgIndex( $table, $index)
setDefault( $table, $field, $default)
DatabasePostgres $db
addPgField( $table, $field, $type)
setSequenceOwner( $table, $pkey, $seq)
dropFkey( $table, $field)
changeFkeyDeferrable( $table, $field, $clause)
checkIndex( $index, $should_be, $good_def)
changeFieldPurgeTable( $table, $field, $newtype, $default)
addPgIndex( $table, $index, $type)
$res
Definition database.txt:21
design txt This is a brief overview of the new design More thorough and up to date information is available on the documentation wiki at etc Handles the details of getting and saving to the user table of the and dealing with sessions and cookies OutputPage Encapsulates the entire HTML page that will be sent in response to any server request It is used by calling its functions to add in any and then calling output() to send it all. It could be easily changed to send incrementally if that becomes useful
null means default in associative array with keys and values unescaped Should be merged with default with a value of false meaning to suppress the attribute in associative array with keys and values unescaped noclasses just before the function returns a value If you return true
Definition hooks.txt:2006
null for the local wiki Added should default to null in handler for backwards compatibility add a value to it if you want to add a cookie that have to vary cache options can modify $query
Definition hooks.txt:1620