DBManager.cpp

Go to the documentation of this file.

// //////////////////////////////////////////////////////////////////////
// Import section
// //////////////////////////////////////////////////////////////////////
// STL
#include <cassert>
// SOCI
#if defined(SOCI_HEADERS_BURIED)
#include <soci/core/soci.h>
#include <soci/backends/mysql/soci-mysql.h>
#else // SOCI_HEADERS_BURIED
#include <soci/soci.h>
#include <soci/mysql/soci-mysql.h>
#endif // SOCI_HEADERS_BURIED
// StdAir
#include <stdair/bom/AirlineStruct.hpp>
#include <stdair/service/Logger.hpp>
// TraDemGen
#include <trademgen/command/DBManager.hpp>

namespace TRADEMGEN {

  // //////////////////////////////////////////////////////////////////////
  void DBManager::
  prepareSelectStatement (stdair::DBSession_T& ioSociSession,
                          stdair::DBRequestStatement_T& ioSelectStatement,
                          stdair::AirlineStruct& ioAirline) {
  
    try {
    
      // Instanciate a SQL statement (no request is performed at that stage)
    } catch (std::exception const& lException) {
      STDAIR_LOG_ERROR ("Error: " << lException.what());
      throw stdair::SQLDatabaseException (lException.what());
    }
  }

  // //////////////////////////////////////////////////////////////////////
  void DBManager::
  prepareSelectOnAirlineCodeStatement (stdair::DBSession_T& ioSociSession,
                                       stdair::DBRequestStatement_T& ioSelectStatement,
                                       const stdair::AirlineCode_T& iAirlineCode,
                                       stdair::AirlineStruct& ioAirline) {
  
    try {
    
      // Instanciate a SQL statement (no request is performed at that stage)
    } catch (std::exception const& lException) {
      STDAIR_LOG_ERROR ("Error: " << lException.what());
      throw stdair::SQLDatabaseException (lException.what());
    }
  }

  // //////////////////////////////////////////////////////////////////////
  bool DBManager::iterateOnStatement (stdair::DBRequestStatement_T& ioStatement,
                                      stdair::AirlineStruct& ioAirline,
                                      const bool iShouldDoReset) {
    bool hasStillData = false;
  
    try {

      // Reset the list of names of the given Airline object
      if (iShouldDoReset == true) {
        // ioAirline.resetMatrix();
      }

      // Retrieve the next row of Airline object
      hasStillData = ioStatement.fetch();
      
    } catch (std::exception const& lException) {
      STDAIR_LOG_ERROR ("Error: " << lException.what());
      throw stdair::SQLDatabaseException (lException.what());
    }

    return hasStillData;
  }

  // //////////////////////////////////////////////////////////////////////
  void DBManager::updateAirlineInDB (stdair::DBSession_T& ioSociSession,
                                     const stdair::AirlineStruct& iAirline) {
  
    try {
    
      // Begin a transaction on the database
      ioSociSession.begin();
      
      // Instanciate a SQL statement (no request is performed at that stage)
      std::string lAirlineCode;
      /*
      stdair::DBRequestStatement_T lUpdateStatement =
        (ioSociSession.prepare
         << "update ref_airline_details "
         << "set xapian_docid = :xapian_docid "
         << "where code = :code", soci::use (lDocID), soci::use (lAirlineCode));
      
      // Execute the SQL query
      lDocID = iAirline.getDocID();
      lAirlineCode = iAirline.getAirlineCode();
      lUpdateStatement.execute (true);
      */
      
      // Commit the transaction on the database
      ioSociSession.commit();
        
      // Debug
      // TRADEMGEN_LOG_DEBUG ("[" << lDocID << "] " << iAirline);
      
    } catch (std::exception const& lException) {
      STDAIR_LOG_ERROR ("Error: " << lException.what());
      throw stdair::SQLDatabaseException (lException.what());
    }
  }

  // //////////////////////////////////////////////////////////////////////
  bool DBManager::retrieveAirline (stdair::DBSession_T& ioSociSession,
                                   const stdair::AirlineCode_T& iAirlineCode,
                                   stdair::AirlineStruct& ioAirline) {
    bool oHasRetrievedAirline = false;
      
    try {

      // Prepare the SQL request corresponding to the select statement
      stdair::DBRequestStatement_T lSelectStatement (ioSociSession);
      DBManager::prepareSelectOnAirlineCodeStatement (ioSociSession,
                                                    lSelectStatement,
                                                    iAirlineCode, ioAirline);
      const bool shouldDoReset = true;
      bool hasStillData = iterateOnStatement (lSelectStatement, ioAirline,
                                              shouldDoReset);
      if (hasStillData == true) {
        oHasRetrievedAirline = true;
      }

      // Sanity check
      const bool shouldNotDoReset = false;
      hasStillData = iterateOnStatement (lSelectStatement, ioAirline,
                                         shouldNotDoReset);
      // Debug
      // STDAIR_LOG_DEBUG ("[" << iDocID << "] " << ioAirline);
      
    } catch (std::exception const& lException) {
      STDAIR_LOG_ERROR ("Error: " << lException.what());
      throw stdair::SQLDatabaseException (lException.what());
    }

    return oHasRetrievedAirline;
  }

}