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

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. /* open a MyISAM MERGE table */
  14. #include "myrg_def.h"
  15. #include <stddef.h>
  16. #include <errno.h>
  17. #ifdef VMS
  18. #include "mrg_static.c"
  19. #endif
  20. /*
  21. open a MyISAM MERGE table
  22. if handle_locking is 0 then exit with error if some table is locked
  23. if handle_locking is 1 then wait if table is locked
  24. */
  25. MYRG_INFO *myrg_open(const char *name, int mode, int handle_locking)
  26. {
  27.   int save_errno,errpos=0;
  28.   uint files=0,i,dir_length,length,key_parts;
  29.   ulonglong file_offset=0;
  30.   char name_buff[FN_REFLEN*2],buff[FN_REFLEN],*end;
  31.   MYRG_INFO *m_info=0;
  32.   File fd;
  33.   IO_CACHE file;
  34.   MI_INFO *isam=0;
  35.   uint found_merge_insert_method= 0;
  36.   DBUG_ENTER("myrg_open");
  37.   LINT_INIT(key_parts);
  38.   bzero((char*) &file,sizeof(file));
  39.   if ((fd=my_open(fn_format(name_buff,name,"",MYRG_NAME_EXT,4),
  40.   O_RDONLY | O_SHARE,MYF(0))) < 0)
  41.      goto err;
  42.    errpos=1;
  43.    if (init_io_cache(&file, fd, 4*IO_SIZE, READ_CACHE, 0, 0,
  44.     MYF(MY_WME | MY_NABP)))
  45.      goto err;
  46.    errpos=2;
  47.   dir_length=dirname_part(name_buff,name);
  48.   while ((length=my_b_gets(&file,buff,FN_REFLEN-1)))
  49.   {
  50.     if ((end=buff+length)[-1] == 'n')
  51.       end[-1]='';
  52.     if (buff[0] && buff[0] != '#')
  53.       files++;
  54.   }
  55.   my_b_seek(&file, 0);
  56.   while ((length=my_b_gets(&file,buff,FN_REFLEN-1)))
  57.   {
  58.     if ((end=buff+length)[-1] == 'n')
  59.       *--end='';
  60.     if (!buff[0])
  61.       continue; /* Skip empty lines */
  62.     if (buff[0] == '#')
  63.     {
  64.       if (!strncmp(buff+1,"INSERT_METHOD=",14))
  65.       { /* Lookup insert method */
  66. int tmp=find_type(buff+15,&merge_insert_method,2);
  67. found_merge_insert_method = (uint) (tmp >= 0 ? tmp : 0);
  68.       }
  69.       continue; /* Skip comments */
  70.     }
  71.     if (!has_path(buff))
  72.     {
  73.       VOID(strmake(name_buff+dir_length,buff,
  74.                    sizeof(name_buff)-1-dir_length));
  75.       VOID(cleanup_dirname(buff,name_buff));
  76.     }
  77.     else
  78.       fn_format(buff, buff, "", "", 0);
  79.     if (!(isam=mi_open(buff,mode,(handle_locking?HA_OPEN_WAIT_IF_LOCKED:0))))
  80.       goto err;
  81.     if (!m_info)                                /* First file */
  82.     {
  83.       key_parts=isam->s->base.key_parts;
  84.       if (!(m_info= (MYRG_INFO*) my_malloc(sizeof(MYRG_INFO) +
  85.                                            files*sizeof(MYRG_TABLE) +
  86.                                            key_parts*sizeof(long),
  87.                                            MYF(MY_WME|MY_ZEROFILL))))
  88.         goto err;
  89.       if (files)
  90.       {
  91.         m_info->open_tables=(MYRG_TABLE *) (m_info+1);
  92.         m_info->rec_per_key_part=(ulong *) (m_info->open_tables+files);
  93.         m_info->tables= files;
  94.         files= 0;
  95.       }
  96.       m_info->reclength=isam->s->base.reclength;
  97.       errpos=3;
  98.     }
  99.     m_info->open_tables[files].table= isam;
  100.     m_info->open_tables[files].file_offset=(my_off_t) file_offset;
  101.     file_offset+=isam->state->data_file_length;
  102.     files++;
  103.     if (m_info->reclength != isam->s->base.reclength)
  104.     {
  105.       my_errno=HA_ERR_WRONG_MRG_TABLE_DEF;
  106.       goto err;
  107.     }
  108.     m_info->options|= isam->s->options;
  109.     m_info->records+= isam->state->records;
  110.     m_info->del+= isam->state->del;
  111.     m_info->data_file_length+= isam->state->data_file_length;
  112.     for (i=0; i < key_parts; i++)
  113.       m_info->rec_per_key_part[i]+= (isam->s->state.rec_per_key_part[i] /
  114.                                      m_info->tables);
  115.   }
  116.   if (!m_info && !(m_info= (MYRG_INFO*) my_malloc(sizeof(MYRG_INFO),
  117.                                                   MYF(MY_WME | MY_ZEROFILL))))
  118.     goto err;
  119.   /* Don't mark table readonly, for ALTER TABLE ... UNION=(...) to work */
  120.   m_info->options&= ~(HA_OPTION_COMPRESS_RECORD | HA_OPTION_READ_ONLY_DATA);
  121.   m_info->merge_insert_method= found_merge_insert_method;
  122.   if (sizeof(my_off_t) == 4 && file_offset > (ulonglong) (ulong) ~0L)
  123.   {
  124.     my_errno=HA_ERR_RECORD_FILE_FULL;
  125.     goto err;
  126.   }
  127.   m_info->keys= files ? isam->s->base.keys : 0;
  128.   bzero((char*) &m_info->by_key,sizeof(m_info->by_key));
  129.   /* this works ok if the table list is empty */
  130.   m_info->end_table=m_info->open_tables+files;
  131.   m_info->last_used_table=m_info->open_tables;
  132.   VOID(my_close(fd,MYF(0)));
  133.   end_io_cache(&file);
  134.   m_info->open_list.data=(void*) m_info;
  135.   pthread_mutex_lock(&THR_LOCK_open);
  136.   myrg_open_list=list_add(myrg_open_list,&m_info->open_list);
  137.   pthread_mutex_unlock(&THR_LOCK_open);
  138.   DBUG_RETURN(m_info);
  139. err:
  140.   save_errno=my_errno;
  141.   switch (errpos) {
  142.   case 3:
  143.     while (files)
  144.       mi_close(m_info->open_tables[--files].table);
  145.     my_free((char*) m_info,MYF(0));
  146.     /* Fall through */
  147.   case 2:
  148.     end_io_cache(&file);
  149.     /* Fall through */
  150.   case 1:
  151.     VOID(my_close(fd,MYF(0)));
  152.   }
  153.   my_errno=save_errno;
  154.   DBUG_RETURN (NULL);
  155. }