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

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. /* Functions to handle fixed-length-records */
  14. #include "isamdef.h"
  15. int _nisam_write_static_record(N_INFO *info, const byte *record)
  16. {
  17.   uchar temp[4]; /* Not sizeof(long) */
  18.   if (info->s->state.dellink != NI_POS_ERROR)
  19.   {
  20.     ulong filepos=info->s->state.dellink;
  21.     info->rec_cache.seek_not_done=1; /* We have done a seek */
  22.     VOID(my_seek(info->dfile,info->s->state.dellink+1,MY_SEEK_SET,MYF(0)));
  23.     if (my_read(info->dfile,(char*) &temp[0],sizeof(temp), MYF(MY_NABP)))
  24.       goto err;
  25.     info->s->state.dellink=uint4korr(temp);
  26.     if (info->s->state.dellink == (uint32) ~0) /* Fix for 64 bit long */
  27.       info->s->state.dellink=NI_POS_ERROR;
  28.     info->s->state.del--;
  29.     info->s->state.empty-=info->s->base.reclength;
  30.     VOID(my_seek(info->dfile,filepos,MY_SEEK_SET,MYF(0)));
  31.     if (my_write(info->dfile, (char*) record, info->s->base.reclength,
  32.  MYF(MY_NABP)))
  33.       goto err;
  34.   }
  35.   else
  36.   {
  37.     if (info->s->state.data_file_length > info->s->base.max_data_file_length)
  38.     {
  39.       my_errno=HA_ERR_RECORD_FILE_FULL;
  40.       return(2);
  41.     }
  42.     if (info->opt_flag & WRITE_CACHE_USED)
  43.     { /* Cash in use */
  44.       if (my_b_write(&info->rec_cache, (byte*) record, info->s->base.reclength))
  45. goto err;
  46.     }
  47.     else
  48.     {
  49.       info->rec_cache.seek_not_done=1; /* We have done a seek */
  50.       VOID(my_seek(info->dfile,info->s->state.data_file_length,
  51.    MY_SEEK_SET,MYF(0)));
  52.       if (my_write(info->dfile,(char*) record,info->s->base.reclength,
  53.    MYF(MY_NABP | MY_WAIT_IF_FULL)))
  54. goto err;
  55.     }
  56.     info->s->state.data_file_length+=info->s->base.reclength;
  57.     info->s->state.splitt++;
  58.   }
  59.   return 0;
  60.  err:
  61.   return 1;
  62. }
  63. int _nisam_update_static_record(N_INFO *info, ulong pos, const byte *record)
  64. {
  65.   info->rec_cache.seek_not_done=1; /* We have done a seek */
  66.   VOID(my_seek(info->dfile,pos,MY_SEEK_SET,MYF(0)));
  67.   return (my_write(info->dfile,(char*) record,info->s->base.reclength,
  68.    MYF(MY_NABP)) != 0);
  69. }
  70. int _nisam_delete_static_record(N_INFO *info)
  71. {
  72.   uchar temp[5]; /* 1+sizeof(uint32) */
  73.   info->s->state.del++;
  74.   info->s->state.empty+=info->s->base.reclength;
  75.   temp[0]= ''; /* Mark that record is deleted */
  76.   int4store(temp+1,info->s->state.dellink);
  77.   info->s->state.dellink = info->lastpos;
  78.   info->rec_cache.seek_not_done=1;
  79.   VOID(my_seek(info->dfile,info->lastpos,MY_SEEK_SET,MYF(0)));
  80.   return (my_write(info->dfile,(byte*) temp,(uint) sizeof(temp),
  81.    MYF(MY_NABP)) != 0);
  82. }
  83. int _nisam_cmp_static_record(register N_INFO *info, register const byte *old)
  84. {
  85.   DBUG_ENTER("_nisam_rectest");
  86.   /* We are going to do changes; dont let anybody disturb */
  87.   dont_break(); /* Dont allow SIGHUP or SIGINT */
  88.   if (info->opt_flag & WRITE_CACHE_USED)
  89.   {
  90.     if (flush_io_cache(&info->rec_cache))
  91.     {
  92.       DBUG_RETURN(-1);
  93.     }
  94.     info->rec_cache.seek_not_done=1; /* We have done a seek */
  95.   }
  96.   if ((info->opt_flag & READ_CHECK_USED))
  97.   { /* If check isn't disabled  */
  98.     info->rec_cache.seek_not_done=1; /* We have done a seek */
  99.     VOID(my_seek(info->dfile,info->lastpos,MY_SEEK_SET,MYF(0)));
  100.     if (my_read(info->dfile, (char*) info->rec_buff, info->s->base.reclength,
  101. MYF(MY_NABP)))
  102.       DBUG_RETURN(-1);
  103.     if (memcmp((byte*) info->rec_buff, (byte*) old,
  104.        (uint) info->s->base.reclength))
  105.     {
  106.       DBUG_DUMP("read",old,info->s->base.reclength);
  107.       DBUG_DUMP("disk",info->rec_buff,info->s->base.reclength);
  108.       my_errno=HA_ERR_RECORD_CHANGED; /* Record have changed */
  109.       DBUG_RETURN(1);
  110.     }
  111.   }
  112.   DBUG_RETURN(0);
  113. }
  114. /* Read a fixed-length-record */
  115. /* Returns 0 if Ok. */
  116. /*    1 if record is deleted */
  117. /*   MY_FILE_ERROR on read-error or locking-error */
  118. int _nisam_read_static_record(register N_INFO *info, register ulong pos,
  119.    register byte *record)
  120. {
  121.   int error;
  122.   if (pos != NI_POS_ERROR)
  123.   {
  124.     if (info->opt_flag & WRITE_CACHE_USED &&
  125. info->rec_cache.pos_in_file <= pos &&
  126. flush_io_cache(&info->rec_cache))
  127.       return(-1);
  128.     info->rec_cache.seek_not_done=1; /* We have done a seek */
  129.     error=my_pread(info->dfile,(char*) record,info->s->base.reclength,
  130.    pos,MYF(MY_NABP)) != 0;
  131.     if (info->s->r_locks == 0 && info->s->w_locks == 0)
  132.       VOID(_nisam_writeinfo(info,0));
  133.     if (! error)
  134.     {
  135.       if (!*record) return(1); /* Record is deleted */
  136.       info->update|= HA_STATE_AKTIV; /* Record is read */
  137.       my_errno=HA_ERR_RECORD_DELETED;
  138.       return(0);
  139.     }
  140.     return(-1); /* Error on read */
  141.   }
  142.   VOID(_nisam_writeinfo(info,0)); /* No such record */
  143.   return(-1);
  144. } /* _nisam_read_record */
  145. int _nisam_read_rnd_static_record(N_INFO *info, byte *buf,
  146.   register ulong filepos,
  147.   int skipp_deleted_blocks)
  148. {
  149.   int locked,error,cache_read;
  150.   uint cache_length;
  151.   ISAM_SHARE *share=info->s;
  152.   DBUG_ENTER("_nisam_read_rnd_static_record");
  153.   cache_read=0;
  154.   LINT_INIT(cache_length);
  155.   if (info->opt_flag & WRITE_CACHE_USED &&
  156.       (info->rec_cache.pos_in_file <= filepos || skipp_deleted_blocks) &&
  157.       flush_io_cache(&info->rec_cache))
  158.     DBUG_RETURN(-1);
  159.   if (info->opt_flag & READ_CACHE_USED)
  160.   { /* Cash in use */
  161.     if (filepos == my_b_tell(&info->rec_cache) &&
  162. (skipp_deleted_blocks || !filepos))
  163.     {
  164.       cache_read=1; /* Read record using cache */
  165.       cache_length=(uint) (info->rec_cache.read_end - info->rec_cache.read_pos);
  166.     }
  167.     else
  168.       info->rec_cache.seek_not_done=1; /* Filepos is changed */
  169.   }
  170. #ifndef NO_LOCKING
  171.   locked=0;
  172.   if (info->lock_type == F_UNLCK)
  173.   {
  174.     if (filepos >= share->state.data_file_length)
  175.     { /* Test if new records */
  176.       if (_nisam_readinfo(info,F_RDLCK,0))
  177. DBUG_RETURN(-1);
  178.       locked=1;
  179.     }
  180.     else
  181.     { /* We don't nead new info */
  182. #ifndef UNSAFE_LOCKING
  183.       if ((! cache_read || share->base.reclength > cache_length) &&
  184.   share->r_locks == 0 && share->w_locks == 0)
  185.       { /* record not in cache */
  186. if (my_lock(share->kfile,F_RDLCK,0L,F_TO_EOF,
  187.     MYF(MY_SEEK_NOT_DONE) | info->lock_wait))
  188.   DBUG_RETURN(-1);
  189. locked=1;
  190.       }
  191. #else
  192.       info->tmp_lock_type=F_RDLCK;
  193. #endif
  194.     }
  195.   }
  196. #endif
  197.   if (filepos >= share->state.data_file_length)
  198.   {
  199. #ifndef NO_LOCKING
  200.     DBUG_PRINT("test",("filepos: %ld (%ld)  records: %ld  del: %ld",
  201.        filepos/share->base.reclength,filepos,
  202.        share->state.records, share->state.del));
  203.     VOID(_nisam_writeinfo(info,0));
  204. #endif
  205.     my_errno=HA_ERR_END_OF_FILE;
  206.     DBUG_RETURN(-1);
  207.   }
  208.   info->lastpos= filepos;
  209.   info->nextpos= filepos+share->base.reclength;
  210.   if (! cache_read) /* No cacheing */
  211.   {
  212.     error=_nisam_read_static_record(info,filepos,buf);
  213.     if (error > 0)
  214.       my_errno=HA_ERR_RECORD_DELETED;
  215.     DBUG_RETURN(error);
  216.   }
  217. /* Read record with cacheing */
  218.   error=my_b_read(&info->rec_cache,(byte*) buf,share->base.reclength);
  219. #ifndef NO_LOCKING
  220.   if (locked)
  221.     VOID(_nisam_writeinfo(info,0)); /* Unlock keyfile */
  222. #endif
  223.   if (!error)
  224.   {
  225.     if (!buf[0])
  226.     { /* Record is removed */
  227.       my_errno=HA_ERR_RECORD_DELETED;
  228.       DBUG_RETURN(1);
  229.     }
  230. /* Found and may be updated */
  231.     info->update|= HA_STATE_AKTIV | HA_STATE_KEY_CHANGED;
  232.     DBUG_RETURN(0);
  233.   }
  234.   if (info->rec_cache.error != -1 || my_errno == 0)
  235.     my_errno=HA_ERR_WRONG_IN_RECORD;
  236.   DBUG_RETURN(-1); /* Something wrong (EOF?) */
  237. }