dict0mem.c
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:7k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /**********************************************************************
  2. Data dictionary memory object creation
  3. (c) 1996 Innobase Oy
  4. Created 1/8/1996 Heikki Tuuri
  5. ***********************************************************************/
  6. #include "dict0mem.h"
  7. #ifdef UNIV_NONINL
  8. #include "dict0mem.ic"
  9. #endif
  10. #include "rem0rec.h"
  11. #include "data0type.h"
  12. #include "mach0data.h"
  13. #include "dict0dict.h"
  14. #include "que0que.h"
  15. #include "pars0pars.h"
  16. #define DICT_HEAP_SIZE 100 /* initial memory heap size when
  17. creating a table or index object */
  18. /**************************************************************************
  19. Creates a table memory object. */
  20. dict_table_t*
  21. dict_mem_table_create(
  22. /*==================*/
  23. /* out, own: table object */
  24. char* name, /* in: table name */
  25. ulint space, /* in: space where the clustered index of
  26. the table is placed; this parameter is
  27. ignored if the table is made a member of
  28. a cluster */
  29. ulint n_cols) /* in: number of columns */
  30. {
  31. dict_table_t* table;
  32. char* str;
  33. mem_heap_t* heap;
  34. ut_ad(name);
  35. heap = mem_heap_create(DICT_HEAP_SIZE);
  36. table = mem_heap_alloc(heap, sizeof(dict_table_t));
  37. table->heap = heap;
  38. str = mem_heap_alloc(heap, 1 + ut_strlen(name));
  39. ut_strcpy(str, name);
  40. table->type = DICT_TABLE_ORDINARY;
  41. table->name = str;
  42. table->space = space;
  43. table->n_def = 0;
  44. table->n_cols = n_cols + DATA_N_SYS_COLS;
  45. table->mem_fix = 0;
  46. table->cached = FALSE;
  47. table->cols = mem_heap_alloc(heap, (n_cols + DATA_N_SYS_COLS)
  48. * sizeof(dict_col_t));
  49. UT_LIST_INIT(table->indexes);
  50. UT_LIST_INIT(table->locks);
  51. table->does_not_fit_in_memory = FALSE;
  52. table->stat_last_estimate_counter = (ulint)(-1);
  53. table->stat_modif_counter = 0;
  54. table->magic_n = DICT_TABLE_MAGIC_N;
  55. return(table);
  56. }
  57. /**************************************************************************
  58. Creates a cluster memory object. */
  59. dict_table_t*
  60. dict_mem_cluster_create(
  61. /*====================*/
  62. /* out, own: cluster object */
  63. char* name, /* in: cluster name */
  64. ulint space, /* in: space where the clustered indexes
  65. of the member tables are placed */
  66. ulint n_cols, /* in: number of columns */
  67. ulint mix_len) /* in: length of the common key prefix in the
  68. cluster */
  69. {
  70. dict_table_t* cluster;
  71. cluster = dict_mem_table_create(name, space, n_cols);
  72. cluster->type = DICT_TABLE_CLUSTER;
  73. cluster->mix_len = mix_len;
  74. return(cluster);
  75. }
  76. /**************************************************************************
  77. Declares a non-published table as a member in a cluster. */
  78. void
  79. dict_mem_table_make_cluster_member(
  80. /*===============================*/
  81. dict_table_t* table, /* in: non-published table */
  82. char* cluster_name) /* in: cluster name */
  83. {
  84. table->type = DICT_TABLE_CLUSTER_MEMBER;
  85. table->cluster_name = cluster_name;
  86. }
  87. /**************************************************************************
  88. Adds a column definition to a table. */
  89. void
  90. dict_mem_table_add_col(
  91. /*===================*/
  92. dict_table_t* table, /* in: table */
  93. char* name, /* in: column name */
  94. ulint mtype, /* in: main datatype */
  95. ulint prtype, /* in: precise type */
  96. ulint len, /* in: length */
  97. ulint prec) /* in: precision */
  98. {
  99. char* str;
  100. dict_col_t* col;
  101. dtype_t* type;
  102. ut_ad(table && name);
  103. ut_ad(table->magic_n == DICT_TABLE_MAGIC_N);
  104. table->n_def++;
  105. col = dict_table_get_nth_col(table, table->n_def - 1);
  106. str = mem_heap_alloc(table->heap, 1 + ut_strlen(name));
  107. ut_strcpy(str, name);
  108. col->ind = table->n_def - 1;
  109. col->name = str;
  110. col->table = table;
  111. col->ord_part = 0;
  112. col->clust_pos = ULINT_UNDEFINED;
  113. type = dict_col_get_type(col);
  114. dtype_set(type, mtype, prtype, len, prec);
  115. }
  116. /**************************************************************************
  117. Creates an index memory object. */
  118. dict_index_t*
  119. dict_mem_index_create(
  120. /*==================*/
  121. /* out, own: index object */
  122. char* table_name, /* in: table name */
  123. char* index_name, /* in: index name */
  124. ulint space, /* in: space where the index tree is placed,
  125. ignored if the index is of the clustered
  126. type */
  127. ulint type, /* in: DICT_UNIQUE, DICT_CLUSTERED, ... ORed */
  128. ulint n_fields) /* in: number of fields */
  129. {
  130. char* str;
  131. dict_index_t* index;
  132. mem_heap_t* heap;
  133. ut_ad(table_name && index_name);
  134. heap = mem_heap_create(DICT_HEAP_SIZE);
  135. index = mem_heap_alloc(heap, sizeof(dict_index_t));
  136. index->heap = heap;
  137. str = mem_heap_alloc(heap, 1 + ut_strlen(index_name));
  138. ut_strcpy(str, index_name);
  139. index->type = type;
  140. index->space = space;
  141. index->name = str;
  142. index->table_name = table_name;
  143. index->table = NULL;
  144. index->n_def = 0;
  145. index->n_fields = n_fields;
  146. index->fields = mem_heap_alloc(heap, 1 + n_fields
  147. * sizeof(dict_field_t));
  148. /* The '1 +' above prevents allocation
  149. of an empty mem block */
  150. index->cached = FALSE;
  151. index->magic_n = DICT_INDEX_MAGIC_N;
  152. return(index);
  153. }
  154. /**************************************************************************
  155. Adds a field definition to an index. NOTE: does not take a copy
  156. of the column name if the field is a column. The memory occupied
  157. by the column name may be released only after publishing the index. */
  158. void
  159. dict_mem_index_add_field(
  160. /*=====================*/
  161. dict_index_t* index, /* in: index */
  162. char* name, /* in: column name */
  163. ulint order) /* in: order criterion; 0 means an ascending
  164. order */
  165. {
  166. dict_field_t* field;
  167. ut_ad(index && name);
  168. ut_ad(index->magic_n == DICT_INDEX_MAGIC_N);
  169. index->n_def++;
  170. field = dict_index_get_nth_field(index, index->n_def - 1);
  171. field->name = name;
  172. field->order = order;
  173. }
  174. /**************************************************************************
  175. Frees an index memory object. */
  176. void
  177. dict_mem_index_free(
  178. /*================*/
  179. dict_index_t* index) /* in: index */
  180. {
  181. mem_heap_free(index->heap);
  182. }
  183. /**************************************************************************
  184. Creates a procedure memory object. */
  185. dict_proc_t*
  186. dict_mem_procedure_create(
  187. /*======================*/
  188. /* out, own: procedure object */
  189. char* name, /* in: procedure name */
  190. char* sql_string, /* in: procedure definition as an SQL
  191. string */
  192. que_fork_t* graph) /* in: parsed procedure graph */
  193. {
  194. dict_proc_t* proc;
  195. proc_node_t* proc_node;
  196. mem_heap_t* heap;
  197. char* str;
  198. ut_ad(name);
  199. heap = mem_heap_create(128);
  200. proc = mem_heap_alloc(heap, sizeof(dict_proc_t));
  201. proc->heap = heap;
  202. str = mem_heap_alloc(heap, 1 + ut_strlen(name));
  203. ut_strcpy(str, name);
  204. proc->name = str;
  205. str = mem_heap_alloc(heap, 1 + ut_strlen(sql_string));
  206. ut_strcpy(str, sql_string);
  207. proc->sql_string = str;
  208. UT_LIST_INIT(proc->graphs);
  209. /* UT_LIST_ADD_LAST(graphs, proc->graphs, graph); */
  210. #ifdef UNIV_DEBUG
  211. UT_LIST_VALIDATE(graphs, que_t, proc->graphs);
  212. #endif
  213. proc->mem_fix = 0;
  214. proc_node = que_fork_get_child(graph);
  215. proc_node->dict_proc = proc;
  216. return(proc);
  217. }