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

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    
  3.    This library is free software; you can redistribute it and/or
  4.    modify it under the terms of the GNU Library General Public
  5.    License as published by the Free Software Foundation; either
  6.    version 2 of the License, or (at your option) any later version.
  7.    
  8.    This library is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  11.    Library General Public License for more details.
  12.    
  13.    You should have received a copy of the GNU Library General Public
  14.    License along with this library; if not, write to the Free
  15.    Software Foundation, Inc., 59 Temple Place - Suite 330, Boston,
  16.    MA 02111-1307, USA */
  17. /* This file should be included when using myisam_funktions */
  18. #ifndef _myisam_h
  19. #define _myisam_h
  20. #ifdef __cplusplus
  21. extern "C" {
  22. #endif
  23. #ifndef _my_base_h
  24. #include <my_base.h>
  25. #endif
  26. #ifndef _m_ctype_h
  27. #include <m_ctype.h>
  28. #endif
  29. /* defines used by myisam-funktions */
  30. /* The following defines can be increased if necessary */
  31. #define MI_MAX_KEY 32 /* Max allowed keys */
  32. #define MI_MAX_KEY_SEG 16 /* Max segments for key */
  33. #define MI_MAX_KEY_LENGTH 500
  34. #define MI_MAX_KEY_BUFF  (MI_MAX_KEY_LENGTH+MI_MAX_KEY_SEG*6+8+8)
  35. #define MI_MAX_POSSIBLE_KEY_BUFF (1024+6+6) /* For myisam_chk */
  36. #define MI_MAX_POSSIBLE_KEY 64 /* For myisam_chk */
  37. #define MI_MAX_MSG_BUF      1024 /* used in CHECK TABLE, REPAIR TABLE */
  38. #define MI_NAME_IEXT ".MYI"
  39. #define MI_NAME_DEXT ".MYD"
  40. /* Max extra space to use when sorting keys */
  41. #define MI_MAX_TEMP_LENGTH 256*1024L*1024L
  42. #define mi_portable_sizeof_char_ptr 8
  43. typedef uint32 ha_checksum;
  44. /* Param to/from mi_info */
  45. typedef struct st_mi_isaminfo /* Struct from h_info */
  46. {
  47.   ha_rows records; /* Records in database */
  48.   ha_rows deleted; /* Deleted records in database */
  49.   my_off_t recpos; /* Pos for last used record */
  50.   my_off_t newrecpos; /* Pos if we write new record */
  51.   my_off_t dupp_key_pos; /* Position to record with dupp key */
  52.   my_off_t data_file_length, /* Length of data file */
  53.            max_data_file_length,
  54.            index_file_length,
  55.            max_index_file_length,
  56.            delete_length;
  57.   ulong reclength; /* Recordlength */
  58.   ulong mean_reclength; /* Mean recordlength (if packed) */
  59.   ulonglong auto_increment;
  60.   ulonglong key_map; /* Which keys are used */
  61.   uint  keys; /* Number of keys in use */
  62.   uint options; /* HA_OPTIONS_... used */
  63.   int errkey, /* With key was dupplicated on err */
  64. sortkey; /* clustered by this key */
  65.   File filenr; /* (uniq) filenr for datafile */
  66.   time_t create_time; /* When table was created */
  67.   time_t check_time;
  68.   time_t update_time;
  69.   uint  reflength;
  70.   ulong record_offset;
  71.   ulong *rec_per_key; /* for sql optimizing */
  72.   uint raid_type,raid_chunks;
  73.   ulong raid_chunksize;
  74. } MI_ISAMINFO;
  75. typedef struct st_mi_create_info
  76. {
  77.   ha_rows max_rows;
  78.   ha_rows reloc_rows;
  79.   ulonglong auto_increment;
  80.   ulonglong data_file_length;
  81.   uint raid_type,raid_chunks;
  82.   ulong raid_chunksize;
  83.   uint old_options;
  84.   uint8 language;
  85. } MI_CREATE_INFO;
  86. struct st_myisam_info; /* For referense */
  87. typedef struct st_myisam_info MI_INFO;
  88. typedef struct st_mi_keyseg /* Key-portion */
  89. {
  90.   uint8  type; /* Type of key (for sort) */
  91.   uint8  language;
  92.   uint8  null_bit; /* bitmask to test for NULL */
  93.   uint8  bit_start,bit_end; /* if bit field */
  94.   uint16 flag;
  95.   uint16 length; /* Keylength */
  96.   uint32 start; /* Start of key in record */
  97.   uint32 null_pos; /* position to NULL indicator */
  98.   CHARSET_INFO *charset;
  99. } MI_KEYSEG;
  100. struct st_mi_s_param;
  101. typedef struct st_mi_keydef /* Key definition with open & info */
  102. {
  103.   uint16 keysegs; /* Number of key-segment */
  104.   uint16 flag; /* NOSAME, PACK_USED */
  105.   uint16 block_length; /* Length of keyblock (auto) */
  106.   uint16 underflow_block_length; /* When to execute underflow */
  107.   uint16 keylength; /* Tot length of keyparts (auto) */
  108.   uint16 minlength; /* min length of (packed) key (auto) */
  109.   uint16 maxlength; /* max length of (packed) key (auto) */
  110.   uint16 block_size; /* block_size (auto) */
  111.   uint32 version; /* For concurrent read/write */
  112.   MI_KEYSEG *seg,*end;
  113.   int (*bin_search)(struct st_myisam_info *info,struct st_mi_keydef *keyinfo,
  114.     uchar *page,uchar *key,
  115.     uint key_len,uint comp_flag,uchar * *ret_pos,
  116.     uchar *buff, my_bool *was_last_key);
  117.   uint (*get_key)(struct st_mi_keydef *keyinfo,uint nod_flag,uchar * *page,
  118.   uchar *key);
  119.   int (*pack_key)(struct st_mi_keydef *keyinfo,uint nod_flag,uchar *next_key,
  120.   uchar *org_key, uchar *prev_key, uchar *key,
  121.   struct st_mi_s_param *s_temp);
  122.   void (*store_key)(struct st_mi_keydef *keyinfo, uchar *key_pos,
  123.     struct st_mi_s_param *s_temp);
  124. } MI_KEYDEF;
  125. #define MI_UNIQUE_HASH_LENGTH 4
  126. typedef struct st_unique_def /* Segment definition of unique */
  127. {
  128.   uint16 keysegs; /* Number of key-segment */
  129.   uchar key; /* Mapped to which key */
  130.   uint8 null_are_equal;
  131.   MI_KEYSEG *seg,*end;
  132. } MI_UNIQUEDEF;
  133. typedef struct st_mi_decode_tree /* Decode huff-table */
  134. {
  135.   uint16 *table;
  136.   uint  quick_table_bits;
  137.   byte  *intervalls;
  138. } MI_DECODE_TREE;
  139. struct st_mi_bit_buff;
  140. /* Note that null markers should always be first in a row !
  141.    When creating a column, one should only specify:
  142.    type, length, null_bit and null_pos */
  143. typedef struct st_columndef /* column information */
  144. {
  145.   int16  type; /* en_fieldtype */
  146.   uint16 length; /* length of field */
  147.   uint32 offset; /* Offset to position in row */
  148.   uint8  null_bit; /* If column may be 0 */
  149.   uint16 null_pos; /* position for null marker */
  150. #ifndef NOT_PACKED_DATABASES
  151.   void (*unpack)(struct st_columndef *rec,struct st_mi_bit_buff *buff,
  152.  uchar *start,uchar *end);
  153.   enum en_fieldtype base_type;
  154.   uint space_length_bits,pack_type;
  155.   MI_DECODE_TREE *huff_tree;
  156. #endif
  157. } MI_COLUMNDEF;
  158. extern my_string myisam_log_filename; /* Name of logfile */
  159. extern uint myisam_block_size;
  160. extern my_bool myisam_flush,myisam_delay_key_write;
  161. extern my_bool myisam_concurrent_insert;
  162. extern my_off_t myisam_max_temp_length,myisam_max_extra_temp_length;
  163. /* Prototypes for myisam-functions */
  164. extern int mi_close(struct st_myisam_info *file);
  165. extern int mi_delete(struct st_myisam_info *file,const byte *buff);
  166. extern struct st_myisam_info *mi_open(const char *name,int mode,
  167.       uint wait_if_locked);
  168. extern int mi_panic(enum ha_panic_function function);
  169. extern int mi_rfirst(struct st_myisam_info *file,byte *buf,int inx);
  170. extern int mi_rkey(struct st_myisam_info *file,byte *buf,int inx,
  171.    const byte *key,
  172.    uint key_len, enum ha_rkey_function search_flag);
  173. extern int mi_rlast(struct st_myisam_info *file,byte *buf,int inx);
  174. extern int mi_rnext(struct st_myisam_info *file,byte *buf,int inx);
  175. extern int mi_rnext_same(struct st_myisam_info *info, byte *buf);
  176. extern int mi_rprev(struct st_myisam_info *file,byte *buf,int inx);
  177. extern int mi_rrnd(struct st_myisam_info *file,byte *buf, my_off_t pos);
  178. extern int mi_scan_init(struct st_myisam_info *file);
  179. extern int mi_scan(struct st_myisam_info *file,byte *buf);
  180. extern int mi_rsame(struct st_myisam_info *file,byte *record,int inx);
  181. extern int mi_rsame_with_pos(struct st_myisam_info *file,byte *record,
  182.      int inx, my_off_t pos);
  183. extern int mi_update(struct st_myisam_info *file,const byte *old,
  184.      byte *new_record);
  185. extern int mi_write(struct st_myisam_info *file,byte *buff);
  186. extern my_off_t mi_position(struct st_myisam_info *file);
  187. extern int mi_status(struct st_myisam_info *info, MI_ISAMINFO *x, uint flag);
  188. extern int mi_lock_database(struct st_myisam_info *file,int lock_type);
  189. extern int mi_create(const char *name,uint keys,MI_KEYDEF *keydef,
  190.      uint columns, MI_COLUMNDEF *columndef, 
  191.      uint uniques, MI_UNIQUEDEF *uniquedef,
  192.      MI_CREATE_INFO *create_info, uint flags);
  193. extern int mi_delete_table(const char *name);
  194. extern int mi_rename(const char *from, const char *to);
  195. extern int mi_extra(struct st_myisam_info *file,
  196.     enum ha_extra_function function);
  197. extern ha_rows mi_records_in_range(struct st_myisam_info *info,int inx,
  198.    const byte *start_key,uint start_key_len,
  199.    enum ha_rkey_function start_search_flag,
  200.    const byte *end_key,uint end_key_len,
  201.    enum ha_rkey_function end_search_flag);
  202. extern int mi_log(int activate_log);
  203. extern int mi_is_changed(struct st_myisam_info *info);
  204. extern int mi_delete_all_rows(struct st_myisam_info *info);
  205. extern ulong _mi_calc_blob_length(uint length , const byte *pos);
  206. extern uint mi_get_pointer_length(ulonglong file_length, uint def);
  207. /* this is used to pass to mysql_myisamchk_table -- by Sasha Pachev */
  208. #define   MYISAMCHK_REPAIR 1  /* equivalent to myisamchk -r*/
  209. #define   MYISAMCHK_VERIFY 2  /* run equivalent of myisamchk -c,
  210.        * if corruption is detected, do myisamchk -r*/
  211. /* definitions needed for myisamchk.c -- by Sasha Pachev */
  212. #define T_VERBOSE 1
  213. #define T_SILENT 2
  214. #define T_DESCRIPT 4
  215. #define T_EXTEND 8
  216. #define T_INFO 16
  217. #define T_REP 32
  218. #define T_OPT 64 /* Not currently used */
  219. #define T_FORCE_CREATE 128
  220. #define T_WRITE_LOOP 256
  221. #define T_UNPACK 512
  222. #define T_STATISTICS 1024
  223. #define T_VERY_SILENT 2048
  224. #define T_SORT_RECORDS 4096
  225. #define T_SORT_INDEX 8192
  226. #define T_WAIT_FOREVER 16384
  227. #define T_REP_BY_SORT 32768L
  228. #define T_FAST 65536L
  229. #define T_READONLY 131072L
  230. #define T_MEDIUM T_READONLY*2
  231. #define T_AUTO_INC T_MEDIUM*2
  232. #define T_CHECK T_AUTO_INC*2
  233. #define T_UPDATE_STATE T_CHECK*2
  234. #define T_CHECK_ONLY_CHANGED T_UPDATE_STATE*2
  235. #define T_DONT_CHECK_CHECKSUM T_CHECK_ONLY_CHANGED*2
  236. #define T_TRUST_HEADER T_DONT_CHECK_CHECKSUM*2
  237. #define T_CREATE_MISSING_KEYS T_TRUST_HEADER*2
  238. #define T_SAFE_REPAIR T_CREATE_MISSING_KEYS*2
  239. #define T_AUTO_REPAIR    T_SAFE_REPAIR*2
  240. #define T_BACKUP_DATA T_AUTO_REPAIR*2
  241. #define O_NEW_INDEX 1 /* Bits set in out_flag */
  242. #define O_NEW_DATA 2
  243. #define O_DATA_LOST 4
  244. /* these struct is used by my_check to tell it what to do */
  245. typedef struct st_sort_key_blocks { /* Used when sorting */
  246.   uchar *buff,*end_pos;
  247.   uchar lastkey[MI_MAX_POSSIBLE_KEY_BUFF];
  248.   uint last_length;
  249.   int inited;
  250. } SORT_KEY_BLOCKS;
  251. struct st_mi_check_param;
  252. typedef struct st_sort_info {
  253.   MI_INFO *info;
  254.   struct st_mi_check_param *param;
  255.   enum data_file_type new_data_file_type;
  256.   SORT_KEY_BLOCKS *key_block,*key_block_end;
  257.   uint key,find_length;
  258.   my_off_t pos,max_pos,filepos,start_recpos,filelength,dupp,buff_length;
  259.   ha_rows max_records;
  260.   ulonglong unique[MI_MAX_KEY_SEG+1];
  261.   my_bool fix_datafile;
  262.   char *record,*buff;
  263.   MI_KEYDEF *keyinfo;
  264.   MI_KEYSEG *keyseg;
  265. } SORT_INFO;
  266. typedef struct st_mi_check_param
  267. {
  268.   ulonglong auto_increment_value;
  269.   ulonglong max_data_file_length;
  270.   ulonglong keys_in_use;
  271.   my_off_t search_after_block;
  272.   my_off_t new_file_pos,key_file_blocks;
  273.   my_off_t keydata,totaldata,key_blocks,start_check_pos;
  274.   ha_rows total_records,total_deleted;
  275.   ha_checksum record_checksum,glob_crc;
  276.   ulong use_buffers,read_buffer_length,write_buffer_length,
  277. sort_buffer_length,sort_key_blocks;
  278.   uint out_flag,warning_printed,error_printed,
  279.        opt_rep_quick,verbose;
  280.   uint opt_sort_key,total_files,max_level;
  281.   uint testflag;
  282.   uint8 language;
  283.   my_bool using_global_keycache, opt_lock_memory, opt_follow_links;
  284.   my_bool retry_repair,retry_without_quick, force_sort;
  285.   char temp_filename[FN_REFLEN],*isam_file_name,*tmpdir;
  286.   int tmpfile_createflag;
  287.   myf myf_rw;
  288.   IO_CACHE read_cache;
  289.   SORT_INFO sort_info;
  290.   ulonglong unique_count[MI_MAX_KEY_SEG+1];
  291.   ha_checksum key_crc[MI_MAX_POSSIBLE_KEY];
  292.   ulong rec_per_key_part[MI_MAX_KEY_SEG*MI_MAX_POSSIBLE_KEY];
  293.   void* thd;
  294.   char* table_name;
  295.   char* op_name;
  296. } MI_CHECK;
  297. typedef struct st_mi_sortinfo {
  298.   ha_rows max_records;
  299.   SORT_INFO *sort_info;
  300.   char *tmpdir;
  301.   int (*key_cmp)(SORT_INFO *info, const void *, const void *);
  302.   int (*key_read)(SORT_INFO *info,void *buff);
  303.   int (*key_write)(SORT_INFO *info, const void *buff);
  304.   void (*lock_in_memory)(MI_CHECK *info);
  305.   uint key_length;
  306.   myf myf_rw;
  307. } MI_SORT_PARAM;
  308. /* functions in mi_check */
  309. void myisamchk_init(MI_CHECK *param);
  310. int chk_status(MI_CHECK *param, MI_INFO *info);
  311. int chk_del(MI_CHECK *param, register MI_INFO *info, uint test_flag);
  312. int chk_size(MI_CHECK *param, MI_INFO *info);
  313. int chk_key(MI_CHECK *param, MI_INFO *info);
  314. int chk_data_link(MI_CHECK *param, MI_INFO *info,int extend);
  315. int mi_repair(MI_CHECK *param, register MI_INFO *info,
  316.       my_string name, int rep_quick);
  317. int mi_sort_index(MI_CHECK *param, register MI_INFO *info, my_string name);
  318. int mi_repair_by_sort(MI_CHECK *param, register MI_INFO *info,
  319.       const char * name, int rep_quick);
  320. int change_to_newfile(const char * filename, const char * old_ext,
  321.       const char * new_ext, uint raid_chunks,
  322.       myf myflags);
  323. int lock_file(MI_CHECK *param, File file, my_off_t start, int lock_type,
  324.       const char *filetype, const char *filename);
  325. void lock_memory(MI_CHECK *param);
  326. int flush_blocks(MI_CHECK *param, File file);
  327. void update_auto_increment_key(MI_CHECK *param, MI_INFO *info,
  328.        my_bool repair);
  329. int update_state_info(MI_CHECK *param, MI_INFO *info,uint update);
  330. int filecopy(MI_CHECK *param, File to,File from,my_off_t start,
  331.      my_off_t length, const char *type);
  332. int movepoint(MI_INFO *info,byte *record,my_off_t oldpos,
  333.       my_off_t newpos, uint prot_key);
  334. int sort_write_record(SORT_INFO *sort_info);
  335.  int write_data_suffix(MI_CHECK *param, MI_INFO *info);
  336. int _create_index_by_sort(MI_SORT_PARAM *info,my_bool no_messages,
  337.   ulong);
  338. int test_if_almost_full(MI_INFO *info);
  339. int recreate_table(MI_CHECK *param, MI_INFO **org_info, char *filename);
  340. void mi_disable_non_unique_index(MI_INFO *info, ha_rows rows);
  341. my_bool mi_test_if_sort_rep(MI_INFO *info, ha_rows rows, my_bool force);
  342. #ifdef __cplusplus
  343. }
  344. #endif
  345. #endif