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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
DB_File.xs
资源名称：mysql-3.23.35.tar.gz　[点击查看]
上传用户：tsgydb
上传日期：2007-04-14
资源大小：10674k
文件大小：46k
源码类别：

MySQL数据库

开发平台：

Visual C++

DB_File.xs：源码内容
  1. /* 
  3.  DB_File.xs -- Perl 5 interface to Berkeley DB 
  5.  written by Paul Marquess <Paul.Marquess@btinternet.com>
  6.  last modified 15th January 2001
  7.  version 1.76
  9.  All comments/suggestions/problems are welcome
  11.      Copyright (c) 1995-2001 Paul Marquess. All rights reserved.
  12.      This program is free software; you can redistribute it and/or
  13.      modify it under the same terms as Perl itself.
  15.  Changes:
  16. 0.1 -  Initial Release
  17. 0.2 -  No longer bombs out if dbopen returns an error.
  18. 0.3 -  Added some support for multiple btree compares
  19. 1.0 -  Complete support for multiple callbacks added.
  20.        Fixed a problem with pushing a value onto an empty list.
  21. 1.01 -  Fixed a SunOS core dump problem.
  22. The return value from TIEHASH wasn't set to NULL when
  23. dbopen returned an error.
  24. 1.02 -  Use ALIAS to define TIEARRAY.
  25. Removed some redundant commented code.
  26. Merged OS2 code into the main distribution.
  27. Allow negative subscripts with RECNO interface.
  28. Changed the default flags to O_CREAT|O_RDWR
  29. 1.03 -  Added EXISTS
  30. 1.04 -  fixed a couple of bugs in hash_cb. Patches supplied by
  31. Dave Hammen, hammen@gothamcity.jsc.nasa.gov
  32. 1.05 -  Added logic to allow prefix & hash types to be specified via
  33. Makefile.PL
  34. 1.06 -  Minor namespace cleanup: Localized PrintBtree.
  35. 1.07 -  Fixed bug with RECNO, where bval wasn't defaulting to "n". 
  36. 1.08 -  No change to DB_File.xs
  37. 1.09 -  Default mode for dbopen changed to 0666
  38. 1.10 -  Fixed fd method so that it still returns -1 for
  39. in-memory files when db 1.86 is used.
  40. 1.11 -  No change to DB_File.xs
  41. 1.12 -  No change to DB_File.xs
  42. 1.13 -  Tidied up a few casts.     
  43. 1.14 - Made it illegal to tie an associative array to a RECNO
  44. database and an ordinary array to a HASH or BTREE database.
  45. 1.50 -  Make work with both DB 1.x or DB 2.x
  46. 1.51 -  Fixed a bug in mapping 1.x O_RDONLY flag to 2.x DB_RDONLY equivalent
  47. 1.52 -  Patch from Gisle Aas <gisle@aas.no> to suppress "use of 
  48. undefined value" warning with db_get and db_seq.
  49. 1.53 -  Added DB_RENUMBER to flags for recno.
  50. 1.54 -  Fixed bug in the fd method
  51.         1.55 -  Fix for AIX from Jarkko Hietaniemi
  52.         1.56 -  No change to DB_File.xs
  53.         1.57 -  added the #undef op to allow building with Threads support.
  54. 1.58 -  Fixed a problem with the use of sv_setpvn. When the
  55. size is specified as 0, it does a strlen on the data.
  56. This was ok for DB 1.x, but isn't for DB 2.x.
  57.         1.59 -  No change to DB_File.xs
  58.         1.60 -  Some code tidy up
  59.         1.61 -  added flagSet macro for DB 2.5.x
  60. fixed typo in O_RDONLY test.
  61.         1.62 -  No change to DB_File.xs
  62.         1.63 -  Fix to alllow DB 2.6.x to build.
  63.         1.64 -  Tidied up the 1.x to 2.x flags mapping code.
  64. Added a patch from Mark Kettenis <kettenis@wins.uva.nl>
  65. to fix a flag mapping problem with O_RDONLY on the Hurd
  66.         1.65 -  Fixed a bug in the PUSH logic.
  67. Added BOOT check that using 2.3.4 or greater
  68.         1.66 -  Added DBM filter code
  69.         1.67 -  Backed off the use of newSVpvn.
  70. Fixed DBM Filter code for Perl 5.004.
  71. Fixed a small memory leak in the filter code.
  72.         1.68 -  fixed backward compatability bug with R_IAFTER & R_IBEFORE
  73. merged in the 5.005_58 changes
  74.         1.69 -  fixed a bug in push -- DB_APPEND wasn't working properly.
  75. Fixed the R_SETCURSOR bug introduced in 1.68
  76. Added a new Perl variable $DB_File::db_ver 
  77.         1.70 -  Initialise $DB_File::db_ver and $DB_File::db_version with 
  78. GV_ADD|GV_ADDMULT -- bug spotted by Nick Ing-Simmons.
  79. Added a BOOT check to test for equivalent versions of db.h &
  80. libdb.a/so.
  81.         1.71 -  Support for Berkeley DB version 3.
  82. Support for Berkeley DB 2/3's backward compatability mode.
  83. Rewrote push
  84.         1.72 -  No change to DB_File.xs
  85.         1.73 -  No change to DB_File.xs
  86.         1.74 -  A call to open needed parenthesised to stop it clashing
  87.                 with a win32 macro.
  88. Added Perl core patches 7703 & 7801.
  89.         1.75 -  Fixed Perl core patch 7703.
  90. Added suppport to allow DB_File to be built with 
  91. Berkeley DB 3.2 -- btree_compare, btree_prefix and hash_cb
  92. needed to be changed.
  93.         1.76 -  No change to DB_File.xs
  95. */
  97. #include "EXTERN.h"  
  98. #include "perl.h"
  99. #include "XSUB.h"
  101. #ifndef PERL_VERSION
  102. #    include "patchlevel.h"
  103. #    define PERL_REVISION 5
  104. #    define PERL_VERSION PATCHLEVEL
  105. #    define PERL_SUBVERSION SUBVERSION
  106. #endif
  108. #if PERL_REVISION == 5 && (PERL_VERSION < 4 || (PERL_VERSION == 4 && PERL_SUBVERSION <= 75 ))
  110. #    define PL_sv_undef sv_undef
  111. #    define PL_na na
  113. #endif
  115. /* DEFSV appears first in 5.004_56 */
  116. #ifndef DEFSV
  117. #    define DEFSV GvSV(defgv)
  118. #endif
  120. /* Being the Berkeley DB we prefer the <sys/cdefs.h> (which will be
  121.  * shortly #included by the <db.h>) __attribute__ to the possibly
  122.  * already defined __attribute__, for example by GNUC or by Perl. */
  124. #undef __attribute__
  126. /* If Perl has been compiled with Threads support,the symbol op will
  127.    be defined here. This clashes with a field name in db.h, so get rid of it.
  128.  */
  129. #ifdef op
  130. #    undef op
  131. #endif
  133. #ifdef COMPAT185
  134. #    include <db_185.h>
  135. #else
  136. #    include <db.h>
  137. #endif
  139. #ifdef CAN_PROTOTYPE
  140. extern void __getBerkeleyDBInfo(void);
  141. #endif
  143. #ifndef pTHX
  144. #    define pTHX
  145. #    define pTHX_
  146. #    define aTHX
  147. #    define aTHX_
  148. #endif
  150. #ifndef newSVpvn
  151. #    define newSVpvn(a,b) newSVpv(a,b)
  152. #endif
  154. #include <fcntl.h> 
  156. /* #define TRACE */
  157. #define DBM_FILTERING
  159. #ifdef TRACE
  160. #    define Trace(x)        printf x
  161. #else
  162. #    define Trace(x)
  163. #endif
  166. #define DBT_clear(x) Zero(&x, 1, DBT) ;
  168. #ifdef DB_VERSION_MAJOR
  170. #if DB_VERSION_MAJOR == 2
  171. #    define BERKELEY_DB_1_OR_2
  172. #endif
  174. #if DB_VERSION_MAJOR > 3 || (DB_VERSION_MAJOR == 3 && DB_VERSION_MINOR >= 2)
  175. #    define AT_LEAST_DB_3_2
  176. #endif
  178. /* map version 2 features & constants onto their version 1 equivalent */
  180. #ifdef DB_Prefix_t
  181. #    undef DB_Prefix_t
  182. #endif
  183. #define DB_Prefix_t size_t
  185. #ifdef DB_Hash_t
  186. #    undef DB_Hash_t
  187. #endif
  188. #define DB_Hash_t u_int32_t
  190. /* DBTYPE stays the same */
  191. /* HASHINFO, RECNOINFO and BTREEINFO  map to DB_INFO */
  192. #if DB_VERSION_MAJOR == 2
  193.     typedef DB_INFO INFO ;
  194. #else /* DB_VERSION_MAJOR > 2 */
  195. #    define DB_FIXEDLEN (0x8000)
  196. #endif /* DB_VERSION_MAJOR == 2 */
  198. /* version 2 has db_recno_t in place of recno_t */
  199. typedef db_recno_t recno_t;
  202. #define R_CURSOR        DB_SET_RANGE
  203. #define R_FIRST         DB_FIRST
  204. #define R_IAFTER        DB_AFTER
  205. #define R_IBEFORE       DB_BEFORE
  206. #define R_LAST          DB_LAST
  207. #define R_NEXT          DB_NEXT
  208. #define R_NOOVERWRITE   DB_NOOVERWRITE
  209. #define R_PREV          DB_PREV
  211. #if DB_VERSION_MAJOR == 2 && DB_VERSION_MINOR < 5
  212. #  define R_SETCURSOR 0x800000
  213. #else
  214. #  define R_SETCURSOR (-100)
  215. #endif
  217. #define R_RECNOSYNC     0
  218. #define R_FIXEDLEN DB_FIXEDLEN
  219. #define R_DUP DB_DUP
  222. #define db_HA_hash  h_hash
  223. #define db_HA_ffactor h_ffactor
  224. #define db_HA_nelem h_nelem
  225. #define db_HA_bsize db_pagesize
  226. #define db_HA_cachesize db_cachesize
  227. #define db_HA_lorder db_lorder
  229. #define db_BT_compare bt_compare
  230. #define db_BT_prefix bt_prefix
  231. #define db_BT_flags flags
  232. #define db_BT_psize db_pagesize
  233. #define db_BT_cachesize db_cachesize
  234. #define db_BT_lorder db_lorder
  235. #define db_BT_maxkeypage
  236. #define db_BT_minkeypage
  239. #define db_RE_reclen re_len
  240. #define db_RE_flags flags
  241. #define db_RE_bval re_pad
  242. #define db_RE_bfname re_source
  243. #define db_RE_psize db_pagesize
  244. #define db_RE_cachesize db_cachesize
  245. #define db_RE_lorder db_lorder
  247. #define TXN NULL,
  249. #define do_SEQ(db, key, value, flag) (db->cursor->c_get)(db->cursor, &key, &value, flag)
  252. #define DBT_flags(x) x.flags = 0
  253. #define DB_flags(x, v) x |= v 
  255. #if DB_VERSION_MAJOR == 2 && DB_VERSION_MINOR < 5
  256. #    define flagSet(flags, bitmask) ((flags) & (bitmask))
  257. #else
  258. #    define flagSet(flags, bitmask) (((flags) & DB_OPFLAGS_MASK) == (bitmask))
  259. #endif
  261. #else /* db version 1.x */
  263. #define BERKELEY_DB_1
  264. #define BERKELEY_DB_1_OR_2
  266. typedef union INFO {
  267.         HASHINFO  hash ;
  268.         RECNOINFO  recno ;
  269.         BTREEINFO  btree ;
  270.       } INFO ;
  273. #ifdef mDB_Prefix_t 
  274. #  ifdef DB_Prefix_t
  275. #    undef DB_Prefix_t
  276. #  endif
  277. #  define DB_Prefix_t mDB_Prefix_t 
  278. #endif
  280. #ifdef mDB_Hash_t
  281. #  ifdef DB_Hash_t
  282. #    undef DB_Hash_t
  283. #  endif
  284. #  define DB_Hash_t mDB_Hash_t
  285. #endif
  287. #define db_HA_hash  hash.hash
  288. #define db_HA_ffactor hash.ffactor
  289. #define db_HA_nelem hash.nelem
  290. #define db_HA_bsize hash.bsize
  291. #define db_HA_cachesize hash.cachesize
  292. #define db_HA_lorder hash.lorder
  294. #define db_BT_compare btree.compare
  295. #define db_BT_prefix btree.prefix
  296. #define db_BT_flags btree.flags
  297. #define db_BT_psize btree.psize
  298. #define db_BT_cachesize btree.cachesize
  299. #define db_BT_lorder btree.lorder
  300. #define db_BT_maxkeypage btree.maxkeypage
  301. #define db_BT_minkeypage btree.minkeypage
  303. #define db_RE_reclen recno.reclen
  304. #define db_RE_flags recno.flags
  305. #define db_RE_bval recno.bval
  306. #define db_RE_bfname recno.bfname
  307. #define db_RE_psize recno.psize
  308. #define db_RE_cachesize recno.cachesize
  309. #define db_RE_lorder recno.lorder
  311. #define TXN
  313. #define do_SEQ(db, key, value, flag) (db->dbp->seq)(db->dbp, &key, &value, flag)
  314. #define DBT_flags(x)
  315. #define DB_flags(x, v)
  316. #define flagSet(flags, bitmask)        ((flags) & (bitmask))
  318. #endif /* db version 1 */
  322. #define db_DELETE(db, key, flags)       ((db->dbp)->del)(db->dbp, TXN &key, flags)
  323. #define db_STORE(db, key, value, flags) ((db->dbp)->put)(db->dbp, TXN &key, &value, flags)
  324. #define db_FETCH(db, key, flags)        ((db->dbp)->get)(db->dbp, TXN &key, &value, flags)
  326. #define db_sync(db, flags)              ((db->dbp)->sync)(db->dbp, flags)
  327. #define db_get(db, key, value, flags)   ((db->dbp)->get)(db->dbp, TXN &key, &value, flags)
  329. #ifdef DB_VERSION_MAJOR
  330. #define db_DESTROY(db)                  ( db->cursor->c_close(db->cursor),
  331.   (db->dbp->close)(db->dbp, 0) )
  332. #define db_close(db) ((db->dbp)->close)(db->dbp, 0)
  333. #define db_del(db, key, flags)          (flagSet(flags, R_CURSOR) 
  334. ? ((db->cursor)->c_del)(db->cursor, 0)
  335. : ((db->dbp)->del)(db->dbp, NULL, &key, flags) )
  337. #else /* ! DB_VERSION_MAJOR */
  339. #define db_DESTROY(db)                  ((db->dbp)->close)(db->dbp)
  340. #define db_close(db) ((db->dbp)->close)(db->dbp)
  341. #define db_del(db, key, flags)          ((db->dbp)->del)(db->dbp, &key, flags)
  342. #define db_put(db, key, value, flags)   ((db->dbp)->put)(db->dbp, &key, &value, flags)
  344. #endif /* ! DB_VERSION_MAJOR */
  347. #define db_seq(db, key, value, flags)   do_SEQ(db, key, value, flags)
  349. typedef struct {
  350. DBTYPE type ;
  351. DB *  dbp ;
  352. SV * compare ;
  353. SV * prefix ;
  354. SV * hash ;
  355. int in_memory ;
  356. #ifdef BERKELEY_DB_1_OR_2
  357. INFO  info ;
  358. #endif
  359. #ifdef DB_VERSION_MAJOR
  360. DBC * cursor ;
  361. #endif
  362. #ifdef DBM_FILTERING
  363. SV *    filter_fetch_key ;
  364. SV *    filter_store_key ;
  365. SV *    filter_fetch_value ;
  366. SV *    filter_store_value ;
  367. int     filtering ;
  368. #endif /* DBM_FILTERING */
  370. } DB_File_type;
  372. typedef DB_File_type * DB_File ;
  373. typedef DBT DBTKEY ;
  375. #ifdef DBM_FILTERING
  377. #define ckFilter(arg,type,name)
  378. if (db->type) {
  379.     SV * save_defsv ;
  380.             /* printf("filtering %sn", name) ;*/
  381.     if (db->filtering)
  382.         croak("recursion detected in %s", name) ;
  383.     db->filtering = TRUE ;
  384.     save_defsv = newSVsv(DEFSV) ;
  385.     sv_setsv(DEFSV, arg) ;
  386.     PUSHMARK(sp) ;
  387.     (void) perl_call_sv(db->type, G_DISCARD|G_NOARGS); 
  388.     sv_setsv(arg, DEFSV) ;
  389.     sv_setsv(DEFSV, save_defsv) ;
  390.     SvREFCNT_dec(save_defsv) ;
  391.     db->filtering = FALSE ;
  392.     /*printf("end of filtering %sn", name) ;*/
  393. }
  395. #else
  397. #define ckFilter(arg,type, name)
  399. #endif /* DBM_FILTERING */
  401. #define my_sv_setpvn(sv, d, s) sv_setpvn(sv, (s ? d : (void*)""), s)
  403. #define OutputValue(arg, name)  
  404. { if (RETVAL == 0) {
  405.       my_sv_setpvn(arg, name.data, name.size) ;
  406.       ckFilter(arg, filter_fetch_value,"filter_fetch_value") ; 
  407.   }
  408. }
  410. #define OutputKey(arg, name)  
  411. { if (RETVAL == 0) 
  412.   { 
  413. if (db->type != DB_RECNO) {
  414.     my_sv_setpvn(arg, name.data, name.size); 
  415. }
  416. else 
  417.     sv_setiv(arg, (I32)*(I32*)name.data - 1); 
  418.       ckFilter(arg, filter_fetch_key,"filter_fetch_key") ; 
  419.   } 
  420. }
  423. /* Internal Global Data */
  424. static recno_t Value ; 
  425. static recno_t zero = 0 ;
  426. static DB_File CurrentDB ;
  427. static DBTKEY empty ;
  429. #ifdef DB_VERSION_MAJOR
  431. static int
  432. #ifdef CAN_PROTOTYPE
  433. db_put(DB_File db, DBTKEY key, DBT value, u_int flags)
  434. #else
  435. db_put(db, key, value, flags)
  436. DB_File db ;
  437. DBTKEY key ;
  438. DBT value ;
  439. u_int flags ;
  440. #endif
  441. {
  442.     int status ;
  444.     if (flagSet(flags, R_IAFTER) || flagSet(flags, R_IBEFORE)) {
  445.         DBC * temp_cursor ;
  446. DBT l_key, l_value;
  447.         
  448. #if DB_VERSION_MAJOR == 2 && DB_VERSION_MINOR < 6
  449.         if (((db->dbp)->cursor)(db->dbp, NULL, &temp_cursor) != 0)
  450. #else
  451.         if (((db->dbp)->cursor)(db->dbp, NULL, &temp_cursor, 0) != 0)
  452. #endif
  453.     return (-1) ;
  455. memset(&l_key, 0, sizeof(l_key));
  456. l_key.data = key.data;
  457. l_key.size = key.size;
  458. memset(&l_value, 0, sizeof(l_value));
  459. l_value.data = value.data;
  460. l_value.size = value.size;
  462. if ( temp_cursor->c_get(temp_cursor, &l_key, &l_value, DB_SET) != 0) {
  463.     (void)temp_cursor->c_close(temp_cursor);
  464.     return (-1);
  465. }
  467. status = temp_cursor->c_put(temp_cursor, &key, &value, flags);
  468. (void)temp_cursor->c_close(temp_cursor);
  469.     
  470.         return (status) ;
  471.     }
  472.     
  473.     
  474.     if (flagSet(flags, R_CURSOR)) {
  475. return ((db->cursor)->c_put)(db->cursor, &key, &value, DB_CURRENT);
  476.     }
  478.     if (flagSet(flags, R_SETCURSOR)) {
  479. if ((db->dbp)->put(db->dbp, NULL, &key, &value, 0) != 0)
  480. return -1 ;
  481.         return ((db->cursor)->c_get)(db->cursor, &key, &value, DB_SET_RANGE);
  482.     
  483.     }
  485.     return ((db->dbp)->put)(db->dbp, NULL, &key, &value, flags) ;
  487. }
  489. #endif /* DB_VERSION_MAJOR */
  492. static int
  493. #ifdef AT_LEAST_DB_3_2
  495. #ifdef CAN_PROTOTYPE
  496. btree_compare(DB * db, const DBT *key1, const DBT *key2)
  497. #else
  498. btree_compare(db, key1, key2)
  499. DB * db ;
  500. const DBT * key1 ;
  501. const DBT * key2 ;
  502. #endif /* CAN_PROTOTYPE */
  504. #else /* Berkeley DB < 3.2 */
  506. #ifdef CAN_PROTOTYPE
  507. btree_compare(const DBT *key1, const DBT *key2)
  508. #else
  509. btree_compare(key1, key2)
  510. const DBT * key1 ;
  511. const DBT * key2 ;
  512. #endif
  514. #endif
  516. {
  517. #ifdef dTHX
  518.     dTHX;
  519. #endif    
  520.     dSP ;
  521.     void * data1, * data2 ;
  522.     int retval ;
  523.     int count ;
  524.     
  525.     data1 = key1->data ;
  526.     data2 = key2->data ;
  528. #ifndef newSVpvn
  529.     /* As newSVpv will assume that the data pointer is a null terminated C 
  530.        string if the size parameter is 0, make sure that data points to an 
  531.        empty string if the length is 0
  532.     */
  533.     if (key1->size == 0)
  534.         data1 = "" ; 
  535.     if (key2->size == 0)
  536.         data2 = "" ;
  537. #endif
  539.     ENTER ;
  540.     SAVETMPS;
  542.     PUSHMARK(SP) ;
  543.     EXTEND(SP,2) ;
  544.     PUSHs(sv_2mortal(newSVpvn(data1,key1->size)));
  545.     PUSHs(sv_2mortal(newSVpvn(data2,key2->size)));
  546.     PUTBACK ;
  548.     count = perl_call_sv(CurrentDB->compare, G_SCALAR); 
  550.     SPAGAIN ;
  552.     if (count != 1)
  553.         croak ("DB_File btree_compare: expected 1 return value from compare sub, got %dn", count) ;
  555.     retval = POPi ;
  557.     PUTBACK ;
  558.     FREETMPS ;
  559.     LEAVE ;
  560.     return (retval) ;
  562. }
  564. static DB_Prefix_t
  565. #ifdef AT_LEAST_DB_3_2
  567. #ifdef CAN_PROTOTYPE
  568. btree_prefix(DB * db, const DBT *key1, const DBT *key2)
  569. #else
  570. btree_prefix(db, key1, key2)
  571. Db * db ;
  572. const DBT * key1 ;
  573. const DBT * key2 ;
  574. #endif
  576. #else /* Berkeley DB < 3.2 */
  578. #ifdef CAN_PROTOTYPE
  579. btree_prefix(const DBT *key1, const DBT *key2)
  580. #else
  581. btree_prefix(key1, key2)
  582. const DBT * key1 ;
  583. const DBT * key2 ;
  584. #endif
  586. #endif
  587. {
  588. #ifdef dTHX
  589.     dTHX;
  590. #endif    
  591.     dSP ;
  592.     void * data1, * data2 ;
  593.     int retval ;
  594.     int count ;
  595.     
  596.     data1 = key1->data ;
  597.     data2 = key2->data ;
  599. #ifndef newSVpvn
  600.     /* As newSVpv will assume that the data pointer is a null terminated C 
  601.        string if the size parameter is 0, make sure that data points to an 
  602.        empty string if the length is 0
  603.     */
  604.     if (key1->size == 0)
  605.         data1 = "" ;
  606.     if (key2->size == 0)
  607.         data2 = "" ;
  608. #endif
  610.     ENTER ;
  611.     SAVETMPS;
  613.     PUSHMARK(SP) ;
  614.     EXTEND(SP,2) ;
  615.     PUSHs(sv_2mortal(newSVpvn(data1,key1->size)));
  616.     PUSHs(sv_2mortal(newSVpvn(data2,key2->size)));
  617.     PUTBACK ;
  619.     count = perl_call_sv(CurrentDB->prefix, G_SCALAR); 
  621.     SPAGAIN ;
  623.     if (count != 1)
  624.         croak ("DB_File btree_prefix: expected 1 return value from prefix sub, got %dn", count) ;
  625.  
  626.     retval = POPi ;
  627.  
  628.     PUTBACK ;
  629.     FREETMPS ;
  630.     LEAVE ;
  632.     return (retval) ;
  633. }
  636. #ifdef BERKELEY_DB_1
  637. #    define HASH_CB_SIZE_TYPE size_t
  638. #else
  639. #    define HASH_CB_SIZE_TYPE u_int32_t
  640. #endif
  642. static DB_Hash_t
  643. #ifdef AT_LEAST_DB_3_2
  645. #ifdef CAN_PROTOTYPE
  646. hash_cb(DB * db, const void *data, u_int32_t size)
  647. #else
  648. hash_cb(db, data, size)
  649. DB * db ;
  650. const void * data ;
  651. HASH_CB_SIZE_TYPE size ;
  652. #endif
  654. #else /* Berkeley DB < 3.2 */
  656. #ifdef CAN_PROTOTYPE
  657. hash_cb(const void *data, HASH_CB_SIZE_TYPE size)
  658. #else
  659. hash_cb(data, size)
  660. const void * data ;
  661. HASH_CB_SIZE_TYPE size ;
  662. #endif
  664. #endif
  665. {
  666. #ifdef dTHX
  667.     dTHX;
  668. #endif    
  669.     dSP ;
  670.     int retval ;
  671.     int count ;
  673. #ifndef newSVpvn
  674.     if (size == 0)
  675.         data = "" ;
  676. #endif
  678.      /* DGH - Next two lines added to fix corrupted stack problem */
  679.     ENTER ;
  680.     SAVETMPS;
  682.     PUSHMARK(SP) ;
  684.     XPUSHs(sv_2mortal(newSVpvn((char*)data,size)));
  685.     PUTBACK ;
  687.     count = perl_call_sv(CurrentDB->hash, G_SCALAR); 
  689.     SPAGAIN ;
  691.     if (count != 1)
  692.         croak ("DB_File hash_cb: expected 1 return value from hash sub, got %dn", count) ;
  694.     retval = POPi ;
  696.     PUTBACK ;
  697.     FREETMPS ;
  698.     LEAVE ;
  700.     return (retval) ;
  701. }
  704. #if defined(TRACE) && defined(BERKELEY_DB_1_OR_2)
  706. static void
  707. #ifdef CAN_PROTOTYPE
  708. PrintHash(INFO *hash)
  709. #else
  710. PrintHash(hash)
  711. INFO * hash ;
  712. #endif
  713. {
  714.     printf ("HASH Infon") ;
  715.     printf ("  hash      = %sn", 
  716. (hash->db_HA_hash != NULL ? "redefined" : "default")) ;
  717.     printf ("  bsize     = %dn", hash->db_HA_bsize) ;
  718.     printf ("  ffactor   = %dn", hash->db_HA_ffactor) ;
  719.     printf ("  nelem     = %dn", hash->db_HA_nelem) ;
  720.     printf ("  cachesize = %dn", hash->db_HA_cachesize) ;
  721.     printf ("  lorder    = %dn", hash->db_HA_lorder) ;
  723. }
  725. static void
  726. #ifdef CAN_PROTOTYPE
  727. PrintRecno(INFO *recno)
  728. #else
  729. PrintRecno(recno)
  730. INFO * recno ;
  731. #endif
  732. {
  733.     printf ("RECNO Infon") ;
  734.     printf ("  flags     = %dn", recno->db_RE_flags) ;
  735.     printf ("  cachesize = %dn", recno->db_RE_cachesize) ;
  736.     printf ("  psize     = %dn", recno->db_RE_psize) ;
  737.     printf ("  lorder    = %dn", recno->db_RE_lorder) ;
  738.     printf ("  reclen    = %uln", (unsigned long)recno->db_RE_reclen) ;
  739.     printf ("  bval      = %d 0x%xn", recno->db_RE_bval, recno->db_RE_bval) ;
  740.     printf ("  bfname    = %d [%s]n", recno->db_RE_bfname, recno->db_RE_bfname) ;
  741. }
  743. static void
  744. #ifdef CAN_PROTOTYPE
  745. PrintBtree(INFO *btree)
  746. #else
  747. PrintBtree(btree)
  748. INFO * btree ;
  749. #endif
  750. {
  751.     printf ("BTREE Infon") ;
  752.     printf ("  compare    = %sn", 
  753. (btree->db_BT_compare ? "redefined" : "default")) ;
  754.     printf ("  prefix     = %sn", 
  755. (btree->db_BT_prefix ? "redefined" : "default")) ;
  756.     printf ("  flags      = %dn", btree->db_BT_flags) ;
  757.     printf ("  cachesize  = %dn", btree->db_BT_cachesize) ;
  758.     printf ("  psize      = %dn", btree->db_BT_psize) ;
  759. #ifndef DB_VERSION_MAJOR
  760.     printf ("  maxkeypage = %dn", btree->db_BT_maxkeypage) ;
  761.     printf ("  minkeypage = %dn", btree->db_BT_minkeypage) ;
  762. #endif
  763.     printf ("  lorder     = %dn", btree->db_BT_lorder) ;
  764. }
  766. #else
  768. #define PrintRecno(recno)
  769. #define PrintHash(hash)
  770. #define PrintBtree(btree)
  772. #endif /* TRACE */
  775. static I32
  776. #ifdef CAN_PROTOTYPE
  777. GetArrayLength(pTHX_ DB_File db)
  778. #else
  779. GetArrayLength(db)
  780. DB_File db ;
  781. #endif
  782. {
  783.     DBT key ;
  784.     DBT value ;
  785.     int RETVAL ;
  787.     DBT_clear(key) ;
  788.     DBT_clear(value) ;
  789.     RETVAL = do_SEQ(db, key, value, R_LAST) ;
  790.     if (RETVAL == 0)
  791.         RETVAL = *(I32 *)key.data ;
  792.     else /* No key means empty file */
  793.         RETVAL = 0 ;
  795.     return ((I32)RETVAL) ;
  796. }
  798. static recno_t
  799. #ifdef CAN_PROTOTYPE
  800. GetRecnoKey(pTHX_ DB_File db, I32 value)
  801. #else
  802. GetRecnoKey(db, value)
  803. DB_File  db ;
  804. I32      value ;
  805. #endif
  806. {
  807.     if (value < 0) {
  808. /* Get the length of the array */
  809. I32 length = GetArrayLength(aTHX_ db) ;
  811. /* check for attempt to write before start of array */
  812. if (length + value + 1 <= 0)
  813.     croak("Modification of non-creatable array value attempted, subscript %ld", (long)value) ;
  815. value = length + value + 1 ;
  816.     }
  817.     else
  818.         ++ value ;
  820.     return value ;
  821. }
  824. static DB_File
  825. #ifdef CAN_PROTOTYPE
  826. ParseOpenInfo(pTHX_ int isHASH, char *name, int flags, int mode, SV *sv)
  827. #else
  828. ParseOpenInfo(isHASH, name, flags, mode, sv)
  829. int    isHASH ;
  830. char * name ;
  831. int    flags ;
  832. int    mode ;
  833. SV *   sv ;
  834. #endif
  835. {
  837. #ifdef BERKELEY_DB_1_OR_2 /* Berkeley DB Version 1  or 2 */
  839.     SV ** svp;
  840.     HV * action ;
  841.     DB_File RETVAL = (DB_File)safemalloc(sizeof(DB_File_type)) ;
  842.     void * openinfo = NULL ;
  843.     INFO * info  = &RETVAL->info ;
  844.     STRLEN n_a;
  846. /* printf("In ParseOpenInfo name=[%s] flags=[%d] mode = [%d]n", name, flags, mode) ;  */
  847.     Zero(RETVAL, 1, DB_File_type) ;
  849.     /* Default to HASH */
  850. #ifdef DBM_FILTERING
  851.     RETVAL->filtering = 0 ;
  852.     RETVAL->filter_fetch_key = RETVAL->filter_store_key = 
  853.     RETVAL->filter_fetch_value = RETVAL->filter_store_value =
  854. #endif /* DBM_FILTERING */
  855.     RETVAL->hash = RETVAL->compare = RETVAL->prefix = NULL ;
  856.     RETVAL->type = DB_HASH ;
  858.      /* DGH - Next line added to avoid SEGV on existing hash DB */
  859.     CurrentDB = RETVAL; 
  861.     /* fd for 1.86 hash in memory files doesn't return -1 like 1.85 */
  862.     RETVAL->in_memory = (name == NULL) ;
  864.     if (sv)
  865.     {
  866.         if (! SvROK(sv) )
  867.             croak ("type parameter is not a reference") ;
  869.         svp  = hv_fetch( (HV*)SvRV(sv), "GOT", 3, FALSE) ;
  870.         if (svp && SvOK(*svp))
  871.             action  = (HV*) SvRV(*svp) ;
  872. else
  873.     croak("internal error") ;
  875.         if (sv_isa(sv, "DB_File::HASHINFO"))
  876.         {
  878.     if (!isHASH)
  879.         croak("DB_File can only tie an associative array to a DB_HASH database") ;
  881.             RETVAL->type = DB_HASH ;
  882.             openinfo = (void*)info ;
  883.   
  884.             svp = hv_fetch(action, "hash", 4, FALSE); 
  886.             if (svp && SvOK(*svp))
  887.             {
  888.                 info->db_HA_hash = hash_cb ;
  889. RETVAL->hash = newSVsv(*svp) ;
  890.             }
  891.             else
  892.         info->db_HA_hash = NULL ;
  894.            svp = hv_fetch(action, "ffactor", 7, FALSE);
  895.            info->db_HA_ffactor = svp ? SvIV(*svp) : 0;
  896.          
  897.            svp = hv_fetch(action, "nelem", 5, FALSE);
  898.            info->db_HA_nelem = svp ? SvIV(*svp) : 0;
  899.          
  900.            svp = hv_fetch(action, "bsize", 5, FALSE);
  901.            info->db_HA_bsize = svp ? SvIV(*svp) : 0;
  902.            
  903.            svp = hv_fetch(action, "cachesize", 9, FALSE);
  904.            info->db_HA_cachesize = svp ? SvIV(*svp) : 0;
  905.          
  906.            svp = hv_fetch(action, "lorder", 6, FALSE);
  907.            info->db_HA_lorder = svp ? SvIV(*svp) : 0;
  909.            PrintHash(info) ; 
  910.         }
  911.         else if (sv_isa(sv, "DB_File::BTREEINFO"))
  912.         {
  913.     if (!isHASH)
  914.         croak("DB_File can only tie an associative array to a DB_BTREE database");
  916.             RETVAL->type = DB_BTREE ;
  917.             openinfo = (void*)info ;
  918.    
  919.             svp = hv_fetch(action, "compare", 7, FALSE);
  920.             if (svp && SvOK(*svp))
  921.             {
  922.                 info->db_BT_compare = btree_compare ;
  923. RETVAL->compare = newSVsv(*svp) ;
  924.             }
  925.             else
  926.                 info->db_BT_compare = NULL ;
  928.             svp = hv_fetch(action, "prefix", 6, FALSE);
  929.             if (svp && SvOK(*svp))
  930.             {
  931.                 info->db_BT_prefix = btree_prefix ;
  932. RETVAL->prefix = newSVsv(*svp) ;
  933.             }
  934.             else
  935.                 info->db_BT_prefix = NULL ;
  937.             svp = hv_fetch(action, "flags", 5, FALSE);
  938.             info->db_BT_flags = svp ? SvIV(*svp) : 0;
  939.    
  940.             svp = hv_fetch(action, "cachesize", 9, FALSE);
  941.             info->db_BT_cachesize = svp ? SvIV(*svp) : 0;
  942.          
  943. #ifndef DB_VERSION_MAJOR
  944.             svp = hv_fetch(action, "minkeypage", 10, FALSE);
  945.             info->btree.minkeypage = svp ? SvIV(*svp) : 0;
  946.         
  947.             svp = hv_fetch(action, "maxkeypage", 10, FALSE);
  948.             info->btree.maxkeypage = svp ? SvIV(*svp) : 0;
  949. #endif
  951.             svp = hv_fetch(action, "psize", 5, FALSE);
  952.             info->db_BT_psize = svp ? SvIV(*svp) : 0;
  953.          
  954.             svp = hv_fetch(action, "lorder", 6, FALSE);
  955.             info->db_BT_lorder = svp ? SvIV(*svp) : 0;
  957.             PrintBtree(info) ;
  958.          
  959.         }
  960.         else if (sv_isa(sv, "DB_File::RECNOINFO"))
  961.         {
  962.     if (isHASH)
  963.         croak("DB_File can only tie an array to a DB_RECNO database");
  965.             RETVAL->type = DB_RECNO ;
  966.             openinfo = (void *)info ;
  968.     info->db_RE_flags = 0 ;
  970.             svp = hv_fetch(action, "flags", 5, FALSE);
  971.             info->db_RE_flags = (u_long) (svp ? SvIV(*svp) : 0);
  972.          
  973.             svp = hv_fetch(action, "reclen", 6, FALSE);
  974.             info->db_RE_reclen = (size_t) (svp ? SvIV(*svp) : 0);
  975.          
  976.             svp = hv_fetch(action, "cachesize", 9, FALSE);
  977.             info->db_RE_cachesize = (u_int) (svp ? SvIV(*svp) : 0);
  978.          
  979.             svp = hv_fetch(action, "psize", 5, FALSE);
  980.             info->db_RE_psize = (u_int) (svp ? SvIV(*svp) : 0);
  981.          
  982.             svp = hv_fetch(action, "lorder", 6, FALSE);
  983.             info->db_RE_lorder = (int) (svp ? SvIV(*svp) : 0);
  985. #ifdef DB_VERSION_MAJOR
  986.     info->re_source = name ;
  987.     name = NULL ;
  988. #endif
  989.             svp = hv_fetch(action, "bfname", 6, FALSE); 
  990.             if (svp && SvOK(*svp)) {
  991. char * ptr = SvPV(*svp,n_a) ;
  992. #ifdef DB_VERSION_MAJOR
  993. name = (char*) n_a ? ptr : NULL ;
  994. #else
  995.                 info->db_RE_bfname = (char*) (n_a ? ptr : NULL) ;
  996. #endif
  997.     }
  998.     else
  999. #ifdef DB_VERSION_MAJOR
  1000. name = NULL ;
  1001. #else
  1002.                 info->db_RE_bfname = NULL ;
  1003. #endif
  1004.          
  1005.     svp = hv_fetch(action, "bval", 4, FALSE);
  1006. #ifdef DB_VERSION_MAJOR
  1007.             if (svp && SvOK(*svp))
  1008.             {
  1009. int value ;
  1010.                 if (SvPOK(*svp))
  1011.     value = (int)*SvPV(*svp, n_a) ;
  1012. else
  1013.     value = SvIV(*svp) ;
  1015. if (info->flags & DB_FIXEDLEN) {
  1016.     info->re_pad = value ;
  1017.     info->flags |= DB_PAD ;
  1018. }
  1019. else {
  1020.     info->re_delim = value ;
  1021.     info->flags |= DB_DELIMITER ;
  1022. }
  1024.             }
  1025. #else
  1026.             if (svp && SvOK(*svp))
  1027.             {
  1028.                 if (SvPOK(*svp))
  1029.     info->db_RE_bval = (u_char)*SvPV(*svp, n_a) ;
  1030. else
  1031.     info->db_RE_bval = (u_char)(unsigned long) SvIV(*svp) ;
  1032. DB_flags(info->flags, DB_DELIMITER) ;
  1034.             }
  1035.             else
  1036.       {
  1037. if (info->db_RE_flags & R_FIXEDLEN)
  1038.                     info->db_RE_bval = (u_char) ' ' ;
  1039. else
  1040.                     info->db_RE_bval = (u_char) 'n' ;
  1041. DB_flags(info->flags, DB_DELIMITER) ;
  1042.     }
  1043. #endif
  1045. #ifdef DB_RENUMBER
  1046.     info->flags |= DB_RENUMBER ;
  1047. #endif
  1048.          
  1049.             PrintRecno(info) ;
  1050.         }
  1051.         else
  1052.             croak("type is not of type DB_File::HASHINFO, DB_File::BTREEINFO or DB_File::RECNOINFO");
  1053.     }
  1056.     /* OS2 Specific Code */
  1057. #ifdef OS2
  1058. #ifdef __EMX__
  1059.     flags |= O_BINARY;
  1060. #endif /* __EMX__ */
  1061. #endif /* OS2 */
  1063. #ifdef DB_VERSION_MAJOR
  1065.     {
  1066.         int   Flags = 0 ;
  1067.         int status ;
  1069.         /* Map 1.x flags to 2.x flags */
  1070.         if ((flags & O_CREAT) == O_CREAT)
  1071.             Flags |= DB_CREATE ;
  1073. #if O_RDONLY == 0
  1074.         if (flags == O_RDONLY)
  1075. #else
  1076.         if ((flags & O_RDONLY) == O_RDONLY && (flags & O_RDWR) != O_RDWR)
  1077. #endif
  1078.             Flags |= DB_RDONLY ;
  1080. #ifdef O_TRUNC
  1081.         if ((flags & O_TRUNC) == O_TRUNC)
  1082.             Flags |= DB_TRUNCATE ;
  1083. #endif
  1085.         status = db_open(name, RETVAL->type, Flags, mode, NULL, openinfo, &RETVAL->dbp) ; 
  1086.         if (status == 0)
  1087. #if DB_VERSION_MAJOR == 2 && DB_VERSION_MINOR < 6
  1088.             status = (RETVAL->dbp->cursor)(RETVAL->dbp, NULL, &RETVAL->cursor) ;
  1089. #else
  1090.             status = (RETVAL->dbp->cursor)(RETVAL->dbp, NULL, &RETVAL->cursor,
  1091. 0) ;
  1092. #endif
  1094.         if (status)
  1095.     RETVAL->dbp = NULL ;
  1097.     }
  1098. #else
  1100. #if defined(DB_LIBRARY_COMPATIBILITY_API) && DB_VERSION_MAJOR > 2
  1101.     RETVAL->dbp = __db185_open(name, flags, mode, RETVAL->type, openinfo) ; 
  1102. #else    
  1103.     RETVAL->dbp = dbopen(name, flags, mode, RETVAL->type, openinfo) ; 
  1104. #endif /* DB_LIBRARY_COMPATIBILITY_API */
  1106. #endif
  1108.     return (RETVAL) ;
  1110. #else /* Berkeley DB Version > 2 */
  1112.     SV ** svp;
  1113.     HV * action ;
  1114.     DB_File RETVAL = (DB_File)safemalloc(sizeof(DB_File_type)) ;
  1115.     DB * dbp ;
  1116.     STRLEN n_a;
  1117.     int status ;
  1119. /* printf("In ParseOpenInfo name=[%s] flags=[%d] mode = [%d]n", name, flags, mode) ;  */
  1120.     Zero(RETVAL, 1, DB_File_type) ;
  1122.     /* Default to HASH */
  1123. #ifdef DBM_FILTERING
  1124.     RETVAL->filtering = 0 ;
  1125.     RETVAL->filter_fetch_key = RETVAL->filter_store_key = 
  1126.     RETVAL->filter_fetch_value = RETVAL->filter_store_value =
  1127. #endif /* DBM_FILTERING */
  1128.     RETVAL->hash = RETVAL->compare = RETVAL->prefix = NULL ;
  1129.     RETVAL->type = DB_HASH ;
  1131.      /* DGH - Next line added to avoid SEGV on existing hash DB */
  1132.     CurrentDB = RETVAL; 
  1134.     /* fd for 1.86 hash in memory files doesn't return -1 like 1.85 */
  1135.     RETVAL->in_memory = (name == NULL) ;
  1137.     status = db_create(&RETVAL->dbp, NULL,0) ;
  1138.     /* printf("db_create returned %d %sn", status, db_strerror(status)) ; */
  1139.     if (status) {
  1140. RETVAL->dbp = NULL ;
  1141.         return (RETVAL) ;
  1142.     }
  1143.     dbp = RETVAL->dbp ;
  1145.     if (sv)
  1146.     {
  1147.         if (! SvROK(sv) )
  1148.             croak ("type parameter is not a reference") ;
  1150.         svp  = hv_fetch( (HV*)SvRV(sv), "GOT", 3, FALSE) ;
  1151.         if (svp && SvOK(*svp))
  1152.             action  = (HV*) SvRV(*svp) ;
  1153. else
  1154.     croak("internal error") ;
  1156.         if (sv_isa(sv, "DB_File::HASHINFO"))
  1157.         {
  1159.     if (!isHASH)
  1160.         croak("DB_File can only tie an associative array to a DB_HASH database") ;
  1162.             RETVAL->type = DB_HASH ;
  1163.   
  1164.             svp = hv_fetch(action, "hash", 4, FALSE); 
  1166.             if (svp && SvOK(*svp))
  1167.             {
  1168. (void)dbp->set_h_hash(dbp, hash_cb) ;
  1169. RETVAL->hash = newSVsv(*svp) ;
  1170.             }
  1172.            svp = hv_fetch(action, "ffactor", 7, FALSE);
  1173.    if (svp)
  1174.        (void)dbp->set_h_ffactor(dbp, SvIV(*svp)) ;
  1175.          
  1176.            svp = hv_fetch(action, "nelem", 5, FALSE);
  1177.    if (svp)
  1178.                (void)dbp->set_h_nelem(dbp, SvIV(*svp)) ;
  1179.          
  1180.            svp = hv_fetch(action, "bsize", 5, FALSE);
  1181.    if (svp)
  1182.                (void)dbp->set_pagesize(dbp, SvIV(*svp));
  1183.            
  1184.            svp = hv_fetch(action, "cachesize", 9, FALSE);
  1185.    if (svp)
  1186.                (void)dbp->set_cachesize(dbp, 0, SvIV(*svp), 0) ;
  1187.          
  1188.            svp = hv_fetch(action, "lorder", 6, FALSE);
  1189.    if (svp)
  1190.                (void)dbp->set_lorder(dbp, SvIV(*svp)) ;
  1192.            PrintHash(info) ; 
  1193.         }
  1194.         else if (sv_isa(sv, "DB_File::BTREEINFO"))
  1195.         {
  1196.     if (!isHASH)
  1197.         croak("DB_File can only tie an associative array to a DB_BTREE database");
  1199.             RETVAL->type = DB_BTREE ;
  1200.    
  1201.             svp = hv_fetch(action, "compare", 7, FALSE);
  1202.             if (svp && SvOK(*svp))
  1203.             {
  1204.                 (void)dbp->set_bt_compare(dbp, btree_compare) ;
  1205. RETVAL->compare = newSVsv(*svp) ;
  1206.             }
  1208.             svp = hv_fetch(action, "prefix", 6, FALSE);
  1209.             if (svp && SvOK(*svp))
  1210.             {
  1211.                 (void)dbp->set_bt_prefix(dbp, btree_prefix) ;
  1212. RETVAL->prefix = newSVsv(*svp) ;
  1213.             }
  1215.            svp = hv_fetch(action, "flags", 5, FALSE);
  1216.    if (svp)
  1217.        (void)dbp->set_flags(dbp, SvIV(*svp)) ;
  1218.    
  1219.            svp = hv_fetch(action, "cachesize", 9, FALSE);
  1220.    if (svp)
  1221.                (void)dbp->set_cachesize(dbp, 0, SvIV(*svp), 0) ;
  1222.          
  1223.            svp = hv_fetch(action, "psize", 5, FALSE);
  1224.    if (svp)
  1225.                (void)dbp->set_pagesize(dbp, SvIV(*svp)) ;
  1226.          
  1227.            svp = hv_fetch(action, "lorder", 6, FALSE);
  1228.    if (svp)
  1229.                (void)dbp->set_lorder(dbp, SvIV(*svp)) ;
  1231.             PrintBtree(info) ;
  1232.          
  1233.         }
  1234.         else if (sv_isa(sv, "DB_File::RECNOINFO"))
  1235.         {
  1236.     int fixed = FALSE ;
  1238.     if (isHASH)
  1239.         croak("DB_File can only tie an array to a DB_RECNO database");
  1241.             RETVAL->type = DB_RECNO ;
  1243.            svp = hv_fetch(action, "flags", 5, FALSE);
  1244.    if (svp) {
  1245. int flags = SvIV(*svp) ;
  1246. /* remove FIXDLEN, if present */
  1247. if (flags & DB_FIXEDLEN) {
  1248.     fixed = TRUE ;
  1249.     flags &= ~DB_FIXEDLEN ;
  1250.     }
  1251.    }
  1253.            svp = hv_fetch(action, "cachesize", 9, FALSE);
  1254.    if (svp) {
  1255.                status = dbp->set_cachesize(dbp, 0, SvIV(*svp), 0) ;
  1256.    }
  1257.          
  1258.            svp = hv_fetch(action, "psize", 5, FALSE);
  1259.    if (svp) {
  1260.                status = dbp->set_pagesize(dbp, SvIV(*svp)) ;
  1261.     }
  1262.          
  1263.            svp = hv_fetch(action, "lorder", 6, FALSE);
  1264.    if (svp) {
  1265.                status = dbp->set_lorder(dbp, SvIV(*svp)) ;
  1266.    }
  1268.     svp = hv_fetch(action, "bval", 4, FALSE);
  1269.             if (svp && SvOK(*svp))
  1270.             {
  1271. int value ;
  1272.                 if (SvPOK(*svp))
  1273.     value = (int)*SvPV(*svp, n_a) ;
  1274. else
  1275.     value = SvIV(*svp) ;
  1277. if (fixed) {
  1278.     status = dbp->set_re_pad(dbp, value) ;
  1279. }
  1280. else {
  1281.     status = dbp->set_re_delim(dbp, value) ;
  1282. }
  1284.             }
  1286.    if (fixed) {
  1287.                svp = hv_fetch(action, "reclen", 6, FALSE);
  1288.        if (svp) {
  1289.    u_int32_t len =  (u_int32_t)SvIV(*svp) ;
  1290.                    status = dbp->set_re_len(dbp, len) ;
  1291.        }    
  1292.    }
  1293.          
  1294.     if (name != NULL) {
  1295.         status = dbp->set_re_source(dbp, name) ;
  1296.         name = NULL ;
  1297.     }
  1299.             svp = hv_fetch(action, "bfname", 6, FALSE); 
  1300.             if (svp && SvOK(*svp)) {
  1301. char * ptr = SvPV(*svp,n_a) ;
  1302. name = (char*) n_a ? ptr : NULL ;
  1303.     }
  1304.     else
  1305. name = NULL ;
  1306.          
  1308.     status = dbp->set_flags(dbp, DB_RENUMBER) ;
  1309.          
  1310. if (flags){
  1311.             (void)dbp->set_flags(dbp, flags) ;
  1312. }
  1313.             PrintRecno(info) ;
  1314.         }
  1315.         else
  1316.             croak("type is not of type DB_File::HASHINFO, DB_File::BTREEINFO or DB_File::RECNOINFO");
  1317.     }
  1319.     {
  1320.         int   Flags = 0 ;
  1321.         int status ;
  1323.         /* Map 1.x flags to 3.x flags */
  1324.         if ((flags & O_CREAT) == O_CREAT)
  1325.             Flags |= DB_CREATE ;
  1327. #if O_RDONLY == 0
  1328.         if (flags == O_RDONLY)
  1329. #else
  1330.         if ((flags & O_RDONLY) == O_RDONLY && (flags & O_RDWR) != O_RDWR)
  1331. #endif
  1332.             Flags |= DB_RDONLY ;
  1334. #ifdef O_TRUNC
  1335.         if ((flags & O_TRUNC) == O_TRUNC)
  1336.             Flags |= DB_TRUNCATE ;
  1337. #endif
  1339.         status = (RETVAL->dbp->open)(RETVAL->dbp, name, NULL, RETVAL->type, 
  1340.      Flags, mode) ; 
  1341. /* printf("open returned %d %sn", status, db_strerror(status)) ; */
  1343.         if (status == 0)
  1344.             status = (RETVAL->dbp->cursor)(RETVAL->dbp, NULL, &RETVAL->cursor,
  1345. 0) ;
  1346. /* printf("cursor returned %d %sn", status, db_strerror(status)) ; */
  1348.         if (status)
  1349.     RETVAL->dbp = NULL ;
  1351.     }
  1353.     return (RETVAL) ;
  1355. #endif /* Berkeley DB Version > 2 */
  1357. } /* ParseOpenInfo */
  1360. static double 
  1361. #ifdef CAN_PROTOTYPE
  1362. constant(char *name, int arg)
  1363. #else
  1364. constant(name, arg)
  1365. char *name;
  1366. int arg;
  1367. #endif
  1368. {
  1369.     errno = 0;
  1370.     switch (*name) {
  1371.     case 'A':
  1372. break;
  1373.     case 'B':
  1374. if (strEQ(name, "BTREEMAGIC"))
  1375. #ifdef BTREEMAGIC
  1376.     return BTREEMAGIC;
  1377. #else
  1378.     goto not_there;
  1379. #endif
  1380. if (strEQ(name, "BTREEVERSION"))
  1381. #ifdef BTREEVERSION
  1382.     return BTREEVERSION;
  1383. #else
  1384.     goto not_there;
  1385. #endif
  1386. break;
  1387.     case 'C':
  1388. break;
  1389.     case 'D':
  1390. if (strEQ(name, "DB_LOCK"))
  1391. #ifdef DB_LOCK
  1392.     return DB_LOCK;
  1393. #else
  1394.     goto not_there;
  1395. #endif
  1396. if (strEQ(name, "DB_SHMEM"))
  1397. #ifdef DB_SHMEM
  1398.     return DB_SHMEM;
  1399. #else
  1400.     goto not_there;
  1401. #endif
  1402. if (strEQ(name, "DB_TXN"))
  1403. #ifdef DB_TXN
  1404.     return (U32)DB_TXN;
  1405. #else
  1406.     goto not_there;
  1407. #endif
  1408. break;
  1409.     case 'E':
  1410. break;
  1411.     case 'F':
  1412. break;
  1413.     case 'G':
  1414. break;
  1415.     case 'H':
  1416. if (strEQ(name, "HASHMAGIC"))
  1417. #ifdef HASHMAGIC
  1418.     return HASHMAGIC;
  1419. #else
  1420.     goto not_there;
  1421. #endif
  1422. if (strEQ(name, "HASHVERSION"))
  1423. #ifdef HASHVERSION
  1424.     return HASHVERSION;
  1425. #else
  1426.     goto not_there;
  1427. #endif
  1428. break;
  1429.     case 'I':
  1430. break;
  1431.     case 'J':
  1432. break;
  1433.     case 'K':
  1434. break;
  1435.     case 'L':
  1436. break;
  1437.     case 'M':
  1438. if (strEQ(name, "MAX_PAGE_NUMBER"))
  1439. #ifdef MAX_PAGE_NUMBER
  1440.     return (U32)MAX_PAGE_NUMBER;
  1441. #else
  1442.     goto not_there;
  1443. #endif
  1444. if (strEQ(name, "MAX_PAGE_OFFSET"))
  1445. #ifdef MAX_PAGE_OFFSET
  1446.     return MAX_PAGE_OFFSET;
  1447. #else
  1448.     goto not_there;
  1449. #endif
  1450. if (strEQ(name, "MAX_REC_NUMBER"))
  1451. #ifdef MAX_REC_NUMBER
  1452.     return (U32)MAX_REC_NUMBER;
  1453. #else
  1454.     goto not_there;
  1455. #endif
  1456. break;
  1457.     case 'N':
  1458. break;
  1459.     case 'O':
  1460. break;
  1461.     case 'P':
  1462. break;
  1463.     case 'Q':
  1464. break;
  1465.     case 'R':
  1466. if (strEQ(name, "RET_ERROR"))
  1467. #ifdef RET_ERROR
  1468.     return RET_ERROR;
  1469. #else
  1470.     goto not_there;
  1471. #endif
  1472. if (strEQ(name, "RET_SPECIAL"))
  1473. #ifdef RET_SPECIAL
  1474.     return RET_SPECIAL;
  1475. #else
  1476.     goto not_there;
  1477. #endif
  1478. if (strEQ(name, "RET_SUCCESS"))
  1479. #ifdef RET_SUCCESS
  1480.     return RET_SUCCESS;
  1481. #else
  1482.     goto not_there;
  1483. #endif
  1484. if (strEQ(name, "R_CURSOR"))
  1485. #ifdef R_CURSOR
  1486.     return R_CURSOR;
  1487. #else
  1488.     goto not_there;
  1489. #endif
  1490. if (strEQ(name, "R_DUP"))
  1491. #ifdef R_DUP
  1492.     return R_DUP;
  1493. #else
  1494.     goto not_there;
  1495. #endif
  1496. if (strEQ(name, "R_FIRST"))
  1497. #ifdef R_FIRST
  1498.     return R_FIRST;
  1499. #else
  1500.     goto not_there;
  1501. #endif
  1502. if (strEQ(name, "R_FIXEDLEN"))
  1503. #ifdef R_FIXEDLEN
  1504.     return R_FIXEDLEN;
  1505. #else
  1506.     goto not_there;
  1507. #endif
  1508. if (strEQ(name, "R_IAFTER"))
  1509. #ifdef R_IAFTER
  1510.     return R_IAFTER;
  1511. #else
  1512.     goto not_there;
  1513. #endif
  1514. if (strEQ(name, "R_IBEFORE"))
  1515. #ifdef R_IBEFORE
  1516.     return R_IBEFORE;
  1517. #else
  1518.     goto not_there;
  1519. #endif
  1520. if (strEQ(name, "R_LAST"))
  1521. #ifdef R_LAST
  1522.     return R_LAST;
  1523. #else
  1524.     goto not_there;
  1525. #endif
  1526. if (strEQ(name, "R_NEXT"))
  1527. #ifdef R_NEXT
  1528.     return R_NEXT;
  1529. #else
  1530.     goto not_there;
  1531. #endif
  1532. if (strEQ(name, "R_NOKEY"))
  1533. #ifdef R_NOKEY
  1534.     return R_NOKEY;
  1535. #else
  1536.     goto not_there;
  1537. #endif
  1538. if (strEQ(name, "R_NOOVERWRITE"))
  1539. #ifdef R_NOOVERWRITE
  1540.     return R_NOOVERWRITE;
  1541. #else
  1542.     goto not_there;
  1543. #endif
  1544. if (strEQ(name, "R_PREV"))
  1545. #ifdef R_PREV
  1546.     return R_PREV;
  1547. #else
  1548.     goto not_there;
  1549. #endif
  1550. if (strEQ(name, "R_RECNOSYNC"))
  1551. #ifdef R_RECNOSYNC
  1552.     return R_RECNOSYNC;
  1553. #else
  1554.     goto not_there;
  1555. #endif
  1556. if (strEQ(name, "R_SETCURSOR"))
  1557. #ifdef R_SETCURSOR
  1558.     return R_SETCURSOR;
  1559. #else
  1560.     goto not_there;
  1561. #endif
  1562. if (strEQ(name, "R_SNAPSHOT"))
  1563. #ifdef R_SNAPSHOT
  1564.     return R_SNAPSHOT;
  1565. #else
  1566.     goto not_there;
  1567. #endif
  1568. break;
  1569.     case 'S':
  1570. break;
  1571.     case 'T':
  1572. break;
  1573.     case 'U':
  1574. break;
  1575.     case 'V':
  1576. break;
  1577.     case 'W':
  1578. break;
  1579.     case 'X':
  1580. break;
  1581.     case 'Y':
  1582. break;
  1583.     case 'Z':
  1584. break;
  1585.     case '_':
  1586. break;
  1587.     }
  1588.     errno = EINVAL;
  1589.     return 0;
  1591. not_there:
  1592.     errno = ENOENT;
  1593.     return 0;
  1594. }
  1596. MODULE = DB_File PACKAGE = DB_File PREFIX = db_
  1598. BOOT:
  1599.   {
  1600.     __getBerkeleyDBInfo() ;
  1601.  
  1602.     DBT_clear(empty) ; 
  1603.     empty.data = &zero ;
  1604.     empty.size =  sizeof(recno_t) ;
  1605.   }
  1607. double
  1608. constant(name,arg)
  1609. char * name
  1610. int arg
  1613. DB_File
  1614. db_DoTie_(isHASH, dbtype, name=undef, flags=O_CREAT|O_RDWR, mode=0666, type=DB_HASH)
  1615. int isHASH
  1616. char * dbtype
  1617. int flags
  1618. int mode
  1619. CODE:
  1620. {
  1621.     char * name = (char *) NULL ; 
  1622.     SV * sv = (SV *) NULL ; 
  1623.     STRLEN n_a;
  1625.     if (items >= 3 && SvOK(ST(2))) 
  1626.         name = (char*) SvPV(ST(2), n_a) ; 
  1628.             if (items == 6)
  1629.         sv = ST(5) ;
  1631.     RETVAL = ParseOpenInfo(aTHX_ isHASH, name, flags, mode, sv) ;
  1632.     if (RETVAL->dbp == NULL)
  1633.         RETVAL = NULL ;
  1634. }
  1635. OUTPUT:
  1636.     RETVAL
  1638. int
  1639. db_DESTROY(db)
  1640. DB_File db
  1641. INIT:
  1642.   CurrentDB = db ;
  1643. CLEANUP:
  1644.   if (db->hash)
  1645.     SvREFCNT_dec(db->hash) ;
  1646.   if (db->compare)
  1647.     SvREFCNT_dec(db->compare) ;
  1648.   if (db->prefix)
  1649.     SvREFCNT_dec(db->prefix) ;
  1650. #ifdef DBM_FILTERING
  1651.   if (db->filter_fetch_key)
  1652.     SvREFCNT_dec(db->filter_fetch_key) ;
  1653.   if (db->filter_store_key)
  1654.     SvREFCNT_dec(db->filter_store_key) ;
  1655.   if (db->filter_fetch_value)
  1656.     SvREFCNT_dec(db->filter_fetch_value) ;
  1657.   if (db->filter_store_value)
  1658.     SvREFCNT_dec(db->filter_store_value) ;
  1659. #endif /* DBM_FILTERING */
  1660.   safefree(db) ;
  1661. #ifdef DB_VERSION_MAJOR
  1662.   if (RETVAL > 0)
  1663.     RETVAL = -1 ;
  1664. #endif
  1667. int
  1668. db_DELETE(db, key, flags=0)
  1669. DB_File db
  1670. DBTKEY key
  1671. u_int flags
  1672. INIT:
  1673.   CurrentDB = db ;
  1676. int
  1677. db_EXISTS(db, key)
  1678. DB_File db
  1679. DBTKEY key
  1680. CODE:
  1681. {
  1682.           DBT value ;
  1684.   DBT_clear(value) ; 
  1685.   CurrentDB = db ;
  1686.   RETVAL = (((db->dbp)->get)(db->dbp, TXN &key, &value, 0) == 0) ;
  1687. }
  1688. OUTPUT:
  1689.   RETVAL
  1691. int
  1692. db_FETCH(db, key, flags=0)
  1693. DB_File db
  1694. DBTKEY key
  1695. u_int flags
  1696. CODE:
  1697. {
  1698.             DBT value ;
  1700.     DBT_clear(value) ; 
  1701.     CurrentDB = db ;
  1702.     /* RETVAL = ((db->dbp)->get)(db->dbp, TXN &key, &value, flags) ; */
  1703.     RETVAL = db_get(db, key, value, flags) ;
  1704.     ST(0) = sv_newmortal();
  1705.     OutputValue(ST(0), value)
  1706. }
  1708. int
  1709. db_STORE(db, key, value, flags=0)
  1710. DB_File db
  1711. DBTKEY key
  1712. DBT value
  1713. u_int flags
  1714. INIT:
  1715.   CurrentDB = db ;
  1718. int
  1719. db_FIRSTKEY(db)
  1720. DB_File db
  1721. CODE:
  1722. {
  1723.     DBTKEY key ;
  1724.     DBT value ;
  1726.     DBT_clear(key) ; 
  1727.     DBT_clear(value) ; 
  1728.     CurrentDB = db ;
  1729.     RETVAL = do_SEQ(db, key, value, R_FIRST) ;
  1730.     ST(0) = sv_newmortal();
  1731.     OutputKey(ST(0), key) ;
  1732. }
  1734. int
  1735. db_NEXTKEY(db, key)
  1736. DB_File db
  1737. DBTKEY key
  1738. CODE:
  1739. {
  1740.     DBT value ;
  1742.     DBT_clear(value) ; 
  1743.     CurrentDB = db ;
  1744.     RETVAL = do_SEQ(db, key, value, R_NEXT) ;
  1745.     ST(0) = sv_newmortal();
  1746.     OutputKey(ST(0), key) ;
  1747. }
  1749. #
  1750. # These would be nice for RECNO
  1751. #
  1753. int
  1754. unshift(db, ...)
  1755. DB_File db
  1756. ALIAS: UNSHIFT = 1
  1757. CODE:
  1758. {
  1759.     DBTKEY key ;
  1760.     DBT value ;
  1761.     int i ;
  1762.     int One ;
  1763.     DB * Db = db->dbp ;
  1764.     STRLEN n_a;
  1766.     DBT_clear(key) ; 
  1767.     DBT_clear(value) ; 
  1768.     CurrentDB = db ;
  1769. #ifdef DB_VERSION_MAJOR
  1770.     /* get the first value */
  1771.     RETVAL = do_SEQ(db, key, value, DB_FIRST) ;  
  1772.     RETVAL = 0 ;
  1773. #else
  1774.     RETVAL = -1 ;
  1775. #endif
  1776.     for (i = items-1 ; i > 0 ; --i)
  1777.     {
  1778.         value.data = SvPV(ST(i), n_a) ;
  1779.         value.size = n_a ;
  1780.         One = 1 ;
  1781.         key.data = &One ;
  1782.         key.size = sizeof(int) ;
  1783. #ifdef DB_VERSION_MAJOR
  1784.             RETVAL = (db->cursor->c_put)(db->cursor, &key, &value, DB_BEFORE) ;
  1785. #else
  1786.         RETVAL = (Db->put)(Db, &key, &value, R_IBEFORE) ;
  1787. #endif
  1788.         if (RETVAL != 0)
  1789.             break;
  1790.     }
  1791. }
  1792. OUTPUT:
  1793.     RETVAL
  1795. I32
  1796. pop(db)
  1797. DB_File db
  1798. ALIAS: POP = 1
  1799. CODE:
  1800. {
  1801.     DBTKEY key ;
  1802.     DBT value ;
  1804.     DBT_clear(key) ; 
  1805.     DBT_clear(value) ; 
  1806.     CurrentDB = db ;
  1808.     /* First get the final value */
  1809.     RETVAL = do_SEQ(db, key, value, R_LAST) ;  
  1810.     ST(0) = sv_newmortal();
  1811.     /* Now delete it */
  1812.     if (RETVAL == 0)
  1813.     {
  1814. /* the call to del will trash value, so take a copy now */
  1815. OutputValue(ST(0), value) ;
  1816.         RETVAL = db_del(db, key, R_CURSOR) ;
  1817.         if (RETVAL != 0) 
  1818.             sv_setsv(ST(0), &PL_sv_undef); 
  1819.     }
  1820. }
  1822. I32
  1823. shift(db)
  1824. DB_File db
  1825. ALIAS: SHIFT = 1
  1826. CODE:
  1827. {
  1828.     DBT value ;
  1829.     DBTKEY key ;
  1831.     DBT_clear(key) ; 
  1832.     DBT_clear(value) ; 
  1833.     CurrentDB = db ;
  1834.     /* get the first value */
  1835.     RETVAL = do_SEQ(db, key, value, R_FIRST) ;  
  1836.     ST(0) = sv_newmortal();
  1837.     /* Now delete it */
  1838.     if (RETVAL == 0)
  1839.     {
  1840. /* the call to del will trash value, so take a copy now */
  1841. OutputValue(ST(0), value) ;
  1842.         RETVAL = db_del(db, key, R_CURSOR) ;
  1843.         if (RETVAL != 0)
  1844.             sv_setsv (ST(0), &PL_sv_undef) ;
  1845.     }
  1846. }
  1849. I32
  1850. push(db, ...)
  1851. DB_File db
  1852. ALIAS: PUSH = 1
  1853. CODE:
  1854. {
  1855.     DBTKEY key ;
  1856.     DBT value ;
  1857.     DB * Db = db->dbp ;
  1858.     int i ;
  1859.     STRLEN n_a;
  1860.     int keyval ;
  1862.     DBT_flags(key) ; 
  1863.     DBT_flags(value) ; 
  1864.     CurrentDB = db ;
  1865.     /* Set the Cursor to the Last element */
  1866.     RETVAL = do_SEQ(db, key, value, R_LAST) ;
  1867. #ifndef DB_VERSION_MAJOR          
  1868.     if (RETVAL >= 0)
  1869. #endif     
  1870.     {
  1871.      if (RETVAL == 0)
  1872.     keyval = *(int*)key.data ;
  1873. else
  1874.     keyval = 0 ;
  1875.         for (i = 1 ; i < items ; ++i)
  1876.         {
  1877.             value.data = SvPV(ST(i), n_a) ;
  1878.             value.size = n_a ;
  1879.     ++ keyval ;
  1880.             key.data = &keyval ;
  1881.             key.size = sizeof(int) ;
  1882.     RETVAL = (Db->put)(Db, TXN &key, &value, 0) ;
  1883.             if (RETVAL != 0)
  1884.                 break;
  1885.         }
  1886.     }
  1887. }
  1888. OUTPUT:
  1889.     RETVAL
  1891. I32
  1892. length(db)
  1893. DB_File db
  1894. ALIAS: FETCHSIZE = 1
  1895. CODE:
  1896.     CurrentDB = db ;
  1897.     RETVAL = GetArrayLength(aTHX_ db) ;
  1898. OUTPUT:
  1899.     RETVAL
  1902. #
  1903. # Now provide an interface to the rest of the DB functionality
  1904. #
  1906. int
  1907. db_del(db, key, flags=0)
  1908. DB_File db
  1909. DBTKEY key
  1910. u_int flags
  1911. CODE:
  1912.   CurrentDB = db ;
  1913.   RETVAL = db_del(db, key, flags) ;
  1914. #ifdef DB_VERSION_MAJOR
  1915.   if (RETVAL > 0)
  1916.     RETVAL = -1 ;
  1917.   else if (RETVAL == DB_NOTFOUND)
  1918.     RETVAL = 1 ;
  1919. #endif
  1920. OUTPUT:
  1921.   RETVAL
  1924. int
  1925. db_get(db, key, value, flags=0)
  1926. DB_File db
  1927. DBTKEY key
  1928. DBT value = NO_INIT
  1929. u_int flags
  1930. CODE:
  1931.   CurrentDB = db ;
  1932.   DBT_clear(value) ; 
  1933.   RETVAL = db_get(db, key, value, flags) ;
  1934. #ifdef DB_VERSION_MAJOR
  1935.   if (RETVAL > 0)
  1936.     RETVAL = -1 ;
  1937.   else if (RETVAL == DB_NOTFOUND)
  1938.     RETVAL = 1 ;
  1939. #endif
  1940. OUTPUT:
  1941.   RETVAL
  1942.   value
  1944. int
  1945. db_put(db, key, value, flags=0)
  1946. DB_File db
  1947. DBTKEY key
  1948. DBT value
  1949. u_int flags
  1950. CODE:
  1951.   CurrentDB = db ;
  1952.   RETVAL = db_put(db, key, value, flags) ;
  1953. #ifdef DB_VERSION_MAJOR
  1954.   if (RETVAL > 0)
  1955.     RETVAL = -1 ;
  1956.   else if (RETVAL == DB_KEYEXIST)
  1957.     RETVAL = 1 ;
  1958. #endif
  1959. OUTPUT:
  1960.   RETVAL
  1961.   key if (flagSet(flags, R_IAFTER) || flagSet(flags, R_IBEFORE)) OutputKey(ST(1), key);
  1963. int
  1964. db_fd(db)
  1965. DB_File db
  1966. int status = 0 ;
  1967. CODE:
  1968.   CurrentDB = db ;
  1969. #ifdef DB_VERSION_MAJOR
  1970.   RETVAL = -1 ;
  1971.   status = (db->in_memory
  1972. ? -1 
  1973. : ((db->dbp)->fd)(db->dbp, &RETVAL) ) ;
  1974.   if (status != 0)
  1975.     RETVAL = -1 ;
  1976. #else
  1977.   RETVAL = (db->in_memory
  1978. ? -1 
  1979. : ((db->dbp)->fd)(db->dbp) ) ;
  1980. #endif
  1981. OUTPUT:
  1982.   RETVAL
  1984. int
  1985. db_sync(db, flags=0)
  1986. DB_File db
  1987. u_int flags
  1988. CODE:
  1989.   CurrentDB = db ;
  1990.   RETVAL = db_sync(db, flags) ;
  1991. #ifdef DB_VERSION_MAJOR
  1992.   if (RETVAL > 0)
  1993.     RETVAL = -1 ;
  1994. #endif
  1995. OUTPUT:
  1996.   RETVAL
  1999. int
  2000. db_seq(db, key, value, flags)
  2001. DB_File db
  2002. DBTKEY key 
  2003. DBT value = NO_INIT
  2004. u_int flags
  2005. CODE:
  2006.   CurrentDB = db ;
  2007.   DBT_clear(value) ; 
  2008.   RETVAL = db_seq(db, key, value, flags);
  2009. #ifdef DB_VERSION_MAJOR
  2010.   if (RETVAL > 0)
  2011.     RETVAL = -1 ;
  2012.   else if (RETVAL == DB_NOTFOUND)
  2013.     RETVAL = 1 ;
  2014. #endif
  2015. OUTPUT:
  2016.   RETVAL
  2017.   key
  2018.   value
  2020. #ifdef DBM_FILTERING
  2022. #define setFilter(type)
  2023. {
  2024.     if (db->type)
  2025.         RETVAL = sv_mortalcopy(db->type) ;
  2026.     ST(0) = RETVAL ;
  2027.     if (db->type && (code == &PL_sv_undef)) {
  2028.                 SvREFCNT_dec(db->type) ;
  2029.         db->type = NULL ;
  2030.     }
  2031.     else if (code) {
  2032.         if (db->type)
  2033.             sv_setsv(db->type, code) ;
  2034.         else
  2035.             db->type = newSVsv(code) ;
  2036.     }     
  2037. }
  2040. SV *
  2041. filter_fetch_key(db, code)
  2042. DB_File db
  2043. SV * code
  2044. SV * RETVAL = &PL_sv_undef ;
  2045. CODE:
  2046.     setFilter(filter_fetch_key) ;
  2048. SV *
  2049. filter_store_key(db, code)
  2050. DB_File db
  2051. SV * code
  2052. SV * RETVAL = &PL_sv_undef ;
  2053. CODE:
  2054.     setFilter(filter_store_key) ;
  2056. SV *
  2057. filter_fetch_value(db, code)
  2058. DB_File db
  2059. SV * code
  2060. SV * RETVAL = &PL_sv_undef ;
  2061. CODE:
  2062.     setFilter(filter_fetch_value) ;
  2064. SV *
  2065. filter_store_value(db, code)
  2066. DB_File db
  2067. SV * code
  2068. SV * RETVAL = &PL_sv_undef ;
  2069. CODE:
  2070.     setFilter(filter_store_value) ;
  2072. #endif /* DBM_FILTERING */