//*-- AUTHOR : Ilse Koenig
//*-- Modified : 219/04/2006 by I.Koenig

//_HADES_CLASS_DESCRIPTION 
///////////////////////////////////////////////////////////////////////////////
// HParOraIo
//
// Interface class to database Oracle
// It is derived from interface base class HParIo.
//
// It contains a pointer to the connection class (type HOraConn)  and a list
// of interface classes for the detectors. Each detector has its own interface
// class all inherited from a common base class.
//
// This class replaces the former class HOraIo.  
///////////////////////////////////////////////////////////////////////////////
using namespace std;
#include "hparoraio.h"
#include "hdetpario.h"
#include "horainfo.h"
#include "hcondparoraio.h"
#include "hades.h"
#include "hspectrometer.h"
#include "hdetector.h"
#include "hspecparoraio.h"
#include "hmdcparoraio.h"
#include "htofparoraio.h"
#include "htofinoparoraio.h"
#include "hrichparoraio.h"
#include "hshowerparoraio.h"
#include "hstartparoraio.h"
#include "hkickparoraio.h"
#include "htriggerparoraio.h"
#include "hwallparoraio.h"
#include "hhodoparoraio.h"
#include "hrpcparoraio.h"
#include <stdio.h>
#include <iostream> 
#include <iomanip>

ClassImp(HParOraIo)

HParOraIo::HParOraIo() {
  // default constructor
  // creates the connection class but doesn't open a connection
  pConn=new HOraConn();
  autoWritable=kFALSE;
}


HParOraIo::~HParOraIo() {
  // default constructor closes an open connection
  close();
  if (pConn) delete pConn;
}


Bool_t HParOraIo::open() {
  // opens connection to database Hades as user Hades
  // user Hades has Readonly access to Oracle tables
  // all open()-functions activate the detetctor I/Os
  isConnected=pConn->open();
  return activateDetIo();
}


Bool_t HParOraIo::open(Char_t *userName) {
  // opens connection to database Hades for user given by name
  // asks for password
  isConnected=pConn->open(userName);
  return activateDetIo();
}


Bool_t HParOraIo::open(Char_t *dbName, Char_t *userName) {
  // opens connection to database with name dbName for user given by name
  // asks for password
  isConnected=pConn->open(dbName,userName);
  return activateDetIo();
} 


Bool_t HParOraIo::reconnect() {
  // reopens the connection (only applicable for default user hades_ana)
  isConnected=pConn->reconnect();
  return isConnected;
}


void HParOraIo::close() {
  // closes the connection with automatic ROLLBACK
  pConn->close();
  isConnected=kFALSE;
  if (detParIoList) detParIoList->Delete();
  if (pInfo) {
    delete pInfo;
    pInfo=0;
  }
}


void HParOraIo::disconnect() {
  pConn->disconnect();
  isConnected=kFALSE;
}


void HParOraIo::print() {
  // prints information about the database connection
  pConn->print();
  if (isConnected) {
    TIter next(detParIoList);
    HDetParIo* io;
    cout<<"detector I/Os: ";
    while ((io=(HDetParIo*)next())) {
      cout<<" "<<io->GetName();
    }
    cout<<'\n';
  }
}

Bool_t HParOraIo::setHistoryDate(const Char_t* timestamp) {
  // Sets the date to retrieve historic data
  // Returns kFALSE when the date string cannot be converted to a valid date.
  return pConn->setHistoryDate(timestamp);
}

Bool_t HParOraIo::setParamRelease(const Char_t* releaseName) {
  // Sets the history date to the creation date of the parameter release give by name
  // Returns kFALSE when the release is not found.
  return pConn->setParamRelease(releaseName);
}

Bool_t HParOraIo::activateDetIo() {
  // creates the I/O for all detector in the setup
  if (isConnected==kFALSE) return kFALSE;
  pInfo=new HOraInfo(pConn);
  HDetParIo* io=new HCondParOraIo(pConn);
  detParIoList->Add(io);
  io=new HSpecParOraIo(pConn);
  detParIoList->Add(io);
  TList* detSet=gHades->getSetup()->getListOfDetectors();
  TIter next(detSet);
  HDetector* det;
  while ((det=(HDetector*)next())) {
    const Char_t* name=det->GetName();
    io=0;
    if (strcmp(name,"Mdc")==0) io=new HMdcParOraIo(pConn);
    if (strcmp(name,"Tof")==0) io=new HTofParOraIo(pConn);
    if (strcmp(name,"Tofino")==0) io=new HTofinoParOraIo(pConn);
    if (strcmp(name,"Rich")==0) io=new HRichParOraIo(pConn);
    if (strcmp(name,"Shower")==0) io=new HShowerParOraIo(pConn);
    if (strcmp(name,"Start")==0) io=new HStartParOraIo(pConn);
    if (strcmp(name,"Trigger")==0) io=new HTriggerParOraIo(pConn);
    if (strcmp(name,"Wall")==0) io=new HWallParOraIo(pConn);
    if (strcmp(name,"Hodo")==0) io=new HHodoParOraIo(pConn);
    if (strcmp(name,"Rpc")==0) io=new HRpcParOraIo(pConn);
    if (io) detParIoList->Add(io);
  }
  return kTRUE;
}

void HParOraIo::setDetParIo(const Text_t* ioName) {
  // creates the specified I/O
  if (isConnected) {
    TObject* io=detParIoList->FindObject(ioName);
    if (!io) {
      if (strcmp(ioName,"HCondParIo")==0) io=new HCondParOraIo(pConn);
      if (strcmp(ioName,"HMdcParIo")==0) io=new HMdcParOraIo(pConn);
      if (strcmp(ioName,"HTofParIo")==0) io=new HTofParOraIo(pConn);
      if (strcmp(ioName,"HTofinoParIo")==0) io=new HTofinoParOraIo(pConn);
      if (strcmp(ioName,"HRichParIo")==0) io=new HRichParOraIo(pConn);
      if (strcmp(ioName,"HShowerParIo")==0) io=new HShowerParOraIo(pConn);
      if (strcmp(ioName,"HStartParIo")==0) io=new HStartParOraIo(pConn);
      if (strcmp(ioName,"HKickParIo")==0) io=new HKickParOraIo(pConn);
      if (strcmp(ioName,"HTriggerParIo")==0) io=new HTriggerParOraIo(pConn);
      if (strcmp(ioName,"HWallParIo")==0) io=new HWallParOraIo(pConn);
      if (strcmp(ioName,"HHodoParIo")==0) io=new HHodoParOraIo(pConn);
      if (strcmp(ioName,"HRpcParIo")==0) io=new HRpcParOraIo(pConn);
      if (io) detParIoList->Add(io);
    }
  }
}    

TList* HParOraIo::getListOfRuns(const Char_t* experiment,
                                const Char_t* startAt,const Char_t* endAt) {
  // returns the list of runs for the specifies experiment and range
  // accepts dates (format DD-MON-YYYY HH24:MI:SS), hld-filenames and run ids
  if (isConnected) {
      return pInfo->getListOfRuns(experiment,startAt,endAt);
  }
  Error("getListOfRuns","No connection to Oracle");
  return 0;
}