mysql数据字典初始化dict_boot

1260阅读 0评论2013-03-23 gladness
分类:Mysql/postgreSQL

/*****************************************************************//**

Initializes the data dictionary memory structures when the database is

started. This function is also called when the data dictionary is created. */

UNIV_INTERN

void

dict_boot(void)

/*===========*/

{

    dict_table_t*    table;

    dict_index_t*    index;

    dict_hdr_t*  dict_hdr;

    mem_heap_t*  heap;

    mtr_t        mtr;

    ulint        error;

 

    mtr_start(&mtr);

 

    /* Create the hash tables etc. */

    dict_init();

 

    heap = mem_heap_create(450);

 

    mutex_enter(&(dict_sys->mutex));

 

    /* Get the dictionary header */

    dict_hdr = dict_hdr_get(&mtr);

 

    /* Because we only write new row ids to disk-based data structure

    (dictionary header) when it is divisible by

    DICT_HDR_ROW_ID_WRITE_MARGIN, in recovery we will not recover

    the latest value of the row id counter. Therefore we advance

    the counter at the database startup to avoid overlapping values.

    Note that when a user after database startup first time asks for

    a new row id, then because the counter is now divisible by

    ..._MARGIN, it will immediately be updated to the disk-based

    header. */

 

    dict_sys->row_id = DICT_HDR_ROW_ID_WRITE_MARGIN

        + ut_uint64_align_up(mach_read_from_8(dict_hdr + DICT_HDR_ROW_ID),

                      DICT_HDR_ROW_ID_WRITE_MARGIN);

 

    /* Insert into the dictionary cache the descriptions of the basic

    system tables */

    /*-------------------------*/

    table = dict_mem_table_create("SYS_TABLES", DICT_HDR_SPACE, 8, 0);

 

    dict_mem_table_add_col(table, heap, "NAME", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "ID", DATA_BINARY, 0, 0);

    /* ROW_FORMAT = (N_COLS >> 31) ? COMPACT : REDUNDANT */

    dict_mem_table_add_col(table, heap, "N_COLS", DATA_INT, 0, 4);

    /* TYPE is either DICT_TABLE_ORDINARY, or (TYPE & DICT_TF_COMPACT)

    and (TYPE & DICT_TF_FORMAT_MASK) are nonzero and TYPE = table->flags */

    dict_mem_table_add_col(table, heap, "TYPE", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "MIX_ID", DATA_BINARY, 0, 0);

    /* MIX_LEN may contain additional table flags when

    ROW_FORMAT!=REDUNDANT.  Currently, these flags include

    DICT_TF2_TEMPORARY. */

    dict_mem_table_add_col(table, heap, "MIX_LEN", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "CLUSTER_NAME", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "SPACE", DATA_INT, 0, 4);

 

    table->id = DICT_TABLES_ID;

 

    dict_table_add_to_cache(table, heap);

    dict_sys->sys_tables = table;

    mem_heap_empty(heap);

 

    index = dict_mem_index_create("SYS_TABLES", "CLUST_IND",

                       DICT_HDR_SPACE,

                       DICT_UNIQUE | DICT_CLUSTERED, 1);

 

    dict_mem_index_add_field(index, "NAME", 0);

 

    index->id = DICT_TABLES_ID;

 

    error = dict_index_add_to_cache(table, index,

                     mtr_read_ulint(dict_hdr

                                + DICT_HDR_TABLES,

                                MLOG_4BYTES, &mtr),

                     FALSE);

    ut_a(error == DB_SUCCESS);

 

    /*-------------------------*/

    index = dict_mem_index_create("SYS_TABLES", "ID_IND",

                       DICT_HDR_SPACE, DICT_UNIQUE, 1);

    dict_mem_index_add_field(index, "ID", 0);

 

    index->id = DICT_TABLE_IDS_ID;

    error = dict_index_add_to_cache(table, index,

                     mtr_read_ulint(dict_hdr

                                + DICT_HDR_TABLE_IDS,

                                MLOG_4BYTES, &mtr),

                     FALSE);

    ut_a(error == DB_SUCCESS);

 

    /*-------------------------*/

    table = dict_mem_table_create("SYS_COLUMNS", DICT_HDR_SPACE, 7, 0);

 

    dict_mem_table_add_col(table, heap, "TABLE_ID", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "POS", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "NAME", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "MTYPE", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "PRTYPE", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "LEN", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "PREC", DATA_INT, 0, 4);

 

    table->id = DICT_COLUMNS_ID;

 

    dict_table_add_to_cache(table, heap);

    dict_sys->sys_columns = table;

    mem_heap_empty(heap);

 

    index = dict_mem_index_create("SYS_COLUMNS", "CLUST_IND",

                       DICT_HDR_SPACE,

                       DICT_UNIQUE | DICT_CLUSTERED, 2);

 

    dict_mem_index_add_field(index, "TABLE_ID", 0);

    dict_mem_index_add_field(index, "POS", 0);

 

    index->id = DICT_COLUMNS_ID;

    error = dict_index_add_to_cache(table, index,

                     mtr_read_ulint(dict_hdr

                                + DICT_HDR_COLUMNS,

                                MLOG_4BYTES, &mtr),

                     FALSE);

    ut_a(error == DB_SUCCESS);

 

    /*-------------------------*/

    table = dict_mem_table_create("SYS_INDEXES", DICT_HDR_SPACE, 7, 0);

 

    dict_mem_table_add_col(table, heap, "TABLE_ID", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "ID", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "NAME", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "N_FIELDS", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "TYPE", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "SPACE", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "PAGE_NO", DATA_INT, 0, 4);

 

    /* The '+ 2' below comes from the fields DB_TRX_ID, DB_ROLL_PTR */

#if DICT_SYS_INDEXES_PAGE_NO_FIELD != 6 + 2

#error "DICT_SYS_INDEXES_PAGE_NO_FIELD != 6 + 2"

#endif

#if DICT_SYS_INDEXES_SPACE_NO_FIELD != 5 + 2

#error "DICT_SYS_INDEXES_SPACE_NO_FIELD != 5 + 2"

#endif

#if DICT_SYS_INDEXES_TYPE_FIELD != 4 + 2

#error "DICT_SYS_INDEXES_TYPE_FIELD != 4 + 2"

#endif

#if DICT_SYS_INDEXES_NAME_FIELD != 2 + 2

#error "DICT_SYS_INDEXES_NAME_FIELD != 2 + 2"

#endif

 

    table->id = DICT_INDEXES_ID;

    dict_table_add_to_cache(table, heap);

    dict_sys->sys_indexes = table;

    mem_heap_empty(heap);

 

    index = dict_mem_index_create("SYS_INDEXES", "CLUST_IND",

                       DICT_HDR_SPACE,

                       DICT_UNIQUE | DICT_CLUSTERED, 2);

 

    dict_mem_index_add_field(index, "TABLE_ID", 0);

    dict_mem_index_add_field(index, "ID", 0);

 

    index->id = DICT_INDEXES_ID;

    error = dict_index_add_to_cache(table, index,

                     mtr_read_ulint(dict_hdr

                                + DICT_HDR_INDEXES,

                                MLOG_4BYTES, &mtr),

                     FALSE);

    ut_a(error == DB_SUCCESS);

 

    /*-------------------------*/

    table = dict_mem_table_create("SYS_FIELDS", DICT_HDR_SPACE, 3, 0);

 

    dict_mem_table_add_col(table, heap, "INDEX_ID", DATA_BINARY, 0, 0);

    dict_mem_table_add_col(table, heap, "POS", DATA_INT, 0, 4);

    dict_mem_table_add_col(table, heap, "COL_NAME", DATA_BINARY, 0, 0);

 

    table->id = DICT_FIELDS_ID;

    dict_table_add_to_cache(table, heap);

    dict_sys->sys_fields = table;

    mem_heap_free(heap);

 

    index = dict_mem_index_create("SYS_FIELDS", "CLUST_IND",

                       DICT_HDR_SPACE,

                       DICT_UNIQUE | DICT_CLUSTERED, 2);

 

    dict_mem_index_add_field(index, "INDEX_ID", 0);

    dict_mem_index_add_field(index, "POS", 0);

 

    index->id = DICT_FIELDS_ID;

    error = dict_index_add_to_cache(table, index,

                     mtr_read_ulint(dict_hdr

                                + DICT_HDR_FIELDS,

                                MLOG_4BYTES, &mtr),

                     FALSE);

    ut_a(error == DB_SUCCESS);

 

    mtr_commit(&mtr);

    /*-------------------------*/

 

    /* Initialize the insert buffer table and index for each tablespace */

 

    ibuf_init_at_db_start();

 

    /* Load definitions of other indexes on system tables */

 

    dict_load_sys_table(dict_sys->sys_tables);

    dict_load_sys_table(dict_sys->sys_columns);

    dict_load_sys_table(dict_sys->sys_indexes);

    dict_load_sys_table(dict_sys->sys_fields);

 

    mutex_exit(&(dict_sys->mutex));

}

上一篇:mysql计算具体某一行记录中,每列数据占的字节数。
下一篇:创建表,登记cluster index位置dict_create_sys_indexes_tuple(待确定)