TrDb Class Reference

opens and closes the primary and all secondary Berkeley dbs that are the underlying storage for a single GeneralData class. More...

#include <trdb.h>

Collaboration diagram for TrDb:

[legend]List of all members.

Public Types
typedef std::map< std::string, Index >	IndexMap
Public Member Functions
	TrDb (DbEnv *, std::string, IndexMap i)
	~TrDb ()
Index	secondaryIndex (std::string index)
Dbc *	createPrimaryCursor ()
Db *	primaryDb ()
void	open ()
void	close ()
void	sync ()
QString	statistics ()
Private Attributes
std::string	m_name
Db *	db
QString	lastErrPfxStr
QString	lastErrMsgStr
IndexMap	indexMap
DbEnv *	dbenv
Classes
struct	Index
	this defines a secondary index. More...

---

Detailed Description

opens and closes the primary and all secondary Berkeley dbs that are the underlying storage for a single GeneralData class.

Definition at line 34 of file trdb.h.

---

Member Typedef Documentation

typedef std::map<std::string, Index> TrDb::IndexMap

Definition at line 84 of file trdb.h.

---

Constructor & Destructor Documentation

TrDb::TrDb	(	DbEnv *	,
		std::string	,
		IndexMap	i
	)

TrDb::~TrDb

(

)

Definition at line 24 of file trdb.cpp.

{
//   cerr<<"~TrDb() "<<endl;
//   cerr<<"Bye ~TrDb() "<<endl;
}

---

Member Function Documentation

TrDb::Index TrDb::secondaryIndex

(

std::string

index

)

Definition at line 115 of file trdb.cpp.

References indexMap.

Referenced by Database::SecondaryIterator< T >::SecondaryIterator().

{
  Index index = indexMap[str];
  return index;
}

Dbc * TrDb::createPrimaryCursor

(

)

Definition at line 126 of file trdb.cpp.

References db.

{
    Dbc * cursor = NULL;
    if ( db )
    {
        cerr << "in cursor open" << endl;
        int ret;
        ret = db->cursor(NULL, &cursor, 0);
    }
    if ( cursor == NULL )
    {
        cerr << "cursor was null" << endl;
    }
    return cursor;
}

Db * TrDb::primaryDb

(

)

Definition at line 121 of file trdb.cpp.

References db.

Referenced by Database::Creator< T >::Creator(), and Database::PrimaryIterator< T >::PrimaryIterator().

{
    return db;
}

void TrDb::open

(

)

Definition at line 56 of file trdb.cpp.

References db, dbenv, indexMap, m_name, and QDir::mkdir().

Referenced by TrapperDoc::openDbs().

{
//   cerr<<"opening trdb"<<endl;
  string fileName = m_name + "/primary";
  int ret;
  db = new Db(dbenv, 0);
  db->set_error_stream(&std::cerr);
  db->set_errpfx( fileName.c_str() );
  db->set_pagesize(1024);
  if (( ret = db->open( NULL, fileName.c_str() , NULL, DB_RECNO, DB_CREATE , 0664) ) != 0 ) {
    string message = "in function TrDb::open() calling db->open with filename = \"" + fileName + "\"";
    db->err(ret, message.c_str());

    /*  err( ret , NULL );*/
  }
  string secondaryDir = m_name + "/secondary";
  QDir dir;
  dir.mkdir( secondaryDir.c_str(), true);
  
  TrDb::IndexMap::iterator it;
  
  for ( it = indexMap.begin(); it != indexMap.end(); ++it) {
    Db * idb = new Db(dbenv, DB_CXX_NO_EXCEPTIONS );
    
    it->second.db = idb;
    string indexDbFileName = secondaryDir + "/"+  it->first;
    idb->set_errpfx( indexDbFileName.c_str() );
    //         cerr << "setting error prefix for file" <<  indexDbFileName.c_str() << endl;
    idb->set_error_stream(&std::cerr);
    //         cerr << "a1" << endl;
    idb->set_flags(DB_DUP);
    //         cerr << "a2" << endl;
    idb->set_bt_compare( it->second.bt_compare_func );
    //         cerr << "a3" << endl;
    if (( ret = idb->open( NULL, indexDbFileName.c_str(), NULL, DB_BTREE,
                           DB_CREATE, 0664) ) != 0 ) {
      string message = "in function TrDb::open() calling idb->open with filename = \"" + indexDbFileName + "\"";
      idb->err(ret, message.c_str() );  /*  err( ret , NULL );*/
    }
    //         cerr << "a4" << endl;
    /* Associate the secondary with the primary. */
    if ((ret = db->associate(NULL,idb, it->second.associate_func , DB_CREATE)) != 0) {
      db->err(ret, "in function TrDb::open() calling db->associate");  /*  err( ret , NULL );*/
      /*  err( ret , NULL );*/
    }
    //         cerr << "a5" << endl;
  }
  return;
}

void TrDb::close

(

)

Definition at line 36 of file trdb.cpp.

References db, and indexMap.

{
    /* close secondary indeces first and then the primary.
       I beleive this order is correct, although I didn't find
       a clear statement about it in the berkeley db docs */
  
//   cerr<<"closing trdb"<<endl;
  TrDb::IndexMap::iterator it;
  for ( it = indexMap.begin(); it != indexMap.end(); ++it) {
    Db * db_sec = it->second.db;
    Q_CHECK_PTR( db_sec );
    db_sec->close(0);
    delete db_sec;
  }

  Q_CHECK_PTR( db );
  db->close(0);
  delete db;
}

void TrDb::sync

(

)

Definition at line 106 of file trdb.cpp.

References db.

{
  int ret;
  if ( ( ret = db->sync(0) ) != 0 )
    db->err(ret, "TrDb::sync(): Unable to flush db" );

}

QString TrDb::statistics

(

)

Definition at line 143 of file trdb.cpp.

References QString::arg(), db, and m_name.

{
    Q_CHECK_PTR( db );
    DB_BTREE_STAT *statp;
    db->stat(NULL, &statp, 0);
    QString str;
    QString database( m_name.c_str() );
    str = QString("database \"%1\" contains %2 records\n").arg(database).arg( (u_long)statp->bt_ndata );

    // Note: must use free, not delete.
    // This struct is allocated by C.
    //
    free(statp);

    return str;
}

---

Member Data Documentation

std::string TrDb::m_name [private]

Definition at line 95 of file trdb.h.

Referenced by open(), and statistics().

Db* TrDb::db [private]

Definition at line 96 of file trdb.h.

Referenced by close(), createPrimaryCursor(), open(), primaryDb(), statistics(), and sync().

QString TrDb::lastErrPfxStr [private]

Definition at line 97 of file trdb.h.

QString TrDb::lastErrMsgStr [private]

Definition at line 98 of file trdb.h.

IndexMap TrDb::indexMap [private]

Definition at line 99 of file trdb.h.

Referenced by close(), open(), and secondaryIndex().

DbEnv* TrDb::dbenv [private]

Definition at line 100 of file trdb.h.

Referenced by open().

---

The documentation for this class was generated from the following files:

• trdb.h
• trdb.cpp

---