librpmDb.cc

Go to the documentation of this file.

/*---------------------------------------------------------------------\
|                          ____ _   __ __ ___                          |
|                         |__  / \ / / . \ . \                         |
|                           / / \ V /|  _/  _/                         |
|                          / /__ | | | | | |                           |
|                         /_____||_| |_| |_|                           |
|                                                                      |
\---------------------------------------------------------------------*/
#include "librpm.h"

#include <iostream>

#include "zypp/base/Logger.h"
#include "zypp/target/rpm/librpmDb.h"
#include "zypp/target/rpm/RpmHeader.h"
#include "zypp/target/rpm/RpmException.h"

using namespace std;

namespace zypp
{
namespace target
{
namespace rpm
{
//
//      CLASS NAME : librpmDb::D
class librpmDb::D
{
  D & operator=( const D & ); // NO ASSIGNMENT!
  D ( const D & );            // NO COPY!
public:

  const Pathname _root;   // root directory for all operations
  const Pathname _dbPath; // directory (below root) that contains the rpmdb
  rpmdb          _db;     // database handle
  shared_ptr<RpmException> _error;  // database error

  friend ostream & operator<<( ostream & str, const D & obj )
  {
    str << "{" << obj._error  << "(" << obj._root << ")" << obj._dbPath << "}";
    return str;
  }

  D( const Pathname & root_r, const Pathname & dbPath_r, bool readonly_r )
      : _root  ( root_r )
      , _dbPath( dbPath_r )
      , _db    ( 0 )
  {
    _error.reset();
    // set %_dbpath macro
    ::addMacro( NULL, "_dbpath", NULL, _dbPath.asString().c_str(), RMIL_CMDLINE );
    const char * root = ( _root == "/" ? NULL : _root.asString().c_str() );
    int          perms = 0644;

    // check whether to create a new db
    PathInfo master( _root + _dbPath + "Packages" );
    if ( ! master.isFile() )
    {
      // init database
      int res = ::rpmdbInit( root, perms );
      if ( res )
      {
        ERR << "rpmdbInit error(" << res << "): " << *this << endl;
        _error = shared_ptr<RpmInitException>(new RpmInitException(_root, _dbPath));
        ZYPP_THROW(*_error);
      }
    }

    // open database
    int res = ::rpmdbOpen( root, &_db, (readonly_r ? O_RDONLY : O_RDWR ), perms );
    if ( res || !_db )
    {
      if ( _db )
      {
        ::rpmdbClose( _db );
        _db = 0;
      }
      ERR << "rpmdbOpen error(" << res << "): " << *this << endl;
      _error = shared_ptr<RpmDbOpenException>(new RpmDbOpenException(_root, _dbPath));
      ZYPP_THROW(*_error);
      return;
    }

    DBG << "DBACCESS " << *this << endl;
  }

  ~D()
  {
    if ( _db )
    {
      ::rpmdbClose( _db );
    }
  }
};


//
//      CLASS NAME : librpmDb (ststic interface)
//

Pathname         librpmDb::_defaultRoot  ( "/" );
Pathname         librpmDb::_defaultDbPath( "/var/lib/rpm" );
librpmDb::constPtr librpmDb::_defaultDb;
bool             librpmDb::_dbBlocked    ( true );

//
//
//      METHOD NAME : librpmDb::globalInit
//      METHOD TYPE : bool
//
bool librpmDb::globalInit()
{
  static bool initialized = false;

  if ( initialized )
    return true;

  int rc = ::rpmReadConfigFiles( NULL, NULL );
  if ( rc )
  {
    ERR << "rpmReadConfigFiles returned " << rc << endl;
    return false;
  }

  initialized = true; // Necessary to be able to use exand().

#define OUTVAL(n) << " (" #n ":" << expand( "%{" #n "}" ) << ")"
  MIL << "librpm init done:"
  OUTVAL(_target)
  OUTVAL(_dbpath)
  << endl;
#undef OUTVAL
  return initialized;
}

//
//
//      METHOD NAME : librpmDb::expand
//      METHOD TYPE : std::string
//
std::string librpmDb::expand( const std::string & macro_r )
{
  if ( ! globalInit() )
    return macro_r;  // unexpanded

  char * val = ::rpmExpand( macro_r.c_str(), NULL );
  if ( !val )
    return "";

  string ret( val );
  free( val );
  return ret;
}

//
//
//      METHOD NAME : librpmDb::newLibrpmDb
//      METHOD TYPE : librpmDb *
//
librpmDb * librpmDb::newLibrpmDb( Pathname root_r, Pathname dbPath_r, bool readonly_r )
{
  // check arguments
  if ( ! (root_r.absolute() && dbPath_r.absolute()) )
  {
    ZYPP_THROW(RpmInvalidRootException(root_r, dbPath_r));
  }

  // initialize librpm
  if ( ! globalInit() )
  {
    ZYPP_THROW(GlobalRpmInitException());
  }

  // open rpmdb
  librpmDb * ret = 0;
  try
  {
    ret = new librpmDb( root_r, dbPath_r, readonly_r );
  }
  catch (const RpmException & excpt_r)
  {
    ZYPP_CAUGHT(excpt_r);
    delete ret;
    ret = 0;
    ZYPP_RETHROW(excpt_r);
  }
  return ret;
}

//
//
//      METHOD NAME : librpmDb::dbAccess
//      METHOD TYPE : PMError
//
void librpmDb::dbAccess( const Pathname & root_r, const Pathname & dbPath_r )
{
  // check arguments
  if ( ! (root_r.absolute() && dbPath_r.absolute()) )
  {
    ZYPP_THROW(RpmInvalidRootException(root_r, dbPath_r));
  }

  if ( _defaultDb )
  {
    // already accessing a database: switching is not allowed.
    if ( _defaultRoot == root_r && _defaultDbPath == dbPath_r )
      return;
    else
    {
      ZYPP_THROW(RpmDbAlreadyOpenException(_defaultRoot, _defaultDbPath, root_r, dbPath_r));
    }
  }

  // got no database: we could switch to a new one (even if blocked!)
  _defaultRoot = root_r;
  _defaultDbPath = dbPath_r;
  MIL << "Set new database location: " << stringPath( _defaultRoot, _defaultDbPath ) << endl;

  return dbAccess();
}

//
//
//      METHOD NAME : librpmDb::dbAccess
//      METHOD TYPE : PMError
//
void librpmDb::dbAccess()
{
  if ( _dbBlocked )
  {
    ZYPP_THROW(RpmAccessBlockedException(_defaultRoot, _defaultDbPath));
  }

  if ( !_defaultDb )
  {
    // get access
    _defaultDb = newLibrpmDb( _defaultRoot, _defaultDbPath, /*readonly*/true );
  }
}

//
//
//      METHOD NAME : librpmDb::dbAccess
//      METHOD TYPE : PMError
//
void librpmDb::dbAccess( librpmDb::constPtr & ptr_r )
{
  try
  {
    dbAccess();
  }
  catch (const RpmException & excpt_r)
  {
    ZYPP_CAUGHT(excpt_r);
    ptr_r = 0;
    ZYPP_RETHROW(excpt_r);
  }
  ptr_r = _defaultDb;
}

//
//
//      METHOD NAME : librpmDb::dbRelease
//      METHOD TYPE : unsigned
//
unsigned librpmDb::dbRelease( bool force_r )
{
  if ( !_defaultDb )
  {
    return 0;
  }

  unsigned outstanding = _defaultDb->refCount() - 1; // refCount can't be 0

  switch ( outstanding )
  {
  default:
    if ( !force_r )
    {
      DBG << "dbRelease: keep access, outstanding " << outstanding << endl;
      break;
    }
    // else fall through:
  case 0:
    DBG << "dbRelease: release" << (force_r && outstanding ? "(forced)" : "")
    << ", outstanding " << outstanding << endl;

    _defaultDb->_d._error = shared_ptr<RpmAccessBlockedException>(new RpmAccessBlockedException(_defaultDb->_d._root, _defaultDb->_d._dbPath));
    // tag handle invalid
    _defaultDb = 0;
    break;
  }

  return outstanding;
}

//
//
//      METHOD NAME : librpmDb::blockAccess
//      METHOD TYPE : unsigned
//
unsigned librpmDb::blockAccess()
{
  MIL << "Block access" << endl;
  _dbBlocked = true;
  return dbRelease( /*force*/true );
}

//
//
//      METHOD NAME : librpmDb::unblockAccess
//      METHOD TYPE : void
//
void librpmDb::unblockAccess()
{
  MIL << "Unblock access" << endl;
  _dbBlocked = false;
}

//
//
//      METHOD NAME : librpmDb::dumpState
//      METHOD TYPE : ostream &
//
ostream & librpmDb::dumpState( ostream & str )
{
  if ( !_defaultDb )
  {
    return str << "[librpmDb " << (_dbBlocked?"BLOCKED":"CLOSED") << " " << stringPath( _defaultRoot, _defaultDbPath ) << "]";
  }
  return str << "[" << _defaultDb << "]";
}

//
//      CLASS NAME : librpmDb (internal database handle interface (nonstatic))
//

//
//
//      METHOD NAME : librpmDb::librpmDb
//      METHOD TYPE : Constructor
//
//      DESCRIPTION :
//
librpmDb::librpmDb( const Pathname & root_r, const Pathname & dbPath_r, bool readonly_r )
    : _d( * new D( root_r, dbPath_r, readonly_r ) )
{}

//
//
//      METHOD NAME : librpmDb::~librpmDb
//      METHOD TYPE : Destructor
//
//      DESCRIPTION :
//
librpmDb::~librpmDb()
{
  delete &_d;
}

//
//
//      METHOD NAME : librpmDb::unref_to
//      METHOD TYPE : void
//
void librpmDb::unref_to( unsigned refCount_r ) const
{
  if ( refCount_r == 1 )
  {
    dbRelease();
  }
}

//
//
//      METHOD NAME : librpmDb::root
//      METHOD TYPE : const Pathname &
//
const Pathname & librpmDb::root() const
{
  return _d._root;
}

//
//
//      METHOD NAME : librpmDb::dbPath
//      METHOD TYPE : const Pathname &
//
const Pathname & librpmDb::dbPath() const
{
  return _d._dbPath;
}

//
//
//      METHOD NAME : librpmDb::error
//      METHOD TYPE : PMError
//
shared_ptr<RpmException> librpmDb::error() const
{
  return _d._error;
}

//
//
//      METHOD NAME : librpmDb::empty
//      METHOD TYPE : bool
//
bool librpmDb::empty() const
{
  return( valid() && ! *db_const_iterator( this ) );
}

//
//
//      METHOD NAME : librpmDb::size
//      METHOD TYPE : unsigned
//
unsigned librpmDb::size() const
{
  unsigned count = 0;
  if ( valid() )
  {
#if defined(_RPM_4_4_COMPAT) || defined(_RPM_5)
    // looks like rpm-4.7 has no public dbi interface anymore
    int dbi = ::rpmdbOpen("/", &_d._db, O_RDONLY, 0);
    if (dbi == 0) {
        rpmdbMatchIterator mi = ::rpmdbInitIterator(_d._db, RPMTAG_NAME, NULL, 0);
        if (mi != NULL) {
            for (;;) {
                Header rpmHeader = ::rpmdbNextIterator(mi);
                if (rpmHeader != NULL)
                    ++count;
            }
        }
        ::rpmdbClose(_d._db);
    }
#else
    dbiIndex dbi = dbiOpen( _d._db, RPMTAG_NAME, 0 );
    if ( dbi )
    {
      DBC * dbcursor = 0;
      dbiCopen( dbi, dbi->dbi_txnid, &dbcursor, 0 );

      DBT key, data;
      memset( &key, 0, sizeof(key) );
      memset( &data, 0, sizeof(data) );
      while ( dbiGet( dbi, dbcursor, &key, &data, DB_NEXT ) == 0 )
        count += data.size / dbi->dbi_jlen;

      dbiCclose( dbi, dbcursor, 0 );
      /* no need to close dbi */
    }
#endif
  }
  return count;
}

//
//
//      METHOD NAME : librpmDb::dont_call_it
//      METHOD TYPE : void *
//
void * librpmDb::dont_call_it() const
{
  return _d._db;
}

//
//
//      METHOD NAME : librpmDb::dumpOn
//      METHOD TYPE : ostream &
//
//      DESCRIPTION :
//
ostream & librpmDb::dumpOn( ostream & str ) const
{
  ReferenceCounted::dumpOn( str ) << _d;
  return str;
}

//
//      CLASS NAME : librpmDb::DbDirInfo
//

//
//
//      METHOD NAME : librpmDb::DbDirInfo::DbDirInfo
//      METHOD TYPE : Constructor
//
librpmDb::DbDirInfo::DbDirInfo( const Pathname & root_r, const Pathname & dbPath_r )
    : _root( root_r )
    , _dbPath( dbPath_r )
{
  // check and adjust arguments
  if ( ! (root_r.absolute() && dbPath_r.absolute()) )
  {
    ERR << "Relative path for root(" << _root << ") or dbPath(" << _dbPath << ")" << endl;
  }
  else
  {
    _dbDir   ( _root + _dbPath );
    _dbV4    ( _dbDir.path() + "Packages" );
    _dbV3    ( _dbDir.path() + "packages.rpm" );
    _dbV3ToV4( _dbDir.path() + "packages.rpm3" );
    DBG << *this << endl;
  }
}

//
//
//      METHOD NAME : librpmDb::DbDirInfo::update
//      METHOD TYPE : void
//
void librpmDb::DbDirInfo::restat()
{
  _dbDir();
  _dbV4();
  _dbV3();
  _dbV3ToV4();
  DBG << *this << endl;
}

/******************************************************************
**
**
**      FUNCTION NAME : operator<<
**      FUNCTION TYPE : std::ostream &
*/
std::ostream & operator<<( std::ostream & str, const librpmDb::DbDirInfo & obj )
{
  if ( obj.illegalArgs() )
  {
    str << "ILLEGAL: '(" << obj.root() << ")" << obj.dbPath() << "'";
  }
  else
  {
    str << "'(" << obj.root() << ")" << obj.dbPath() << "':" << endl;
    str << "  Dir:    " << obj._dbDir << endl;
    str << "  V4:     " << obj._dbV4 << endl;
    str << "  V3:     " << obj._dbV3 << endl;
    str << "  V3ToV4: " << obj._dbV3ToV4;
  }
  return str;
}

//
//      CLASS NAME : librpmDb::db_const_iterator::D
class librpmDb::db_const_iterator::D
{
  D & operator=( const D & ); // NO ASSIGNMENT!
  D ( const D & );            // NO COPY!
public:

  librpmDb::constPtr     _dbptr;
  shared_ptr<RpmException> _dberr;

  RpmHeader::constPtr _hptr;
  rpmdbMatchIterator   _mi;

  D( librpmDb::constPtr dbptr_r )
      : _dbptr( dbptr_r )
      , _mi( 0 )
  {
    if ( !_dbptr )
    {
      try
      {
        librpmDb::dbAccess( _dbptr );
      }
      catch (const RpmException & excpt_r)
      {
        ZYPP_CAUGHT(excpt_r);
      }
      if ( !_dbptr )
      {
        WAR << "No database access: " << _dberr << endl;
      }
    }
    else
    {
      destroy(); // Checks whether _dbptr still valid
    }
  }

  ~D()
  {
    if ( _mi )
    {
      ::rpmdbFreeIterator( _mi );
    }
  }

  bool create( int rpmtag, const void * keyp = NULL, size_t keylen = 0 )
  {
    destroy();
    if ( ! _dbptr )
      return false;
    _mi = ::rpmdbInitIterator( _dbptr->_d._db, rpmTag(rpmtag), keyp, keylen );
    return _mi;
  }

  bool destroy()
  {
    if ( _mi )
    {
      _mi = ::rpmdbFreeIterator( _mi );
      _hptr = 0;
    }
    if ( _dbptr && _dbptr->error() )
    {
      _dberr = _dbptr->error();
      WAR << "Lost database access: " << _dberr << endl;
      _dbptr = 0;
    }
    return false;
  }

  bool advance()
  {
    if ( !_mi )
      return false;
    Header h = ::rpmdbNextIterator( _mi );
    if ( ! h )
    {
      destroy();
      return false;
    }
    _hptr = new RpmHeader( h );
    return true;
  }

  bool init( int rpmtag, const void * keyp = NULL, size_t keylen = 0 )
  {
    if ( ! create( rpmtag, keyp, keylen ) )
      return false;
    return advance();
  }

  bool set( int off_r )
  {
    if ( ! create( RPMDBI_PACKAGES ) )
      return false;
#warning TESTCASE: rpmdbAppendIterator and (non)sequential access?
    ::rpmdbAppendIterator( _mi, &off_r, 1 );
    return advance();
  }

  unsigned offset()
  {
    return( _mi ? ::rpmdbGetIteratorOffset( _mi ) : 0 );
  }

  int size()
  {
    if ( !_mi )
      return 0;
    int ret = ::rpmdbGetIteratorCount( _mi );
#warning TESTCASE: rpmdbGetIteratorCount returns 0 on sequential access?
    return( ret ? ret : -1 ); // -1: sequential access
  }
};


//
//      CLASS NAME : librpmDb::Ptr::db_const_iterator
//

//
//
//      METHOD NAME : librpmDb::db_const_iterator::db_iterator
//      METHOD TYPE : Constructor
//
librpmDb::db_const_iterator::db_const_iterator( librpmDb::constPtr dbptr_r )
    : _d( * new D( dbptr_r ) )
{
  findAll();
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::~db_const_iterator
//      METHOD TYPE : Destructor
//
librpmDb::db_const_iterator::~db_const_iterator()
{
  delete &_d;
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::operator++
//      METHOD TYPE : void
//
void librpmDb::db_const_iterator::operator++()
{
  _d.advance();
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::dbHdrNum
//      METHOD TYPE : unsigned
//
unsigned librpmDb::db_const_iterator::dbHdrNum() const
{
  return _d.offset();
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::operator*
//      METHOD TYPE : const RpmHeader::constPtr &
//
const RpmHeader::constPtr & librpmDb::db_const_iterator::operator*() const
{
  return _d._hptr;
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::dbError
//      METHOD TYPE : PMError
//
shared_ptr<RpmException> librpmDb::db_const_iterator::dbError() const
{
  if ( _d._dbptr )
    return _d._dbptr->error();

  return _d._dberr;
}

/******************************************************************
**
**
**      FUNCTION NAME : operator<<
**      FUNCTION TYPE : ostream &
*/
ostream & operator<<( ostream & str, const librpmDb::db_const_iterator & obj )
{
  str << "db_const_iterator(" << obj._d._dbptr
  << " Size:" << obj._d.size()
  << " HdrNum:" << obj._d.offset()
  << ")";
  return str;
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findAll
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findAll()
{
  return _d.init( RPMDBI_PACKAGES );
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findByFile
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findByFile( const std::string & file_r )
{
  return _d.init( RPMTAG_BASENAMES, file_r.c_str() );
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findByProvides
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findByProvides( const std::string & tag_r )
{
  return _d.init( RPMTAG_PROVIDENAME, tag_r.c_str() );
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findByRequiredBy
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findByRequiredBy( const std::string & tag_r )
{
  return _d.init( RPMTAG_REQUIRENAME, tag_r.c_str() );
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findByConflicts
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findByConflicts( const std::string & tag_r )
{
  return _d.init( RPMTAG_CONFLICTNAME, tag_r.c_str() );
}

//
//
//      METHOD NAME : librpmDb::findByName
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findByName( const string & name_r )
{
  return _d.init( RPMTAG_NAME, name_r.c_str() );
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findPackage
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findPackage( const string & name_r )
{
  if ( ! _d.init( RPMTAG_NAME, name_r.c_str() ) )
    return false;

  if ( _d.size() == 1 )
    return true;

  // check installtime on multiple entries
  int match    = 0;
  time_t itime = 0;
  for ( ; operator*(); operator++() )
  {
    if ( operator*()->tag_installtime() > itime )
    {
      match = _d.offset();
      itime = operator*()->tag_installtime();
    }
  }

  return _d.set( match );
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findPackage
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findPackage( const std::string & name_r, const Edition & ed_r )
{
  if ( ! _d.init( RPMTAG_NAME, name_r.c_str() ) )
    return false;

  for ( ; operator*(); operator++() )
  {
    if ( ed_r == operator*()->tag_edition() )
    {
      int match = _d.offset();
      return _d.set( match );
    }
  }

  return _d.destroy();
}

//
//
//      METHOD NAME : librpmDb::db_const_iterator::findPackage
//      METHOD TYPE : bool
//
bool librpmDb::db_const_iterator::findPackage( const Package::constPtr & which_r )
{
  if ( ! which_r )
    return _d.destroy();

  return findPackage( which_r->name(), which_r->edition() );
}

} // namespace rpm
} // namespace target
} // namespace zypp