isamdef.h
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:16k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  2.    This program is free software; you can redistribute it and/or modify
  3.    it under the terms of the GNU General Public License as published by
  4.    the Free Software Foundation; either version 2 of the License, or
  5.    (at your option) any later version.
  6.    This program is distributed in the hope that it will be useful,
  7.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  8.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  9.    GNU General Public License for more details.
  10.    You should have received a copy of the GNU General Public License
  11.    along with this program; if not, write to the Free Software
  12.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  13. /* Denna fil includeras i alla isam-filer */
  14. #define ISAM_LIBRARY
  15. #include <nisam.h> /* Structs & some defines */
  16. #ifdef THREAD
  17. #include <my_pthread.h>
  18. #include <thr_lock.h>
  19. #else
  20. #include <my_no_pthread.h>
  21. #endif
  22. #include <keycache.h>
  23. #ifdef my_write
  24. #undef my_write /* We want test if disk full */
  25. #endif
  26. #undef HA_SORT_ALLOWS_SAME
  27. #define HA_SORT_ALLOWS_SAME 128 /* Can't be > 128 in NISAM */
  28. #ifdef __WATCOMC__
  29. #pragma pack(2)
  30. #define uint uint16 /* Same format as in MSDOS */
  31. #endif
  32. #ifdef __ZTC__
  33. #pragma ZTC align 2
  34. #define uint uint16 /* Same format as in MSDOS */
  35. #endif
  36. #if defined(__WIN__) && defined(_MSC_VER)
  37. #pragma pack(push,isamdef,2)
  38. #define uint uint16
  39. #endif
  40. typedef struct st_state_info
  41. {
  42.   struct { /* Fileheader */
  43.     uchar file_version[4];
  44.     uchar options[2];
  45.     uchar header_length[2];
  46.     uchar state_info_length[2];
  47.     uchar base_info_length[2];
  48.     uchar base_pos[2];
  49.     uchar not_used[2];
  50.   } header;
  51.   ulong records; /* Antal record i databasen */
  52.   ulong del; /* Antalet borttagna poster */
  53.   ulong dellink; /* L{nk till n{sta borttagna */
  54.   ulong key_file_length;
  55.   ulong data_file_length;
  56.   ulong splitt; /* Antal splittrade delar */
  57.   ulong empty; /* Outnyttjat utrymme */
  58.   ulong process; /* Vem som senast uppdatera */
  59.   ulong loop; /* not used anymore */
  60.   ulong uniq; /* Unik nr i denna process */
  61.   ulong key_root[N_MAXKEY]; /* Pekare till rootblocken */
  62.   ulong key_del[N_MAXKEY]; /* Del-l{nkar f|r n-block */
  63.   ulong sec_index_changed; /* Updated when new sec_index */
  64.   ulong sec_index_used; /* 1 bit for each sec index in use */
  65.   ulong version; /* timestamp of create */
  66.   uint keys; /* Keys in use for database */
  67. } N_STATE_INFO;
  68. typedef struct st_base_info
  69. {
  70.   ulong keystart; /* Var nycklarna b|rjar */
  71.   ulong records,reloc; /* Parameter vid skapandet */
  72.   ulong max_pack_length; /* Max possibly length of packed rec.*/
  73.   ulong max_data_file_length;
  74.   ulong max_key_file_length;
  75.   uint reclength; /* length of unpacked record */
  76.   uint options; /* Options used */
  77.   uint pack_reclength; /* Length of full packed rec. */
  78.   uint min_pack_length;
  79.   uint min_block_length;
  80.   uint rec_reflength; /* = 2 or 3 or 4 */
  81.   uint key_reflength; /* = 2 or 3 or 4 */
  82.   uint keys; /* Keys defined for database */
  83.   uint blobs; /* Number of blobs */
  84.   uint max_block; /* Max blockl{ngd anv{nd */
  85.   uint max_key_length; /* L{ngsta nyckel-l{ngden */
  86.   uint fields, /* Antal f{lt i databasen */
  87.        pack_fields, /* Packade f{lt i databasen */
  88.        pack_bits; /* Length of packed bits */
  89.   time_t create_time; /* Time when created database */
  90.   time_t isamchk_time; /* Time for last recover */
  91.   ulong rec_per_key[N_MAXKEY]; /* for sql optimizing */
  92.   uint sortkey; /* sorted by this key */
  93. } N_BASE_INFO;
  94. #ifdef __ZTC__
  95. #pragma ZTC align
  96. #undef uint
  97. #endif
  98. #ifdef __WATCOMC__
  99. #pragma pack()
  100. #undef uint
  101. #endif
  102. #if defined(__WIN__) && defined(_MSC_VER)
  103. #pragma pack(pop,isamdef)
  104. #undef uint
  105. #endif
  106. /* Structs used intern in database */
  107. typedef struct st_n_blob /* Info of record */
  108. {
  109.   uint offset; /* Offset to blob in record */
  110.   uint pack_length; /* Type of packed length */
  111.   uint length; /* Calc:ed for each record */
  112. } N_BLOB;
  113. typedef struct st_isam_pack {
  114.   ulong header_length;
  115.   uint ref_length;
  116. } N_PACK;
  117. typedef struct st_isam_share { /* Shared between opens */
  118.   N_STATE_INFO state;
  119.   N_BASE_INFO base;
  120.   N_KEYDEF  *keyinfo; /* Nyckelinfo */
  121.   N_RECINFO *rec; /* Pointer till recdata */
  122.   N_PACK    pack; /* Data about packed records */
  123.   N_BLOB    *blobs; /* Pointer to blobs */
  124.   char *filename; /* Name of indexfile */
  125.   byte *file_map; /* mem-map of file if possible */
  126.   ulong this_process; /* processid */
  127.   ulong last_process; /* For table-change-check */
  128.   ulong last_version; /* Version on start */
  129.   uint rec_reflength; /* rec_reflength in use now */
  130.   int kfile; /* Shared keyfile */
  131.   int mode; /* mode of file on open */
  132.   int reopen; /* How many times reopened */
  133.   uint state_length;
  134.   uint w_locks,r_locks; /* Number of read/write locks */
  135.   uint min_pack_length; /* Theese is used by packed data */
  136.   uint max_pack_length;
  137.   uint blocksize; /* blocksize of keyfile */
  138.   my_bool  changed,not_flushed; /* If changed since lock */
  139.   int rnd; /* rnd-counter */
  140.   DECODE_TREE *decode_trees;
  141.   uint16 *decode_tables;
  142.   enum data_file_type data_file_type;
  143.   int (*read_record)(struct st_isam_info*, ulong, byte*);
  144.   int (*write_record)(struct st_isam_info*, const byte*);
  145.   int (*update_record)(struct st_isam_info*, ulong, const byte*);
  146.   int (*delete_record)(struct st_isam_info*);
  147.   int (*read_rnd)(struct st_isam_info*, byte*, ulong, int);
  148.   int (*compare_record)(struct st_isam_info*, const byte *);
  149. #ifdef THREAD
  150.   THR_LOCK lock;
  151.   pthread_mutex_t intern_lock; /* Locking for use with _locking */
  152. #endif
  153. } ISAM_SHARE;
  154. typedef uint bit_type;
  155. typedef struct st_bit_buff { /* Used for packing of record */
  156.   bit_type current_byte;
  157.   uint bits;
  158.   uchar *pos,*end;
  159.   uint error;
  160. } BIT_BUFF;
  161. typedef struct st_isam_info {
  162.   ISAM_SHARE *s; /* Shared between open:s */
  163.   N_BLOB     *blobs; /* Pointer to blobs */
  164.   int dfile; /* The datafile */
  165.   BIT_BUFF   bit_buff;
  166.   uint options;
  167.   uint opt_flag; /* Optim. for space/speed */
  168.   uint update; /* If file changed since open */
  169.   char *filename; /* parameter to open filename */
  170.   ulong this_uniq; /* uniq filenumber or thread */
  171.   ulong last_uniq; /* last uniq number */
  172.   ulong this_loop; /* counter for this open */
  173.   ulong last_loop; /* last used counter */
  174.   ulong lastpos, /* Last record position */
  175. nextpos; /* Position to next record */
  176.   ulong int_pos; /* Intern variabel */
  177.   ulong dupp_key_pos; /* Position to record with dupp key */
  178.   ulong last_search_keypage;
  179.   ulong save_lastpos;
  180.   uint packed_length; /* Length of found, packed record */
  181.   uint alloced_rec_buff_length; /* Max recordlength malloced */
  182.   uchar *buff, /* Temp area for key */
  183. *lastkey; /* Last used search key */
  184.   byte *rec_buff, /* Tempbuff for recordpack */
  185. *rec_alloc; /* Malloced area for record */
  186.   uchar *int_keypos, /* Intern variabel */
  187. *int_maxpos; /* Intern variabel */
  188.   int lastinx; /* Last used index */
  189.   int errkey; /* Got last error on this key */
  190.   uint data_changed; /* Somebody has changed data */
  191.   int lock_type; /* How database was locked */
  192.   int tmp_lock_type; /* When locked by readinfo */
  193.   int was_locked; /* Was locked in panic */
  194.   myf lock_wait; /* is 0 or MY_DONT_WAIT */
  195.   my_bool page_changed;
  196.   my_bool buff_used;
  197.   uint save_update; /* When using KEY_READ */
  198.   int save_lastinx;
  199.   int (*read_record)(struct st_isam_info*, ulong, byte*);
  200.   LIST open_list;
  201.   IO_CACHE rec_cache; /* When cacheing records */
  202. #ifdef THREAD
  203.   THR_LOCK_DATA lock;
  204. #endif
  205. } N_INFO;
  206. /* Some defines used by isam-funktions */
  207. #define USE_HOLE_KEY 0 /* Use hole key in _nisam_search() */
  208. #define F_EXTRA_LCK -1
  209. /* bits in opt_flag */
  210. #define MEMMAP_USED 32
  211. #define REMEMBER_OLD_POS 64
  212. #define getint(x) ((uint) (uint16) *((int16*) (x)) & 32767)
  213. #define putint(x,y,nod) (*((uint16*) (x))= ((nod ? (uint16) 32768 : 0)+(uint16) (y)))
  214. #ifdef WORDS_BIGENDIAN
  215. #define test_if_nod(x) (x[0] & 128 ? info->s->base.key_reflength : 0)
  216. #else
  217. #define test_if_nod(x) (x[1] & 128 ? info->s->base.key_reflength : 0)
  218. #endif
  219. #define N_MIN_BLOCK_LENGTH 8 /* Because of delete-link */
  220. #define N_EXTEND_BLOCK_LENGTH 20 /* Don't use to small record-blocks */
  221. #define N_SPLITT_LENGTH  ((N_EXTEND_BLOCK_LENGTH+3)*2)
  222. #define MAX_DYN_BLOCK_HEADER 11 /* Max prefix of record-block */
  223. #define DYN_DELETE_BLOCK_HEADER 8 /* length of delete-block-header */
  224. #define MEMMAP_EXTRA_MARGIN 7 /* Write this as a suffix for file */
  225. #define INDEX_BLOCK_MARGIN 16 /* Safety margin for .ISM tables */
  226. #define PACK_TYPE_SELECTED 1 /* Bits in field->pack_type */
  227. #define PACK_TYPE_SPACE_FIELDS 2
  228. #define PACK_TYPE_ZERO_FILL 4
  229. #ifdef THREAD
  230. extern pthread_mutex_t THR_LOCK_isam;
  231. #endif
  232. /* Some extern variables */
  233. extern LIST *nisam_open_list;
  234. extern uchar NEAR nisam_file_magic[],NEAR nisam_pack_file_magic[];
  235. extern uint NEAR nisam_read_vec[],nisam_quick_table_bits;
  236. extern File nisam_log_file;
  237. /* This is used by _nisam_get_pack_key_length och _nisam_store_key */
  238. typedef struct st_s_param
  239. {
  240.   uint ref_length,key_length,
  241. n_ref_length,
  242. n_length,
  243. totlength,
  244.         part_of_prev_key,prev_length;
  245.   uchar *key, *prev_key;
  246. } S_PARAM;
  247. /* Prototypes for intern functions */
  248. extern int _nisam_read_dynamic_record(N_INFO *info,ulong filepos,byte *buf);
  249. extern int _nisam_write_dynamic_record(N_INFO*, const byte*);
  250. extern int _nisam_update_dynamic_record(N_INFO*, ulong, const byte*);
  251. extern int _nisam_delete_dynamic_record(N_INFO *info);
  252. extern int _nisam_cmp_dynamic_record(N_INFO *info,const byte *record);
  253. extern int _nisam_read_rnd_dynamic_record(N_INFO *, byte *,ulong, int);
  254. extern int _nisam_write_blob_record(N_INFO*, const byte*);
  255. extern int _nisam_update_blob_record(N_INFO*, ulong, const byte*);
  256. extern int _nisam_read_static_record(N_INFO *info,ulong filepos,byte *buf);
  257. extern int _nisam_write_static_record(N_INFO*, const byte*);
  258. extern int _nisam_update_static_record(N_INFO*, ulong, const byte*);
  259. extern int _nisam_delete_static_record(N_INFO *info);
  260. extern int _nisam_cmp_static_record(N_INFO *info,const byte *record);
  261. extern int _nisam_read_rnd_static_record(N_INFO*, byte *,ulong, int);
  262. extern int _nisam_ck_write(N_INFO *info,uint keynr,uchar *key);
  263. extern int _nisam_enlarge_root(N_INFO *info,uint keynr,uchar *key);
  264. extern int _nisam_insert(N_INFO *info,N_KEYDEF *keyinfo,uchar *key,
  265.       uchar *anc_buff,uchar *key_pos,uchar *key_buff,
  266.       uchar *father_buff, uchar *father_keypos,
  267.       ulong father_page);
  268. extern int _nisam_splitt_page(N_INFO *info,N_KEYDEF *keyinfo,uchar *key,
  269.    uchar *buff,uchar *key_buff);
  270. extern uchar *_nisam_find_half_pos(N_INFO *info,N_KEYDEF *keyinfo,uchar *page,
  271. uchar *key);
  272. extern uint _nisam_get_pack_key_length(N_KEYDEF *keyinfo,uint nod_flag,
  273.     uchar *key_pos,uchar *key_buff,
  274.     uchar *key, S_PARAM *s_temp);
  275. extern void _nisam_store_key(N_KEYDEF *keyinfo,uchar *key_pos,
  276.   S_PARAM *s_temp);
  277. extern int _nisam_ck_delete(N_INFO *info,uint keynr,uchar *key);
  278. extern int _nisam_readinfo(N_INFO *info,int lock_flag,int check_keybuffer);
  279. extern int _nisam_writeinfo(N_INFO *info, uint flag);
  280. extern int _nisam_test_if_changed(N_INFO *info);
  281. extern int _nisam_check_index(N_INFO *info,int inx);
  282. extern int _nisam_search(N_INFO *info,N_KEYDEF *keyinfo,uchar *key,uint key_len,uint nextflag,ulong pos);
  283. extern int _nisam_bin_search(struct st_isam_info *info,N_KEYDEF *keyinfo,uchar *page,uchar *key,uint key_len,uint comp_flag,uchar * *ret_pos,uchar *buff);
  284. extern int _nisam_seq_search(N_INFO *info,N_KEYDEF *keyinfo,uchar *page,uchar *key,uint key_len,uint comp_flag,uchar * *ret_pos,uchar *buff);
  285. extern ulong _nisam_kpos(uint nod_flag,uchar *after_key);
  286. extern void _nisam_kpointer(N_INFO *info,uchar *buff,ulong pos);
  287. extern ulong _nisam_dpos(N_INFO *info, uint nod_flag,uchar *after_key);
  288. extern void _nisam_dpointer(N_INFO *info, uchar *buff,ulong pos);
  289. extern int _nisam_key_cmp(N_KEYSEG *keyseg,uchar *a,uchar *b,
  290.        uint key_length,uint nextflag);
  291. extern uint _nisam_get_key(N_KEYDEF *keyinfo,uint nod_flag,uchar * *page,uchar *key);
  292. extern uint _nisam_get_static_key(N_KEYDEF *keyinfo,uint nod_flag,uchar * *page,uchar *key);
  293. extern uchar *_nisam_get_last_key(N_INFO *info,N_KEYDEF *keyinfo,uchar *keypos,uchar *lastkey,uchar *endpos);
  294. extern uint _nisam_keylength(N_KEYDEF *keyinfo,uchar *key);
  295. extern uchar *_nisam_move_key(N_KEYDEF *keyinfo,uchar *to,uchar *from);
  296. extern int _nisam_search_next(N_INFO *info,N_KEYDEF *keyinfo,uchar *key,uint nextflag,ulong pos);
  297. extern int _nisam_search_first(N_INFO *info,N_KEYDEF *keyinfo,ulong pos);
  298. extern int _nisam_search_last(N_INFO *info,N_KEYDEF *keyinfo,ulong pos);
  299. extern uchar *_nisam_fetch_keypage(N_INFO *info,N_KEYDEF *keyinfo,my_off_t page,
  300. uchar *buff,int return_buffer);
  301. extern int _nisam_write_keypage(N_INFO *info,N_KEYDEF *keyinfo,my_off_t page,
  302.      uchar *buff);
  303. extern int _nisam_dispose(N_INFO *info,N_KEYDEF *keyinfo,my_off_t pos);
  304. extern ulong _nisam_new(N_INFO *info,N_KEYDEF *keyinfo);
  305. extern uint _nisam_make_key(N_INFO *info,uint keynr,uchar *key,
  306.  const char *record,ulong filepos);
  307. extern uint _nisam_pack_key(N_INFO *info,uint keynr,uchar *key,uchar *old,uint key_length);
  308. extern int _nisam_read_key_record(N_INFO *info,ulong filepos,byte *buf);
  309. extern int _nisam_read_cache(IO_CACHE *info,byte *buff,ulong pos,
  310.   uint length,int re_read_if_possibly);
  311. extern byte *fix_rec_buff_for_blob(N_INFO *info,uint blob_length);
  312. extern uint _nisam_rec_unpack(N_INFO *info,byte *to,byte *from,
  313.    uint reclength);
  314. my_bool _nisam_rec_check(N_INFO *info,const char *from);
  315. extern int _nisam_write_part_record(N_INFO *info,ulong filepos,uint length,
  316.  ulong next_filepos,byte **record,
  317.  uint *reclength,int *flag);
  318. extern void _nisam_print_key(FILE *stream,N_KEYSEG *keyseg,const uchar *key);
  319. extern my_bool _nisam_read_pack_info(N_INFO *info,pbool fix_keys);
  320. extern int _nisam_read_pack_record(N_INFO *info,ulong filepos,byte *buf);
  321. extern int _nisam_read_rnd_pack_record(N_INFO*, byte *,ulong, int);
  322. extern int _nisam_pack_rec_unpack(N_INFO *info,byte *to,byte *from,
  323.        uint reclength);
  324. extern ulong _nisam_checksum(const byte *mem, uint count);
  325. typedef struct st_sortinfo {
  326.   uint key_length;
  327.   ulong max_records;
  328.   int (*key_cmp)(const void *, const void *, const void *);
  329.   int (*key_read)(void *buff);
  330.   int (*key_write)(const void *buff);
  331.   void (*lock_in_memory)(void);
  332. } SORT_PARAM;
  333. int _create_index_by_sort(SORT_PARAM *info,pbool no_messages,
  334.   uint sortbuff_size);
  335. #define BLOCK_INFO_HEADER_LENGTH 11
  336. typedef struct st_block_info { /* Parameter to _nisam_get_block_info */
  337.   uchar header[BLOCK_INFO_HEADER_LENGTH];
  338.   uint rec_len;
  339.   uint data_len;
  340.   uint block_len;
  341.   ulong filepos; /* Must be ulong on Alpha! */
  342.   ulong next_filepos;
  343.   uint second_read;
  344. } BLOCK_INFO;
  345. /* bits in return from _nisam_get_block_info */
  346. #define BLOCK_FIRST 1
  347. #define BLOCK_LAST 2
  348. #define BLOCK_DELETED 4
  349. #define BLOCK_ERROR 8 /* Wrong data */
  350. #define BLOCK_SYNC_ERROR 16 /* Right data at wrong place */
  351. #define BLOCK_FATAL_ERROR 32 /* hardware-error */
  352. enum nisam_log_commands {
  353.   LOG_OPEN,LOG_WRITE,LOG_UPDATE,LOG_DELETE,LOG_CLOSE,LOG_EXTRA,LOG_LOCK
  354. };
  355. #define nisam_log_simple(a,b,c,d) if (nisam_log_file >= 0) _nisam_log(a,b,c,d)
  356. #define nisam_log_command(a,b,c,d,e) if (nisam_log_file >= 0) _nisam_log_command(a,b,c,d,e)
  357. #define nisam_log_record(a,b,c,d,e) if (nisam_log_file >= 0) _nisam_log_record(a,b,c,d,e)
  358. extern uint _nisam_get_block_info(BLOCK_INFO *,File, ulong);
  359. extern uint _nisam_rec_pack(N_INFO *info,byte *to,const byte *from);
  360. extern uint _nisam_pack_get_block_info(BLOCK_INFO *, uint, File, ulong);
  361. extern uint _calc_total_blob_length(N_INFO *info,const byte *record);
  362. extern void _nisam_log(enum nisam_log_commands command,N_INFO *info,
  363.        const byte *buffert,uint length);
  364. extern void _nisam_log_command(enum nisam_log_commands command,
  365.        N_INFO *info, const byte *buffert,
  366.        uint length, int result);
  367. extern void _nisam_log_record(enum nisam_log_commands command,N_INFO *info,
  368.       const byte *record,ulong filepos,
  369.       int result);
  370. extern my_bool _nisam_memmap_file(N_INFO *info);
  371. extern void _nisam_unmap_file(N_INFO *info);