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

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

MySQL数据库

开发平台：

Visual C++

db_cxx.h：源码内容
  1. /* DO NOT EDIT: automatically built by dist/s_win32. */
  2. /*-
  3.  * See the file LICENSE for redistribution information.
  4.  *
  5.  * Copyright (c) 1997-2002
  6.  * Sleepycat Software.  All rights reserved.
  7.  *
  8.  * $Id: db_cxx.in,v 11.113 2002/08/23 13:02:27 mjc Exp $
  9.  */
  11. #ifndef _DB_CXX_H_
  12. #define _DB_CXX_H_
  13. //
  14. // C++ assumptions:
  15. //
  16. // To ensure portability to many platforms, both new and old, we make
  17. // few assumptions about the C++ compiler and library.  For example,
  18. // we do not expect STL, templates or namespaces to be available.  The
  19. // "newest" C++ feature used is exceptions, which are used liberally
  20. // to transmit error information.  Even the use of exceptions can be
  21. // disabled at runtime, to do so, use the DB_CXX_NO_EXCEPTIONS flags
  22. // with the DbEnv or Db constructor.
  23. //
  24. // C++ naming conventions:
  25. //
  26. //  - All top level class names start with Db.
  27. //  - All class members start with lower case letter.
  28. //  - All private data members are suffixed with underscore.
  29. //  - Use underscores to divide names into multiple words.
  30. //  - Simple data accessors are named with get_ or set_ prefix.
  31. //  - All method names are taken from names of functions in the C
  32. //    layer of db (usually by dropping a prefix like "db_").
  33. //    These methods have the same argument types and order,
  34. //    other than dropping the explicit arg that acts as "this".
  35. //
  36. // As a rule, each DbFoo object has exactly one underlying DB_FOO struct
  37. // (defined in db.h) associated with it.  In some cases, we inherit directly
  38. // from the DB_FOO structure to make this relationship explicit.  Often,
  39. // the underlying C layer allocates and deallocates these structures, so
  40. // there is no easy way to add any data to the DbFoo class.  When you see
  41. // a comment about whether data is permitted to be added, this is what
  42. // is going on.  Of course, if we need to add data to such C++ classes
  43. // in the future, we will arrange to have an indirect pointer to the
  44. // DB_FOO struct (as some of the classes already have).
  45. //
  47. ////////////////////////////////////////////////////////////////
  48. ////////////////////////////////////////////////////////////////
  49. //
  50. // Forward declarations
  51. //
  53. #include <stdarg.h>
  55. #define HAVE_CXX_STDHEADERS 1
  56. #ifdef HAVE_CXX_STDHEADERS
  57. #include <iostream>
  58. #define __DB_OSTREAMCLASS std::ostream
  59. #else
  60. #include <iostream.h>
  61. #define __DB_OSTREAMCLASS ostream
  62. #endif
  64. #include "db.h"
  65. #include "cxx_common.h"
  66. #include "cxx_except.h"
  68. class Db;                                        // forward
  69. class Dbc;                                       // forward
  70. class DbEnv;                                     // forward
  71. class DbInfo;                                    // forward
  72. class DbLock;                                    // forward
  73. class DbLogc;                                    // forward
  74. class DbLsn;                                     // forward
  75. class DbMpoolFile;                               // forward
  76. class DbPreplist;                                // forward
  77. class Dbt;                                       // forward
  78. class DbTxn;                                     // forward
  80. // These classes are not defined here and should be invisible
  81. // to the user, but some compilers require forward references.
  82. // There is one for each use of the DEFINE_DB_CLASS macro.
  84. class DbImp;
  85. class DbEnvImp;
  86. class DbMpoolFileImp;
  87. class DbTxnImp;
  89. // DEFINE_DB_CLASS defines an imp_ data member and imp() accessor.
  90. // The underlying type is a pointer to an opaque *Imp class, that
  91. // gets converted to the correct implementation class by the implementation.
  92. //
  93. // Since these defines use "private/public" labels, and leave the access
  94. // being "private", we always use these by convention before any data
  95. // members in the private section of a class.  Keeping them in the
  96. // private section also emphasizes that they are off limits to user code.
  97. //
  98. #define DEFINE_DB_CLASS(name) 
  99. public: class name##Imp* imp() { return (imp_); } 
  100. public: const class name##Imp* constimp() const { return (imp_); } 
  101. private: class name##Imp* imp_
  103. ////////////////////////////////////////////////////////////////
  104. ////////////////////////////////////////////////////////////////
  105. //
  106. // Turn off inappropriate compiler warnings
  107. //
  109. #ifdef _MSC_VER
  111. // These are level 4 warnings that are explicitly disabled.
  112. // With Visual C++, by default you do not see above level 3 unless
  113. // you use /W4.  But we like to compile with the highest level
  114. // warnings to catch other errors.
  115. //
  116. // 4201: nameless struct/union
  117. //       triggered by standard include file <winnt.h>
  118. //
  119. // 4514: unreferenced inline function has been removed
  120. //       certain include files in MSVC define methods that are not called
  121. //
  122. #pragma warning(disable: 4201 4514)
  124. #endif
  126. // Some interfaces can be customized by allowing users to define
  127. // callback functions.  For performance and logistical reasons, some
  128. // callback functions must be declared in extern "C" blocks.  For others,
  129. // we allow you to declare the callbacks in C++ or C (or an extern "C"
  130. // block) as you wish.  See the set methods for the callbacks for
  131. // the choices.
  132. //
  133. extern "C" {
  134. typedef void * (*db_malloc_fcn_type)
  135. (size_t);
  136. typedef void * (*db_realloc_fcn_type)
  137. (void *, size_t);
  138. typedef void (*db_free_fcn_type)
  139. (void *);
  140. typedef int (*bt_compare_fcn_type)          /*C++ version available*/
  141. (DB *, const DBT *, const DBT *);
  142. typedef size_t (*bt_prefix_fcn_type)        /*C++ version available*/
  143. (DB *, const DBT *, const DBT *);
  144. typedef int (*dup_compare_fcn_type)         /*C++ version available*/
  145. (DB *, const DBT *, const DBT *);
  146. typedef u_int32_t (*h_hash_fcn_type)        /*C++ version available*/
  147. (DB *, const void *, u_int32_t);
  148. typedef int (*pgin_fcn_type)
  149. (DB_ENV *dbenv, db_pgno_t pgno, void *pgaddr, DBT *pgcookie);
  150. typedef int (*pgout_fcn_type)
  151. (DB_ENV *dbenv, db_pgno_t pgno, void *pgaddr, DBT *pgcookie);
  152. };
  154. ////////////////////////////////////////////////////////////////
  155. ////////////////////////////////////////////////////////////////
  156. //
  157. // Lock classes
  158. //
  160. class _exported DbLock
  161. {
  162. friend class DbEnv;
  164. public:
  165. DbLock();
  166. DbLock(const DbLock &);
  167. DbLock &operator = (const DbLock &);
  169. protected:
  170. // We can add data to this class if needed
  171. // since its contained class is not allocated by db.
  172. // (see comment at top)
  174. DbLock(DB_LOCK);
  175. DB_LOCK lock_;
  176. };
  178. ////////////////////////////////////////////////////////////////
  179. ////////////////////////////////////////////////////////////////
  180. //
  181. // Log classes
  182. //
  184. class _exported DbLsn : protected DB_LSN
  185. {
  186. friend class DbEnv;          // friendship needed to cast to base class
  187. friend class DbLogc;         // friendship needed to cast to base class
  188. };
  190. ////////////////////////////////////////////////////////////////
  191. ////////////////////////////////////////////////////////////////
  192. //
  193. // Memory pool classes
  194. //
  196. class _exported DbMpoolFile
  197. {
  198. friend class DbEnv;
  200. private:
  201. // Put this first to allow inlining with some C++ compilers (g++-2.95)
  202. DEFINE_DB_CLASS(DbMpoolFile);
  204. public:
  205. int close(u_int32_t flags);
  206. int get(db_pgno_t *pgnoaddr, u_int32_t flags, void *pagep);
  207. void last_pgno(db_pgno_t *pgnoaddr);
  208. int open(const char *file, u_int32_t flags, int mode, size_t pagesize);
  209. int put(void *pgaddr, u_int32_t flags);
  210. void refcnt(db_pgno_t *pgnoaddr);
  211. int set(void *pgaddr, u_int32_t flags);
  212. int set_clear_len(u_int32_t len);
  213. int set_fileid(u_int8_t *fileid);
  214. int set_ftype(int ftype);
  215. int set_lsn_offset(int32_t offset);
  216. int set_pgcookie(DBT *dbt);
  217. void set_unlink(int);
  218. int sync();
  220. virtual DB_MPOOLFILE *get_DB_MPOOLFILE()
  221. {
  222. return (DB_MPOOLFILE *)imp();
  223. }
  225. virtual const DB_MPOOLFILE *get_const_DB_MPOOLFILE() const
  226. {
  227. return (const DB_MPOOLFILE *)constimp();
  228. }
  230. private:
  231. // We can add data to this class if needed
  232. // since it is implemented via a pointer.
  233. // (see comment at top)
  235. // Note: use DbEnv::memp_fcreate() to get pointers to a DbMpoolFile,
  236. // and call DbMpoolFile::close() rather than delete to release them.
  237. //
  238. DbMpoolFile();
  240. // Shut g++ up.
  241. protected:
  242. virtual ~DbMpoolFile();
  244. private:
  245. // no copying
  246. DbMpoolFile(const DbMpoolFile &);
  247. void operator = (const DbMpoolFile &);
  248. };
  250. ////////////////////////////////////////////////////////////////
  251. ////////////////////////////////////////////////////////////////
  252. //
  253. // This is filled in and returned by the DbEnv::txn_recover() method.
  254. //
  256. class _exported DbPreplist
  257. {
  258. public:
  259. DbTxn *txn;
  260. u_int8_t gid[DB_XIDDATASIZE];
  261. };
  263. ////////////////////////////////////////////////////////////////
  264. ////////////////////////////////////////////////////////////////
  265. //
  266. // Transaction classes
  267. //
  269. class _exported DbTxn
  270. {
  271. friend class DbEnv;
  273. private:
  274. // Put this first to allow inlining with some C++ compilers (g++-2.95)
  275. DEFINE_DB_CLASS(DbTxn);
  277. public:
  278. int abort();
  279. int commit(u_int32_t flags);
  280. int discard(u_int32_t flags);
  281. u_int32_t id();
  282. int prepare(u_int8_t *gid);
  283. int set_timeout(db_timeout_t timeout, u_int32_t flags);
  285. virtual DB_TXN *get_DB_TXN()
  286. {
  287. return (DB_TXN *)imp();
  288. }
  290. virtual const DB_TXN *get_const_DB_TXN() const
  291. {
  292. return (const DB_TXN *)constimp();
  293. }
  295. static DbTxn* get_DbTxn(DB_TXN *txn)
  296. {
  297. return (DbTxn *)txn->api_internal;
  298. }
  300. static const DbTxn* get_const_DbTxn(const DB_TXN *txn)
  301. {
  302. return (const DbTxn *)txn->api_internal;
  303. }
  305. // For internal use only.
  306. static DbTxn* wrap_DB_TXN(DB_TXN *txn);
  308. private:
  309. // We can add data to this class if needed
  310. // since it is implemented via a pointer.
  311. // (see comment at top)
  313. // Note: use DbEnv::txn_begin() to get pointers to a DbTxn,
  314. // and call DbTxn::abort() or DbTxn::commit rather than
  315. // delete to release them.
  316. //
  317. DbTxn();
  318. // For internal use only.
  319. DbTxn(DB_TXN *txn);
  320. virtual ~DbTxn();
  322. // no copying
  323. DbTxn(const DbTxn &);
  324. void operator = (const DbTxn &);
  325. };
  327. //
  328. // Berkeley DB environment class.  Provides functions for opening databases.
  329. // User of this library can use this class as a starting point for
  330. // developing a DB application - derive their application class from
  331. // this one, add application control logic.
  332. //
  333. // Note that if you use the default constructor, you must explicitly
  334. // call appinit() before any other db activity (e.g. opening files)
  335. //
  336. class _exported DbEnv
  337. {
  338. friend class Db;
  339. friend class DbLock;
  340. friend class DbMpoolFile;
  342. private:
  343. // Put this first to allow inlining with some C++ compilers (g++-2.95)
  344. DEFINE_DB_CLASS(DbEnv);
  346. public:
  347. // After using this constructor, you can set any needed
  348. // parameters for the environment using the set_* methods.
  349. // Then call open() to finish initializing the environment
  350. // and attaching it to underlying files.
  351. //
  352. DbEnv(u_int32_t flags);
  354. virtual ~DbEnv();
  356. // These methods match those in the C interface.
  357. //
  358. virtual int close(u_int32_t);
  359. virtual int dbremove(DbTxn *txn, const char *name, const char *subdb,
  360.     u_int32_t flags);
  361. virtual int dbrename(DbTxn *txn, const char *name, const char *subdb,
  362.     const char *newname, u_int32_t flags);
  363. virtual void err(int, const char *, ...);
  364. virtual void errx(const char *, ...);
  365. virtual void *get_app_private() const;
  366. virtual int open(const char *, u_int32_t, int);
  367. virtual int remove(const char *, u_int32_t);
  368. virtual int set_alloc(db_malloc_fcn_type, db_realloc_fcn_type,
  369.       db_free_fcn_type);
  370. virtual void set_app_private(void *);
  371. virtual int set_cachesize(u_int32_t, u_int32_t, int);
  372. virtual int set_data_dir(const char *);
  373. virtual int set_encrypt(const char *, int);
  374. virtual void set_errcall(void (*)(const char *, char *));
  375. virtual void set_errfile(FILE *);
  376. virtual void set_errpfx(const char *);
  377. virtual int set_flags(u_int32_t, int);
  378. virtual int set_feedback(void (*)(DbEnv *, int, int));
  379. virtual int set_lg_bsize(u_int32_t);
  380. virtual int set_lg_dir(const char *);
  381. virtual int set_lg_max(u_int32_t);
  382. virtual int set_lg_regionmax(u_int32_t);
  383. virtual int set_lk_conflicts(u_int8_t *, int);
  384. virtual int set_lk_detect(u_int32_t);
  385. virtual int set_lk_max(u_int32_t);
  386. virtual int set_lk_max_lockers(u_int32_t);
  387. virtual int set_lk_max_locks(u_int32_t);
  388. virtual int set_lk_max_objects(u_int32_t);
  389. virtual int set_mp_mmapsize(size_t);
  390. virtual int set_paniccall(void (*)(DbEnv *, int));
  391. virtual int set_rpc_server(void *, char *, long, long, u_int32_t);
  392. virtual int set_shm_key(long);
  393. virtual int set_timeout(db_timeout_t timeout, u_int32_t flags);
  394. virtual int set_tmp_dir(const char *);
  395. virtual int set_tas_spins(u_int32_t);
  396. virtual int set_tx_max(u_int32_t);
  397. virtual int set_app_dispatch(int (*)(DbEnv *,
  398.     Dbt *, DbLsn *, db_recops));
  399. virtual int set_tx_timestamp(time_t *);
  400. virtual int set_verbose(u_int32_t which, int onoff);
  402. // Version information.  A static method so it can be obtained anytime.
  403. //
  404. static char *version(int *major, int *minor, int *patch);
  406. // Convert DB errors to strings
  407. static char *strerror(int);
  409. // If an error is detected and the error call function
  410. // or stream is set, a message is dispatched or printed.
  411. // If a prefix is set, each message is prefixed.
  412. //
  413. // You can use set_errcall() or set_errfile() above to control
  414. // error functionality.  Alternatively, you can call
  415. // set_error_stream() to force all errors to a C++ stream.
  416. // It is unwise to mix these approaches.
  417. //
  418. virtual void set_error_stream(__DB_OSTREAMCLASS *);
  420. // used internally
  421. static void runtime_error(const char *caller, int err,
  422.   int error_policy);
  423. static void runtime_error_dbt(const char *caller, Dbt *dbt,
  424.   int error_policy);
  425. static void runtime_error_lock_get(const char *caller, int err,
  426.   db_lockop_t op, db_lockmode_t mode,
  427.   const Dbt *obj, DbLock lock, int index,
  428.   int error_policy);
  430. // Lock functions
  431. //
  432. virtual int lock_detect(u_int32_t flags, u_int32_t atype, int *aborted);
  433. virtual int lock_get(u_int32_t locker, u_int32_t flags, const Dbt *obj,
  434.      db_lockmode_t lock_mode, DbLock *lock);
  435. virtual int lock_id(u_int32_t *idp);
  436. virtual int lock_id_free(u_int32_t id);
  437. virtual int lock_put(DbLock *lock);
  438. virtual int lock_stat(DB_LOCK_STAT **statp, u_int32_t flags);
  439. virtual int lock_vec(u_int32_t locker, u_int32_t flags, DB_LOCKREQ list[],
  440.      int nlist, DB_LOCKREQ **elistp);
  442. // Log functions
  443. //
  444. virtual int log_archive(char **list[], u_int32_t flags);
  445. static int log_compare(const DbLsn *lsn0, const DbLsn *lsn1);
  446. virtual int log_cursor(DbLogc **cursorp, u_int32_t flags);
  447. virtual int log_file(DbLsn *lsn, char *namep, size_t len);
  448. virtual int log_flush(const DbLsn *lsn);
  449. virtual int log_put(DbLsn *lsn, const Dbt *data, u_int32_t flags);
  451. virtual int log_stat(DB_LOG_STAT **spp, u_int32_t flags);
  453. // Mpool functions
  454. //
  455. virtual int memp_fcreate(DbMpoolFile **dbmfp, u_int32_t flags);
  456. virtual int memp_register(int ftype,
  457.   pgin_fcn_type pgin_fcn,
  458.   pgout_fcn_type pgout_fcn);
  459. virtual int memp_stat(DB_MPOOL_STAT
  460.       **gsp, DB_MPOOL_FSTAT ***fsp, u_int32_t flags);
  461. virtual int memp_sync(DbLsn *lsn);
  462. virtual int memp_trickle(int pct, int *nwrotep);
  464. // Transaction functions
  465. //
  466. virtual int txn_begin(DbTxn *pid, DbTxn **tid, u_int32_t flags);
  467. virtual int txn_checkpoint(u_int32_t kbyte, u_int32_t min, u_int32_t flags);
  468. virtual int txn_recover(DbPreplist *preplist, long count,
  469. long *retp, u_int32_t flags);
  470. virtual int txn_stat(DB_TXN_STAT **statp, u_int32_t flags);
  472. // Replication functions
  473. //
  474. virtual int rep_elect(int, int, u_int32_t, int *);
  475. virtual int rep_process_message(Dbt *, Dbt *, int *);
  476. virtual int rep_start(Dbt *, u_int32_t);
  477. virtual int rep_stat(DB_REP_STAT **statp, u_int32_t flags);
  478. virtual int set_rep_limit(u_int32_t, u_int32_t);
  479. virtual int set_rep_transport(u_int32_t,
  480.     int (*)(DbEnv *, const Dbt *, const Dbt *, int, u_int32_t));
  482. // Conversion functions
  483. //
  484. virtual DB_ENV *get_DB_ENV()
  485. {
  486. return (DB_ENV *)imp();
  487. }
  489. virtual const DB_ENV *get_const_DB_ENV() const
  490. {
  491. return (const DB_ENV *)constimp();
  492. }
  494. static DbEnv* get_DbEnv(DB_ENV *dbenv)
  495. {
  496. return (DbEnv *)dbenv->api1_internal;
  497. }
  499. static const DbEnv* get_const_DbEnv(const DB_ENV *dbenv)
  500. {
  501. return (const DbEnv *)dbenv->api1_internal;
  502. }
  504. // For internal use only.
  505. static DbEnv* wrap_DB_ENV(DB_ENV *dbenv);
  507. // These are public only because they need to be called
  508. // via C functions.  They should never be called by users
  509. // of this class.
  510. //
  511. static void _stream_error_function(const char *, char *);
  512. static int _app_dispatch_intercept(DB_ENV *env, DBT *dbt, DB_LSN *lsn,
  513. db_recops op);
  514. static void _paniccall_intercept(DB_ENV *env, int errval);
  515. static void _feedback_intercept(DB_ENV *env, int opcode, int pct);
  516. static int _rep_send_intercept(DB_ENV *env,
  517.        const DBT *cntrl, const DBT *data,
  518.        int id, u_int32_t flags);
  520. private:
  521. void cleanup();
  522. int initialize(DB_ENV *env);
  523. int error_policy();
  525. // For internal use only.
  526. DbEnv(DB_ENV *, u_int32_t flags);
  528. // no copying
  529. DbEnv(const DbEnv &);
  530. void operator = (const DbEnv &);
  532. // instance data
  533. int construct_error_;
  534. u_int32_t construct_flags_;
  535. int (*app_dispatch_callback_)(DbEnv *, Dbt *, DbLsn *, db_recops);
  536. void (*feedback_callback_)(DbEnv *, int, int);
  537. void (*paniccall_callback_)(DbEnv *, int);
  538. int (*pgin_callback_)(DbEnv *dbenv, db_pgno_t pgno,
  539.       void *pgaddr, Dbt *pgcookie);
  540. int (*pgout_callback_)(DbEnv *dbenv, db_pgno_t pgno,
  541.        void *pgaddr, Dbt *pgcookie);
  542. int (*rep_send_callback_)(DbEnv *,
  543.     const Dbt *, const Dbt *, int, u_int32_t);
  545. // class data
  546. static __DB_OSTREAMCLASS *error_stream_;
  547. };
  549. ////////////////////////////////////////////////////////////////
  550. ////////////////////////////////////////////////////////////////
  551. //
  552. // Table access classes
  553. //
  555. //
  556. // Represents a database table = a set of keys with associated values.
  557. //
  558. class _exported Db
  559. {
  560. friend class DbEnv;
  562. private:
  563. // Put this first to allow inlining with some C++ compilers (g++-2.95)
  564. DEFINE_DB_CLASS(Db);
  566. public:
  567. Db(DbEnv*, u_int32_t);      // create a Db object, then call open()
  568. virtual ~Db();              // does *not* call close.
  570. // These methods exactly match those in the C interface.
  571. //
  572. virtual int associate(DbTxn *txn, Db *secondary,
  573.     int (*callback)(Db *, const Dbt *, const Dbt *, Dbt *),
  574.     u_int32_t flags);
  575. virtual int close(u_int32_t flags);
  576.         virtual int cursor(DbTxn *txnid, Dbc **cursorp, u_int32_t flags);
  577. virtual int del(DbTxn *txnid, Dbt *key, u_int32_t flags);
  578. virtual void err(int, const char *, ...);
  579. virtual void errx(const char *, ...);
  580. virtual int fd(int *fdp);
  581. virtual int get(DbTxn *txnid, Dbt *key, Dbt *data, u_int32_t flags);
  582. virtual void *get_app_private() const;
  583. virtual int get_byteswapped(int *);
  584. virtual int get_type(DBTYPE *);
  585. virtual int join(Dbc **curslist, Dbc **dbcp, u_int32_t flags);
  586. virtual int key_range(DbTxn *, Dbt *, DB_KEY_RANGE *, u_int32_t);
  587. virtual int open(DbTxn *txnid,
  588.     const char *, const char *subname, DBTYPE, u_int32_t, int);
  589. virtual int pget(DbTxn *txnid, Dbt *key, Dbt *pkey, Dbt *data,
  590.  u_int32_t flags);
  591. virtual int put(DbTxn *, Dbt *, Dbt *, u_int32_t);
  592. virtual int remove(const char *, const char *, u_int32_t);
  593. virtual int rename(const char *, const char *, const char *, u_int32_t);
  594. virtual int set_alloc(db_malloc_fcn_type, db_realloc_fcn_type,
  595.       db_free_fcn_type);
  596. virtual void set_app_private(void *);
  597. virtual int set_append_recno(int (*)(Db *, Dbt *, db_recno_t));
  598. virtual int set_bt_compare(bt_compare_fcn_type); /*deprecated*/
  599. virtual int set_bt_compare(int (*)(Db *, const Dbt *, const Dbt *));
  600. virtual int set_bt_maxkey(u_int32_t);
  601. virtual int set_bt_minkey(u_int32_t);
  602. virtual int set_bt_prefix(bt_prefix_fcn_type); /*deprecated*/
  603. virtual int set_bt_prefix(size_t (*)(Db *, const Dbt *, const Dbt *));
  604. virtual int set_cachesize(u_int32_t, u_int32_t, int);
  605. virtual int set_cache_priority(DB_CACHE_PRIORITY);
  606. virtual int set_dup_compare(dup_compare_fcn_type); /*deprecated*/
  607. virtual int set_dup_compare(int (*)(Db *, const Dbt *, const Dbt *));
  608. virtual int set_encrypt(const char *, int);
  609. virtual void set_errcall(void (*)(const char *, char *));
  610. virtual void set_errfile(FILE *);
  611. virtual void set_errpfx(const char *);
  612. virtual int set_feedback(void (*)(Db *, int, int));
  613. virtual int set_flags(u_int32_t);
  614. virtual int set_h_ffactor(u_int32_t);
  615. virtual int set_h_hash(h_hash_fcn_type); /*deprecated*/
  616. virtual int set_h_hash(u_int32_t (*)(Db *, const void *, u_int32_t));
  617. virtual int set_h_nelem(u_int32_t);
  618. virtual int set_lorder(int);
  619. virtual int set_pagesize(u_int32_t);
  620. virtual int set_paniccall(void (*)(DbEnv *, int));
  621. virtual int set_re_delim(int);
  622. virtual int set_re_len(u_int32_t);
  623. virtual int set_re_pad(int);
  624. virtual int set_re_source(char *);
  625. virtual int set_q_extentsize(u_int32_t);
  626. virtual int stat(void *sp, u_int32_t flags);
  627. virtual int sync(u_int32_t flags);
  628. virtual int truncate(DbTxn *, u_int32_t *, u_int32_t);
  629. virtual int upgrade(const char *name, u_int32_t flags);
  630. virtual int verify(const char *, const char *, __DB_OSTREAMCLASS *, u_int32_t);
  632. // These additional methods are not in the C interface, and
  633. // are only available for C++.
  634. //
  635. virtual void set_error_stream(__DB_OSTREAMCLASS *);
  637. virtual DB *get_DB()
  638. {
  639. return (DB *)imp();
  640. }
  642. virtual const DB *get_const_DB() const
  643. {
  644. return (const DB *)constimp();
  645. }
  647. static Db* get_Db(DB *db)
  648. {
  649. return (Db *)db->api_internal;
  650. }
  652. static const Db* get_const_Db(const DB *db)
  653. {
  654. return (const Db *)db->api_internal;
  655. }
  657. private:
  658. // no copying
  659. Db(const Db &);
  660. Db &operator = (const Db &);
  662. void cleanup();
  663. int initialize();
  664. int error_policy();
  666. // instance data
  667. DbEnv *env_;
  668. int construct_error_;
  669. u_int32_t flags_;
  670. u_int32_t construct_flags_;
  672. public:
  673. // These are public only because they need to be called
  674. // via C callback functions.  They should never be used by
  675. // external users of this class.
  676. //
  677. int (*append_recno_callback_)(Db *, Dbt *, db_recno_t);
  678. int (*associate_callback_)(Db *, const Dbt *, const Dbt *, Dbt *);
  679. int (*bt_compare_callback_)(Db *, const Dbt *, const Dbt *);
  680. size_t (*bt_prefix_callback_)(Db *, const Dbt *, const Dbt *);
  681. int (*dup_compare_callback_)(Db *, const Dbt *, const Dbt *);
  682. void (*feedback_callback_)(Db *, int, int);
  683. u_int32_t (*h_hash_callback_)(Db *, const void *, u_int32_t);
  684. };
  686. //
  687. // A chunk of data, maybe a key or value.
  688. //
  689. class _exported Dbt : private DBT
  690. {
  691. friend class Dbc;
  692. friend class Db;
  693. friend class DbEnv;
  694. friend class DbLogc;
  696. public:
  698. // key/data
  699. void *get_data() const                 { return data; }
  700. void set_data(void *value)             { data = value; }
  702. // key/data length
  703. u_int32_t get_size() const             { return size; }
  704. void set_size(u_int32_t value)         { size = value; }
  706. // RO: length of user buffer.
  707. u_int32_t get_ulen() const             { return ulen; }
  708. void set_ulen(u_int32_t value)         { ulen = value; }
  710. // RO: get/put record length.
  711. u_int32_t get_dlen() const             { return dlen; }
  712. void set_dlen(u_int32_t value)         { dlen = value; }
  714. // RO: get/put record offset.
  715. u_int32_t get_doff() const             { return doff; }
  716. void set_doff(u_int32_t value)         { doff = value; }
  718. // flags
  719. u_int32_t get_flags() const            { return flags; }
  720. void set_flags(u_int32_t value)        { flags = value; }
  722. // Conversion functions
  723. DBT *get_DBT()                         { return (DBT *)this; }
  724. const DBT *get_const_DBT() const       { return (const DBT *)this; }
  726. static Dbt* get_Dbt(DBT *dbt)          { return (Dbt *)dbt; }
  727. static const Dbt* get_const_Dbt(const DBT *dbt)
  728.        { return (const Dbt *)dbt; }
  730. Dbt(void *data, u_int32_t size);
  731. Dbt();
  732. ~Dbt();
  733. Dbt(const Dbt &);
  734. Dbt &operator = (const Dbt &);
  736. private:
  737. // Note: no extra data appears in this class (other than
  738. // inherited from DBT) since we need DBT and Dbt objects
  739. // to have interchangable pointers.
  740. //
  741. // When subclassing this class, remember that callback
  742. // methods like bt_compare, bt_prefix, dup_compare may
  743. // internally manufacture DBT objects (which later are
  744. // cast to Dbt), so such callbacks might receive objects
  745. // not of your subclassed type.
  746. };
  748. class _exported Dbc : protected DBC
  749. {
  750. friend class Db;
  752. public:
  753. int close();
  754. int count(db_recno_t *countp, u_int32_t flags);
  755. int del(u_int32_t flags);
  756. int dup(Dbc** cursorp, u_int32_t flags);
  757. int get(Dbt* key, Dbt *data, u_int32_t flags);
  758. int pget(Dbt* key, Dbt* pkey, Dbt *data, u_int32_t flags);
  759. int put(Dbt* key, Dbt *data, u_int32_t flags);
  761. private:
  762. // No data is permitted in this class (see comment at top)
  764. // Note: use Db::cursor() to get pointers to a Dbc,
  765. // and call Dbc::close() rather than delete to release them.
  766. //
  767. Dbc();
  768. ~Dbc();
  770. // no copying
  771. Dbc(const Dbc &);
  772. Dbc &operator = (const Dbc &);
  773. };
  775. class _exported DbLogc : protected DB_LOGC
  776. {
  777. friend class DbEnv;
  779. public:
  780. int close(u_int32_t _flags);
  781. int get(DbLsn *lsn, Dbt *data, u_int32_t _flags);
  783. private:
  784. // No data is permitted in this class (see comment at top)
  786. // Note: use Db::cursor() to get pointers to a Dbc,
  787. // and call Dbc::close() rather than delete to release them.
  788. //
  789. DbLogc();
  790. ~DbLogc();
  792. // no copying
  793. DbLogc(const Dbc &);
  794. DbLogc &operator = (const Dbc &);
  795. };
  796. #endif /* !_DB_CXX_H_ */