MJDatabasePsqlImpl.cc

Go to the documentation of this file.

//---------------------------------------------------------------------------//
//bb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nu//
//                                                                           //
//                         MAJORANA Simulation                               //
//                                                                           //
//      This code implementation is the intellectual property of the         //
//      MAJORANA Collaboration. It is based on Geant4, an intellectual       //
//      property of the RD44 GEANT4 collaboration.                           //
//                                                                           //
//                        *********************                              //
//                                                                           //
//    Neither the authors of this software system, nor their employing       //
//    institutes, nor the agencies providing financial support for this      //
//    work  make  any representation or  warranty, express or implied,       //
//    regarding this software system or assume any liability for its use.    //
//    By copying, distributing or modifying the Program (or any work based   //
//    on on the Program) you indicate your acceptance of this statement,     //
//    and all its terms.                                                     //
//                                                                           //
//bb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nubb0nu//
//---------------------------------------------------------------------------//
//                                                          
// $Id: MJDatabasePsqlImpl.cc,v 1.2 2004/11/09 13:42:39 xliu Exp $ 
//      
// CLASS IMPLEMENTATION:  MJDatabasePsqlImpl.cc
//
//---------------------------------------------------------------------------//
// 
//---------------------------------------------------------------------------//
//---------------------------------------------------------------------------//
//

#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include "libpq-fe.h"
#include <string>
#include <iostream>

#include "database/MJDatabaseConnection.hh"    //additional MJ Headers

using namespace std;

//---------------------------------------------------------------------------//

#include "database/MJDatabasePsqlImpl.hh"         //Present MJ Class Headers 
#include "database/MJDatabaseMEGACrystal.hh"
#include "database/MJDatabaseSEGACrystal.hh"
#include "database/MJDatabaseCloverCrystal.hh"
#include "database/MJDatabaseCloverDetector.hh"
#include "database/MJDatabaseElement.hh"
#include "database/MJDatabaseIsotope.hh"
#include "database/MJDatabaseMaterial.hh"
#include "database/MJDatabaseSimple800g.hh"
#include "database/MJDatabaseClover4x50x80DetCalib.hh"

#include "io/MJLogger.hh"
//---------------------------------------------------------------------------//

MJDatabasePsqlImpl::MJDatabasePsqlImpl()
{
  fdbconn = new MJDatabaseConnection();
}
MJDatabasePsqlImpl::~MJDatabasePsqlImpl()
{
  if(fdbconn)delete fdbconn;
  fdbconn=0;
  MJLog(trace) << "deleting connection" << endlog;
}
MJDatabaseMEGACrystal*
MJDatabasePsqlImpl::MJDatabaseMegaPsqlImpl(string name)
{
  MJDatabaseMEGACrystal* crystal = 0;
  /*
  string cmd = "select * from megacrystall where name='" + name + "'";
  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find " << name << " in the database " << endlog;
    return NULL;
  }
  */
  //crystal->createCrystal(res);

    return crystal;
}
MJDatabaseMEGACrystal*
MJDatabasePsqlImpl::MJDatabaseMegaPsqlImpl(int id)
{
    return new MJDatabaseMEGACrystal();
}
MJDatabaseSEGACrystal*
MJDatabasePsqlImpl::MJDatabaseSegaPsqlImpl(string name)
{
    return new MJDatabaseSEGACrystal();
}
MJDatabaseSEGACrystal*
MJDatabasePsqlImpl::MJDatabaseSegaPsqlImpl(int id)
{
    return new MJDatabaseSEGACrystal();
}
MJDatabaseCloverCrystal*
MJDatabasePsqlImpl::MJDatabaseCloverPsqlImpl(string name)
{
  MJDatabaseCloverCrystal* crystal =  new MJDatabaseCloverCrystal();
   
  string cmd = "select * from clovercrystal where partid='" + name + "'";
  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find " << name << " in the database " << endlog;
    return NULL;
  }

  crystal->createCrystal(res);
 
  fdbconn->qDone(res);
  
  //return crystal->createCrystal(res);
  return crystal;
}
MJDatabaseCloverCrystal*
MJDatabasePsqlImpl::MJDatabaseCloverPsqlImpl(int id)
{
    return new MJDatabaseCloverCrystal();

}
MJDatabaseCloverDetector*
MJDatabasePsqlImpl::MJDatabaseCloverDetectorPsqlImpl(string name)
{
  MJDatabaseCloverDetector* detector = new MJDatabaseCloverDetector();
  string cmd = "select * from cloverdetector where serialno='" + name + "'";
  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find " << name << " in the database " << endlog;
    return NULL;
  }

  detector->createDetector(res, fdbconn->GetConnection());
 
  fdbconn->qDone(res);
  return detector;
}
MJDatabaseCloverDetector*
MJDatabasePsqlImpl::MJDatabaseCloverDetectorPsqlImpl(int id)
{
    return new MJDatabaseCloverDetector();
}
MJDatabaseIsotope*
MJDatabasePsqlImpl::MJDatabaseIsotopePsqlImpl(string name)
{

 MJDatabaseIsotope* iso = new MJDatabaseIsotope();
 string cmd = "select * from mjisotopes where isoname = '" + name + "'";
  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find " << name << " in the database " << endlog;
    return NULL;
  }

  iso->createIsotope(res);
  fdbconn->qDone(res);
  
  return iso;
}
MJDatabaseMaterial*
MJDatabasePsqlImpl::MJDatabaseMaterialPsqlImpl(string name)
{
  
  MJDatabaseMaterial  *mat = new MJDatabaseMaterial();
  string cmd = "select mt.*, ct.matname, ct.noofatoms, ct.fracmass ";
  cmd += " from mjmaterials mt, mjcomponents ct ";
  cmd += " where mt.matname='" + name + "'";
  cmd += " AND mt.matname=ct.name";

  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find " << name << " in the database " << endlog;
    return NULL;
  }
  //there should be only one record
  mat->createMaterial(res, 0);
  fdbconn->qDone(res);
  
  // return mat->createMaterial(res);
  return mat;
  
}
MJDatabaseElement* 
MJDatabasePsqlImpl::MJDatabaseElementPsqlImpl(string name)
{
  
  MJDatabaseElement  *ele= new MJDatabaseElement();
  string cmd = "select et.name, et.symbol, et.z, et.niostope, " ;
  cmd += " it.isoname, it.symbol, it.abundance" ;
  cmd += " from mjelements et, mjisotopesabundance it " ;
  cmd += " where et.name='" + name + "'" ;  
  cmd += " AND et.name=it.elename";
  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find " << name << " in the database " << endlog;
    return NULL;
  }

  ele->createElement(res);
  fdbconn->qDone(res);

  return ele;
}

MJDatabaseSimple800g*
MJDatabasePsqlImpl::MJDatabaseSimple800gPsqlImpl(string name)
{
  MJDatabaseSimple800g* crystal =  new MJDatabaseSimple800g();
   
  string cmd = "select * from simple800gcrystal where partid='" + name + "'" ;
  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find " << name << " in the database " << endlog;
    return NULL;
  }

  crystal->createCrystal(res);
 
  fdbconn->qDone(res);
  
  //return crystal->createCrystal(res);
  return crystal;
}
MJDatabaseClover4x50x80DetCalib*
MJDatabasePsqlImpl::MJDatabaseClover4x50x80CalibPsqlImpl(string name, 
                                                         string beginT, 
                                                         string endT)
{
  MJDatabaseClover4x50x80DetCalib* detCalib = new 
    MJDatabaseClover4x50x80DetCalib();
  string cmd = "select * from CloverDetectorCalib where detector='" + name + "'";
  cmd += " and beginTime>='" + beginT;
  cmd += "' and endTime<='" + endT + "'";
  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find calibration constants for " << name 
                 << " for time interval " << beginT 
                 << " and " << endT <<" in the database " << endlog;
    return NULL;
  }

  detCalib->createCalib(res);

   fdbconn->qDone(res);
 
  return detCalib ;
}
vector<MJDatabaseMaterial>
MJDatabasePsqlImpl::MJDatabaseAllMaterialsPsqlImpl()
{
  
  vector<MJDatabaseMaterial>  matVec;
  string cmd = "select mt.*, ct.matname, ct.noofatoms, ct.fracmass ";
  cmd += " from mjmaterials mt, mjcomponents ct ";
  cmd += " where mt.matname=ct.name";

  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find materials in the database " << endlog;
    //    return NULL;
  }
  int n=0;
  for (int i = 0; i < PQntuples(res); i+=n){
    MJDatabaseMaterial* mat = new MJDatabaseMaterial(); 
    mat->createMaterial(res, i);
    matVec.push_back(*mat);
    n = *((int*)PQgetvalue(res, i, 4));
  }
  fdbconn->qDone(res);
  
  // return mat->createMaterial(res);
  return matVec;
  
}
vector<string>
MJDatabasePsqlImpl::MJDatabaseMaterialNamesPsqlImpl()
{
  
  vector<string>  nameVec;
  string cmd = "select matname from mjmaterials ";

  PGresult *res = fdbconn->qResult(cmd);

  //check to see if we found the object in database
  if( PQntuples(res) == 0 ) {
    MJLog(error) << "Could not find materials in the database " << endlog;
    //    return NULL;
  }
  for (int i = 0; i < PQntuples(res); i++){
    nameVec.push_back(PQgetvalue(res, i, 0));
  }
  fdbconn->qDone(res);
  
  // return mat->createMaterial(res);
  return nameVec;  
}

---