DBSessionManager.cpp

Go to the documentation of this file.

// //////////////////////////////////////////////////////////////////////
// Import section
// //////////////////////////////////////////////////////////////////////
// STL
#include <cassert>
#include <string>
#include <sstream>
// SOCI
#include <soci/soci.h>
#include <soci/sqlite3/soci-sqlite3.h>
// OpenTrep
#include <opentrep/DBParams.hpp>
#include <opentrep/command/DBSessionManager.hpp>
#include <opentrep/service/Logger.hpp>
 
namespace OPENTREP {
 
  // //////////////////////////////////////////////////////////////////////
  DBSessionManager::DBSessionManager() : _dbSession (NULL) {
  }
 
  // //////////////////////////////////////////////////////////////////////
  DBSessionManager::DBSessionManager (const DBParams& iDBParams)
    : _dbSession (NULL) {
    init (iDBParams);
  }
 
  // //////////////////////////////////////////////////////////////////////
  DBSessionManager::~DBSessionManager() {
    // Properly close the (SOCI) database session, only when one has been created
    if (_dbSession != NULL) {
      _dbSession->close();
    }
    // Reset the underlying (SOCI) database connection
    delete _dbSession; _dbSession = NULL;
  }
 
  // //////////////////////////////////////////////////////////////////////
  soci::session& DBSessionManager::getDBSessionRef() const {
    assert (_dbSession != NULL);
    return *_dbSession;
  }
 
  // //////////////////////////////////////////////////////////////////////
  void DBSessionManager::init (const DBParams& iDBParams) {
    
    // Check that the parameters for the SQL database are not empty
    if (iDBParams.checkSQLite() == false) {
      std::ostringstream errorStr;
      errorStr << "At least one of the parameters for the SQL "
               << "database is empty: " << iDBParams;
      OPENTREP_LOG_ERROR (errorStr.str());
      throw XapianTravelDatabaseEmptyException (errorStr.str());
    }
 
    // Instanciate a (SOCI) database session: nothing is performed at
    // that stage, else than creating a SOCI session object
    _dbSession = new soci::session();
    
    try {
 
      // Open the connection to the database
      _dbSession->open (soci::sqlite3, iDBParams.toSQLiteConnectionString());
      
    } catch (std::exception const& lException) {
      std::ostringstream errorStr;
      errorStr << "Error while opening a connection to database: "
               << lException.what() << std::endl;
      errorStr << "Database parameters used: " << iDBParams.toString();
      OPENTREP_LOG_ERROR (errorStr.str());
      throw SQLDatabaseImpossibleConnectionException (errorStr.str());
    }
  }
  
}