dict0load.c 33.3 KB
Newer Older
1 2 3 4 5 6 7 8 9 10
/******************************************************
Loads to the memory cache database object definitions
from dictionary tables

(c) 1996 Innobase Oy

Created 4/24/1996 Heikki Tuuri
*******************************************************/

#include "dict0load.h"
11
#ifndef UNIV_HOTBACKUP
monty@mysql.com's avatar
monty@mysql.com committed
12
#include "mysql_version.h"
13
#endif /* !UNIV_HOTBACKUP */
14 15 16 17 18 19 20 21 22 23 24

#ifdef UNIV_NONINL
#include "dict0load.ic"
#endif

#include "btr0pcur.h"
#include "btr0btr.h"
#include "page0page.h"
#include "mach0data.h"
#include "dict0dict.h"
#include "dict0boot.h"
25
#include "rem0cmp.h"
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
26
#include "srv0start.h"
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
27
#include "srv0srv.h"
28

29 30 31 32 33 34
/************************************************************************
Finds the first table name in the given database. */

char*
dict_get_first_table_name_in_db(
/*============================*/
35 36 37
				/* out, own: table name, NULL if
				does not exist; the caller must
				free the memory in the string! */
38
	const char*	name)	/* in: database name which ends in '/' */
39 40 41 42 43 44 45 46 47 48 49 50
{
	dict_table_t*	sys_tables;
	btr_pcur_t	pcur;
	dict_index_t*	sys_index;
	dtuple_t*	tuple;
	mem_heap_t*	heap;
	dfield_t*	dfield;
	rec_t*		rec;
	byte*		field;
	ulint		len;
	mtr_t		mtr;
	
51
#ifdef UNIV_SYNC_DEBUG
52
	ut_ad(mutex_own(&(dict_sys->mutex)));
53
#endif /* UNIV_SYNC_DEBUG */
54 55 56 57 58

	heap = mem_heap_create(1000);
	
	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
59
	sys_tables = dict_table_get_low("SYS_TABLES");
60
	sys_index = UT_LIST_GET_FIRST(sys_tables->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
61
	ut_a(!sys_tables->comp);
62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83

	tuple = dtuple_create(heap, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

	dfield_set_data(dfield, name, ut_strlen(name));
	dict_index_copy_types(tuple, sys_index, 1);

	btr_pcur_open_on_user_rec(sys_index, tuple, PAGE_CUR_GE,
					BTR_SEARCH_LEAF, &pcur, &mtr);
loop:
	rec = btr_pcur_get_rec(&pcur);

	if (!btr_pcur_is_on_user_rec(&pcur, &mtr)) {
		/* Not found */

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap);
		
		return(NULL);
	}	

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
84
	field = rec_get_nth_field_old(rec, 0, &len);
85 86 87 88 89 90 91 92 93 94 95 96

	if (len < strlen(name)
	    || ut_memcmp(name, field, strlen(name)) != 0) {
		/* Not found */

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap);
		
		return(NULL);
	}

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
97
	if (!rec_get_deleted_flag(rec, sys_tables->comp)) {
98 99 100

		/* We found one */

101
                char*	table_name = mem_strdupl((char*) field, len);
102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131
		
		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap);
		
		return(table_name);
	}
	
	btr_pcur_move_to_next_user_rec(&pcur, &mtr);

	goto loop;
}

/************************************************************************
Prints to the standard output information on all tables found in the data
dictionary system table. */

void
dict_print(void)
/*============*/
{
	dict_table_t*	sys_tables;
	dict_index_t*	sys_index;
	dict_table_t*	table;
	btr_pcur_t	pcur;
	rec_t*		rec;
	byte*		field;
	ulint		len;
	mtr_t		mtr;
	
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
132 133 134 135 136 137 138
	/* Enlarge the fatal semaphore wait timeout during the InnoDB table
	monitor printout */

	mutex_enter(&kernel_mutex);
	srv_fatal_semaphore_wait_threshold += 7200; /* 2 hours */
	mutex_exit(&kernel_mutex);

139 140 141 142
	mutex_enter(&(dict_sys->mutex));

	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
143
	sys_tables = dict_table_get_low("SYS_TABLES");
144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160
	sys_index = UT_LIST_GET_FIRST(sys_tables->indexes);

	btr_pcur_open_at_index_side(TRUE, sys_index, BTR_SEARCH_LEAF, &pcur,
								TRUE, &mtr);
loop:
	btr_pcur_move_to_next_user_rec(&pcur, &mtr);

	rec = btr_pcur_get_rec(&pcur);

	if (!btr_pcur_is_on_user_rec(&pcur, &mtr)) {
		/* end of index */

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		
		mutex_exit(&(dict_sys->mutex));

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
161 162 163 164 165 166
		/* Restore the fatal semaphore wait timeout */

		mutex_enter(&kernel_mutex);
		srv_fatal_semaphore_wait_threshold -= 7200; /* 2 hours */
		mutex_exit(&kernel_mutex);

167 168 169
		return;
	}	

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
170
	field = rec_get_nth_field_old(rec, 0, &len);
171

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
172
	if (!rec_get_deleted_flag(rec, sys_tables->comp)) {
173 174 175

		/* We found one */

176
                char*	table_name = mem_strdupl((char*) field, len);
177

178 179 180
		btr_pcur_store_position(&pcur, &mtr);

		mtr_commit(&mtr);
181

182
		table = dict_table_get_low(table_name);
183
		mem_free(table_name);
184 185

		if (table == NULL) {
186
			fputs("InnoDB: Failed to load table ", stderr);
187
			ut_print_namel(stderr, NULL, (char*) field, len);
188
			putc('\n', stderr);
189
		} else {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
190 191 192 193 194 195
			/* The table definition was corrupt if there
			is no index */

			if (dict_table_get_first_index(table)) {
				dict_update_statistics_low(table, TRUE);
			}
196 197 198 199 200 201 202 203 204 205 206 207

			dict_table_print_low(table);
		}

		mtr_start(&mtr);

		btr_pcur_restore_position(BTR_SEARCH_LEAF, &pcur, &mtr);
	}

	goto loop;
}

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
208 209 210 211
/************************************************************************
In a crash recovery we already have all the tablespace objects created.
This function compares the space id information in the InnoDB data dictionary
to what we already read with fil_load_single_table_tablespaces().
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
212 213 214 215

In a normal startup, we create the tablespace objects for every table in
InnoDB's data dictionary, if the corresponding .ibd file exists.
We also scan the biggest space id, and store it to fil_system. */
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
216 217

void
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
218 219
dict_check_tablespaces_and_store_max_id(
/*====================================*/
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235
	ibool	in_crash_recovery)	/* in: are we doing a crash recovery */
{
	dict_table_t*	sys_tables;
	dict_index_t*	sys_index;
	btr_pcur_t	pcur;
	rec_t*		rec;
	byte*		field;
	ulint		len;
	ulint		space_id;
	ulint		max_space_id	= 0;
	mtr_t		mtr;
	
	mutex_enter(&(dict_sys->mutex));

	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
236
	sys_tables = dict_table_get_low("SYS_TABLES");
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
237
	sys_index = UT_LIST_GET_FIRST(sys_tables->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
238
	ut_a(!sys_tables->comp);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264

	btr_pcur_open_at_index_side(TRUE, sys_index, BTR_SEARCH_LEAF, &pcur,
								TRUE, &mtr);
loop:
	btr_pcur_move_to_next_user_rec(&pcur, &mtr);

	rec = btr_pcur_get_rec(&pcur);

	if (!btr_pcur_is_on_user_rec(&pcur, &mtr)) {
		/* end of index */

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		
		/* We must make the tablespace cache aware of the biggest
		known space id */

		/* printf("Biggest space id in data dictionary %lu\n",
							    max_space_id); */
		fil_set_max_space_id_if_bigger(max_space_id);

		mutex_exit(&(dict_sys->mutex));

		return;
	}	

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
265
	field = rec_get_nth_field_old(rec, 0, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
266

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
267
	if (!rec_get_deleted_flag(rec, sys_tables->comp)) {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
268 269 270

		/* We found one */

271
                char*	name = mem_strdupl((char*) field, len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
272

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
273
		field = rec_get_nth_field_old(rec, 9, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
274 275 276 277 278 279 280 281 282 283 284 285 286
		ut_a(len == 4);
			
		space_id = mach_read_from_4(field);

		btr_pcur_store_position(&pcur, &mtr);

		mtr_commit(&mtr);
		
		if (space_id != 0 && in_crash_recovery) {
			/* Check that the tablespace (the .ibd file) really
			exists; print a warning to the .err log if not */
			
			fil_space_for_table_exists_in_mem(space_id, name,
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
287
							FALSE, TRUE, TRUE);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
288
		}
289

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
290 291 292 293 294 295 296 297
		if (space_id != 0 && !in_crash_recovery) {
			/* It is a normal database startup: create the space
			object and check that the .ibd file exists. */

			fil_open_single_table_tablespace(FALSE, space_id,
									name);
		}

298 299
		mem_free(name);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
300 301 302 303 304 305 306 307 308 309 310 311
		if (space_id > max_space_id) {
			max_space_id = space_id;
		}

		mtr_start(&mtr);

		btr_pcur_restore_position(BTR_SEARCH_LEAF, &pcur, &mtr);
	}

	goto loop;
}

312
/************************************************************************
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
313 314 315 316 317 318 319
Loads definitions for table columns. */
static
void
dict_load_columns(
/*==============*/
	dict_table_t*	table,	/* in: table */
	mem_heap_t*	heap)	/* in: memory heap for temporary storage */
320
{
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
321
	dict_table_t*	sys_columns;
322
	dict_index_t*	sys_index;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
323
	btr_pcur_t	pcur;
324 325 326 327 328
	dtuple_t*	tuple;
	dfield_t*	dfield;
	rec_t*		rec;
	byte*		field;
	ulint		len;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
329 330 331 332 333 334 335
	byte*		buf;
	char*		name;
	ulint		mtype;
	ulint		prtype;
	ulint		col_len;
	ulint		prec;
	ulint		i;
336
	mtr_t		mtr;
337
	
338
#ifdef UNIV_SYNC_DEBUG
339
	ut_ad(mutex_own(&(dict_sys->mutex)));
340
#endif /* UNIV_SYNC_DEBUG */
341 342 343

	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
344
	sys_columns = dict_table_get_low("SYS_COLUMNS");
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
345
	sys_index = UT_LIST_GET_FIRST(sys_columns->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
346
	ut_a(!sys_columns->comp);
347 348 349 350

	tuple = dtuple_create(heap, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
351 352 353 354
	buf = mem_heap_alloc(heap, 8);
	mach_write_to_8(buf, table->id);

	dfield_set_data(dfield, buf, 8);
355 356 357
	dict_index_copy_types(tuple, sys_index, 1);

	btr_pcur_open_on_user_rec(sys_index, tuple, PAGE_CUR_GE,
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
358 359
						BTR_SEARCH_LEAF, &pcur, &mtr);
   	for (i = 0; i < table->n_cols - DATA_N_SYS_COLS; i++) {
360

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
361
		rec = btr_pcur_get_rec(&pcur);
362

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
363
		ut_a(btr_pcur_is_on_user_rec(&pcur, &mtr));
364

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
365 366 367
		ut_a(!rec_get_deleted_flag(rec, sys_columns->comp));

		field = rec_get_nth_field_old(rec, 0, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
368 369
		ut_ad(len == 8);
		ut_a(ut_dulint_cmp(table->id, mach_read_from_8(field)) == 0);
370

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
371
		field = rec_get_nth_field_old(rec, 1, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
372 373
		ut_ad(len == 4);
		ut_a(i == mach_read_from_4(field));
374

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
375
		ut_a(0 == ut_strcmp("NAME",
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
376
			dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
377
			dict_index_get_nth_field(sys_index, 4))->name));
378

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
379
		field = rec_get_nth_field_old(rec, 4, &len);
380
		name = mem_heap_strdupl(heap, (char*) field, len);
381

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
382
		field = rec_get_nth_field_old(rec, 5, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
383
		mtype = mach_read_from_4(field);
384

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
385
		field = rec_get_nth_field_old(rec, 6, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
386
		prtype = mach_read_from_4(field);
387

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
388 389 390 391 392 393 394 395 396
		if (dtype_is_non_binary_string_type(mtype, prtype)
		    && dtype_get_charset_coll(prtype) == 0) {
			/* This is a non-binary string type, and the table
			was created with < 4.1.2. Use the default charset. */

			prtype = dtype_form_prtype(prtype,
					data_mysql_default_charset_coll);
		}

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
397
		field = rec_get_nth_field_old(rec, 7, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
398
		col_len = mach_read_from_4(field);
399

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
400
		ut_a(0 == ut_strcmp("PREC",
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
401
			dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
402
			dict_index_get_nth_field(sys_index, 8))->name));
403

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
404
		field = rec_get_nth_field_old(rec, 8, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
405
		prec = mach_read_from_4(field);
406

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
407 408 409 410
		dict_mem_table_add_col(table, name, mtype, prtype, col_len,
									prec);
		btr_pcur_move_to_next_user_rec(&pcur, &mtr);
	} 
411

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
412 413
	btr_pcur_close(&pcur);
	mtr_commit(&mtr);
414 415
}

416 417 418 419 420
/************************************************************************
Report that an index field or index for a table has been delete marked. */
static
void
dict_load_report_deleted_index(
421
/*===========================*/
422 423
	const char*	name,	/* in: table name */
	ulint		field)	/* in: index field, or ULINT_UNDEFINED */
424
{
425 426
	fprintf(stderr, "InnoDB: Error: data dictionary entry"
		" for table %s is corrupt!\n", name);
427 428 429
	if (field != ULINT_UNDEFINED) {
		fprintf(stderr,
			"InnoDB: Index field %lu is delete marked.\n", field);
430
	} else {
431 432 433 434
		fputs("InnoDB: An index is delete marked.\n", stderr);
	}
}

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
435 436 437 438 439 440 441 442 443
/************************************************************************
Loads definitions for index fields. */
static
void
dict_load_fields(
/*=============*/
	dict_table_t*	table,	/* in: table */
	dict_index_t*	index,	/* in: index whose fields to load */
	mem_heap_t*	heap)	/* in: memory heap for temporary storage */
444
{
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
445 446
	dict_table_t*	sys_fields;
	dict_index_t*	sys_index;
447 448 449
	btr_pcur_t	pcur;
	dtuple_t*	tuple;
	dfield_t*	dfield;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
450 451
	ulint		pos_and_prefix_len;
	ulint		prefix_len;
452 453
	rec_t*		rec;
	byte*		field;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
454 455 456
	ulint		len;
	byte*		buf;
	ulint		i;
457 458
	mtr_t		mtr;
	
459
#ifdef UNIV_SYNC_DEBUG
460
	ut_ad(mutex_own(&(dict_sys->mutex)));
461
#endif /* UNIV_SYNC_DEBUG */
462

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
463
	UT_NOT_USED(table);
464

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
465
	mtr_start(&mtr);
466

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
467
	sys_fields = dict_table_get_low("SYS_FIELDS");
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
468
	sys_index = UT_LIST_GET_FIRST(sys_fields->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
469
	ut_a(!sys_fields->comp);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
470 471

	tuple = dtuple_create(heap, 1);
472 473
	dfield = dtuple_get_nth_field(tuple, 0);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
474 475
	buf = mem_heap_alloc(heap, 8);
	mach_write_to_8(buf, index->id);
476

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
477 478
	dfield_set_data(dfield, buf, 8);
	dict_index_copy_types(tuple, sys_index, 1);
479

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
480
	btr_pcur_open_on_user_rec(sys_index, tuple, PAGE_CUR_GE,
481
						BTR_SEARCH_LEAF, &pcur, &mtr);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
482
   	for (i = 0; i < index->n_fields; i++) {
483

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
484
		rec = btr_pcur_get_rec(&pcur);
485 486

		ut_a(btr_pcur_is_on_user_rec(&pcur, &mtr));
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
487
		if (rec_get_deleted_flag(rec, sys_fields->comp)) {
488
			dict_load_report_deleted_index(table->name, i);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
489
		}
490
		
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
491
		field = rec_get_nth_field_old(rec, 0, &len);
492
		ut_ad(len == 8);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
493
		ut_a(ut_memcmp(buf, field, len) == 0);
494

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
495
		field = rec_get_nth_field_old(rec, 1, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
496 497 498 499 500 501 502 503 504 505 506 507
		ut_a(len == 4);

		/* The next field stores the field position in the index
		and a possible column prefix length if the index field
		does not contain the whole column. The storage format is
		like this: if there is at least one prefix field in the index,
		then the HIGH 2 bytes contain the field number (== i) and the
		low 2 bytes the prefix length for the field. Otherwise the
		field number (== i) is contained in the 2 LOW bytes. */

		pos_and_prefix_len = mach_read_from_4(field);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
508 509
		ut_a((pos_and_prefix_len & 0xFFFFUL) == i
		     || (pos_and_prefix_len & 0xFFFF0000UL) == (i << 16));
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
510 511

		if ((i == 0 && pos_and_prefix_len > 0)
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
512
		    || (pos_and_prefix_len & 0xFFFF0000UL) > 0) {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
513

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
514
		        prefix_len = pos_and_prefix_len & 0xFFFFUL;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
515 516 517
		} else {
		        prefix_len = 0;
		}
518

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
519
		ut_a(0 == ut_strcmp("COL_NAME",
520
			dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
521
			dict_index_get_nth_field(sys_index, 4))->name));
522

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
523
		field = rec_get_nth_field_old(rec, 4, &len);
524

525
		dict_mem_index_add_field(index,
526
                                         mem_heap_strdupl(heap, (char*) field, len), 0, prefix_len);
527 528 529 530 531 532 533 534 535

		btr_pcur_move_to_next_user_rec(&pcur, &mtr);
	} 

	btr_pcur_close(&pcur);
	mtr_commit(&mtr);
}

/************************************************************************
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
536 537
Loads definitions for table indexes. Adds them to the data dictionary
cache. */
538
static
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
539
ibool
540 541
dict_load_indexes(
/*==============*/
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
542 543
				/* out: TRUE if ok, FALSE if corruption
				of dictionary table */
544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566
	dict_table_t*	table,	/* in: table */
	mem_heap_t*	heap)	/* in: memory heap for temporary storage */
{
	dict_table_t*	sys_indexes;
	dict_index_t*	sys_index;
	dict_index_t*	index;
	btr_pcur_t	pcur;
	dtuple_t*	tuple;
	dfield_t*	dfield;
	rec_t*		rec;
	byte*		field;
	ulint		len;
	ulint		name_len;
	char*		name_buf;
	ulint		type;
	ulint		space;
	ulint		page_no;
	ulint		n_fields;
	byte*		buf;
	ibool		is_sys_table;
	dulint		id;
	mtr_t		mtr;
	
567
#ifdef UNIV_SYNC_DEBUG
568
	ut_ad(mutex_own(&(dict_sys->mutex)));
569
#endif /* UNIV_SYNC_DEBUG */
570 571 572 573 574 575 576 577 578 579

	if ((ut_dulint_get_high(table->id) == 0)
	    && (ut_dulint_get_low(table->id) < DICT_HDR_FIRST_ID)) {
		is_sys_table = TRUE;
	} else {
		is_sys_table = FALSE;
	}
	
	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
580
	sys_indexes = dict_table_get_low("SYS_INDEXES");
581
	sys_index = UT_LIST_GET_FIRST(sys_indexes->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
582
	ut_a(!sys_indexes->comp);
583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602

	tuple = dtuple_create(heap, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

	buf = mem_heap_alloc(heap, 8);
	mach_write_to_8(buf, table->id);

	dfield_set_data(dfield, buf, 8);
	dict_index_copy_types(tuple, sys_index, 1);

	btr_pcur_open_on_user_rec(sys_index, tuple, PAGE_CUR_GE,
						BTR_SEARCH_LEAF, &pcur, &mtr);
   	for (;;) {
		if (!btr_pcur_is_on_user_rec(&pcur, &mtr)) {

			break;
		}

		rec = btr_pcur_get_rec(&pcur);
		
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
603
		field = rec_get_nth_field_old(rec, 0, &len);
604 605 606 607 608 609
		ut_ad(len == 8);

		if (ut_memcmp(buf, field, len) != 0) {
			break;
		}

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
610
		if (rec_get_deleted_flag(rec, table->comp)) {
611 612
			dict_load_report_deleted_index(table->name,
				ULINT_UNDEFINED);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
613 614 615 616 617 618

			btr_pcur_close(&pcur);
			mtr_commit(&mtr);

			return(FALSE);
		}
619

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
620
		field = rec_get_nth_field_old(rec, 1, &len);
621 622 623
		ut_ad(len == 8);
		id = mach_read_from_8(field);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
624
		ut_a(0 == ut_strcmp("NAME",
625
			dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
626 627 628
			dict_index_get_nth_field(sys_index, 4))->name));

		field = rec_get_nth_field_old(rec, 4, &name_len);
629
		name_buf = mem_heap_strdupl(heap, (char*) field, name_len);
630

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
631
		field = rec_get_nth_field_old(rec, 5, &len);
632 633
		n_fields = mach_read_from_4(field);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
634
		field = rec_get_nth_field_old(rec, 6, &len);
635 636
		type = mach_read_from_4(field);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
637
		field = rec_get_nth_field_old(rec, 7, &len);
638 639
		space = mach_read_from_4(field);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
640
		ut_a(0 == ut_strcmp("PAGE_NO",
641
			dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
642
			dict_index_get_nth_field(sys_index, 8))->name));
643

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
644
		field = rec_get_nth_field_old(rec, 8, &len);
645 646
		page_no = mach_read_from_4(field);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
647 648
		if (page_no == FIL_NULL) {

649 650 651 652
			fprintf(stderr,
		"InnoDB: Error: trying to load index %s for table %s\n"
		"InnoDB: but the index tree has been freed!\n",
				name_buf, table->name);
653

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
654 655 656 657 658 659 660 661 662
			btr_pcur_close(&pcur);
			mtr_commit(&mtr);

			return(FALSE);
		}

		if ((type & DICT_CLUSTERED) == 0
			    && NULL == dict_table_get_first_index(table)) {

663 664 665 666
			fprintf(stderr,
		"InnoDB: Error: trying to load index %s for table %s\n"
		"InnoDB: but the first index is not clustered!\n",
				name_buf, table->name);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
667 668 669 670 671 672 673

			btr_pcur_close(&pcur);
			mtr_commit(&mtr);

			return(FALSE);
		}
		
674 675 676
		if (is_sys_table
		    && ((type & DICT_CLUSTERED)
		        || ((table == dict_sys->sys_tables)
677
		            && (name_len == (sizeof "ID_IND") - 1)
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
678
			    && (0 == ut_memcmp(name_buf, "ID_IND",
679 680
							name_len))))) {

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
681 682
			/* The index was created in memory already at booting
			of the database server */
683 684 685 686 687 688
		} else {
 			index = dict_mem_index_create(table->name, name_buf,
						space, type, n_fields);
			index->id = id;
		
			dict_load_fields(table, index, heap);
689
			dict_index_add_to_cache(table, index, page_no);
690 691 692 693 694 695 696
		}

		btr_pcur_move_to_next_user_rec(&pcur, &mtr);
	} 

	btr_pcur_close(&pcur);
	mtr_commit(&mtr);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
697 698

	return(TRUE);
699 700 701
}

/************************************************************************
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
702 703 704 705 706 707 708 709 710
Loads a table definition and also all its index definitions, and also
the cluster definition if the table is a member in a cluster. Also loads
all foreign key constraints where the foreign key is in the table or where
a foreign key references columns in this table. Adds all these to the data
dictionary cache. */

dict_table_t*
dict_load_table(
/*============*/
711 712 713 714 715 716 717
				/* out: table, NULL if does not exist;
				if the table is stored in an .ibd file,
				but the file does not exist,
				then we set the ibd_file_missing flag TRUE
				in the table object we return */
	const char*	name)	/* in: table name in the
				databasename/tablename format */
718
{
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
719
	ibool		ibd_file_missing	= FALSE;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
720 721
	dict_table_t*	table;
	dict_table_t*	sys_tables;
722
	btr_pcur_t	pcur;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
723
	dict_index_t*	sys_index;
724
	dtuple_t*	tuple;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
725
	mem_heap_t*	heap;
726 727 728 729
	dfield_t*	dfield;
	rec_t*		rec;
	byte*		field;
	ulint		len;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
730 731
	ulint		space;
	ulint		n_cols;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
732
	ulint		err;
733
	mtr_t		mtr;
734
	
735
#ifdef UNIV_SYNC_DEBUG
736
	ut_ad(mutex_own(&(dict_sys->mutex)));
737
#endif /* UNIV_SYNC_DEBUG */
738

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
739 740
	heap = mem_heap_create(1000);
	
741 742
	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
743
	sys_tables = dict_table_get_low("SYS_TABLES");
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
744
	sys_index = UT_LIST_GET_FIRST(sys_tables->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
745
	ut_a(!sys_tables->comp);
746 747 748 749

	tuple = dtuple_create(heap, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
750
	dfield_set_data(dfield, name, ut_strlen(name));
751 752 753
	dict_index_copy_types(tuple, sys_index, 1);

	btr_pcur_open_on_user_rec(sys_index, tuple, PAGE_CUR_GE,
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
754 755
					BTR_SEARCH_LEAF, &pcur, &mtr);
	rec = btr_pcur_get_rec(&pcur);
756

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
757
	if (!btr_pcur_is_on_user_rec(&pcur, &mtr)
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
758
			|| rec_get_deleted_flag(rec, sys_tables->comp)) {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
759
		/* Not found */
760

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
761 762 763
		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap);
764
		
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
765 766
		return(NULL);
	}	
767

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
768
	field = rec_get_nth_field_old(rec, 0, &len);
769

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
770 771 772 773 774 775 776 777
	/* Check if the table name in record is the searched one */
	if (len != ut_strlen(name) || ut_memcmp(name, field, len) != 0) {
		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap);
		
		return(NULL);
	}
778

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
779
	ut_a(0 == ut_strcmp("SPACE",
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
780
		dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
781
		dict_index_get_nth_field(sys_index, 9))->name));
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
782
	
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
783
	field = rec_get_nth_field_old(rec, 9, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
784 785
	space = mach_read_from_4(field);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
786 787 788
	/* Check if the tablespace exists and has the right name */
	if (space != 0) {
		if (fil_space_for_table_exists_in_mem(space, name, FALSE,
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
789
							FALSE, FALSE)) {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
790 791 792
			/* Ok; (if we did a crash recovery then the tablespace
			can already be in the memory cache) */
		} else {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
793 794 795 796 797 798 799 800 801
			/* In >= 4.1.9, InnoDB scans the data dictionary also
			at a normal mysqld startup. It is an error if the
			space object does not exist in memory. */

			ut_print_timestamp(stderr);
			fprintf(stderr,
"  InnoDB: error: space object of table %s,\n"
"InnoDB: space id %lu did not exist in memory. Retrying an open.\n",
							name, (ulong)space);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
802
			/* Try to open the tablespace */
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
803 804
			if (!fil_open_single_table_tablespace(TRUE,
							space, name)) {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
805 806 807 808 809 810 811 812
				/* We failed to find a sensible tablespace
				file */

				ibd_file_missing = TRUE;
			}
		}
	}

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
813
	ut_a(0 == ut_strcmp("N_COLS",
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
814
		dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
815
		dict_index_get_nth_field(sys_index, 4))->name));
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
816

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
817
	field = rec_get_nth_field_old(rec, 4, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
818 819
	n_cols = mach_read_from_4(field);

820 821 822 823
	/* The high-order bit of N_COLS is the "compact format" flag. */
	table = dict_mem_table_create(name, space,
					n_cols & ~0x80000000UL,
					!!(n_cols & 0x80000000UL));
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
824

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
825 826
	table->ibd_file_missing = ibd_file_missing;

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
827
	ut_a(0 == ut_strcmp("ID",
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
828
		dict_field_get_col(
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
829
		dict_index_get_nth_field(sys_index, 3))->name));
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
830

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
831
	field = rec_get_nth_field_old(rec, 3, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
832 833
	table->id = mach_read_from_8(field);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
834
	field = rec_get_nth_field_old(rec, 5, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
835 836 837
	table->type = mach_read_from_4(field);

	if (table->type == DICT_TABLE_CLUSTER_MEMBER) {
838
		ut_error;
839
#if 0 /* clustered tables have not been implemented yet */
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
840
		field = rec_get_nth_field_old(rec, 6, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
841 842
		table->mix_id = mach_read_from_8(field);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
843
		field = rec_get_nth_field_old(rec, 8, &len);
844
		table->cluster_name = mem_heap_strdupl(heap, (char*) field, len);
845
#endif
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
846 847 848 849
	}

	if ((table->type == DICT_TABLE_CLUSTER)
	    || (table->type == DICT_TABLE_CLUSTER_MEMBER)) {
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
850

851 852 853
		field = rec_get_nth_field_old(rec, 7, &len);
		ut_a(len == 4);
		table->mix_len = mach_read_from_4(field);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
854
	}
855

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
856 857
	btr_pcur_close(&pcur);
	mtr_commit(&mtr);
858

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
859 860 861 862 863 864 865 866 867 868 869 870
	if (table->type == DICT_TABLE_CLUSTER_MEMBER) {
		/* Load the cluster table definition if not yet in
		memory cache */
		dict_table_get_low(table->cluster_name);
	}

	dict_load_columns(table, heap);

	dict_table_add_to_cache(table);
	
	dict_load_indexes(table, heap);
	
871
	err = dict_load_foreigns(table->name, TRUE);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
872 873 874 875
/*
	if (err != DB_SUCCESS) {
	
 		mutex_enter(&dict_foreign_err_mutex);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
876

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
877 878 879 880 881 882 883
 		ut_print_timestamp(stderr);
 		
		fprintf(stderr,
"  InnoDB: Error: could not make a foreign key definition to match\n"
"InnoDB: the foreign key table or the referenced table!\n"
"InnoDB: The data dictionary of InnoDB is corrupt. You may need to drop\n"
"InnoDB: and recreate the foreign key table or the referenced table.\n"
884
"InnoDB: Submit a detailed bug report to http://bugs.mysql.com\n"
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
885 886 887 888 889
"InnoDB: Latest foreign key error printout:\n%s\n", dict_foreign_err_buf);
				
		mutex_exit(&dict_foreign_err_mutex);
	}
*/
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916
	mem_heap_free(heap);

	return(table);
}

/***************************************************************************
Loads a table object based on the table id. */

dict_table_t*
dict_load_table_on_id(
/*==================*/
				/* out: table; NULL if table does not exist */
	dulint	table_id)	/* in: table id */	
{
	byte		id_buf[8];
	btr_pcur_t	pcur;
	mem_heap_t* 	heap;
	dtuple_t*	tuple;
	dfield_t*	dfield;
	dict_index_t*	sys_table_ids;
	dict_table_t*	sys_tables;
	rec_t*		rec;
	byte*		field;
	ulint		len;	
	dict_table_t*	table;
	mtr_t		mtr;
	
917
#ifdef UNIV_SYNC_DEBUG
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
918
	ut_ad(mutex_own(&(dict_sys->mutex)));
919
#endif /* UNIV_SYNC_DEBUG */
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
920 921 922 923 924 925 926 927 928 929 930

	/* NOTE that the operation of this function is protected by
	the dictionary mutex, and therefore no deadlocks can occur
	with other dictionary operations. */

	mtr_start(&mtr);	
	/*---------------------------------------------------*/
	/* Get the secondary index based on ID for table SYS_TABLES */	
	sys_tables = dict_sys->sys_tables;
	sys_table_ids = dict_table_get_next_index(
				dict_table_get_first_index(sys_tables));
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
931
	ut_a(!sys_tables->comp);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947
	heap = mem_heap_create(256);

	tuple  = dtuple_create(heap, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

	/* Write the table id in byte format to id_buf */
	mach_write_to_8(id_buf, table_id);
	
	dfield_set_data(dfield, id_buf, 8);
	dict_index_copy_types(tuple, sys_table_ids, 1);

	btr_pcur_open_on_user_rec(sys_table_ids, tuple, PAGE_CUR_GE,
						BTR_SEARCH_LEAF, &pcur, &mtr);
	rec = btr_pcur_get_rec(&pcur);
	
	if (!btr_pcur_is_on_user_rec(&pcur, &mtr)
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
948
			|| rec_get_deleted_flag(rec, sys_tables->comp)) {
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
949 950 951 952 953 954 955 956 957 958 959 960 961 962
		/* Not found */

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap);
		
		return(NULL);
	}

	/*---------------------------------------------------*/
	/* Now we have the record in the secondary index containing the
	table ID and NAME */

	rec = btr_pcur_get_rec(&pcur);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
963
	field = rec_get_nth_field_old(rec, 0, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
964
	ut_ad(len == 8);
965

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
966 967 968 969 970 971 972 973 974 975 976
	/* Check if the table id in record is the one searched for */
	if (ut_dulint_cmp(table_id, mach_read_from_8(field)) != 0) {

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap);
		
		return(NULL);
	}
		
	/* Now we get the table name from the record */
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
977
	field = rec_get_nth_field_old(rec, 1, &len);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
978
	/* Load the table definition to memory */
979
	table = dict_load_table(mem_heap_strdupl(heap, (char*) field, len));
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
980
	
981 982
	btr_pcur_close(&pcur);
	mtr_commit(&mtr);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999
	mem_heap_free(heap);

	return(table);
}

/************************************************************************
This function is called when the database is booted. Loads system table
index definitions except for the clustered index which is added to the
dictionary cache at booting before calling this function. */

void
dict_load_sys_table(
/*================*/
	dict_table_t*	table)	/* in: system table */
{
	mem_heap_t*	heap;

1000
#ifdef UNIV_SYNC_DEBUG
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
1001
	ut_ad(mutex_own(&(dict_sys->mutex)));
1002
#endif /* UNIV_SYNC_DEBUG */
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
1003 1004 1005 1006 1007 1008

	heap = mem_heap_create(1000);

	dict_load_indexes(table, heap);
	
	mem_heap_free(heap);
1009 1010
}

1011 1012 1013 1014 1015 1016
/************************************************************************
Loads foreign key constraint col names (also for the referenced table). */
static
void
dict_load_foreign_cols(
/*===================*/
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1017
	const char*	id,	/* in: foreign constraint id as a null-
1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031
				terminated string */
	dict_foreign_t*	foreign)/* in: foreign constraint object */
{
	dict_table_t*	sys_foreign_cols;
	dict_index_t*	sys_index;
	btr_pcur_t	pcur;
	dtuple_t*	tuple;
	dfield_t*	dfield;
	rec_t*		rec;
	byte*		field;
	ulint		len;
	ulint		i;
	mtr_t		mtr;
	
1032
#ifdef UNIV_SYNC_DEBUG
1033
	ut_ad(mutex_own(&(dict_sys->mutex)));
1034
#endif /* UNIV_SYNC_DEBUG */
1035 1036 1037 1038 1039 1040 1041 1042

	foreign->foreign_col_names = mem_heap_alloc(foreign->heap,
					foreign->n_fields * sizeof(void*));

	foreign->referenced_col_names = mem_heap_alloc(foreign->heap,
					foreign->n_fields * sizeof(void*));
	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1043
	sys_foreign_cols = dict_table_get_low("SYS_FOREIGN_COLS");
1044
	sys_index = UT_LIST_GET_FIRST(sys_foreign_cols->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1045
	ut_a(!sys_foreign_cols->comp);
1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059

	tuple = dtuple_create(foreign->heap, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

	dfield_set_data(dfield, id, ut_strlen(id));
	dict_index_copy_types(tuple, sys_index, 1);

	btr_pcur_open_on_user_rec(sys_index, tuple, PAGE_CUR_GE,
						BTR_SEARCH_LEAF, &pcur, &mtr);
   	for (i = 0; i < foreign->n_fields; i++) {

		rec = btr_pcur_get_rec(&pcur);

		ut_a(btr_pcur_is_on_user_rec(&pcur, &mtr));
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1060 1061 1062
		ut_a(!rec_get_deleted_flag(rec, sys_foreign_cols->comp));

		field = rec_get_nth_field_old(rec, 0, &len);
1063 1064 1065
		ut_a(len == ut_strlen(id));
		ut_a(ut_memcmp(id, field, len) == 0);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1066
		field = rec_get_nth_field_old(rec, 1, &len);
1067 1068 1069
		ut_a(len == 4);
		ut_a(i == mach_read_from_4(field));

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1070
		field = rec_get_nth_field_old(rec, 4, &len);
1071
		foreign->foreign_col_names[i] =
1072
                        mem_heap_strdupl(foreign->heap, (char*) field, len);
1073

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1074
		field = rec_get_nth_field_old(rec, 5, &len);
1075
		foreign->referenced_col_names[i] =
1076
                  mem_heap_strdupl(foreign->heap, (char*) field, len);
1077 1078 1079 1080 1081 1082 1083 1084

		btr_pcur_move_to_next_user_rec(&pcur, &mtr);
	} 

	btr_pcur_close(&pcur);
	mtr_commit(&mtr);
}

1085
/***************************************************************************
1086 1087 1088 1089 1090
Loads a foreign key constraint to the dictionary cache. */
static
ulint
dict_load_foreign(
/*==============*/
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1091
				/* out: DB_SUCCESS or error code */
1092
	const char*	id,	/* in: foreign constraint id as a
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1093
				null-terminated string */
1094
	ibool		check_types)/* in: TRUE=check type compatibility */
1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107
{	
	dict_foreign_t*	foreign;
	dict_table_t*	sys_foreign;
	btr_pcur_t	pcur;
	dict_index_t*	sys_index;
	dtuple_t*	tuple;
	mem_heap_t*	heap2;
	dfield_t*	dfield;
	rec_t*		rec;
	byte*		field;
	ulint		len;
	mtr_t		mtr;
	
1108
#ifdef UNIV_SYNC_DEBUG
1109
	ut_ad(mutex_own(&(dict_sys->mutex)));
1110
#endif /* UNIV_SYNC_DEBUG */
1111

1112 1113 1114 1115
	heap2 = mem_heap_create(1000);
	
	mtr_start(&mtr);

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1116
	sys_foreign = dict_table_get_low("SYS_FOREIGN");
1117
	sys_index = UT_LIST_GET_FIRST(sys_foreign->indexes);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1118
	ut_a(!sys_foreign->comp);
1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130

	tuple = dtuple_create(heap2, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

	dfield_set_data(dfield, id, ut_strlen(id));
	dict_index_copy_types(tuple, sys_index, 1);

	btr_pcur_open_on_user_rec(sys_index, tuple, PAGE_CUR_GE,
					BTR_SEARCH_LEAF, &pcur, &mtr);
	rec = btr_pcur_get_rec(&pcur);

	if (!btr_pcur_is_on_user_rec(&pcur, &mtr)
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1131
			|| rec_get_deleted_flag(rec, sys_foreign->comp)) {
1132 1133
		/* Not found */

1134 1135 1136
		fprintf(stderr,
			"InnoDB: Error A: cannot load foreign constraint %s\n",
			id);
1137 1138 1139 1140 1141 1142 1143 1144

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap2);
		
		return(DB_ERROR);
	}	

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1145
	field = rec_get_nth_field_old(rec, 0, &len);
1146 1147 1148 1149

	/* Check if the id in record is the searched one */
	if (len != ut_strlen(id) || ut_memcmp(id, field, len) != 0) {

1150 1151 1152
		fprintf(stderr,
			"InnoDB: Error B: cannot load foreign constraint %s\n",
			id);
1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167

		btr_pcur_close(&pcur);
		mtr_commit(&mtr);
		mem_heap_free(heap2);
		
		return(DB_ERROR);
	}

	/* Read the table names and the number of columns associated
	with the constraint */

	mem_heap_free(heap2);
	
	foreign = dict_mem_foreign_create();

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1168 1169
	foreign->n_fields =
		mach_read_from_4(rec_get_nth_field_old(rec, 5, &len));
1170 1171

	ut_a(len == 4);
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
1172 1173 1174 1175

	/* We store the type to the bits 24-31 of n_fields */
	
	foreign->type = foreign->n_fields >> 24;
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
1176
	foreign->n_fields = foreign->n_fields & 0xFFFFFFUL;
1177
	
1178
	foreign->id = mem_heap_strdup(foreign->heap, id);
1179

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1180
	field = rec_get_nth_field_old(rec, 3, &len);
1181
	foreign->foreign_table_name =
1182
                mem_heap_strdupl(foreign->heap, (char*) field, len);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1183 1184

	field = rec_get_nth_field_old(rec, 4, &len);
1185
	foreign->referenced_table_name =
1186
                mem_heap_strdupl(foreign->heap, (char*) field, len);
1187 1188 1189 1190 1191 1192

	btr_pcur_close(&pcur);
	mtr_commit(&mtr);

	dict_load_foreign_cols(id, foreign);

heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
1193 1194 1195 1196 1197 1198
	/* If the foreign table is not yet in the dictionary cache, we
	have to load it so that we are able to make type comparisons
	in the next function call. */

	dict_table_get_low(foreign->foreign_table_name);

1199 1200 1201
	/* Note that there may already be a foreign constraint object in
	the dictionary cache for this constraint: then the following
	call only sets the pointers in it to point to the appropriate table
heikki@hundin.mysql.fi's avatar
heikki@hundin.mysql.fi committed
1202 1203 1204 1205
	and index objects and frees the newly created object foreign.
	Adding to the cache should always succeed since we are not creating
	a new foreign key constraint but loading one from the data
	dictionary. */
1206

1207
	return(dict_foreign_add_to_cache(foreign, check_types));
1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219
}

/***************************************************************************
Loads foreign key constraints where the table is either the foreign key
holder or where the table is referenced by a foreign key. Adds these
constraints to the data dictionary. Note that we know that the dictionary
cache already contains all constraints where the other relevant table is
already in the dictionary cache. */

ulint
dict_load_foreigns(
/*===============*/
1220
					/* out: DB_SUCCESS or error code */
1221
	const char*	table_name,	/* in: table name */
1222
	ibool		check_types)	/* in: TRUE=check type compatibility */
1223 1224 1225 1226 1227
{
	btr_pcur_t	pcur;
	mem_heap_t* 	heap;
	dtuple_t*	tuple;
	dfield_t*	dfield;
1228 1229
	dict_index_t*	sec_index;
	dict_table_t*	sys_foreign;
1230 1231 1232
	rec_t*		rec;
	byte*		field;
	ulint		len;	
1233 1234 1235
	char*		id ;
	ulint		err;
	mtr_t		mtr;
1236
	
1237
#ifdef UNIV_SYNC_DEBUG
1238
	ut_ad(mutex_own(&(dict_sys->mutex)));
1239
#endif /* UNIV_SYNC_DEBUG */
1240

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1241
	sys_foreign = dict_table_get_low("SYS_FOREIGN");
1242 1243 1244 1245 1246 1247 1248 1249 1250

	if (sys_foreign == NULL) {
		/* No foreign keys defined yet in this database */

		fprintf(stderr,
	"InnoDB: Error: no foreign key system tables in the database\n");
		
		return(DB_ERROR);
	}
1251

marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1252
	ut_a(!sys_foreign->comp);
1253
	mtr_start(&mtr);	
1254 1255 1256 1257 1258 1259 1260

	/* Get the secondary index based on FOR_NAME from table
	SYS_FOREIGN */	

	sec_index = dict_table_get_next_index(
				dict_table_get_first_index(sys_foreign));
start_load:
1261 1262 1263 1264 1265
	heap = mem_heap_create(256);

	tuple  = dtuple_create(heap, 1);
	dfield = dtuple_get_nth_field(tuple, 0);

1266 1267
	dfield_set_data(dfield, table_name, ut_strlen(table_name));
	dict_index_copy_types(tuple, sec_index, 1);
1268

1269
	btr_pcur_open_on_user_rec(sec_index, tuple, PAGE_CUR_GE,
1270
						BTR_SEARCH_LEAF, &pcur, &mtr);
1271
loop:
1272 1273
	rec = btr_pcur_get_rec(&pcur);
	
1274 1275
	if (!btr_pcur_is_on_user_rec(&pcur, &mtr)) {
		/* End of index */
1276

1277
		goto load_next_index;
1278 1279
	}

1280 1281
	/* Now we have the record in the secondary index containing a table
	name and a foreign constraint ID */
1282 1283

	rec = btr_pcur_get_rec(&pcur);
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1284
	field = rec_get_nth_field_old(rec, 0, &len);
1285

1286 1287 1288
	/* Check if the table name in the record is the one searched for; the
	following call does the comparison in the latin1_swedish_ci
	charset-collation, in a case-insensitive way. */
1289

1290 1291 1292 1293
	if (0 != cmp_data_data(dfield_get_type(dfield),
			dfield_get_data(dfield), dfield_get_len(dfield),
			field, len)) {
		
1294
		goto load_next_index;
1295
	}
1296 1297 1298 1299 1300 1301 1302 1303 1304 1305

	/* Since table names in SYS_FOREIGN are stored in a case-insensitive
	order, we have to check that the table name matches also in a binary
	string comparison. On Unix, MySQL allows table names that only differ
	in character case. */

	if (0 != ut_memcmp(field, table_name, len)) {

		goto next_rec;
	}
1306
		
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1307
	if (rec_get_deleted_flag(rec, sys_foreign->comp)) {
1308 1309 1310 1311 1312

		goto next_rec;
	}

	/* Now we get a foreign key constraint id */
marko@hundin.mysql.fi's avatar
marko@hundin.mysql.fi committed
1313
	field = rec_get_nth_field_old(rec, 1, &len);
1314
	id = mem_heap_strdupl(heap, (char*) field, len);
1315
	
1316
	btr_pcur_store_position(&pcur, &mtr);
1317

1318 1319 1320
	mtr_commit(&mtr);

	/* Load the foreign constraint definition to the dictionary cache */
1321
	
1322
	err = dict_load_foreign(id, check_types);
1323 1324 1325 1326 1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339

	if (err != DB_SUCCESS) {
		btr_pcur_close(&pcur);
		mem_heap_free(heap);

		return(err);
	}

	mtr_start(&mtr);

	btr_pcur_restore_position(BTR_SEARCH_LEAF, &pcur, &mtr);
next_rec:
	btr_pcur_move_to_next_user_rec(&pcur, &mtr);

	goto loop;

load_next_index:
1340 1341 1342
	btr_pcur_close(&pcur);
	mtr_commit(&mtr);
	mem_heap_free(heap);
1343 1344
	
	sec_index = dict_table_get_next_index(sec_index);
1345

1346 1347 1348 1349 1350 1351 1352 1353
	if (sec_index != NULL) {

		mtr_start(&mtr);	

		goto start_load;
	}

	return(DB_SUCCESS);
1354
}