db-btree.t
上传用户:tsgydb
上传日期:2007-04-14
资源大小:10674k
文件大小:28k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. #!./perl -w
  2. use warnings;
  3. use strict;
  4. BEGIN {
  5.     unless(grep /blib/, @INC) {
  6.         chdir 't' if -d 't';
  7.         @INC = '../lib' if -d '../lib';
  8.     }
  9. }
  10.  
  11. use Config;
  12.  
  13. BEGIN {
  14.     if(-d "lib" && -f "TEST") {
  15.         if ($Config{'extensions'} !~ /bDB_Fileb/ ) {
  16.             print "1..157n";
  17.             exit 0;
  18.         }
  19.     }
  20. }
  21. use DB_File; 
  22. use Fcntl;
  23. print "1..157n";
  24. sub ok
  25. {
  26.     my $no = shift ;
  27.     my $result = shift ;
  28.  
  29.     print "not " unless $result ;
  30.     print "ok $non" ;
  31. }
  32. sub lexical
  33. {
  34.     my(@a) = unpack ("C*", $a) ;
  35.     my(@b) = unpack ("C*", $b) ;
  36.     my $len = (@a > @b ? @b : @a) ;
  37.     my $i = 0 ;
  38.     foreach $i ( 0 .. $len -1) {
  39.         return $a[$i] - $b[$i] if $a[$i] != $b[$i] ;
  40.     }
  41.     return @a - @b ;
  42. }
  43. {
  44.     package Redirect ;
  45.     use Symbol ;
  46.     sub new
  47.     {
  48.         my $class = shift ;
  49.         my $filename = shift ;
  50. my $fh = gensym ;
  51. open ($fh, ">$filename") || die "Cannot open $filename: $!" ;
  52. my $real_stdout = select($fh) ;
  53. return bless [$fh, $real_stdout ] ;
  54.     }
  55.     sub DESTROY
  56.     {
  57.         my $self = shift ;
  58. close $self->[0] ;
  59. select($self->[1]) ;
  60.     }
  61. }
  62. sub docat
  63.     my $file = shift;
  64.     #local $/ = undef unless wantarray ;
  65.     open(CAT,$file) || die "Cannot open $file: $!";
  66.     my @result = <CAT>;
  67.     close(CAT);
  68.     wantarray ? @result : join("", @result) ;
  69. }   
  70. sub docat_del
  71.     my $file = shift;
  72.     #local $/ = undef unless wantarray ;
  73.     open(CAT,$file) || die "Cannot open $file: $!";
  74.     my @result = <CAT>;
  75.     close(CAT);
  76.     unlink $file ;
  77.     wantarray ? @result : join("", @result) ;
  78. }   
  79. my $db185mode =  ($DB_File::db_version == 1 && ! $DB_File::db_185_compat) ;
  80. my $null_keys_allowed = ($DB_File::db_ver < 2.004010 
  81. || $DB_File::db_ver >= 3.1 );
  82. my $Dfile = "dbbtree.tmp";
  83. unlink $Dfile;
  84. umask(0);
  85. # Check the interface to BTREEINFO
  86. my $dbh = new DB_File::BTREEINFO ;
  87. ok(1, ! defined $dbh->{flags}) ;
  88. ok(2, ! defined $dbh->{cachesize}) ;
  89. ok(3, ! defined $dbh->{psize}) ;
  90. ok(4, ! defined $dbh->{lorder}) ;
  91. ok(5, ! defined $dbh->{minkeypage}) ;
  92. ok(6, ! defined $dbh->{maxkeypage}) ;
  93. ok(7, ! defined $dbh->{compare}) ;
  94. ok(8, ! defined $dbh->{prefix}) ;
  95. $dbh->{flags} = 3000 ;
  96. ok(9, $dbh->{flags} == 3000) ;
  97. $dbh->{cachesize} = 9000 ;
  98. ok(10, $dbh->{cachesize} == 9000);
  99. $dbh->{psize} = 400 ;
  100. ok(11, $dbh->{psize} == 400) ;
  101. $dbh->{lorder} = 65 ;
  102. ok(12, $dbh->{lorder} == 65) ;
  103. $dbh->{minkeypage} = 123 ;
  104. ok(13, $dbh->{minkeypage} == 123) ;
  105. $dbh->{maxkeypage} = 1234 ;
  106. ok(14, $dbh->{maxkeypage} == 1234 );
  107. $dbh->{compare} = 1234 ;
  108. ok(15, $dbh->{compare} == 1234) ;
  109. $dbh->{prefix} = 1234 ;
  110. ok(16, $dbh->{prefix} == 1234 );
  111. # Check that an invalid entry is caught both for store & fetch
  112. eval '$dbh->{fred} = 1234' ;
  113. ok(17, $@ =~ /^DB_File::BTREEINFO::STORE - Unknown element 'fred' at/ ) ;
  114. eval 'my $q = $dbh->{fred}' ;
  115. ok(18, $@ =~ /^DB_File::BTREEINFO::FETCH - Unknown element 'fred' at/ ) ;
  116. # Now check the interface to BTREE
  117. my ($X, %h) ;
  118. ok(19, $X = tie(%h, 'DB_File',$Dfile, O_RDWR|O_CREAT, 0640, $DB_BTREE )) ;
  119. my ($dev,$ino,$mode,$nlink,$uid,$gid,$rdev,$size,$atime,$mtime,$ctime,
  120.    $blksize,$blocks) = stat($Dfile);
  121. ok(20, ($mode & 0777) == ($^O eq 'os2' ? 0666 : 0640) || $^O eq 'amigaos' || $^O eq 'MSWin32');
  122. my ($key, $value, $i);
  123. while (($key,$value) = each(%h)) {
  124.     $i++;
  125. }
  126. ok(21, !$i ) ;
  127. $h{'goner1'} = 'snork';
  128. $h{'abc'} = 'ABC';
  129. ok(22, $h{'abc'} eq 'ABC' );
  130. ok(23, ! defined $h{'jimmy'} ) ;
  131. ok(24, ! exists $h{'jimmy'} ) ;
  132. ok(25,  defined $h{'abc'} ) ;
  133. $h{'def'} = 'DEF';
  134. $h{'jkl','mno'} = "JKL34MNO";
  135. $h{'a',2,3,4,5} = join("34",'A',2,3,4,5);
  136. $h{'a'} = 'A';
  137. #$h{'b'} = 'B';
  138. $X->STORE('b', 'B') ;
  139. $h{'c'} = 'C';
  140. #$h{'d'} = 'D';
  141. $X->put('d', 'D') ;
  142. $h{'e'} = 'E';
  143. $h{'f'} = 'F';
  144. $h{'g'} = 'X';
  145. $h{'h'} = 'H';
  146. $h{'i'} = 'I';
  147. $h{'goner2'} = 'snork';
  148. delete $h{'goner2'};
  149. # IMPORTANT - $X must be undefined before the untie otherwise the
  150. #             underlying DB close routine will not get called.
  151. undef $X ;
  152. untie(%h);
  153. # tie to the same file again
  154. ok(26, $X = tie(%h,'DB_File',$Dfile, O_RDWR, 0640, $DB_BTREE)) ;
  155. # Modify an entry from the previous tie
  156. $h{'g'} = 'G';
  157. $h{'j'} = 'J';
  158. $h{'k'} = 'K';
  159. $h{'l'} = 'L';
  160. $h{'m'} = 'M';
  161. $h{'n'} = 'N';
  162. $h{'o'} = 'O';
  163. $h{'p'} = 'P';
  164. $h{'q'} = 'Q';
  165. $h{'r'} = 'R';
  166. $h{'s'} = 'S';
  167. $h{'t'} = 'T';
  168. $h{'u'} = 'U';
  169. $h{'v'} = 'V';
  170. $h{'w'} = 'W';
  171. $h{'x'} = 'X';
  172. $h{'y'} = 'Y';
  173. $h{'z'} = 'Z';
  174. $h{'goner3'} = 'snork';
  175. delete $h{'goner1'};
  176. $X->DELETE('goner3');
  177. my @keys = keys(%h);
  178. my @values = values(%h);
  179. ok(27, $#keys == 29 && $#values == 29) ;
  180. $i = 0 ;
  181. while (($key,$value) = each(%h)) {
  182.     if ($key eq $keys[$i] && $value eq $values[$i] && $key eq lc($value)) {
  183. $key =~ y/a-z/A-Z/;
  184. $i++ if $key eq $value;
  185.     }
  186. }
  187. ok(28, $i == 30) ;
  188. @keys = ('blurfl', keys(%h), 'dyick');
  189. ok(29, $#keys == 31) ;
  190. #Check that the keys can be retrieved in order
  191. my @b = keys %h ;
  192. my @c = sort lexical @b ;
  193. ok(30, ArrayCompare(@b, @c)) ;
  194. $h{'foo'} = '';
  195. ok(31, $h{'foo'} eq '' ) ;
  196. # Berkeley DB from version 2.4.10 to 3.0 does not allow null keys.
  197. # This feature was reenabled in version 3.1 of Berkeley DB.
  198. my $result = 0 ;
  199. if ($null_keys_allowed) {
  200.     $h{''} = 'bar';
  201.     $result = ( $h{''} eq 'bar' );
  202. }
  203. else
  204.   { $result = 1 }
  205. ok(32, $result) ;
  206. # check cache overflow and numeric keys and contents
  207. my $ok = 1;
  208. for ($i = 1; $i < 200; $i++) { $h{$i + 0} = $i + 0; }
  209. for ($i = 1; $i < 200; $i++) { $ok = 0 unless $h{$i} == $i; }
  210. ok(33, $ok);
  211. ($dev,$ino,$mode,$nlink,$uid,$gid,$rdev,$size,$atime,$mtime,$ctime,
  212.    $blksize,$blocks) = stat($Dfile);
  213. ok(34, $size > 0 );
  214. @h{0..200} = 200..400;
  215. my @foo = @h{0..200};
  216. ok(35, join(':',200..400) eq join(':',@foo) );
  217. # Now check all the non-tie specific stuff
  218. # Check R_NOOVERWRITE flag will make put fail when attempting to overwrite
  219. # an existing record.
  220.  
  221. my $status = $X->put( 'x', 'newvalue', R_NOOVERWRITE) ;
  222. ok(36, $status == 1 );
  223.  
  224. # check that the value of the key 'x' has not been changed by the 
  225. # previous test
  226. ok(37, $h{'x'} eq 'X' );
  227. # standard put
  228. $status = $X->put('key', 'value') ;
  229. ok(38, $status == 0 );
  230. #check that previous put can be retrieved
  231. $value = 0 ;
  232. $status = $X->get('key', $value) ;
  233. ok(39, $status == 0 );
  234. ok(40, $value eq 'value' );
  235. # Attempting to delete an existing key should work
  236. $status = $X->del('q') ;
  237. ok(41, $status == 0 );
  238. if ($null_keys_allowed) {
  239.     $status = $X->del('') ;
  240. } else {
  241.     $status = 0 ;
  242. }
  243. ok(42, $status == 0 );
  244. # Make sure that the key deleted, cannot be retrieved
  245. ok(43, ! defined $h{'q'}) ;
  246. ok(44, ! defined $h{''}) ;
  247. undef $X ;
  248. untie %h ;
  249. ok(45, $X = tie(%h, 'DB_File',$Dfile, O_RDWR, 0640, $DB_BTREE ));
  250. # Attempting to delete a non-existant key should fail
  251. $status = $X->del('joe') ;
  252. ok(46, $status == 1 );
  253. # Check the get interface
  254. # First a non-existing key
  255. $status = $X->get('aaaa', $value) ;
  256. ok(47, $status == 1 );
  257. # Next an existing key
  258. $status = $X->get('a', $value) ;
  259. ok(48, $status == 0 );
  260. ok(49, $value eq 'A' );
  261. # seq
  262. # ###
  263. # use seq to find an approximate match
  264. $key = 'ke' ;
  265. $value = '' ;
  266. $status = $X->seq($key, $value, R_CURSOR) ;
  267. ok(50, $status == 0 );
  268. ok(51, $key eq 'key' );
  269. ok(52, $value eq 'value' );
  270. # seq when the key does not match
  271. $key = 'zzz' ;
  272. $value = '' ;
  273. $status = $X->seq($key, $value, R_CURSOR) ;
  274. ok(53, $status == 1 );
  275. # use seq to set the cursor, then delete the record @ the cursor.
  276. $key = 'x' ;
  277. $value = '' ;
  278. $status = $X->seq($key, $value, R_CURSOR) ;
  279. ok(54, $status == 0 );
  280. ok(55, $key eq 'x' );
  281. ok(56, $value eq 'X' );
  282. $status = $X->del(0, R_CURSOR) ;
  283. ok(57, $status == 0 );
  284. $status = $X->get('x', $value) ;
  285. ok(58, $status == 1 );
  286. # ditto, but use put to replace the key/value pair.
  287. $key = 'y' ;
  288. $value = '' ;
  289. $status = $X->seq($key, $value, R_CURSOR) ;
  290. ok(59, $status == 0 );
  291. ok(60, $key eq 'y' );
  292. ok(61, $value eq 'Y' );
  293. $key = "replace key" ;
  294. $value = "replace value" ;
  295. $status = $X->put($key, $value, R_CURSOR) ;
  296. ok(62, $status == 0 );
  297. ok(63, $key eq 'replace key' );
  298. ok(64, $value eq 'replace value' );
  299. $status = $X->get('y', $value) ;
  300. ok(65, 1) ; # hard-wire to always pass. the previous test ($status == 1)
  301.     # only worked because of a bug in 1.85/6
  302. # use seq to walk forwards through a file 
  303. $status = $X->seq($key, $value, R_FIRST) ;
  304. ok(66, $status == 0 );
  305. my $previous = $key ;
  306. $ok = 1 ;
  307. while (($status = $X->seq($key, $value, R_NEXT)) == 0)
  308. {
  309.     ($ok = 0), last if ($previous cmp $key) == 1 ;
  310. }
  311. ok(67, $status == 1 );
  312. ok(68, $ok == 1 );
  313. # use seq to walk backwards through a file 
  314. $status = $X->seq($key, $value, R_LAST) ;
  315. ok(69, $status == 0 );
  316. $previous = $key ;
  317. $ok = 1 ;
  318. while (($status = $X->seq($key, $value, R_PREV)) == 0)
  319. {
  320.     ($ok = 0), last if ($previous cmp $key) == -1 ;
  321.     #print "key = [$key] value = [$value]n" ;
  322. }
  323. ok(70, $status == 1 );
  324. ok(71, $ok == 1 );
  325. # check seq FIRST/LAST
  326. # sync
  327. # ####
  328. $status = $X->sync ;
  329. ok(72, $status == 0 );
  330. # fd
  331. # ##
  332. $status = $X->fd ;
  333. ok(73, $status != 0 );
  334. undef $X ;
  335. untie %h ;
  336. unlink $Dfile;
  337. # Now try an in memory file
  338. my $Y;
  339. ok(74, $Y = tie(%h, 'DB_File',undef, O_RDWR|O_CREAT, 0640, $DB_BTREE ));
  340. # fd with an in memory file should return failure
  341. $status = $Y->fd ;
  342. ok(75, $status == -1 );
  343. undef $Y ;
  344. untie %h ;
  345. # Duplicate keys
  346. my $bt = new DB_File::BTREEINFO ;
  347. $bt->{flags} = R_DUP ;
  348. my ($YY, %hh);
  349. ok(76, $YY = tie(%hh, 'DB_File', $Dfile, O_RDWR|O_CREAT, 0640, $bt )) ;
  350. $hh{'Wall'} = 'Larry' ;
  351. $hh{'Wall'} = 'Stone' ; # Note the duplicate key
  352. $hh{'Wall'} = 'Brick' ; # Note the duplicate key
  353. $hh{'Wall'} = 'Brick' ; # Note the duplicate key and value
  354. $hh{'Smith'} = 'John' ;
  355. $hh{'mouse'} = 'mickey' ;
  356. # first work in scalar context
  357. ok(77, scalar $YY->get_dup('Unknown') == 0 );
  358. ok(78, scalar $YY->get_dup('Smith') == 1 );
  359. ok(79, scalar $YY->get_dup('Wall') == 4 );
  360. # now in list context
  361. my @unknown = $YY->get_dup('Unknown') ;
  362. ok(80, "@unknown" eq "" );
  363. my @smith = $YY->get_dup('Smith') ;
  364. ok(81, "@smith" eq "John" );
  365. {
  366. my @wall = $YY->get_dup('Wall') ;
  367. my %wall ;
  368. @wall{@wall} = @wall ;
  369. ok(82, (@wall == 4 && $wall{'Larry'} && $wall{'Stone'} && $wall{'Brick'}) );
  370. }
  371. # hash
  372. my %unknown = $YY->get_dup('Unknown', 1) ;
  373. ok(83, keys %unknown == 0 );
  374. my %smith = $YY->get_dup('Smith', 1) ;
  375. ok(84, keys %smith == 1 && $smith{'John'}) ;
  376. my %wall = $YY->get_dup('Wall', 1) ;
  377. ok(85, keys %wall == 3 && $wall{'Larry'} == 1 && $wall{'Stone'} == 1 
  378. && $wall{'Brick'} == 2);
  379. undef $YY ;
  380. untie %hh ;
  381. unlink $Dfile;
  382. # test multiple callbacks
  383. my $Dfile1 = "btree1" ;
  384. my $Dfile2 = "btree2" ;
  385. my $Dfile3 = "btree3" ;
  386.  
  387. my $dbh1 = new DB_File::BTREEINFO ;
  388. $dbh1->{compare} = sub { 
  389. no warnings 'numeric' ;
  390. $_[0] <=> $_[1] } ; 
  391.  
  392. my $dbh2 = new DB_File::BTREEINFO ;
  393. $dbh2->{compare} = sub { $_[0] cmp $_[1] } ;
  394.  
  395. my $dbh3 = new DB_File::BTREEINFO ;
  396. $dbh3->{compare} = sub { length $_[0] <=> length $_[1] } ;
  397.  
  398.  
  399. my (%g, %k);
  400. tie(%h, 'DB_File',$Dfile1, O_RDWR|O_CREAT, 0640, $dbh1 ) ; 
  401. tie(%g, 'DB_File',$Dfile2, O_RDWR|O_CREAT, 0640, $dbh2 ) ;
  402. tie(%k, 'DB_File',$Dfile3, O_RDWR|O_CREAT, 0640, $dbh3 ) ;
  403.  
  404. my @Keys = qw( 0123 12 -1234 9 987654321 def  ) ;
  405. my (@srt_1, @srt_2, @srt_3);
  406.   no warnings 'numeric' ;
  407.   @srt_1 = sort { $a <=> $b } @Keys ; 
  408. }
  409. @srt_2 = sort { $a cmp $b } @Keys ;
  410. @srt_3 = sort { length $a <=> length $b } @Keys ;
  411.  
  412. foreach (@Keys) {
  413.     $h{$_} = 1 ;
  414.     $g{$_} = 1 ;
  415.     $k{$_} = 1 ;
  416. }
  417.  
  418. sub ArrayCompare
  419. {
  420.     my($a, $b) = @_ ;
  421.  
  422.     return 0 if @$a != @$b ;
  423.  
  424.     foreach (1 .. length @$a)
  425.     {
  426.         return 0 unless $$a[$_] eq $$b[$_] ;
  427.     }
  428.  
  429.     1 ;
  430. }
  431.  
  432. ok(86, ArrayCompare (@srt_1, [keys %h]) );
  433. ok(87, ArrayCompare (@srt_2, [keys %g]) );
  434. ok(88, ArrayCompare (@srt_3, [keys %k]) );
  435. untie %h ;
  436. untie %g ;
  437. untie %k ;
  438. unlink $Dfile1, $Dfile2, $Dfile3 ;
  439. # clear
  440. # #####
  441. ok(89, tie(%h, 'DB_File', $Dfile1, O_RDWR|O_CREAT, 0640, $DB_BTREE ) );
  442. foreach (1 .. 10)
  443.   { $h{$_} = $_ * 100 }
  444. # check that there are 10 elements in the hash
  445. $i = 0 ;
  446. while (($key,$value) = each(%h)) {
  447.     $i++;
  448. }
  449. ok(90, $i == 10);
  450. # now clear the hash
  451. %h = () ;
  452. # check it is empty
  453. $i = 0 ;
  454. while (($key,$value) = each(%h)) {
  455.     $i++;
  456. }
  457. ok(91, $i == 0);
  458. untie %h ;
  459. unlink $Dfile1 ;
  460. {
  461.     # check that attempting to tie an array to a DB_BTREE will fail
  462.     my $filename = "xyz" ;
  463.     my @x ;
  464.     eval { tie @x, 'DB_File', $filename, O_RDWR|O_CREAT, 0640, $DB_BTREE ; } ;
  465.     ok(92, $@ =~ /^DB_File can only tie an associative array to a DB_BTREE database/) ;
  466.     unlink $filename ;
  467. }
  468. {
  469.    # sub-class test
  470.    package Another ;
  471.    use warnings ;
  472.    use strict ;
  473.    open(FILE, ">SubDB.pm") or die "Cannot open SubDB.pm: $!n" ;
  474.    print FILE <<'EOM' ;
  475.    package SubDB ;
  476.    use warnings ;
  477.    use strict ;
  478.    use vars qw( @ISA @EXPORT) ;
  479.    require Exporter ;
  480.    use DB_File;
  481.    @ISA=qw(DB_File);
  482.    @EXPORT = @DB_File::EXPORT ;
  483.    sub STORE { 
  484. my $self = shift ;
  485.         my $key = shift ;
  486.         my $value = shift ;
  487.         $self->SUPER::STORE($key, $value * 2) ;
  488.    }
  489.    sub FETCH { 
  490. my $self = shift ;
  491.         my $key = shift ;
  492.         $self->SUPER::FETCH($key) - 1 ;
  493.    }
  494.    sub put { 
  495. my $self = shift ;
  496.         my $key = shift ;
  497.         my $value = shift ;
  498.         $self->SUPER::put($key, $value * 3) ;
  499.    }
  500.    sub get { 
  501. my $self = shift ;
  502.         $self->SUPER::get($_[0], $_[1]) ;
  503. $_[1] -= 2 ;
  504.    }
  505.    sub A_new_method
  506.    {
  507. my $self = shift ;
  508.         my $key = shift ;
  509.         my $value = $self->FETCH($key) ;
  510. return "[[$value]]" ;
  511.    }
  512.    1 ;
  513. EOM
  514.     close FILE ;
  515.     BEGIN { push @INC, '.'; }    
  516.     eval 'use SubDB ; ';
  517.     main::ok(93, $@ eq "") ;
  518.     my %h ;
  519.     my $X ;
  520.     eval '
  521. $X = tie(%h, "SubDB","dbbtree.tmp", O_RDWR|O_CREAT, 0640, $DB_BTREE );
  522. ' ;
  523.     main::ok(94, $@ eq "") ;
  524.     my $ret = eval '$h{"fred"} = 3 ; return $h{"fred"} ' ;
  525.     main::ok(95, $@ eq "") ;
  526.     main::ok(96, $ret == 5) ;
  527.     my $value = 0;
  528.     $ret = eval '$X->put("joe", 4) ; $X->get("joe", $value) ; return $value' ;
  529.     main::ok(97, $@ eq "") ;
  530.     main::ok(98, $ret == 10) ;
  531.     $ret = eval ' R_NEXT eq main::R_NEXT ' ;
  532.     main::ok(99, $@ eq "" ) ;
  533.     main::ok(100, $ret == 1) ;
  534.     $ret = eval '$X->A_new_method("joe") ' ;
  535.     main::ok(101, $@ eq "") ;
  536.     main::ok(102, $ret eq "[[11]]") ;
  537.     undef $X;
  538.     untie(%h);
  539.     unlink "SubDB.pm", "dbbtree.tmp" ;
  540. }
  541. {
  542.    # DBM Filter tests
  543.    use warnings ;
  544.    use strict ;
  545.    my (%h, $db) ;
  546.    my ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  547.    unlink $Dfile;
  548.    sub checkOutput
  549.    {
  550.        my($fk, $sk, $fv, $sv) = @_ ;
  551.        return
  552.            $fetch_key eq $fk && $store_key eq $sk && 
  553.    $fetch_value eq $fv && $store_value eq $sv &&
  554.    $_ eq 'original' ;
  555.    }
  556.    
  557.    ok(103, $db = tie(%h, 'DB_File', $Dfile, O_RDWR|O_CREAT, 0640, $DB_BTREE ) );
  558.    $db->filter_fetch_key   (sub { $fetch_key = $_ }) ;
  559.    $db->filter_store_key   (sub { $store_key = $_ }) ;
  560.    $db->filter_fetch_value (sub { $fetch_value = $_}) ;
  561.    $db->filter_store_value (sub { $store_value = $_ }) ;
  562.    $_ = "original" ;
  563.    $h{"fred"} = "joe" ;
  564.    #                   fk   sk     fv   sv
  565.    ok(104, checkOutput( "", "fred", "", "joe")) ;
  566.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  567.    ok(105, $h{"fred"} eq "joe");
  568.    #                   fk    sk     fv    sv
  569.    ok(106, checkOutput( "", "fred", "joe", "")) ;
  570.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  571.    ok(107, $db->FIRSTKEY() eq "fred") ;
  572.    #                    fk     sk  fv  sv
  573.    ok(108, checkOutput( "fred", "", "", "")) ;
  574.    # replace the filters, but remember the previous set
  575.    my ($old_fk) = $db->filter_fetch_key   
  576.     (sub { $_ = uc $_ ; $fetch_key = $_ }) ;
  577.    my ($old_sk) = $db->filter_store_key   
  578.     (sub { $_ = lc $_ ; $store_key = $_ }) ;
  579.    my ($old_fv) = $db->filter_fetch_value 
  580.     (sub { $_ = "[$_]"; $fetch_value = $_ }) ;
  581.    my ($old_sv) = $db->filter_store_value 
  582.     (sub { s/o/x/g; $store_value = $_ }) ;
  583.    
  584.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  585.    $h{"Fred"} = "Joe" ;
  586.    #                   fk   sk     fv    sv
  587.    ok(109, checkOutput( "", "fred", "", "Jxe")) ;
  588.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  589.    ok(110, $h{"Fred"} eq "[Jxe]");
  590.    #                   fk   sk     fv    sv
  591.    ok(111, checkOutput( "", "fred", "[Jxe]", "")) ;
  592.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  593.    ok(112, $db->FIRSTKEY() eq "FRED") ;
  594.    #                   fk   sk     fv    sv
  595.    ok(113, checkOutput( "FRED", "", "", "")) ;
  596.    # put the original filters back
  597.    $db->filter_fetch_key   ($old_fk);
  598.    $db->filter_store_key   ($old_sk);
  599.    $db->filter_fetch_value ($old_fv);
  600.    $db->filter_store_value ($old_sv);
  601.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  602.    $h{"fred"} = "joe" ;
  603.    ok(114, checkOutput( "", "fred", "", "joe")) ;
  604.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  605.    ok(115, $h{"fred"} eq "joe");
  606.    ok(116, checkOutput( "", "fred", "joe", "")) ;
  607.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  608.    ok(117, $db->FIRSTKEY() eq "fred") ;
  609.    ok(118, checkOutput( "fred", "", "", "")) ;
  610.    # delete the filters
  611.    $db->filter_fetch_key   (undef);
  612.    $db->filter_store_key   (undef);
  613.    $db->filter_fetch_value (undef);
  614.    $db->filter_store_value (undef);
  615.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  616.    $h{"fred"} = "joe" ;
  617.    ok(119, checkOutput( "", "", "", "")) ;
  618.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  619.    ok(120, $h{"fred"} eq "joe");
  620.    ok(121, checkOutput( "", "", "", "")) ;
  621.    ($fetch_key, $store_key, $fetch_value, $store_value) = ("") x 4 ;
  622.    ok(122, $db->FIRSTKEY() eq "fred") ;
  623.    ok(123, checkOutput( "", "", "", "")) ;
  624.    undef $db ;
  625.    untie %h;
  626.    unlink $Dfile;
  627. }
  628. {    
  629.     # DBM Filter with a closure
  630.     use warnings ;
  631.     use strict ;
  632.     my (%h, $db) ;
  633.     unlink $Dfile;
  634.     ok(124, $db = tie(%h, 'DB_File', $Dfile, O_RDWR|O_CREAT, 0640, $DB_BTREE ) );
  635.     my %result = () ;
  636.     sub Closure
  637.     {
  638.         my ($name) = @_ ;
  639. my $count = 0 ;
  640. my @kept = () ;
  641. return sub { ++$count ; 
  642.      push @kept, $_ ; 
  643.      $result{$name} = "$name - $count: [@kept]" ;
  644.    }
  645.     }
  646.     $db->filter_store_key(Closure("store key")) ;
  647.     $db->filter_store_value(Closure("store value")) ;
  648.     $db->filter_fetch_key(Closure("fetch key")) ;
  649.     $db->filter_fetch_value(Closure("fetch value")) ;
  650.     $_ = "original" ;
  651.     $h{"fred"} = "joe" ;
  652.     ok(125, $result{"store key"} eq "store key - 1: [fred]");
  653.     ok(126, $result{"store value"} eq "store value - 1: [joe]");
  654.     ok(127, ! defined $result{"fetch key"} );
  655.     ok(128, ! defined $result{"fetch value"} );
  656.     ok(129, $_ eq "original") ;
  657.     ok(130, $db->FIRSTKEY() eq "fred") ;
  658.     ok(131, $result{"store key"} eq "store key - 1: [fred]");
  659.     ok(132, $result{"store value"} eq "store value - 1: [joe]");
  660.     ok(133, $result{"fetch key"} eq "fetch key - 1: [fred]");
  661.     ok(134, ! defined $result{"fetch value"} );
  662.     ok(135, $_ eq "original") ;
  663.     $h{"jim"}  = "john" ;
  664.     ok(136, $result{"store key"} eq "store key - 2: [fred jim]");
  665.     ok(137, $result{"store value"} eq "store value - 2: [joe john]");
  666.     ok(138, $result{"fetch key"} eq "fetch key - 1: [fred]");
  667.     ok(139, ! defined $result{"fetch value"} );
  668.     ok(140, $_ eq "original") ;
  669.     ok(141, $h{"fred"} eq "joe");
  670.     ok(142, $result{"store key"} eq "store key - 3: [fred jim fred]");
  671.     ok(143, $result{"store value"} eq "store value - 2: [joe john]");
  672.     ok(144, $result{"fetch key"} eq "fetch key - 1: [fred]");
  673.     ok(145, $result{"fetch value"} eq "fetch value - 1: [joe]");
  674.     ok(146, $_ eq "original") ;
  675.     undef $db ;
  676.     untie %h;
  677.     unlink $Dfile;
  678. }
  679. {
  680.    # DBM Filter recursion detection
  681.    use warnings ;
  682.    use strict ;
  683.    my (%h, $db) ;
  684.    unlink $Dfile;
  685.    ok(147, $db = tie(%h, 'DB_File', $Dfile, O_RDWR|O_CREAT, 0640, $DB_BTREE ) );
  686.    $db->filter_store_key (sub { $_ = $h{$_} }) ;
  687.    eval '$h{1} = 1234' ;
  688.    ok(148, $@ =~ /^recursion detected in filter_store_key at/ );
  689.    
  690.    undef $db ;
  691.    untie %h;
  692.    unlink $Dfile;
  693. }
  694. {
  695.    # Examples from the POD
  696.   my $file = "xyzt" ;
  697.   {
  698.     my $redirect = new Redirect $file ;
  699.     # BTREE example 1
  700.     ###
  701.     use warnings FATAL => qw(all) ;
  702.     use strict ;
  703.     use DB_File ;
  704.     my %h ;
  705.     sub Compare
  706.     {
  707.         my ($key1, $key2) = @_ ;
  708.         "L$key1" cmp "L$key2" ;
  709.     }
  710.     # specify the Perl sub that will do the comparison
  711.     $DB_BTREE->{'compare'} = &Compare ;
  712.     unlink "tree" ;
  713.     tie %h, "DB_File", "tree", O_RDWR|O_CREAT, 0640, $DB_BTREE 
  714.         or die "Cannot open file 'tree': $!n" ;
  715.     # Add a key/value pair to the file
  716.     $h{'Wall'} = 'Larry' ;
  717.     $h{'Smith'} = 'John' ;
  718.     $h{'mouse'} = 'mickey' ;
  719.     $h{'duck'}  = 'donald' ;
  720.     # Delete
  721.     delete $h{"duck"} ;
  722.     # Cycle through the keys printing them in order.
  723.     # Note it is not necessary to sort the keys as
  724.     # the btree will have kept them in order automatically.
  725.     foreach (keys %h)
  726.       { print "$_n" }
  727.     untie %h ;
  728.     unlink "tree" ;
  729.   }  
  730.   delete $DB_BTREE->{'compare'} ;
  731.   ok(149, docat_del($file) eq <<'EOM') ;
  732. mouse
  733. Smith
  734. Wall
  735. EOM
  736.    
  737.   {
  738.     my $redirect = new Redirect $file ;
  739.     # BTREE example 2
  740.     ###
  741.     use warnings FATAL => qw(all) ;
  742.     use strict ;
  743.     use DB_File ;
  744.     use vars qw($filename %h ) ;
  745.     $filename = "tree" ;
  746.     unlink $filename ;
  747.  
  748.     # Enable duplicate records
  749.     $DB_BTREE->{'flags'} = R_DUP ;
  750.  
  751.     tie %h, "DB_File", $filename, O_RDWR|O_CREAT, 0640, $DB_BTREE 
  752. or die "Cannot open $filename: $!n";
  753.  
  754.     # Add some key/value pairs to the file
  755.     $h{'Wall'} = 'Larry' ;
  756.     $h{'Wall'} = 'Brick' ; # Note the duplicate key
  757.     $h{'Wall'} = 'Brick' ; # Note the duplicate key and value
  758.     $h{'Smith'} = 'John' ;
  759.     $h{'mouse'} = 'mickey' ;
  760.     # iterate through the associative array
  761.     # and print each key/value pair.
  762.     foreach (keys %h)
  763.       { print "$_ -> $h{$_}n" }
  764.     untie %h ;
  765.     unlink $filename ;
  766.   }  
  767.   ok(150, docat_del($file) eq ($db185mode ? <<'EOM' : <<'EOM') ) ;
  768. Smith -> John
  769. Wall -> Brick
  770. Wall -> Brick
  771. Wall -> Brick
  772. mouse -> mickey
  773. EOM
  774. Smith -> John
  775. Wall -> Larry
  776. Wall -> Larry
  777. Wall -> Larry
  778. mouse -> mickey
  779. EOM
  780.   {
  781.     my $redirect = new Redirect $file ;
  782.     # BTREE example 3
  783.     ###
  784.     use warnings FATAL => qw(all) ;
  785.     use strict ;
  786.     use DB_File ;
  787.  
  788.     use vars qw($filename $x %h $status $key $value) ;
  789.     $filename = "tree" ;
  790.     unlink $filename ;
  791.  
  792.     # Enable duplicate records
  793.     $DB_BTREE->{'flags'} = R_DUP ;
  794.  
  795.     $x = tie %h, "DB_File", $filename, O_RDWR|O_CREAT, 0640, $DB_BTREE 
  796. or die "Cannot open $filename: $!n";
  797.  
  798.     # Add some key/value pairs to the file
  799.     $h{'Wall'} = 'Larry' ;
  800.     $h{'Wall'} = 'Brick' ; # Note the duplicate key
  801.     $h{'Wall'} = 'Brick' ; # Note the duplicate key and value
  802.     $h{'Smith'} = 'John' ;
  803.     $h{'mouse'} = 'mickey' ;
  804.  
  805.     # iterate through the btree using seq
  806.     # and print each key/value pair.
  807.     $key = $value = 0 ;
  808.     for ($status = $x->seq($key, $value, R_FIRST) ;
  809.          $status == 0 ;
  810.          $status = $x->seq($key, $value, R_NEXT) )
  811.       {  print "$key -> $valuen" }
  812.  
  813.  
  814.     undef $x ;
  815.     untie %h ;
  816.   }
  817.   ok(151, docat_del($file) eq ($db185mode == 1 ? <<'EOM' : <<'EOM') ) ;
  818. Smith -> John
  819. Wall -> Brick
  820. Wall -> Brick
  821. Wall -> Larry
  822. mouse -> mickey
  823. EOM
  824. Smith -> John
  825. Wall -> Larry
  826. Wall -> Brick
  827. Wall -> Brick
  828. mouse -> mickey
  829. EOM
  830.   {
  831.     my $redirect = new Redirect $file ;
  832.     # BTREE example 4
  833.     ###
  834.     use warnings FATAL => qw(all) ;
  835.     use strict ;
  836.     use DB_File ;
  837.  
  838.     use vars qw($filename $x %h ) ;
  839.     $filename = "tree" ;
  840.  
  841.     # Enable duplicate records
  842.     $DB_BTREE->{'flags'} = R_DUP ;
  843.  
  844.     $x = tie %h, "DB_File", $filename, O_RDWR|O_CREAT, 0640, $DB_BTREE 
  845. or die "Cannot open $filename: $!n";
  846.  
  847.     my $cnt  = $x->get_dup("Wall") ;
  848.     print "Wall occurred $cnt timesn" ;
  849.     my %hash = $x->get_dup("Wall", 1) ;
  850.     print "Larry is theren" if $hash{'Larry'} ;
  851.     print "There are $hash{'Brick'} Brick Wallsn" ;
  852.     my @list = sort $x->get_dup("Wall") ;
  853.     print "Wall => [@list]n" ;
  854.     @list = $x->get_dup("Smith") ;
  855.     print "Smith => [@list]n" ;
  856.  
  857.     @list = $x->get_dup("Dog") ;
  858.     print "Dog => [@list]n" ; 
  859.  
  860.     undef $x ;
  861.     untie %h ;
  862.   }
  863.   ok(152, docat_del($file) eq <<'EOM') ;
  864. Wall occurred 3 times
  865. Larry is there
  866. There are 2 Brick Walls
  867. Wall => [Brick Brick Larry]
  868. Smith => [John]
  869. Dog => []
  870. EOM
  871.   {
  872.     my $redirect = new Redirect $file ;
  873.     # BTREE example 5
  874.     ###
  875.     use warnings FATAL => qw(all) ;
  876.     use strict ;
  877.     use DB_File ;
  878.  
  879.     use vars qw($filename $x %h $found) ;
  880.     my $filename = "tree" ;
  881.  
  882.     # Enable duplicate records
  883.     $DB_BTREE->{'flags'} = R_DUP ;
  884.  
  885.     $x = tie %h, "DB_File", $filename, O_RDWR|O_CREAT, 0640, $DB_BTREE 
  886. or die "Cannot open $filename: $!n";
  887.     $found = ( $x->find_dup("Wall", "Larry") == 0 ? "" : "not") ; 
  888.     print "Larry Wall is $found theren" ;
  889.     
  890.     $found = ( $x->find_dup("Wall", "Harry") == 0 ? "" : "not") ; 
  891.     print "Harry Wall is $found theren" ;
  892.     
  893.     undef $x ;
  894.     untie %h ;
  895.   }
  896.   ok(153, docat_del($file) eq <<'EOM') ;
  897. Larry Wall is  there
  898. Harry Wall is not there
  899. EOM
  900.   {
  901.     my $redirect = new Redirect $file ;
  902.     # BTREE example 6
  903.     ###
  904.     use warnings FATAL => qw(all) ;
  905.     use strict ;
  906.     use DB_File ;
  907.  
  908.     use vars qw($filename $x %h $found) ;
  909.     my $filename = "tree" ;
  910.  
  911.     # Enable duplicate records
  912.     $DB_BTREE->{'flags'} = R_DUP ;
  913.  
  914.     $x = tie %h, "DB_File", $filename, O_RDWR|O_CREAT, 0640, $DB_BTREE 
  915. or die "Cannot open $filename: $!n";
  916.     $x->del_dup("Wall", "Larry") ;
  917.     $found = ( $x->find_dup("Wall", "Larry") == 0 ? "" : "not") ; 
  918.     print "Larry Wall is $found theren" ;
  919.     
  920.     undef $x ;
  921.     untie %h ;
  922.     unlink $filename ;
  923.   }
  924.   ok(154, docat_del($file) eq <<'EOM') ;
  925. Larry Wall is not there
  926. EOM
  927.   {
  928.     my $redirect = new Redirect $file ;
  929.     # BTREE example 7
  930.     ###
  931.     use warnings FATAL => qw(all) ;
  932.     use strict ;
  933.     use DB_File ;
  934.     use Fcntl ;
  935.     use vars qw($filename $x %h $st $key $value) ;
  936.     sub match
  937.     {
  938.         my $key = shift ;
  939.         my $value = 0;
  940.         my $orig_key = $key ;
  941.         $x->seq($key, $value, R_CURSOR) ;
  942.         print "$orig_keyt-> $keyt-> $valuen" ;
  943.     }
  944.     $filename = "tree" ;
  945.     unlink $filename ;
  946.     $x = tie %h, "DB_File", $filename, O_RDWR|O_CREAT, 0640, $DB_BTREE
  947.         or die "Cannot open $filename: $!n";
  948.  
  949.     # Add some key/value pairs to the file
  950.     $h{'mouse'} = 'mickey' ;
  951.     $h{'Wall'} = 'Larry' ;
  952.     $h{'Walls'} = 'Brick' ; 
  953.     $h{'Smith'} = 'John' ;
  954.  
  955.     $key = $value = 0 ;
  956.     print "IN ORDERn" ;
  957.     for ($st = $x->seq($key, $value, R_FIRST) ;
  958.  $st == 0 ;
  959.          $st = $x->seq($key, $value, R_NEXT) )
  960.       {  print "$key -> $valuen" }
  961.  
  962.     print "nPARTIAL MATCHn" ;
  963.     match "Wa" ;
  964.     match "A" ;
  965.     match "a" ;
  966.     undef $x ;
  967.     untie %h ;
  968.     unlink $filename ;
  969.   }
  970.   ok(155, docat_del($file) eq <<'EOM') ;
  971. IN ORDER
  972. Smith -> John
  973. Wall -> Larry
  974. Walls -> Brick
  975. mouse -> mickey
  976. PARTIAL MATCH
  977. Wa -> Wall -> Larry
  978. A -> Smith -> John
  979. a -> mouse -> mickey
  980. EOM
  981. }
  982. #{
  983. #   # R_SETCURSOR
  984. #   use strict ;
  985. #   my (%h, $db) ;
  986. #   unlink $Dfile;
  987. #
  988. #   ok(156, $db = tie(%h, 'DB_File', $Dfile, O_RDWR|O_CREAT, 0640, $DB_BTREE ) );
  989. #
  990. #   $h{abc} = 33 ;
  991. #   my $k = "newest" ;
  992. #   my $v = 44 ;
  993. #   my $status = $db->put($k, $v, R_SETCURSOR) ;
  994. #   print "status = [$status]n" ;
  995. #   ok(157, $status == 0) ;
  996. #   $status = $db->del($k, R_CURSOR) ;
  997. #   print "status = [$status]n" ;
  998. #   ok(158, $status == 0) ;
  999. #   $k = "newest" ;
  1000. #   ok(159, $db->get($k, $v, R_CURSOR)) ;
  1001. #
  1002. #   ok(160, keys %h == 1) ;
  1003. #   
  1004. #   undef $db ;
  1005. #   untie %h;
  1006. #   unlink $Dfile;
  1007. #}
  1008. {
  1009.     # Bug ID 20001013.009
  1010.     #
  1011.     # test that $hash{KEY} = undef doesn't produce the warning
  1012.     #     Use of uninitialized value in null operation 
  1013.     use warnings ;
  1014.     use strict ;
  1015.     use DB_File ;
  1016.     unlink $Dfile;
  1017.     my %h ;
  1018.     my $a = "";
  1019.     local $SIG{__WARN__} = sub {$a = $_[0]} ;
  1020.     
  1021.     tie %h, 'DB_File', $Dfile, O_RDWR|O_CREAT, 0664, $DB_BTREE
  1022. or die "Can't open file: $!n" ;
  1023.     $h{ABC} = undef;
  1024.     ok(156, $a eq "") ;
  1025.     untie %h ;
  1026.     unlink $Dfile;
  1027. }
  1028. {
  1029.     # test that %hash = () doesn't produce the warning
  1030.     #     Argument "" isn't numeric in entersub
  1031.     use warnings ;
  1032.     use strict ;
  1033.     use DB_File ;
  1034.     unlink $Dfile;
  1035.     my %h ;
  1036.     my $a = "";
  1037.     local $SIG{__WARN__} = sub {$a = $_[0]} ;
  1038.     
  1039.     tie %h, 'DB_File', $Dfile, O_RDWR|O_CREAT, 0664, $DB_BTREE
  1040. or die "Can't open file: $!n" ;
  1041.     %h = (); ;
  1042.     ok(157, $a eq "") ;
  1043.     untie %h ;
  1044.     unlink $Dfile;
  1045. }
  1046. exit ;