开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
test2.c
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：24k
源码类别：

MySQL数据库

开发平台：

Visual C++

test2.c：源码内容
  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program 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
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. /* Test av isam-databas: stor test */
  19. #ifndef USE_MY_FUNC /* We want to be able to dbug this !! */
  20. #define USE_MY_FUNC
  21. #endif
  22. #ifdef DBUG_OFF
  23. #undef DBUG_OFF
  24. #endif
  25. #ifndef SAFEMALLOC
  26. #define SAFEMALLOC
  27. #endif
  29. #include "isamdef.h"
  31. #define STANDAR_LENGTH 37
  32. #define NISAM_KEYS 6
  33. #if !defined(MSDOS) && !defined(labs)
  34. #define labs(a) abs(a)
  35. #endif
  37. static void get_options(int argc, char *argv[]);
  38. static uint rnd(uint max_value);
  39. static void fix_length(byte *record,uint length);
  40. static void put_blob_in_record(char *blob_pos,char **blob_buffer);
  41. static void copy_key(struct st_isam_info *info,uint inx,
  42.      uchar *record,uchar *key);
  44. static int verbose=0,testflag=0,pack_type=HA_SPACE_PACK,
  45.     first_key=0,async_io=0,key_cacheing=0,write_cacheing=0,locking=0,
  46.     rec_pointer_size=0,pack_fields=1,use_log=0;
  47. static uint keys=NISAM_KEYS,recant=1000;
  48. static uint use_blob=0;
  49. static uint16 key1[1000],key3[5000];
  50. static char record[300],record2[300],key[100],key2[100],
  51.     read_record[300],read_record2[300],read_record3[300];
  54. /* Test program */
  56. int main(int argc, char *argv[])
  57. {
  58.   uint i;
  59.   int j,n1,n2,n3,error,k;
  60.   uint write_count,update,dupp_keys,opt_delete,start,length,blob_pos,
  61.        reclength,ant;
  62.   ulong lastpos,range_records,records;
  63.   N_INFO *file;
  64.   N_KEYDEF keyinfo[10];
  65.   N_RECINFO recinfo[10];
  66.   N_ISAMINFO info;
  67.   char *filename,*blob_buffer;
  68.   MY_INIT(argv[0]);
  70.   filename= (char*) "test2.ISM";
  71.   get_options(argc,argv);
  72.   if (! async_io)
  73.     my_disable_async_io=1;
  75.   reclength=STANDAR_LENGTH+60+(use_blob ? 8 : 0);
  76.   blob_pos=STANDAR_LENGTH+60;
  77.   keyinfo[0].seg[0].base.start=0;
  78.   keyinfo[0].seg[0].base.length=6;
  79.   keyinfo[0].seg[0].base.type=HA_KEYTYPE_TEXT;
  80.   keyinfo[0].seg[0].base.flag=(uint8) pack_type;
  81.   keyinfo[0].seg[1].base.type=0;
  82.   keyinfo[0].base.flag = (uint8) (pack_type ? HA_PACK_KEY : 0);
  83.   keyinfo[1].seg[0].base.start=7;
  84.   keyinfo[1].seg[0].base.length=6;
  85.   keyinfo[1].seg[0].base.type=HA_KEYTYPE_BINARY;
  86.   keyinfo[1].seg[0].base.flag=0;
  87.   keyinfo[1].seg[1].base.start=0; /* Tv}delad nyckel */
  88.   keyinfo[1].seg[1].base.length=6;
  89.   keyinfo[1].seg[1].base.type=HA_KEYTYPE_NUM;
  90.   keyinfo[1].seg[1].base.flag=HA_REVERSE_SORT;
  91.   keyinfo[1].seg[2].base.type=0;
  92.   keyinfo[1].base.flag =0;
  93.   keyinfo[2].seg[0].base.start=12;
  94.   keyinfo[2].seg[0].base.length=8;
  95.   keyinfo[2].seg[0].base.type=HA_KEYTYPE_BINARY;
  96.   keyinfo[2].seg[0].base.flag=HA_REVERSE_SORT;
  97.   keyinfo[2].seg[1].base.type=0;
  98.   keyinfo[2].base.flag =HA_NOSAME;
  99.   keyinfo[3].seg[0].base.start=0;
  100.   keyinfo[3].seg[0].base.length=reclength-(use_blob ? 8 : 0);
  101.   keyinfo[3].seg[0].base.type=HA_KEYTYPE_TEXT;
  102.   keyinfo[3].seg[0].base.flag=(uint8) pack_type;
  103.   keyinfo[3].seg[1].base.type=0;
  104.   keyinfo[3].base.flag = (uint8) (pack_type ? HA_PACK_KEY : 0);
  105.   keyinfo[4].seg[0].base.start=0;
  106.   keyinfo[4].seg[0].base.length=5;
  107.   keyinfo[4].seg[0].base.type=HA_KEYTYPE_TEXT;
  108.   keyinfo[4].seg[0].base.flag=0;
  109.   keyinfo[4].seg[1].base.type=0;
  110.   keyinfo[4].base.flag = (uint8) (pack_type ? HA_PACK_KEY : 0);
  111.   keyinfo[5].seg[0].base.start=0;
  112.   keyinfo[5].seg[0].base.length=4;
  113.   keyinfo[5].seg[0].base.type=HA_KEYTYPE_TEXT;
  114.   keyinfo[5].seg[0].base.flag=(uint8) pack_type;
  115.   keyinfo[5].seg[1].base.type=0;
  116.   keyinfo[5].base.flag = (uint8) (pack_type ? HA_PACK_KEY : 0);
  118.   recinfo[0].base.type=pack_fields ? FIELD_SKIP_PRESPACE : 0;
  119.   recinfo[0].base.length=7;
  120.   recinfo[1].base.type=pack_fields ? FIELD_SKIP_PRESPACE : 0;
  121.   recinfo[1].base.length=5;
  122.   recinfo[2].base.type=pack_fields ? FIELD_SKIP_PRESPACE : 0;
  123.   recinfo[2].base.length=9;
  124.   recinfo[3].base.type=FIELD_NORMAL;
  125.   recinfo[3].base.length=STANDAR_LENGTH-7-5-9-4;
  126.   recinfo[4].base.type=pack_fields ? FIELD_SKIP_ZERO : 0;
  127.   recinfo[4].base.length=4;
  128.   recinfo[5].base.type=pack_fields ? FIELD_SKIP_ENDSPACE : 0;
  129.   recinfo[5].base.length=60;
  130.   if (use_blob)
  131.   {
  132.     recinfo[6].base.type=FIELD_BLOB;
  133.     recinfo[6].base.length=4+sizeof(char*); /* 4 byte ptr, 4 byte length */
  134.     recinfo[7].base.type= FIELD_LAST;
  135.   }
  136.   else
  137.     recinfo[6].base.type= FIELD_LAST;
  139.   write_count=update=dupp_keys=opt_delete=0;
  140.   blob_buffer=0;
  142.   for (i=999 ; i>0 ; i--) key1[i]=0;
  143.   for (i=4999 ; i>0 ; i--) key3[i]=0;
  145.   printf("- Creating isam-filen");
  146.   /*  DBUG_PUSH(""); */
  147.   my_delete(filename,MYF(0)); /* Remove old locks under gdb */
  148.   file= 0;
  149.   if (nisam_create(filename,keys,&keyinfo[first_key],&recinfo[0],
  150.    (ulong) (rec_pointer_size ? (1L << (rec_pointer_size*8))/
  151.     reclength : 0),100l,0,0,0L))
  152.     goto err;
  153.   if (use_log)
  154.     nisam_log(1);
  155.   if (!(file=nisam_open(filename,2,HA_OPEN_ABORT_IF_LOCKED)))
  156.     goto err;
  157.   printf("- Writing key:sn");
  158.   if (key_cacheing)
  159.     init_key_cache(dflt_key_cache,512,IO_SIZE*16,0,0); /* Use a small cache */
  160.   if (locking)
  161.     nisam_lock_database(file,F_WRLCK);
  162.   if (write_cacheing)
  163.     nisam_extra(file,HA_EXTRA_WRITE_CACHE);
  165.   for (i=0 ; i < recant ; i++)
  166.   {
  167.     n1=rnd(1000); n2=rnd(100); n3=rnd(5000);
  168.     sprintf(record,"%6d:%4d:%8d:Pos: %4d    ",n1,n2,n3,write_count);
  169.     longstore(record+STANDAR_LENGTH-4,(long) i);
  170.     fix_length(record,(uint) STANDAR_LENGTH+rnd(60));
  171.     put_blob_in_record(record+blob_pos,&blob_buffer);
  172.     DBUG_PRINT("test",("record: %d",i));
  174.     if (nisam_write(file,record))
  175.     {
  176.       if (my_errno != HA_ERR_FOUND_DUPP_KEY || key3[n3] == 0)
  177.       {
  178. printf("Error: %d in write at record: %dn",my_errno,i);
  179. goto err;
  180.       }
  181.       if (verbose) printf("   Double key: %dn",n3);
  182.     }
  183.     else
  184.     {
  185.       if (key3[n3] == 1 && first_key <3 && first_key+keys >= 3)
  186.       {
  187. printf("Error: Didn't get error when writing second key: '%8d'n",n3);
  188. goto err;
  189.       }
  190.       write_count++; key1[n1]++; key3[n3]=1;
  191.     }
  193.     /* Check if we can find key without flushing database */
  194.     if (i == recant/2)
  195.     {
  196.       for (j=rnd(1000) ; j>0 && key1[j] == 0 ; j--) ;
  197.       if (!j)
  198. for (j=999 ; j>0 && key1[j] == 0 ; j--) ;
  199.       sprintf(key,"%6d",j);
  200.       if (nisam_rkey(file,read_record,0,key,0,HA_READ_KEY_EXACT))
  201.       {
  202. printf("Test in loop: Can't find key: "%s"n",key);
  203. goto err;
  204.       }
  205.     }
  206.   }
  207.   if (testflag==1) goto end;
  209.   if (write_cacheing)
  210.     if (nisam_extra(file,HA_EXTRA_NO_CACHE))
  211.     {
  212.       puts("got error from nisam_extra(HA_EXTRA_NO_CACHE)");
  213.       goto end;
  214.     }
  216.   printf("- Deleten");
  217.   for (i=0 ; i<recant/10 ; i++)
  218.   {
  219.     for (j=rnd(1000) ; j>0 && key1[j] == 0 ; j--) ;
  220.     if (j != 0)
  221.     {
  222.       sprintf(key,"%6d",j);
  223.       if (nisam_rkey(file,read_record,0,key,0,HA_READ_KEY_EXACT))
  224.       {
  225. printf("can't find key1: "%s"n",key);
  226. goto err;
  227.       }
  228.       if (nisam_delete(file,read_record))
  229.       {
  230. printf("error: %d; can't delete record: "%s"n", my_errno,read_record);
  231. goto err;
  232.       }
  233.       opt_delete++;
  234.       key1[atoi(read_record+keyinfo[0].seg[0].base.start)]--;
  235.       key3[atoi(read_record+keyinfo[2].seg[0].base.start)]=0;
  236.     }
  237.   }
  238.   if (testflag==2) goto end;
  240.   printf("- Updaten");
  241.   for (i=0 ; i<recant/10 ; i++)
  242.   {
  243.     n1=rnd(1000); n2=rnd(100); n3=rnd(5000);
  244.     sprintf(record2,"%6d:%4d:%8d:XXX: %4d     ",n1,n2,n3,update);
  245.     longstore(record2+STANDAR_LENGTH-4,(long) i);
  246.     fix_length(record2,(uint) STANDAR_LENGTH+rnd(60));
  248.     for (j=rnd(1000) ; j>0 && key1[j] == 0 ; j--) ;
  249.     if (j != 0)
  250.     {
  251.       sprintf(key,"%6d",j);
  252.       if (nisam_rkey(file,read_record,0,key,0,HA_READ_KEY_EXACT))
  253.       {
  254. printf("can't find key1: "%s"n",key);
  255. goto err;
  256.       }
  257.       if (use_blob)
  258.       {
  259. if (i & 1)
  260.   put_blob_in_record(record+blob_pos,&blob_buffer);
  261. else
  262.   bmove(record+blob_pos,read_record+blob_pos,8);
  263.       }
  264.       if (nisam_update(file,read_record,record2))
  265.       {
  266. if (my_errno != HA_ERR_FOUND_DUPP_KEY || key3[n3] == 0)
  267. {
  268.   printf("error: %d; can't update:nFrom: "%s"nTo:   "%s"n",
  269.  my_errno,read_record,record2);
  270.   goto err;
  271. }
  272. if (verbose)
  273.   printf("Double key when tried to update:nFrom: "%s"nTo:   "%s"n",record,record2);
  274.       }
  275.       else
  276.       {
  277. key1[atoi(read_record+keyinfo[0].seg[0].base.start)]--;
  278. key3[atoi(read_record+keyinfo[2].seg[0].base.start)]=0;
  279. key1[n1]++; key3[n3]=1;
  280. update++;
  281.       }
  282.     }
  283.   }
  284.   if (testflag==3) goto end;
  286.   printf("- Same key: first - next -> last - prev -> firstn");
  287.   DBUG_PRINT("progpos",("first - next -> last - prev -> first"));
  288.   for (i=999, dupp_keys=j=0 ; i>0 ; i--)
  289.   {
  290.     if (key1[i] >dupp_keys) { dupp_keys=key1[i]; j=i; }
  291.   }
  292.   sprintf(key,"%6d",j);
  293.   if (verbose) printf("  Using key: "%s"  Keys: %dn",key,dupp_keys);
  294.   if (nisam_rkey(file,read_record,0,key,0,HA_READ_KEY_EXACT)) goto err;
  295.   if (nisam_rsame(file,read_record2,-1)) goto err;
  296.   if (memcmp(read_record,read_record2,reclength) != 0)
  297.   {
  298.     printf("nisam_rsame didn't find same recordn");
  299.     goto end;
  300.   }
  301.   nisam_info(file,&info,0);
  302.   if (nisam_rfirst(file,read_record2,0) ||
  303.       nisam_rsame_with_pos(file,read_record2,0,info.recpos) ||
  304.       memcmp(read_record,read_record2,reclength) != 0)
  305.   {
  306.     printf("nisam_rsame_with_pos didn't find same recordn");
  307.     goto end;
  308.   }
  309.   {
  310.     int skr=nisam_rnext(file,read_record2,0);
  311.     if ((skr && my_errno != HA_ERR_END_OF_FILE) ||
  312. nisam_rprev(file,read_record2,-1) ||
  313. memcmp(read_record,read_record2,reclength) != 0)
  314.     {
  315.       printf("nisam_rsame_with_pos lost positionn");
  316.       goto end;
  317.     }
  318.   }
  319.   ant=1;
  320.   start=keyinfo[0].seg[0].base.start; length=keyinfo[0].seg[0].base.length;
  321.   while (nisam_rnext(file,read_record2,0) == 0 &&
  322.  memcmp(read_record2+start,key,length) == 0) ant++;
  323.   if (ant != dupp_keys)
  324.   {
  325.     printf("next: I can only find: %d keys of %dn",ant,dupp_keys);
  326.     goto end;
  327.   }
  328.   ant=0;
  329.   while (nisam_rprev(file,read_record3,0) == 0 &&
  330.  bcmp(read_record3+start,key,length) == 0) ant++;
  331.   if (ant != dupp_keys)
  332.   {
  333.     printf("prev: I can only find: %d records of %dn",ant,dupp_keys);
  334.     goto end;
  335.   }
  337.   printf("- All keys: first - next -> last - prev -> firstn");
  338.   DBUG_PRINT("progpos",("All keys: first - next -> last - prev -> first"));
  339.   ant=1;
  340.   if (nisam_rfirst(file,read_record,0))
  341.   {
  342.     printf("Can't find first recordn");
  343.     goto end;
  344.   }
  345.   while (nisam_rnext(file,read_record3,0) == 0 && ant < write_count+10)
  346.     ant++;
  347.   if (ant != write_count - opt_delete)
  348.   {
  349.     printf("next: I found: %d records of %dn",ant,write_count - opt_delete);
  350.     goto end;
  351.   }
  352.   if (nisam_rlast(file,read_record2,0) ||
  353.       bcmp(read_record2,read_record3,reclength))
  354.   {
  355.     printf("Can't find last recordn");
  356.     DBUG_DUMP("record2",(byte*) read_record2,reclength);
  357.     DBUG_DUMP("record3",(byte*) read_record3,reclength);
  358.     goto end;
  359.   }
  360.   ant=1;
  361.   while (nisam_rprev(file,read_record3,0) == 0 && ant < write_count+10)
  362.     ant++;
  363.   if (ant != write_count - opt_delete)
  364.   {
  365.     printf("prev: I found: %d records of %dn",ant,write_count);
  366.     goto end;
  367.   }
  368.   if (bcmp(read_record,read_record3,reclength))
  369.   {
  370.     printf("Can't find first recordn");
  371.     goto end;
  372.   }
  374.   printf("- Test if: Read first - next - prev - prev - next == firstn");
  375.   DBUG_PRINT("progpos",("- Read first - next - prev - prev - next == first"));
  376.   if (nisam_rfirst(file,read_record,0) ||
  377.       nisam_rnext(file,read_record3,0) ||
  378.       nisam_rprev(file,read_record3,0) ||
  379.       nisam_rprev(file,read_record3,0) == 0 ||
  380.       nisam_rnext(file,read_record3,0))
  381.       goto err;
  382.   if (bcmp(read_record,read_record3,reclength) != 0)
  383.      printf("Can't find first recordn");
  385.   printf("- Test if: Read last - prev - next - next - prev == lastn");
  386.   DBUG_PRINT("progpos",("Read last - prev - next - next - prev == last"));
  387.   if (nisam_rlast(file,read_record2,0) ||
  388.       nisam_rprev(file,read_record3,0) ||
  389.       nisam_rnext(file,read_record3,0) ||
  390.       nisam_rnext(file,read_record3,0) == 0 ||
  391.       nisam_rprev(file,read_record3,0))
  392.       goto err;
  393.   if (bcmp(read_record2,read_record3,reclength))
  394.      printf("Can't find last recordn");
  396.   puts("- Test read key-part");
  397.   strmov(key2,key);
  398.   for(i=strlen(key2) ; i-- > 1 ;)
  399.   {
  400.     key2[i]=0;
  401.     if (nisam_rkey(file,read_record,0,key2,(uint) i,HA_READ_KEY_EXACT)) goto err;
  402.     if (bcmp(read_record+start,key,(uint) i))
  403.     {
  404.       puts("Didn't find right record");
  405.       goto end;
  406.     }
  407.   }
  408.   if (dupp_keys > 2)
  409.   {
  410.     printf("- Read key (first) - next - delete - next -> lastn");
  411.     DBUG_PRINT("progpos",("first - next - delete - next -> last"));
  412.     if (nisam_rkey(file,read_record,0,key,0,HA_READ_KEY_EXACT)) goto err;
  413.     if (nisam_rnext(file,read_record3,0)) goto err;
  414.     if (nisam_delete(file,read_record3)) goto err;
  415.     opt_delete++;
  416.     ant=1;
  417.     while (nisam_rnext(file,read_record3,0) == 0 &&
  418.    bcmp(read_record3+start,key,length) == 0) ant++;
  419.     if (ant != dupp_keys-1)
  420.     {
  421.       printf("next: I can only find: %d keys of %dn",ant,dupp_keys-1);
  422.       goto end;
  423.     }
  424.   }
  425.   if (dupp_keys>4)
  426.   {
  427.     printf("- Read last of key - prev - delete - prev -> firstn");
  428.     DBUG_PRINT("progpos",("last - prev - delete - prev -> first"));
  429.     if (nisam_rprev(file,read_record3,0)) goto err;
  430.     if (nisam_rprev(file,read_record3,0)) goto err;
  431.     if (nisam_delete(file,read_record3)) goto err;
  432.     opt_delete++;
  433.     ant=1;
  434.     while (nisam_rprev(file,read_record3,0) == 0 &&
  435.    bcmp(read_record3+start,key,length) == 0) ant++;
  436.     if (ant != dupp_keys-2)
  437.     {
  438.       printf("next: I can only find: %d keys of %dn",ant,dupp_keys-2);
  439.       goto end;
  440.     }
  441.   }
  442.   if (dupp_keys > 6)
  443.   {
  444.     printf("- Read first - delete - next -> lastn");
  445.     DBUG_PRINT("progpos",("first - delete - next -> last"));
  446.     if (nisam_rkey(file,read_record3,0,key,0,HA_READ_KEY_EXACT)) goto err;
  447.     if (nisam_delete(file,read_record3)) goto err;
  448.     opt_delete++;
  449.     ant=1;
  450.     if (nisam_rnext(file,read_record,0))
  451.       goto err; /* Skall finnas poster */
  452.     while (nisam_rnext(file,read_record3,0) == 0 &&
  453.    bcmp(read_record3+start,key,length) == 0) ant++;
  454.     if (ant != dupp_keys-3)
  455.     {
  456.       printf("next: I can only find: %d keys of %dn",ant,dupp_keys-3);
  457.       goto end;
  458.     }
  460.     printf("- Read last - delete - prev -> firstn");
  461.     DBUG_PRINT("progpos",("last - delete - prev -> first"));
  462.     if (nisam_rprev(file,read_record3,0)) goto err;
  463.     if (nisam_delete(file,read_record3)) goto err;
  464.     opt_delete++;
  465.     ant=0;
  466.     while (nisam_rprev(file,read_record3,0) == 0 &&
  467.    bcmp(read_record3+start,key,length) == 0) ant++;
  468.     if (ant != dupp_keys-4)
  469.     {
  470.       printf("next: I can only find: %d keys of %dn",ant,dupp_keys-4);
  471.       goto end;
  472.     }
  473.   }
  475.   puts("- Test if: Read rrnd - same");
  476.   DBUG_PRINT("progpos",("Read rrnd - same"));
  477.   for (i=0 ; i < write_count ; i++)
  478.   {
  479.     if (nisam_rrnd(file,read_record,i == 0 ? 0L : NI_POS_ERROR) == 0)
  480.       break;
  481.   }
  482.   if (i == write_count)
  483.     goto err;
  485.   bmove(read_record2,read_record,reclength);
  486.   for (i=2 ; i-- > 0 ;)
  487.   {
  488.     if (nisam_rsame(file,read_record2,(int) i)) goto err;
  489.     if (bcmp(read_record,read_record2,reclength) != 0)
  490.     {
  491.       printf("is_rsame didn't find same recordn");
  492.       goto end;
  493.     }
  494.   }
  495.   puts("- Test nisam_records_in_range");
  496.   nisam_info(file,&info,HA_STATUS_VARIABLE);
  497.   for (i=0 ; i < info.keys ; i++)
  498.   {
  499.     if (nisam_rfirst(file,read_record,(int) i) ||
  500. nisam_rlast(file,read_record2,(int) i))
  501.       goto err;
  502.     copy_key(file,(uint) i,(uchar*) read_record,(uchar*) key);
  503.     copy_key(file,(uint) i,(uchar*) read_record2,(uchar*) key2);
  504.     range_records=nisam_records_in_range(file,(int) i,key,0,HA_READ_KEY_EXACT,
  505.       key2,0,HA_READ_AFTER_KEY);
  506.     if (range_records < info.records*8/10 ||
  507. range_records > info.records*12/10)
  508.     {
  509.       printf("ni_records_range returned %lu; Should be about %lun",
  510.      range_records,info.records);
  511.       goto end;
  512.     }
  513.     if (verbose)
  514.     {
  515.       printf("ni_records_range returned %ld;  Exact is %ld  (diff: %4.2g %%)n",
  516.      range_records,info.records,
  517.      labs((long) range_records - (long) info.records)*100.0/
  518.      info.records);
  520.     }
  521.   }
  522.   for (i=0 ; i < 5 ; i++)
  523.   {
  524.     for (j=rnd(1000) ; j>0 && key1[j] == 0 ; j--) ;
  525.     for (k=rnd(1000) ; k>0 && key1[k] == 0 ; k--) ;
  526.     if (j != 0 && k != 0)
  527.     {
  528.       if (j > k)
  529. swap_variables(int, j, k);
  530.       sprintf(key,"%6d",j);
  531.       sprintf(key2,"%6d",k);
  532.       range_records=nisam_records_in_range(file,0,key,0,HA_READ_AFTER_KEY,
  533. key2,0,HA_READ_BEFORE_KEY);
  534.       records=0;
  535.       for (j++ ; j < k ; j++)
  536. records+=key1[j];
  537.       if ((long) range_records < (long) records*7/10-2 ||
  538.   (long) range_records > (long) records*13/10+2)
  539.       {
  540. printf("ni_records_range returned %ld; Should be about %ldn",
  541.        range_records,records);
  542. goto end;
  543.       }
  544.       if (verbose && records)
  545.       {
  546. printf("ni_records_range returned %ld;  Exact is %ld  (diff: %4.2g %%)n",
  547.        range_records,records,
  548.        labs((long) range_records-(long) records)*100.0/records);
  550.       }
  551.     }
  552.     }
  554.   printf("- nisam_infon");
  555.   nisam_info(file,&info,0);
  556.   if (info.records != write_count-opt_delete || info.deleted > opt_delete + update
  557.       || info.keys != keys)
  558.   {
  559.     puts("Wrong info from nisam_info");
  560.     printf("Got: records: %ld  opt_delete: %ld  i_keys: %dn",
  561.    info.records,info.deleted,info.keys);
  562.   }
  563.   if (verbose)
  564.   {
  565.     char buff[80];
  566.     get_date(buff,3,info.create_time);
  567.     printf("info: Created %sn",buff);
  568.     get_date(buff,3,info.isamchk_time);
  569.     printf("info: checked %sn",buff);
  570.     get_date(buff,3,info.update_time);
  571.     printf("info: Modified %sn",buff);
  572.   }
  574.   nisam_panic(HA_PANIC_WRITE);
  575.   nisam_panic(HA_PANIC_READ);
  576.   if (nisam_is_changed(file))
  577.     puts("Warning: nisam_is_changed reported that datafile was changed");
  579.   printf("- nisam_extra(CACHE) + nisam_rrnd.... + nisam_extra(NO_CACHE)n");
  580.   if (nisam_extra(file,HA_EXTRA_RESET) || nisam_extra(file,HA_EXTRA_CACHE))
  581.   {
  582.     if (locking || (!use_blob && !pack_fields))
  583.     {
  584.       puts("got error from nisam_extra(HA_EXTRA_CACHE)");
  585.       goto end;
  586.     }
  587.   }
  588.   ant=0;
  589.   while ((error=nisam_rrnd(file,record,NI_POS_ERROR)) >= 0 &&
  590.  ant < write_count + 10)
  591. ant+= error ? 0 : 1;
  592.   if (ant != write_count-opt_delete)
  593.   {
  594.     printf("rrnd with cache: I can only find: %d records of %dn",
  595.    ant,write_count-opt_delete);
  596.     goto end;
  597.   }
  598.   if (nisam_extra(file,HA_EXTRA_NO_CACHE))
  599.   {
  600.     puts("got error from nisam_extra(HA_EXTRA_NO_CACHE)");
  601.     goto end;
  602.   }
  604.   if (testflag == 4) goto end;
  606.   printf("- Removing keysn");
  607.   lastpos = NI_POS_ERROR;
  608.   /* DBUG_POP(); */
  609.   nisam_extra(file,HA_EXTRA_RESET);
  610.   while ((error=nisam_rrnd(file,read_record,NI_POS_ERROR)) >=0)
  611.   {
  612.     nisam_info(file,&info,1);
  613.     if (lastpos >= info.recpos && lastpos != NI_POS_ERROR)
  614.     {
  615.       printf("nisam_rrnd didn't advance filepointer; old: %ld, new: %ldn",
  616.      lastpos,info.recpos);
  617.       goto err;
  618.     }
  619.     lastpos=info.recpos;
  620.     if (error == 0)
  621.     {
  622.       if (nisam_rsame(file,read_record,-1))
  623.       {
  624. printf("can't find record %lxn",info.recpos);
  625. goto err;
  626.       }
  627.       if (use_blob)
  628.       {
  629. ulong blob_length,pos;
  630. uchar *ptr;
  631. longget(blob_length,read_record+blob_pos+4);
  632. ptr=(uchar*) blob_length;
  633. longget(blob_length,read_record+blob_pos);
  634. for (pos=0 ; pos < blob_length ; pos++)
  635. {
  636.   if (ptr[pos] != (uchar) (blob_length+pos))
  637.   {
  638.     printf("found blob with wrong info at %ldn",lastpos);
  639.     use_blob=0;
  640.     break;
  641.   }
  642. }
  643.       }
  644.       if (nisam_delete(file,read_record))
  645.       {
  646. printf("can't delete record: %sn",read_record);
  647. goto err;
  648.       }
  649.       opt_delete++;
  650.     }
  651.   }
  652.   if (my_errno != HA_ERR_END_OF_FILE && my_errno != HA_ERR_RECORD_DELETED)
  653.     printf("error: %d from nisam_rrndn",my_errno);
  654.   if (write_count != opt_delete)
  655.   {
  656.     printf("Deleted only %d of %d recordsn",write_count,opt_delete);
  657.     goto err;
  658.   }
  659. end:
  660.   if (nisam_close(file))
  661.     goto err;
  662.   nisam_panic(HA_PANIC_CLOSE); /* Should close log */
  663.   printf("nFollowing test have been made:n");
  664.   printf("Write records: %dnUpdate records: %dnSame-key-read: %dnDelete records: %dn", write_count,update,dupp_keys,opt_delete);
  665.   if (rec_pointer_size)
  666.     printf("Record pointer size: %dn",rec_pointer_size);
  667.   if (key_cacheing)
  668.     puts("Key cacheing used");
  669.   if (write_cacheing)
  670.     puts("Write cacheing used");
  671.   if (async_io && locking)
  672.     puts("Asyncron io with locking used");
  673.   else if (locking)
  674.     puts("Locking used");
  675.   if (use_blob)
  676.     puts("blobs used");
  677.   end_key_cache(dflt_key_cache,1);
  678.   if (blob_buffer)
  679.     my_free(blob_buffer,MYF(0));
  680.   my_end(MY_CHECK_ERROR | MY_GIVE_INFO);
  681.   return(0);
  682. err:
  683.   printf("got error: %d when using NISAM-databasen",my_errno);
  684.   if (file)
  685.     VOID(nisam_close(file));
  686.   return(1);
  687. } /* main */
  690. /* l{ser optioner */
  691. /* OBS! intierar endast DEBUG - ingen debuggning h{r ! */
  693. static void get_options( int argc, char *argv[])
  694. {
  695.   char *pos,*progname;
  696.   DEBUGGER_OFF;
  698.   progname= argv[0];
  700.   while (--argc >0 && *(pos = *(++argv)) == '-' ) {
  701.     switch(*++pos) {
  702.     case 'b':
  703.       if (*++pos)
  704. nisam_block_size= MY_ALIGN(atoi(pos),512);
  705.       set_if_bigger(nisam_block_size,8192); /* Max block size */
  706.       set_if_smaller(nisam_block_size,1024);
  707.       break;
  708.     case 'B':
  709.       use_blob=1;
  710.       break;
  711.     case 'K': /* Use key cacheing */
  712.       key_cacheing=1;
  713.       break;
  714.     case 'W': /* Use write cacheing */
  715.       write_cacheing=1;
  716.       if (*++pos)
  717. my_default_record_cache_size=atoi(pos);
  718.       break;
  719.     case 'i':
  720.       if (*++pos)
  721. srand(atoi(pos));
  722.       break;
  723.     case 'l':
  724.       use_log=1;
  725.       break;
  726.     case 'L':
  727.       locking=1;
  728.       break;
  729.     case 'A': /* use asyncron io */
  730.       async_io=1;
  731.       if (*++pos)
  732. my_default_record_cache_size=atoi(pos);
  733.       break;
  734.     case 'v': /* verbose */
  735.       verbose=1;
  736.       break;
  737.     case 'm': /* records */
  738.       recant=atoi(++pos);
  739.       break;
  740.     case 'f':
  741.       if ((first_key=atoi(++pos)) <0 || first_key >= NISAM_KEYS)
  742. first_key=0;
  743.       break;
  744.     case 'k':
  745.       if ((keys=(uint) atoi(++pos)) < 1 ||
  746.    keys > (uint) (NISAM_KEYS-first_key))
  747. keys=NISAM_KEYS-first_key;
  748.       break;
  749.     case 'P':
  750.       pack_type=0; /* Don't use DIFF_LENGTH */
  751.       break;
  752.     case 'R': /* Length of record pointer */
  753.       rec_pointer_size=atoi(++pos);
  754.       if (rec_pointer_size > 3)
  755. rec_pointer_size=0;
  756.       break;
  757.     case 'S':
  758.       pack_fields=0; /* Static-length-records */
  759.       break;
  760.     case 't':
  761.       testflag=atoi(++pos); /* testmod */
  762.       break;
  763.     case '?':
  764.     case 'I':
  765.     case 'V':
  766.       printf("%s  Ver 1.4 for %s at %sn",progname,SYSTEM_TYPE,MACHINE_TYPE);
  767.       puts("TCX Datakonsult AB, by Monty, for your professional usen");
  768.       printf("Usage: %s [-?ABIKLPRSVWltv] [-b#] [-k#] [-f#] [-m#] [-t#]n",progname);
  769.       exit(0);
  770.     case '#':
  771.       DEBUGGER_ON;
  772.       DBUG_PUSH (++pos);
  773.       break;
  774.     default:
  775.       printf("Illegal option: '%c'n",*pos);
  776.       break;
  777.     }
  778.   }
  779.   return;
  780. } /* get options */
  782. /* Ge ett randomv{rde inom ett intervall 0 <=x <= n */
  784. static uint rnd( uint max_value)
  785. {
  786.   return (uint) ((rand() & 32767)/32767.0*max_value);
  787. } /* rnd */
  790. /* G|r en record av skiftande length */
  792. static void fix_length( byte *rec, uint length)
  793. {
  794.   bmove(rec+STANDAR_LENGTH,
  795. "0123456789012345678901234567890123456789012345678901234567890",
  796. length-STANDAR_LENGTH);
  797.   strfill(rec+length,STANDAR_LENGTH+60-length,' ');
  798. } /* fix_length */
  801. /* Put maybe a blob in record */
  803. static void put_blob_in_record(char *blob_pos, char **blob_buffer)
  804. {
  805.   ulong i,length;
  806.   if (use_blob)
  807.   {
  808.     if (rnd(10) == 0)
  809.     {
  810.       if (! *blob_buffer &&
  811.   !(*blob_buffer=my_malloc((uint) use_blob,MYF(MY_WME))))
  812.       {
  813. use_blob=0;
  814. return;
  815.       }
  816.       length=rnd(use_blob);
  817.       for (i=0 ; i < length ; i++)
  818. (*blob_buffer)[i]=(char) (length+i);
  819.       longstore(blob_pos,length);
  820.       bmove(blob_pos+4,(char*) blob_buffer,sizeof(char*));
  821.     }
  822.     else
  823.     {
  824.       longstore(blob_pos,0);
  825.     }
  826.   }
  827.   return;
  828. }
  831. static void copy_key( N_INFO *info, uint inx, uchar *rec, uchar *key_buff)
  832. {
  833.   N_KEYSEG *keyseg;
  835.   for (keyseg=info->s->keyinfo[inx].seg ; keyseg->base.type ; keyseg++)
  836.   {
  837.     memcpy(key_buff,rec+keyseg->base.start,(size_t) keyseg->base.length);
  838.     key_buff+=keyseg->base.length;
  839.   }
  840.   return;
  841. }