FairParTSQLIo.cxx

Go to the documentation of this file. Or view the newest version in sPHENIX GitHub for file FairParTSQLIo.cxx

/***************************************
 * Author: M.Babai (M.Babai@rug.nl)    *
 * License:                            *
 * Version:                            *
 ***************************************/
#include "FairParTSQLIo.h"


#include "FairGenericParTSQLIo.h"
#include "FairDbMultConnector.h"

ClassImp(FairParTSQLIo)


FairParTSQLIo::FairParTSQLIo()
  : FairParIo(),
    fDefaultDb (-1),
    fConnections( new FairDbMultConnector() )
{
  std::cout << "\t<DEBUG_INFO>FairParTSQLIo::FairParTSQLIo()\n";
}

FairParTSQLIo::FairParTSQLIo(FairDbMultConnector const& cons, int const dbNum)
  : FairParIo(),
    fDefaultDb (dbNum),
    fConnections(new FairDbMultConnector(cons))
{
  std::cout << "\t<DEBUG_INFO>FairParTSQLIo::FairParTSQLIo()12\n";
}

FairParTSQLIo::~FairParTSQLIo()
{
  disconnect();
}

bool FairParTSQLIo::check()
{
  //FairDbMultConnector::Status s;
  int stat = -100;
  // Check if at least one DB is connected.
  if(fDefaultDb != -1) { // Has been specified.
    stat = fConnections->GetStatus(fDefaultDb);
    if(stat == FairDbMultConnector::kFailed ||
        stat == FairDbMultConnector::kClosed)
      std::cerr << "<Error> The connection to specified default Database"
                << " is not alive.\n";
  } else { // No selection
    for(size_t db = 0; db < fConnections->GetNumDb(); ++db) {
      stat = fConnections->GetStatus(db);
    }
  }
  return kTRUE;
  //return ( stat == FairDbMultConnector::kOpen);
}

void FairParTSQLIo::setDetParIo(Text_t* ioName)
{
  if (fConnections) {
    TObject* io = detParIoList->FindObject(ioName);
    // If does not exist
    if(!io) {
      if (strcmp(ioName, "FairGenericParIo") == 0) {
        io = new FairGenericParTSQLIo();
      }
      if (io) {
        detParIoList->Add(io);
      }
    }
  }
}

void FairParTSQLIo::disconnect()
{
  if(fConnections) {
    std::cout << "\n\t<DEBUG> Terminating connection and status = "
              << fConnections->GetStatusAsString(0)
              <<"\n\n";
    delete fConnections;
    fConnections = 0;
  }
}

bool FairParTSQLIo::activateDetIo()
{
  std::cout << "<DEBUG> FairParTSQLIo::activateDetIo()\n";
  // FIXME FIXME Maybe better to call check first
  if(!fConnections) {
    return false;
  }
  FairDetParIo* io=new FairGenericParTSQLIo();
  detParIoList->Add(io);
  return true;
}

bool FairParTSQLIo::open()
{
  std::cout << "<DEBUG> FairParTSQLIo::open()\n";
  return activateDetIo();
}

void FairParTSQLIo::print()
{
  std::cout << "<DEBUG> FairParTSQLIo::print()\n";
  if (fConnections) {
    std::cout << "<INFO> Number of available DBs = " << fConnections->GetNumDb()
              << std::endl;

    TIter next(detParIoList);
    FairDetParIo* io;
    std::cout << " Number of detector I/Os = " << detParIoList->GetSize()
              << "\nDetector IO list:\n";

    while ((io=(FairDetParIo*)next())) {
      std::cout<<" Name = " << io->GetName();
    }//while
    std::cout << std::endl;
  }//if
}//print