home *** CD-ROM | disk | FTP | other *** search
/ Chip 2001 January / Chip_2001-01_cd1.bin / tema / mysql / mysql-3.23.28g-win-source.exe / sql / crebas.cpp < prev    next >
C/C++ Source or Header  |  1999-01-13  |  7KB  |  218 lines
  1. /* Copyright (C) 1979-1996 TcX AB & Monty Program KB & Detron HB
  2.  
  3.    This software is distributed with NO WARRANTY OF ANY KIND.  No author or
  4.    distributor accepts any responsibility for the consequences of using it, or
  5.    for whether it serves any particular purpose or works at all, unless he or
  6.    she says so in writing.  Refer to the Free Public License (the "License")
  7.    for full details.
  8.    Every copy of this file must include a copy of the License, normally in a
  9.    plain ASCII text file named PUBLIC.    The License grants you the right to
  10.    copy, modify and redistribute this file, but only under certain conditions
  11.    described in the License.  Among other things, the License requires that
  12.    the copyright notice and this notice be preserved on all copies. */
  13.  
  14. /* Makes a database from a form-file */
  15.  
  16. #include "mysql_priv.h"
  17. #ifndef NO_HASH
  18. #include <hashdb.h>
  19. #endif
  20. #include <heap.h>
  21. #include <nisam.h>
  22. #include <merge.h>
  23.  
  24.     /* Functions in this file */
  25.  
  26. #ifndef NO_HASH
  27. static int NEAR_F cre_hash(char *name,TABLE *form);
  28. #endif
  29. static int NEAR_F cre_isam(char *name,TABLE *form,uint options);
  30.  
  31.  
  32.     /* Initiates form-file and calls apropriate database-creator */
  33.     /* Returns 1 if something got wrong */
  34.  
  35. int cre_database(my_string name)
  36. {
  37.   int error;
  38.   TABLE form;
  39.   DBUG_ENTER("cre_database");
  40.  
  41.   error=0;                    // Keep lint happy
  42.   if (openfrm(name,"",0,(uint) (READ_ALL+GET_NAME_OF_INDEXFILE),&form))
  43.     DBUG_RETURN(1);
  44.  
  45.   switch (form.db_type)
  46.   {
  47. #ifndef NO_HASH
  48.     case DB_TYPE_HASH:        error=cre_hash(name,&form); break;
  49. #endif
  50. #ifndef NO_HEAP
  51.     case DB_TYPE_HEAP:
  52.       {                        /* Remove old database */
  53.     char buff[FN_REFLEN];
  54.     error=heap_create(fn_format(buff,name,"","",1+2));
  55.     break;
  56.       }
  57. #endif
  58.     case DB_TYPE_ISAM:
  59.       error=cre_isam(name,&form, form.db_create_options);
  60.       break;
  61.   case DB_TYPE_MRG_ISAM:
  62. #ifndef NO_MERGE
  63.       {
  64.     char buff[FN_REFLEN];
  65.     error=mrg_create(fn_format(buff,name,"","",2+4+16),0);
  66.     break;
  67.       }
  68. #endif
  69.     default: break;                /* impossible */
  70.   }
  71.   VOID(closefrm(&form));
  72.   if (error)
  73.     my_error(ER_CANT_CREATE_TABLE,MYF(ME_BELL+ME_WAITTANG),name,my_errno);
  74.   DBUG_RETURN(error != 0);
  75. } /* cre_database */
  76.  
  77.  
  78.     /* makes a hash-database */
  79.  
  80. #ifndef NO_HASH
  81.  
  82. static int NEAR_F cre_hash(my_string name, register TABLE *form)
  83. {
  84.   register uint i,j;
  85.   char buff[FN_REFLEN];
  86.   KEY *pos;
  87.   H_KEYDEF keydef[MAX_KEY];
  88.   DBUG_ENTER("cre_hash");
  89.  
  90.   pos=form->key_info;
  91.   for (i=0; i < form->keys ; i++, pos++)
  92.   {
  93.     keydef[i].hk_flag=     pos->dupp_key ? 0 : HA_NOSAME;
  94.     for (j=0 ; (int7) j < pos->key_parts ; j++)
  95.     {
  96.       uint flag=pos->key_part[j].key_type;
  97.       if (!f_is_packed(flag) && f_packtype(flag) == (int) FIELD_TYPE_DECIMAL &&
  98.       !(flag & FIELDFLAG_BINARY))
  99.     keydef[i].hk_keyseg[j].key_type= (int) HA_KEYTYPE_TEXT;
  100.       else
  101.     keydef[i].hk_keyseg[j].key_type= (int) HA_KEYTYPE_BINARY;
  102.       keydef[i].hk_keyseg[j].start=  pos->key_part[j].offset;
  103.       keydef[i].hk_keyseg[j].length= pos->key_part[j].length;
  104.     }
  105.     keydef[i].hk_keyseg[j].key_type= 0;
  106.   }
  107.   DBUG_RETURN(h_create(fn_format(buff,name,"","",2+4+16),i,
  108.                keydef,form->reclength,form->max_records,form->reloc,
  109.                0));
  110. } /* cre_hash */
  111. #endif
  112.  
  113.  
  114.     /* makes a new-isam-database */
  115.  
  116. static int NEAR_F cre_isam(my_string name, register TABLE *form, uint options)
  117. {
  118.   int error;
  119.   uint i,j,recpos,minpos,fieldpos,temp_length,length;
  120.   enum ha_base_keytype type;
  121.   char buff[FN_REFLEN];
  122.   KEY *pos;
  123.   N_KEYDEF keydef[MAX_KEY];
  124.   N_RECINFO *recinfo,*recinfo_pos;
  125.   DBUG_ENTER("cre_isam");
  126.  
  127.   type=HA_KEYTYPE_BINARY;                // Keep compiler happy
  128.   if (!(recinfo= (N_RECINFO*) my_malloc((form->fields*2+3)*sizeof(N_RECINFO),
  129.                     MYF(MY_WME))))
  130.     DBUG_RETURN(1);
  131.  
  132.   pos=form->key_info;
  133.   for (i=0; i < form->keys ; i++, pos++)
  134.   {
  135.     keydef[i].base.flag= (pos->dupp_key ? 0 : HA_NOSAME);
  136.     for (j=0 ; (int7) j < pos->key_parts ; j++)
  137.     {
  138.       keydef[i].seg[j].base.flag=pos->key_part[j].key_part_flag;
  139.       Field *field=pos->key_part[j].field;
  140.       type=field->key_type();
  141.  
  142.       if ((options & HA_OPTION_PACK_KEYS) && pos->key_part[j].length > 8 &&
  143.       (type == HA_KEYTYPE_TEXT ||
  144.        type == HA_KEYTYPE_NUM ||
  145.        (type == HA_KEYTYPE_BINARY && !field->zero_pack())))
  146.       {
  147.     if (j == 0)
  148.       keydef[i].base.flag|=HA_PACK_KEY;
  149.     if (!(field->flags & ZEROFILL_FLAG) &&
  150.         (field->type() == FIELD_TYPE_STRING ||
  151.          field->type() == FIELD_TYPE_VAR_STRING ||
  152.          (pos->key_part[j].length - ((Field_num*) field)->decimals)
  153.          >= 4))
  154.       keydef[i].seg[j].base.flag|=HA_SPACE_PACK;
  155.       }
  156.       keydef[i].seg[j].base.type=(int) type;
  157.       keydef[i].seg[j].base.start=  pos->key_part[j].offset;
  158.       keydef[i].seg[j].base.length= pos->key_part[j].length;
  159.     }
  160.     keydef[i].seg[j].base.type=(int) HA_KEYTYPE_END;    /* End of key-parts */
  161.   }
  162.  
  163.   recpos=0; recinfo_pos=recinfo;
  164.   while (recpos < (uint) form->reclength)
  165.   {
  166.     Field **field,*found=0;
  167.     minpos=form->reclength; length=0;
  168.  
  169.     for (field=form->field ; *field ; field++)
  170.     {
  171.       if ((fieldpos=(*field)->offset()) >= recpos &&
  172.       fieldpos <= minpos)
  173.       {
  174.     if (!(temp_length= (*field)->pack_length()))
  175.       continue;                /* Skipp null-fields */
  176.     if (! found || fieldpos < minpos ||
  177.         (fieldpos == minpos && temp_length < length))
  178.     {
  179.       minpos=fieldpos; found= *field; length=temp_length;
  180.     }
  181.       }
  182.     }
  183.     DBUG_PRINT("loop",("found: %lx  recpos: %d  minpos: %d  length: %d",
  184.                found,recpos,minpos,length));
  185.     if (recpos != minpos)
  186.     {                        // Not used space
  187.       recinfo_pos->base.type=(int) FIELD_NORMAL;
  188.       recinfo_pos++->base.length= (uint16) (minpos-recpos);
  189.     }
  190.     if (! found)
  191.       break;
  192.  
  193.     if (found->flags & BLOB_FLAG)
  194.       recinfo_pos->base.type= (int) FIELD_BLOB;
  195.     else if (!(options & HA_OPTION_PACK_RECORD))
  196.       recinfo_pos->base.type= (int) FIELD_NORMAL;
  197.     else if (found->zero_pack())
  198.       recinfo_pos->base.type= (int) FIELD_SKIPP_ZERO;
  199.     else
  200.       recinfo_pos->base.type= (int) ((length <= 3 ||
  201.                       (found->flags & ZEROFILL_FLAG)) ?
  202.                      FIELD_NORMAL :
  203.                      found->type() == FIELD_TYPE_STRING ||
  204.                      found->type() == FIELD_TYPE_VAR_STRING ?
  205.                      FIELD_SKIPP_ENDSPACE :
  206.                      FIELD_SKIPP_PRESPACE);
  207.     recinfo_pos++ ->base.length=(uint16) length;
  208.     recpos=minpos+length;
  209.     DBUG_PRINT("loop",("length: %d  type: %d",
  210.                recinfo_pos[-1].base.length,recinfo_pos[-1].base.type));
  211.   }
  212.   recinfo_pos->base.type= (int) FIELD_LAST;    /* End of fieldinfo */
  213.   error=ni_create(fn_format(buff,name,"","",2+4+16),form->keys,keydef,
  214.           recinfo,form->max_records,form->reloc,0,0,0L);
  215.   my_free((gptr) recinfo,MYF(0));
  216.   DBUG_RETURN(error);
  217. }
  218.