TOracleServerE2 Class Reference

#include <TOracleServerE2.h>

Inheritance diagram for TOracleServerE2:

Collaboration diagram for TOracleServerE2:

Public Member Functions
Int_t	ConvertMicrotracksDataSetToEdb (const char *query, const char *outdir, int major=0, int minor=0, bool structure_only=false)
Int_t	ConvertMicrotracksParentProcessToEdb (ULong64_t parentprocessoperation, const char *outdir, int major=0, int minor=0, bool structure_only=false)
Int_t	ConvertMicrotracksProcessToEdb (ULong64_t processoperation, const char *outdir, int major=0, int minor=0, bool structure_only=false)
Int_t	ConvertMicrotracksVolumeToEdb (ULong64_t id_volume, const char *outdir, int major=0, int minor=0, bool structure_only=false)
Int_t	ConvertMicrotracksZoneToEdb (Int_t id_eventbrick, ULong64_t id_zone, EdbRun &run)
Int_t	ConvertScanbackPathToEdb (Int_t id_eventbrick, Int_t path, const char *outdir, int major, int minor)
Int_t	DumpBrickVolumesID (char *id_eventbrick)
Int_t	DumpEventsID (char *id_eventbrick)
Int_t	DumpProcessOperations (char *id_eventbrick, char *id_programsettings)
Int_t	DumpProcessOperations (char *id_eventbrick, Int_t driverlevel)
Int_t	GetId_EventBrick (const char *id_brick, const char *id_set, char *id)
Int_t	GetId_ScanbackPath (char *id_eventbrick, char *id_process_operation, int path, char *id)
ULong64_t	GetId_ScanbackPath (ULong64_t id_eventbrick, ULong64_t id_process_operation, int path)
Int_t	GetId_Volume (char *id_eventbrick, char *id_process_operation, int ivolume, char *id)
Int_t	GetId_Zone (char *id_eventbrick, char *id_plate, char *id_process_operation, char *series, char *id)
Int_t	GetProcessOperationID (char *id_eventbrick, char *id_parent_operation, char *id_programsettings, char *id_plate, char *id)
Int_t	GetProcessOperationID (char *id_eventbrick, char *id_programsettings, char *id)
ULong64_t	GetProcessOperationID (ULong64_t id_eventbrick, ULong64_t id_parent_operation, ULong64_t id_programsettings, int id_plate)
Int_t	GetProcessType (char *IDPROCESS)
const char *	Ostr (Int_t num)
const char *	Ostr (ULong64_t num)
void	Print ()
void	PrintBrickInfo (Long_t id_eventbrick, int level)
void	PrintBrickInfoFull (Long_t id_eventbrick, int level)
Int_t	ReadBasetracksPattern (char *selection, EdbPattern &pat)
Int_t	ReadBrickOffset (Int_t id_brick, EdbMarksSet &ms)
Int_t	ReadCSPredictions (Int_t id_brick, EdbPattern &pred)
Int_t	ReadCSPredictions2 (Int_t id_brick, EdbPattern &pred)
Int_t	ReadCSPredictions_remote_v2 (Int_t id_brick, EdbPattern &pred, int csid)
Int_t	ReadDataSet (ULong64_t id_parent_op, int id_brick, ULong64_t path, EdbPatternsVolume &vol)
Int_t	ReadMicrotracksPattern (int id_eventbrick, char *selection, EdbPattern &pat)
Int_t	ReadMicrotracksZone (Int_t id_eventbrick, ULong64_t id_zone, int side, TObjArray &edbviews)
Int_t	ReadScanbackPath (Int_t id_eventbrick, Int_t path, EdbTrackP &t)
Int_t	ReadTemplateMarks (Int_t id_brick, EdbMarksSet &ms)
Int_t	ReadVetoTracks (Int_t id_brick, EdbPattern &pred)
Int_t	ReadViewsZone (ULong64_t id_zone, int side, TObjArray &edbviews)
Int_t	ReadVolume (char *id_volume, EdbPatternsVolume &vol)
Int_t	ReadVolume (char *id_volume, EdbPatternsVolume &vol, Int_t min, Int_t max)
Int_t	ReadVolume (ULong64_t id_volume, EdbPatternsVolume &vol)
Int_t	ReadVolume (ULong64_t id_volume, EdbPatternsVolume &vol, Int_t min_pl, Int_t max_pl)
bool	ReadZplate (int id_plate, int id_eventbrick, EdbPattern &pat)
bool	ReadZplate_nominal (int id_plate, int id_eventbrick, EdbPattern &pat)
	TOracleServerE2 (const char *db, const char *uid, const char *pw)
	~TOracleServerE2 ()
Public Member Functions inherited from TOracleServer
void	Close (Option_t *opt="")
Int_t	CreateDataBase (const char *dbname)
Int_t	DropDataBase (const char *dbname)
TSQLResult *	GetColumns (const char *dbname, const char *table, const char *wild=0)
TSQLResult *	GetDataBases (const char *wild=0)
TSQLResult *	GetTables (const char *dbname, const char *wild=0)
Int_t	PrintResult ()
Int_t	PrintResultStr (TString &result)
TSQLResult *	Query (const char *sql)
Int_t	QueryTree (char *query, TTree *tree, char *leafs=0)
Int_t	Reload ()
Int_t	SelectDataBase (const char *dbname)
const char *	ServerInfo ()
Int_t	Shutdown ()
	TOracleServer (const char *db, const char *uid, const char *pw)
	~TOracleServer ()

Public Attributes
TString	eRTS

Constructor & Destructor Documentation

TOracleServerE2()

TOracleServerE2::TOracleServerE2 ( const char *  db, const char *  uid, const char *  pw  )

inline

                                                                  :
    TOracleServer(db, uid, pw){}

~TOracleServerE2()

TOracleServerE2::~TOracleServerE2 ( )

inline

{}

Member Function Documentation

ConvertMicrotracksDataSetToEdb()

Int_t TOracleServerE2::ConvertMicrotracksDataSetToEdb	(	const char *	query,
		const char *	outdir,
		int	major = 0,
		int	minor = 0,
		bool	structure_only = false
	)

{
  // Input: query providing the list of zones to be extracted
  //        outdir - where to write the dataset
  //        major,minor - versions for the files names like: brick.plate,major.minor.raw.root
 
  //check if outdir is accessible:
  EdbScanProc sproc;
  if(!sproc.CheckDirWritable(outdir))     return 0;
  EdbScanSet  ss;
 
  int  nviewtot=0;
  std::map<int,ULong64_t> pl_zones;
  int brick =-999, plate=0;
  ULong64_t zone=0;
  Float_t   z=0;
 
  try{
    if (!fStmt)      fStmt = fConn->createStatement();
    fStmt->setSQL(query);
    Log(2,"ConvertMicrotracksDataSetToEdb","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      sscanf( (rs->getString(1)).c_str(),"%d"  , &brick );
      sscanf( (rs->getString(2)).c_str(),"%d"  , &plate );
      sscanf( (rs->getString(3)).c_str(),"%lld", &zone );
      sscanf( (rs->getString(4)).c_str(),"%f"  , &z );
      pl_zones[plate]=zone;
 
      EdbPlateP *plt = new EdbPlateP();
      plt->SetID(plate);
      plt->SetZlayer(z,z-150,z+150);
      ss.eB.AddPlate(plt);
      ss.eIDS.Add(new EdbID(brick,plate,major,minor));
    }
  } catch (SQLException &oraex) {
    Error("TOracleServerE", "ConvertMicrotracksDataSetToEdb: failed: (error: %s)", (oraex.getMessage()).c_str());
  }
    
  Log(1,"ConvertMicrotracksDataSetToEdb","found ScanSet: %d %d %d %d with %d plates",brick,0,major,minor,ss.eB.Npl() );
 
  sproc.eProcDirClient=outdir;
  int id[4]={brick,0,major,minor};
  ss.eB.SetID(brick);
  ss.MakePIDList();
  if(gEDBDEBUGLEVEL>2) ss.Print();
  sproc.WriteScanSet(id,ss);
  sproc.MakeAFFSet(ss);
 
  if(!structure_only) {
//    int plate0 =-999;
    EdbRun *run=0;
    map<int,ULong64_t>::const_iterator iter;
    for (iter=pl_zones.begin(); iter != pl_zones.end(); ++iter) {
      plate= iter->first;
      zone = iter->second;
      Log(2,"ConvertMicrotracksDataSetToEdb","for plate: %d read zone: %lld", plate,zone);
      id[0] = brick; id[1]=plate; id[2]=major; id[3]=minor;
      /*          // it seems that update is never required so - comment out
      TString str; sproc.MakeFileName(str,id,"raw.root");
      sproc.CheckProcDir(id);
      if(plate!=plate0) {
    plate0=plate;
    run = new EdbRun(str.Data(),"RECREATE");
      } else run = new EdbRun(str.Data(),"UPDATE");
      */
      run=sproc.InitRun(id);     // in case of more zones in the same plate - create *root.save files so one can resolve manually
      if(run) {
        nviewtot+=ConvertMicrotracksZoneToEdb(brick,zone,*run);
        run->Close();      SafeDelete(run);
      }
    }
 
  }
  Log(1,"ConvertMicrotracksDataSetToEdb","%d views are extracted from db for the brick %d",nviewtot,brick);
  return nviewtot;
}

ConvertMicrotracksParentProcessToEdb()

Int_t TOracleServerE2::ConvertMicrotracksParentProcessToEdb	(	ULong64_t	parentprocessoperation,
		const char *	outdir,
		int	major = 0,
		int	minor = 0,
		bool	structure_only = false
	)

{
  char query[2048];
   sprintf(query,"\
   select tz.id_eventbrick,tz.id_plate,tz.ID,tp.Z \
    from TB_ZONES%s tz, TB_PLATES%s tp, tb_proc_operations%s op where \
    tz.id_eventbrick=tp.id_eventbrick and op.id_eventbrick=tp.id_eventbrick and \
    op.id_parent_operation=%lld and tz.id_plate=tp.id and tp.id=op.id_plate and tz.ID_PROCESSOPERATION=op.id \
    order by tp.id",
   eRTS.Data(),eRTS.Data(),eRTS.Data(), processoperation);
  
  int nv= ConvertMicrotracksDataSetToEdb( query, outdir, major, minor, structure_only );
  Log(1,"ConvertMicrotracksProcessToEdb","%d views are extracted from db for the processoperation %lld",nv,processoperation);
  return nv;
}

ConvertMicrotracksProcessToEdb()

Int_t TOracleServerE2::ConvertMicrotracksProcessToEdb	(	ULong64_t	processoperation,
		const char *	outdir,
		int	major = 0,
		int	minor = 0,
		bool	structure_only = false
	)

{  
  char query[2048];
   sprintf(query,"\
    select tz.id_eventbrick,tz.id_plate,tz.ID,tp.Z from TB_ZONES%s tz, TB_PLATES%s tp where \
    tz.id_processoperation=%lld and tz.id_eventbrick=tp.id_eventbrick and tz.id_plate=tp.id order by tp.id",
        eRTS.Data(),
        eRTS.Data(),
        processoperation);
  int nv= ConvertMicrotracksDataSetToEdb( query, outdir, major, minor, structure_only );
  Log(1,"ConvertMicrotracksProcessToEdb","%d views are extracted from db for the processoperation %lld",nv,processoperation);
  return nv;
}

ConvertMicrotracksVolumeToEdb()

Int_t TOracleServerE2::ConvertMicrotracksVolumeToEdb	(	ULong64_t	id_volume,
		const char *	outdir,
		int	major = 0,
		int	minor = 0,
		bool	structure_only = false
	)

{  
  char query[2048];
   sprintf(query,"\
    select sl.id_eventbrick,sl.id_plate,sl.id_zone, pl.z from TB_VOLUME_SLICES%s sl, TB_PLATES%s pl where \
    sl.id_volume=%lld and sl.id_eventbrick=pl.id_eventbrick and sl.id_plate=pl.id order by pl.id",
        eRTS.Data(),
        eRTS.Data(),
        id_volume);
  int nv= ConvertMicrotracksDataSetToEdb( query, outdir, major, minor, structure_only );
  Log(1,"ConvertMicrotracksVolumeToEdb","%d views are extracted from db for the volume %lld",nv,id_volume);
  return nv;
}

ConvertMicrotracksZoneToEdb()

Int_t TOracleServerE2::ConvertMicrotracksZoneToEdb	(	Int_t	id_eventbrick,
		ULong64_t	id_zone,
		EdbRun &	run
	)

{
  // read possibly full information for all views and microtracks for the given zone and fill the run file with the raw data (rwd like)
 
  int nviews=0;
  TObjArray edbviews1;
  int n1= ReadViewsZone(id_zone,1,edbviews1);
  if(n1>0) {
    nviews += n1;  
    ReadMicrotracksZone( id_eventbrick, id_zone, 1, edbviews1 );
    for(int i=0; i<edbviews1.GetEntries(); i++)    run.AddView( (EdbView *)(edbviews1.At(i)) );
  }
 
  TObjArray edbviews2;
  int n2 = ReadViewsZone(id_zone,2,edbviews2);
  if(n2>0) {
    nviews += n2;
    ReadMicrotracksZone( id_eventbrick, id_zone, 2, edbviews2 );
    for(int i=0; i<edbviews2.GetEntries(); i++)    run.AddView( (EdbView *)(edbviews2.At(i)) );
  }
  run.Save();
  return nviews;
}

ConvertScanbackPathToEdb()

Int_t TOracleServerE2::ConvertScanbackPathToEdb	(	Int_t	id_eventbrick,
		Int_t	path,
		const char *	outdir,
		int	major,
		int	minor
	)

{
  EdbScanProc sproc;
  if(!sproc.CheckDirWritable(outdir))     return 0;
  sproc.eProcDirClient=outdir;
  EdbTrackP t;
  if(ReadScanbackPath(id_eventbrick,path,t)) {
    EdbID id(id_eventbrick,0,major,minor);
    if(sproc.WriteSBTrack(t, path, id))  return 1;
  }
  return 0;
}

DumpBrickVolumesID()

Int_t TOracleServerE2::DumpBrickVolumesID

(

char *

id_eventbrick

)

{
  // Dump on the screen the list of volumes IDs and correspondent process operation IDs
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select volume, id_processoperation, id from tb_volumes%s where id_eventbrick=%s",
        eRTS.Data(), id_eventbrick);
 
    fStmt->setSQL(query);
    Log(2,"DumpProcessOperations","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    int count=0;
    while (rs->next()){
      if(++count==1) {
        printf("\n------------ Volumes stored for brick %s -------------\n",id_eventbrick);
        printf("\nVolume      ProcessID       volumeID\n");
      }
      printf(" %s    %s    %s\n",
         rs->getString(1).c_str(), rs->getString(2).c_str(), rs->getString(3).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "DumpBrickVolumesID: failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

DumpEventsID()

Int_t TOracleServerE2::DumpEventsID

(

char *

id_eventbrick

)

{
  // Dump on the screen the list of volumes IDs and correspondent process operation IDs
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select event  from tb_predicted_events%s where ID in \
                   (select id_event from tb_cs_candidates%s where id_eventbrick in \
                   (select id from tb_eventbricks%s where id_brick=%s))",
        eRTS.Data(),eRTS.Data(),eRTS.Data(), id_eventbrick);
 
    fStmt->setSQL(query);
    Log(2,"DumpEventsID","execute sql query: %s ...\n",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    int count=0;
    while (rs->next()){
      if(++count==1) {
        printf("\n------------ Events defined for brick %s -------------\n",id_eventbrick);
      }
      printf("Event \t%s  is associated with brick %s\n", rs->getString(1).c_str(), id_eventbrick);
    }
    if(count>0) printf("---------------------------------------------------------\n");
 
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "DumpEventsID: failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

DumpProcessOperations() [1/2]

Int_t TOracleServerE2::DumpProcessOperations	(	char *	id_eventbrick,
		char *	id_programsettings
	)

{
  // Dump on the screen the list of process operation IDs related to a given brick and program setting
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID,to_char(starttime),to_char(notes) from tb_proc_operations%s where id_eventbrick=%s and id_programsettings=%s",
        eRTS.Data(), id_eventbrick, id_programsettings);
 
    fStmt->setSQL(query);
    Log(2,"DumpProcessOperations","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      printf("Operation: %s, start time: %s, notes: %s\n",
         rs->getString(1).c_str(),rs->getString(2).c_str(),rs->getString(3).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "DumpProcessOperations; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

DumpProcessOperations() [2/2]

Int_t TOracleServerE2::DumpProcessOperations	(	char *	id_eventbrick,
		Int_t	driverlevel
	)

{
  // Dump on the screen the list of process operation IDs related to a given brick with a driverlevel greater or equal than the given value
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID, id_plate,to_char(starttime),to_char(notes),driverlevel from tb_proc_operations%s where id_eventbrick=%s and driverlevel>=%d order by starttime",
        eRTS.Data(), id_eventbrick, driverlevel);
 
    fStmt->setSQL(query);
    Log(2,"DumpProcessOperations","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    int count=0;
    while (rs->next()){
      if(++count==1) {
        printf("\n----------------- Operations with driverlevel >= %d for brick %s ------------------------\n", driverlevel, id_eventbrick);
        printf("\n  OperationID        Plate   Date     Driverlevel   Notes\n");
      }
      printf("%18s  %3d    %s       %d        %s\n",
         rs->getString(1).c_str(), rs->getInt(2), rs->getString(3).c_str(), rs->getInt(5), rs->getString(4).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "DumpProcessOperations; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

GetId_EventBrick()

Int_t TOracleServerE2::GetId_EventBrick	(	const char *	id_brick,
		const char *	id_set,
		char *	id
	)

{
  // Get the brick ID related to a given brick name and brick-set
  Int_t idnum=0;
  char *query= new char[2048];
   try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID from tb_eventbricks%s where id_brick=%s and id_set=%s ",
        eRTS.Data(), id_brick, id_set);
 
    //    fStmt->setSQL(query);
    Log(2,"GetId_EventBrick","execute sql query: %s ...",query);
    //    fStmt->execute();
    Query(query);
    ResultSet *rs = fStmt->getResultSet();
    if(rs) {
      while (rs->next()){
        if(id) strcpy(id,rs->getString(1).c_str());
        sscanf(rs->getString(1).c_str(),"%d", &idnum);
      }
      delete rs;
    }
   } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetId_Eventbrick; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return idnum;
}

GetId_ScanbackPath() [1/2]

Int_t TOracleServerE2::GetId_ScanbackPath	(	char *	id_eventbrick,
		char *	id_process_operation,
		int	path,
		char *	id
	)

{
  // Get the scanback path ID related to a given brick, process operation and path
 
  char *query= new char[2048];
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID from TB_SCANBACK_PATHS%s where id_eventbrick=%s and ID_PROCESSOPERATION=%s and PATH=%d", 
            eRTS.Data(), id_eventbrick, id_process_operation, path);
 
    fStmt->setSQL(query);
    Log(2,"GetId_ScanbackPath","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      strcpy(id,rs->getString(1).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetId_ScanbackPath; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

GetId_ScanbackPath() [2/2]

ULong64_t TOracleServerE2::GetId_ScanbackPath	(	ULong64_t	id_eventbrick,
		ULong64_t	id_process_operation,
		int	path
	)

{
  // Get the scanback path ID related to a given brick, process operation and path
 
  ULong64_t id=0;
  char *query= new char[2048];
   try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID from TB_SCANBACK_PATHS%s where id_eventbrick=%s and ID_PROCESSOPERATION=%s and PATH=%d", 
        eRTS.Data(), 
      Ostr(id_eventbrick), Ostr(id_process_operation), path);
 
    fStmt->setSQL(query);
    Log(2,"GetId_ScanbackPath","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      sscanf( (rs->getString(1)).c_str(),"%lld",&id);
      Log(2,"TOracleServerE2::GetId_ScanbackPath","%lld",id);
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetId_ScanbackPath; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return id;
}

GetId_Volume()

Int_t TOracleServerE2::GetId_Volume	(	char *	id_eventbrick,
		char *	id_process_operation,
		int	ivolume,
		char *	id
	)

{
  // Get the volume ID related to a given brick, process operation and progressive number of the volume
 
  char *query= new char[2048];
   try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID from TB_VOLUMES%s where id_eventbrick=%s and ID_PROCESSOPERATION=%s and VOLUME=%d", 
        eRTS.Data(), id_eventbrick, id_process_operation, ivolume);
 
    fStmt->setSQL(query);
    Log(2,"GetId_Volume","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      strcpy(id,rs->getString(1).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetId_Volume; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

GetId_Zone()

Int_t TOracleServerE2::GetId_Zone	(	char *	id_eventbrick,
		char *	id_plate,
		char *	id_process_operation,
		char *	series,
		char *	id
	)

{
  // Get the zone ID related to a given brick, plate, process operation and series
 
  char *query= new char[2048];
   try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID from tb_zones%s where id_eventbrick=%s and id_plate=%s and id_processoperation=%s and series=%s", 
        eRTS.Data(), id_eventbrick, id_plate, id_process_operation, series);
 
    fStmt->setSQL(query);
    Log(2,"GetId_Zone","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      strcpy(id,rs->getString(1).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetId_Zone; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

GetProcessOperationID() [1/3]

Int_t TOracleServerE2::GetProcessOperationID	(	char *	id_eventbrick,
		char *	id_parent_operation,
		char *	id_programsettings,
		char *	id_plate,
		char *	id
	)

{
  // Get the last process operation ID related to a given brick, plate and program setting
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"\
 select ID from tb_proc_operations%s \
 where id_parent_operation=%s and id_programsettings=%s and id_eventbrick=%s and id_plate=%s",eRTS.Data(),
        id_parent_operation, id_programsettings, id_eventbrick, id_plate);
 
    fStmt->setSQL(query);
    Log(2,"GetProcessOperationID","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      strcpy(id,rs->getString(1).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetProcessOperationID; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

GetProcessOperationID() [2/3]

Int_t TOracleServerE2::GetProcessOperationID	(	char *	id_eventbrick,
		char *	id_programsettings,
		char *	id
	)

{
  // Get the last process operation ID related to a given brick and program setting
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"select ID from tb_proc_operations%s where id_eventbrick=%s and id_programsettings=%s"
        ,eRTS.Data(), id_eventbrick, id_programsettings);
 
    fStmt->setSQL(query);
    Log(2,"GetProcessOperationID","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      strcpy(id,rs->getString(1).c_str());
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetProcessOperationID; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return 0;
}

GetProcessOperationID() [3/3]

ULong64_t TOracleServerE2::GetProcessOperationID	(	ULong64_t	id_eventbrick,
		ULong64_t	id_parent_operation,
		ULong64_t	id_programsettings,
		int	id_plate
	)

{
  // Get the last process operation ID related to a given brick, plate and program setting
 
  ULong64_t id = 0;
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"\
        select ID from tb_proc_operations%s \
            where id_parent_operation=%s and id_programsettings=%s and id_eventbrick=%s and id_plate=%d",eRTS.Data(),
        Ostr(id_parent_operation), Ostr(id_programsettings), Ostr(id_eventbrick), id_plate);
 
    fStmt->setSQL(query);
    Log(2,"GetProcessOperationID","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      sscanf( (rs->getString(1)).c_str(),"%lld",&id);
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2", "GetProcessOperationID; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return id;
}

GetProcessType()

Int_t TOracleServerE2::GetProcessType

(

char *

IDPROCESS

)

{
  // GL: strange function; probably can be useful as an example of the complex query
 
  char *query= new char[2048];
  int scanback=-1;
  int SBFLAG=-99,TSFLAG=-99;
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"\
select SBFLAG, TSFLAG FROM (select decode(count(*),0,0,1) as SBFLAG from tb_scanback_paths \
where (id_eventbrick, id_processoperation) in (select id_eventbrick, id from tb_proc_operations \
where id = %s)),(select decode(count(*),0,0,1) as TSFLAG from tb_volumes \
where (id_eventbrick, id_processoperation) \
in (select id_eventbrick, id from tb_proc_operations where id = %s))",
        IDPROCESS,IDPROCESS);
 
    fStmt->setSQL(query);
    Log(2,"GetProcessType","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
 
    if(!rs->next())  return scanback;
 
    SBFLAG = rs->getInt(1);
    TSFLAG = rs->getInt(2);
 
    if (SBFLAG == 0 && TSFLAG == 0)
      scanback = -1;
    else if (SBFLAG == 1)
      scanback = 1;
    else if (TSFLAG == 1)
      scanback = 0;
 
    delete rs;
  } catch (SQLException &oraex) {
    Error("TOracleServerE", "GetProcessType; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  return scanback;
}

Ostr() [1/2]

const char * TOracleServerE2::Ostr

(

Int_t

num

)

{
    // return "null" if arg<=0;
  return num>0 ? Form("%d",num) : Form("null");
}

Ostr() [2/2]

const char * TOracleServerE2::Ostr

(

ULong64_t

num

)

Print()

void TOracleServerE2::Print

(

)

{
  if(IsConnected()) printf("TOracleServerE2 is connected to: %s://%s:%d/%s\n", ServerInfo(),GetHost(),GetPort(),GetDB() );
  else printf("TOracleServerE2 is not connected!\n");
}

PrintBrickInfo()

void TOracleServerE2::PrintBrickInfo	(	Long_t	id_eventbrick,
		int	level
	)

{
  DumpProcessOperations( Form("%ld",brick), 0);
  DumpBrickVolumesID( Form("%ld",brick));
  DumpEventsID( Form("%ld",brick) );
}

PrintBrickInfoFull()

void TOracleServerE2::PrintBrickInfoFull	(	Long_t	id_eventbrick,
		int	level
	)

{
  if(brick<1000000) {
    PrintBrickInfo( 4000000 + brick, level );
    PrintBrickInfo( 3000000 + brick, level );
    PrintBrickInfo( 2000000 + brick, level );
    PrintBrickInfo( 1000000 + brick, level );
    DumpEventsID(Form("%ld",brick));
  }  else {
    PrintBrickInfo( brick, level );
    DumpEventsID( Form("%ld",brick%1000000));
  }
}

ReadBasetracksPattern()

Int_t TOracleServerE2::ReadBasetracksPattern	(	char *	selection,
		EdbPattern &	pat
	)

!! a kind of hack

{
  // read basetracks from the tb_mipbasetracks table using the given selection string
 
  int ntracks=0;
  char query[2048];
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
    sprintf(query, "SELECT \
  ID_EVENTBRICK, id_zone, ID, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM, PH, SIGMA \
  from tb_mipbasetracks%s where %s",eRTS.Data(),
        selection);
    fStmt->setSQL(query);
    fStmt->setPrefetchRowCount(2000);
    Log(2,"ReadBasetracksPattern","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    EdbSegP seg;
    while (rs->next()){
      seg.Set(
          rs->getInt(3),    //id
          rs->getFloat(4),  //posx
          rs->getFloat(5),  //posy
          rs->getFloat(6),  //slopex
          rs->getFloat(7),  //slopey
          rs->getInt(8),    //grains
          0                 //flag
          );
      seg.SetZ(pat.Z());
      seg.SetDZ(300.);                          
      seg.SetVolume(rs->getInt(10));
      seg.SetVid(pat.PID(),0);          // keep in a segment also plate ID (by Ale)
      pat.AddSegment(seg);
      ntracks++;
    }
    delete rs;
  } catch (SQLException &oraex)  {
    Error("TOracleServerE", "ReadBasetracksPattern failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  Log(2,"ReadBasetracksPattern","%d segments are read\n", ntracks);
  return ntracks;
}

ReadBrickOffset()

Int_t TOracleServerE2::ReadBrickOffset	(	Int_t	id_brick,
		EdbMarksSet &	ms
	)

{
  ms.GetAbsolute()->GetMarks()->Clear("C");
  ms.eBrick = id_brick;
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,
        "select MINX_CM*10000,MINY_CM*10000 from tb_opera_predicted_bricks%s \
             where id_event in \
             (select id_event from tb_b_bmm_brick_extractions%s where id_eventbrick = 1000000+%d) \
             and id_eventbrick = 1000000+%d",
        eRTS.Data(),eRTS.Data(),id_brick,id_brick);
    fStmt->setSQL(query);
    Log(2,"ReadBrickOffset","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      ms.eXmin = rs->getFloat(1);
      ms.eXmax = 0.;
      ms.eYmin = rs->getFloat(2);
      ms.eYmax = 0.;
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE::ReadBrickOffset", "Error!!! %s", (oraex.getMessage()).c_str());
    return false;
  }
  return (0);
}

ReadCSPredictions()

Int_t TOracleServerE2::ReadCSPredictions	(	Int_t	id_brick,
		EdbPattern &	pred
	)

{
  // Fills an EdbPattern object with CS predictions
  // bugged version. Please use ReadCSPredictions2() instead
 
  pred.Reset();
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    // select * from vw_cs_candidates@opita01 vwcs 
    // inner join tb_cs_candidate_validation@opita01 vld on (vld.id_candidate= vwcs.id_candidate)
    // where vld.id_eventbrick = 3021343 and vld.valid = 'Y';
 
    sprintf(query,
        "select cand,posx,posy,slopex,slopey,grains from vw_local_cs_candidates%s where id_cs_eventbrick in (select id from tb_eventbricks where id_brick=%d) and id_plate=2",
        eRTS.Data(),id_brick);
    
    fStmt->setSQL(query);
    Log(2,"ReadCSPredictions","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      pred.AddSegment(rs->getInt(1),rs->getFloat(2),rs->getFloat(3),rs->getFloat(4),rs->getFloat(5),
              rs->getInt(6),0);
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE::ReadCSPredictions", "Error!!! %s", (oraex.getMessage()).c_str());
    return false;
  }
  return (pred.N());
}

ReadCSPredictions2()

Int_t TOracleServerE2::ReadCSPredictions2	(	Int_t	id_brick,
		EdbPattern &	pred
	)

{
  // Fills an EdbPattern object with CS predictions
  // The query is better than the one in ReadCSPredictions because takes
  // into account also the 3 over 4 selection
 
  pred.Reset();
  EdbSegP seg;
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    // select * from vw_cs_candidates@opita01 vwcs 
    // inner join tb_cs_candidate_validation@opita01 vld on (vld.id_candidate= vwcs.id_candidate)
    // where vld.id_eventbrick = 3021343 and vld.valid = 'Y';
 
    sprintf(query,
            "select cand, posx, posy, slopex, slopey, grains, id_plate from \
                (select idcand, cand, posx, posy, slopex, slopey, id_plate, grains, row_number() \
                over (partition by idcand order by grains desc, id_plate desc) as rnum from \
                vw_local_cs_candidates where id_cs_eventbrick in \
                (select id from tb_eventbricks where mod(id_brick,1000000)=%d)) \
                where rnum = 1 order by cand",
            id_brick);
    
    fStmt->setSQL(query);
    Log(2,"ReadCSPredictions2","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      seg.Set(rs->getInt(1),rs->getFloat(2),rs->getFloat(3),rs->getFloat(4),rs->getFloat(5),
              rs->getInt(6),0);
      seg.SetPID(rs->getInt(7));
      pred.AddSegment(seg);
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE::ReadCSPredictions2", "Error!!! %s", (oraex.getMessage()).c_str());
    return false;
  }
  return (pred.N());
}

ReadCSPredictions_remote_v2()

Int_t TOracleServerE2::ReadCSPredictions_remote_v2	(	Int_t	id_brick,
		EdbPattern &	pred,
		int	csid
	)

{
  // Fills an EdbPattern object with CS predictions
  // The query is better than the one in ReadCSPredictions because takes
  // into account also the 3 over 4 selection
  // csid: 1 or 2
 
  pred.Reset();
  EdbSegP seg;
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    if(csid==1) {
      sprintf(query, "select distinct candidate,posx_1,posy_1,slopex_1,slopey_1,grains_1 from vw_cs_candidates_v2 where mod(id_eventbrick,1000000)=%d order by candidate", id_brick);
    } else if(csid==2) {
      sprintf(query, "select distinct candidate,posx_2,posy_2,slopex_2,slopey_2,grains_2 from vw_cs_candidates_v2 where mod(id_eventbrick,1000000)=%d order by candidate", id_brick);
    }
 
    fStmt->setSQL(query);
    Log(2,"ReadCSPredictions2","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      seg.Set(rs->getInt(1),rs->getFloat(2),rs->getFloat(3),rs->getFloat(4),rs->getFloat(5),
          rs->getInt(6),0);
      seg.SetPID(csid);
      pred.AddSegment(seg);
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE::ReadCSPredictions2", "Error!!! %s", (oraex.getMessage()).c_str());
    return false;
  }
  return (pred.N());
}

ReadDataSet()

Int_t TOracleServerE2::ReadDataSet	(	ULong64_t	id_parent_op,
		int	id_brick,
		ULong64_t	path,
		EdbPatternsVolume &	vol
	)

{
  // read all basetracks patterns corresponsing to the given parent process for the given brick and given path ("series" in tb_zones table)
  // TO CHECK: this set of selection parameters guarantee the consistence and uniqueness of data? (all data of calibration/scanback/totalscan, etc)
  int  nsegtot=0;
  char query[2048];
  int npat = 0;
  TObjArray patterns(100);
  ULong64_t *proc_list = new ULong64_t[100];
  EdbPattern *pat=0;
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"\
 select to_char(op.id), op.id_plate, pl.z, op.success \
 from tb_proc_operations%s op, tb_plates%s pl \
 where op.id_eventbrick=%d and pl.id_eventbrick=%d and pl.id=op.id_plate and op.id_parent_operation=%lld \
 order by op.id_plate", eRTS.Data(), eRTS.Data(),
        id_brick, id_brick, id_parent_op);
 
    fStmt->setSQL(query);
    Log(2,"ReadDataSet","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
 
    ULong64_t procop=0LL;
    float z=0;
    int plate=0;
    npat=0;
    while (rs->next()){
      sscanf( (rs->getString(1)).c_str(),"%lld", &procop );
      if(strncmp(rs->getString(4).c_str(),"Y",1)) continue;
      plate = rs->getInt(2);
      z     = rs->getFloat(3);
      proc_list[npat] = procop;
      npat++;
      pat = new EdbPattern(0.,0.,z);
      pat->SetPID(plate);
      patterns.Add( pat );
    }
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE", "ReadPatternsVolume; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
 
  for(int i=0; i<npat; i++) {
    pat = (EdbPattern*)patterns.At(i);
    if( !ReadZplate(id_brick, pat->PID(), *pat ) )
      { Log(1,"ReadDataSet","skip plate %d %d !", id_brick,pat->PID()); continue; }
    sprintf(query,"id_zone in (select id from tb_zones%s where id_processoperation=%lld and id_plate=%d and series=%lld)",eRTS.Data(),
        proc_list[i],pat->PID(), path);
    nsegtot  += ReadBasetracksPattern( query, *pat);
    vol.AddPattern(pat);
  }
  Log(2,"ReadDataSet","%d segments extracted from db into PatternsVolume",nsegtot);
 
  return nsegtot;
}

ReadMicrotracksPattern()

Int_t TOracleServerE2::ReadMicrotracksPattern	(	int	id_eventbrick,
		char *	selection,
		EdbPattern &	pat
	)

!! a kind of hack

{
  // read all microtracks from TB_MIPMICROTRACKS table for the given selection
 
  int ntracks=0;
  char query[2048];
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query, "SELECT \
  ID_EVENTBRICK, id_zone, ID, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM, SIGMA, SIDE, ID_VIEW \
  from TB_MIPMICROTRACKS%s where id_eventbrick=%d and %s",eRTS.Data(),
        id_eventbrick, selection);
 
    fStmt->setSQL(query);
    fStmt->setPrefetchRowCount(2000);
    Log(2,"ReadMicrotracksPattern","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    EdbSegP seg;
    while (rs->next()){
      seg.Set(
          rs->getInt(3),    //id
          rs->getFloat(4),  //posx
          rs->getFloat(5),  //posy
          rs->getFloat(6),  //slopex
          rs->getFloat(7),  //slopey
          rs->getInt(8),    //grains
          0                 //flag
          );
      seg.SetSZ(rs->getFloat(11)); // put sigma here!
      seg.SetZ(pat.Z());
      seg.SetDZ(45.);                          
      seg.SetVolume(rs->getInt(9));     //areasum
      seg.SetVid(pat.PID(),0);          // keep in a segment also plate ID (by Ale)
      seg.SetAid(0,rs->getInt(12), rs->getInt(11));     // area id, view id, side
      pat.AddSegment(seg);
      ntracks++;
    }
    delete rs;
  } catch (SQLException &oraex)  {
    Error("TOracleServerE2", "ReadMicrotracksPattern failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  Log(2,"ReadMicrotracksPattern","%d segments are read", ntracks);
  return ntracks;
}

ReadMicrotracksZone()

Int_t TOracleServerE2::ReadMicrotracksZone	(	Int_t	id_eventbrick,
		ULong64_t	id_zone,
		int	side,
		TObjArray &	edbviews
	)

{
  // read all microtracks for the one side of the one zone
 
  char selection[1024];
  sprintf(selection, " id_zone=%lld and side=%d", id_zone, side );
  EdbPattern pat;
  int nseg = ReadMicrotracksPattern( id_eventbrick, selection, pat);
 
  std::map<int,EdbView*> id_views;
  EdbView     *v=0;
  for(int i=0; i<edbviews.GetEntriesFast(); i++) {
    v = (EdbView*)edbviews.At(i);
    id_views[v->GetViewID()]=v;
  }
 
  EdbSegment   sv;
  EdbSegP    *sp=0;
  float z=0;
  for(int i=0; i<nseg; i++ ) {
    sp = pat.GetSegment(i);
    //v = (EdbView*)edbviews.At(sp->Aid(1)-1);   // assume that views are in the order!
 
    v = id_views.find(sp->Aid(1))->second;       // do not assume that views are in the order
    if(!v) {
      Log(1,"ReadMicrotracksZone","ERROR! do not found view for segment with Aid: %d %d - skipped!",sp->Aid(0),sp->Aid(1));
      continue;
    }
 
    if(v->GetNframesTop()>0) z = v->GetZ2(); 
    else                     z = v->GetZ3();
    sv.Set( sp->X()-v->GetXview(),
        sp->Y()-v->GetYview(),
        z,sp->TX(),
        sp->TY(), 
        sp->DZ(),         // dz - not exist the real one??
        side, 
        int(sp->W()), 
        0 );              // id - where to get it???
    sv.SetSigma(sp->SZ(),0);
    v->AddSegment(&sv);
  }
 
  return 0;
}

ReadScanbackPath()

Int_t TOracleServerE2::ReadScanbackPath	(	Int_t	id_eventbrick,
		Int_t	path,
		EdbTrackP &	t
	)

!! a kind of hack

!! a kind of hack

{
  // read scanback track from vw_scanback_history and fill track t
  // the found segments stored as "s", the predicted ones as "sf"
 
  int  nseg=0;
  char query[2048];
  try{
    if (!fStmt)  fStmt = fConn->createStatement();
 
    sprintf(query, "select \
id_track,id_plate,z,grains,fpx,fpy,fsx,fsy,ppx,ppy,psx,psy \
from vw_scanback_history%s \
where id_eventbrick=%d and path=%d and grains is not null order by id_plate"
        ,eRTS.Data(), id_eventbrick, path);
 
    fStmt->setSQL(query);
    fStmt->setPrefetchRowCount(2000);
    Log(2,"ReadScanbackPath","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    EdbSegP seg;
    EdbSegP segp;
    while (rs->next()){
      seg.Set(
          rs->getInt(1),    //id_track
          rs->getFloat(5),  //fpx
          rs->getFloat(6),  //fpy
          rs->getFloat(7),  //fsx
          rs->getFloat(8),  //fsy
          rs->getInt(4),    //grains
          0                 //flag
          );
      seg.SetPID(rs->getInt(2));          // id_plate
      seg.SetZ(rs->getFloat(3));          // z
      seg.SetDZ(300.);                    
      segp.Set(
          rs->getInt(1),     //id_track
          rs->getFloat(9),   //ppx
          rs->getFloat(10),  //ppy
          rs->getFloat(11),  //psx
          rs->getFloat(12),  //psy
          rs->getInt(4),     //grains
          0                  //flag
          );
      segp.SetPID(rs->getInt(2));          // id_plate
      segp.SetZ(rs->getFloat(3));          // z
      segp.SetDZ(300.);                    
      t.AddSegment(new EdbSegP(seg));
      t.AddSegmentF(new EdbSegP(segp));
      nseg++;
    }
    delete rs;
  } catch (SQLException &oraex)  {
    Error("TOracleServerE", "ReadBasetracksPattern failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  Log(2,"ReadScanbackPath","%d segments are read\n", nseg);
  t.SetID(path);
  t.SetSegmentsTrack(path);
  t.SetCounters();
  return nseg;
}

ReadTemplateMarks()

Int_t TOracleServerE2::ReadTemplateMarks	(	Int_t	id_brick,
		EdbMarksSet &	ms
	)

{
  ms.GetAbsolute()->GetMarks()->Clear("C");
  ms.eBrick = id_brick;
 
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,
        "select minx,maxx,miny,maxy from tb_eventbricks%s where mod(id_brick,1000000)=%d",
        eRTS.Data(),id_brick);
    fStmt->setSQL(query);
    Log(2,"ReadTemplateMarks","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      ms.eXmin = rs->getFloat(1);
      ms.eXmax = rs->getFloat(2);
      ms.eYmin = rs->getFloat(3);
      ms.eYmax = rs->getFloat(4);
    }
    delete rs;
 
    sprintf(query,
        "select id_mark,posx,posy,side from tb_templatemarksets%s where id_eventbrick in \
             (select id from tb_eventbricks where mod(id_brick,1000000)=%d) and shape='X'",
        eRTS.Data(),id_brick);
 
    fStmt->setSQL(query);
    Log(2,"ReadTemplateMarks","execute sql query: %s ...",query);
    fStmt->execute();
    rs = fStmt->getResultSet();
    while (rs->next()){
      ms.GetAbsolute()->AddMark(rs->getInt(1),rs->getFloat(2),rs->getFloat(3),rs->getInt(4));
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE::ReadTemplateMarks", "Error!!! %s", (oraex.getMessage()).c_str());
    return false;
  }
  return (ms.GetAbsolute()->N());
}

ReadVetoTracks()

Int_t TOracleServerE2::ReadVetoTracks	(	Int_t	id_brick,
		EdbPattern &	pred
	)

{
  // Fills an EdbPattern object with veto tracks
  // The query reads from the table tb_veto_tracks
 
  veto.Reset();
  EdbSegP seg;
  char *query= new char[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,
        "select track,posx,posy,slopex,slopey from tb_veto_tracks%s where mod(id_cs_eventbrick,1000000)=%d",
        eRTS.Data(),id_brick);
    
    fStmt->setSQL(query);
    Log(2,"ReadVetoTracks","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      seg.Set(rs->getInt(1),rs->getFloat(2),rs->getFloat(3),rs->getFloat(4),rs->getFloat(5),0,0);
      seg.SetPID(57);
      veto.AddSegment(seg);
    }
    delete rs;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE::ReadVetoTracks", "Error!!! %s", (oraex.getMessage()).c_str());
    return false;
  }
  return (veto.N());
}

ReadViewsZone()

Int_t TOracleServerE2::ReadViewsZone	(	ULong64_t	id_zone,
		int	side,
		TObjArray &	edbviews
	)

{
  // read TB_VIEWS for the given zone and fill the array of edbviews with the correct headers information
 
  int  nviews=0;
  char query[2048];
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
    sprintf(query, "SELECT \
  id_eventbrick, side, id, downz, upz, posx, posy \
  from TB_VIEWS%s where id_zone=%lld and side=%d order by id", eRTS.Data(),
        id_zone,side);
    fStmt->setSQL(query);
    fStmt->setPrefetchRowCount(2000);
    Log(2,"ReadViewsZone","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    EdbView *view=0;
    while (rs->next()) {
      view = new EdbView();
      view->GetHeader()->SetAreaID(id_zone%10000000);
      view->GetHeader()->SetViewID(rs->getInt(3));
 
      //inverted 1 and 2 (vt 26/05)
      if     (side==2)  {
    view->SetNframes(0,15);  //bottom side
    view->GetHeader()->SetCoordZ( 0,0, rs->getFloat(5), rs->getFloat(4) );  //to check it!
      }
      else if(side==1) {
    view->SetNframes(15,0);  //top side
    view->GetHeader()->SetCoordZ( rs->getFloat(5), rs->getFloat(4), 0,0 );  //to check it!
      }
      view->GetHeader()->SetCoordXY( rs->getFloat(6), rs->getFloat(7) );
 
      edbviews.Add(view);
      nviews++;
    }
    delete rs;
  } catch (SQLException &oraex)  {
    Error("TOracleServerE2", "ReadViews is failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  Log(2,"ReadViewsZone","%d views are read\n", nviews);
  return nviews;
}

ReadVolume() [1/4]

Int_t TOracleServerE2::ReadVolume	(	char *	id_volume,
		EdbPatternsVolume &	vol
	)

{
  int  nsegtot=0;
  char query[2048];
  TObjArray patterns(100);
  EdbPattern *pat=0;
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
    sprintf(query,"\
    select id_plate,id_eventbrick from TB_VOLUME_SLICES%s where id_volume=%s order by id_plate",eRTS.Data(), id_volume);
    fStmt->setSQL(query);
    Log(2,"ReadVolume","\nexecute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    if(!rs) return 0;
    int plate=0;
    int brick=0;
    while (rs->next()){
      sscanf( (rs->getString(1)).c_str(),"%d", &plate );
      sscanf( (rs->getString(2)).c_str(),"%d", &brick );
      pat = new EdbPattern(0.,0.,0);
      pat->SetPID(plate);
      pat->SetID(brick);
      patterns.Add( pat );
    }
  } catch (SQLException &oraex) {
    Error("TOracleServerE", "ReadPatternsVolume; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  int npat = patterns.GetEntries();
  for(int i=0; i<npat; i++) {
    pat = (EdbPattern*)patterns.At(i);
    //if( !ReadZplate(pat->ID(), pat->PID(), *pat ) )
    if( !ReadZplate_nominal(pat->ID(), pat->PID(), *pat ) )
      { Log(1,"ReadVolume","skip plate %d %d !", pat->ID(),pat->PID()); continue; }
    sprintf(query,"id_eventbrick=%d and id_zone in (select id_zone from TB_VOLUME_SLICES%s where id_volume=%s and id_plate=%d)",pat->ID(), eRTS.Data(), id_volume,pat->PID());
    nsegtot  += ReadBasetracksPattern(query, *pat);
    vol.AddPattern(pat);
  }
  Log(2,"ReadVolume","%d segments extracted from db into PatternsVolume",nsegtot);
 
  return nsegtot;
}

ReadVolume() [2/4]

Int_t TOracleServerE2::ReadVolume	(	char *	id_volume,
		EdbPatternsVolume &	vol,
		Int_t	min,
		Int_t	max
	)

{
  int  nsegtot=0;
  char query[2048];
  TObjArray patterns(100);
  EdbPattern *pat=0;
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
    sprintf(query,"\
    select id_plate,id_eventbrick from TB_VOLUME_SLICES%s where (id_volume=%s and id_plate > %d-1 and id_plate < %d+1) order by id_plate", 
        eRTS.Data(),
        id_volume,min,max);
    fStmt->setSQL(query);
    Log(2,"ReadVolume","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    int plate=0;
    int brick=0;
    while (rs->next()){
      sscanf( (rs->getString(1)).c_str(),"%d", &plate );
      sscanf( (rs->getString(2)).c_str(),"%d", &brick );
      pat = new EdbPattern(0.,0.,0);
      pat->SetPID(plate);
      pat->SetID(brick);
      patterns.Add( pat );
    }
  } catch (SQLException &oraex) {
    Error("TOracleServerE", "ReadPatternsVolume; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
  int npat = patterns.GetEntries();
  for(int i=0; i<npat; i++) {
    pat = (EdbPattern*)patterns.At(i);
    if( !ReadZplate(pat->ID(), pat->PID(), *pat ) )
      { Log(1,"ReadVolume","skip plate %d %d !", pat->ID(),pat->PID()); continue; }
    sprintf(query,"id_zone in (select id_zone from TB_VOLUME_SLICES%s where id_volume=%s and id_plate=%d)",eRTS.Data(),
        id_volume,pat->PID());
    nsegtot  += ReadBasetracksPattern(query, *pat);
    vol.AddPattern(pat);
  }
  Log(2,"ReadVolume","%d segments extracted from db into PatternsVolume",nsegtot);
 
  return nsegtot;
}

ReadVolume() [3/4]

Int_t TOracleServerE2::ReadVolume	(	ULong64_t	id_volume,
		EdbPatternsVolume &	vol
	)

{
  char id[24];
  sprintf(id,"%lld",id_volume);
  return ReadVolume(id,vol);
}

ReadVolume() [4/4]

Int_t TOracleServerE2::ReadVolume	(	ULong64_t	id_volume,
		EdbPatternsVolume &	vol,
		Int_t	min_pl,
		Int_t	max_pl
	)

{
  char id[24];
  Int_t min= min_pl;
  Int_t max= max_pl;
  sprintf(id,"%lld",id_volume);
  return ReadVolume(id,vol,min,max);
}

ReadZplate()

bool TOracleServerE2::ReadZplate	(	int	id_plate,
		int	id_eventbrick,
		EdbPattern &	pat
	)

{
  // read z of the plate after calibration from the tb_plate_calibrations table
 
  char *query= new char[2048];
  Float_t Z=0;
  EdbAffine2D *aff=0;
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,
            "select z,MAPXX,MAPXY,MAPYX,MAPYY,MAPDX,MAPDY from tb_plate_calibrations%s \
             where id_eventbrick=%d and id_plate=%d", eRTS.Data(),
            id_eventbrick, id_plate);
    fStmt->setSQL(query);
    Log(2,"ReadZplate","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      Z = rs->getFloat(1);
      aff = new EdbAffine2D(rs->getFloat(2),
                            rs->getFloat(3),
                            rs->getFloat(4),
                            rs->getFloat(5),
                            rs->getFloat(6),
                            rs->getFloat(7));
    }
    delete rs;
    pat.SetZ(Z);
    aff->Print();
  } catch (SQLException &oraex) {
    Error("TOracleServerE", "ReadBasetracksPattern; Affine failed: (error: %s)", (oraex.getMessage()).c_str());
    return false;
  }
  return true;
}

ReadZplate_nominal()

bool TOracleServerE2::ReadZplate_nominal	(	int	id_plate,
		int	id_eventbrick,
		EdbPattern &	pat
	)

{
  // read nominal z of the plate from the tb_plates table
 
  char *query= new char[2048];
  Float_t Z=0;
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,
            "select pl.z-br.minz from tb_plates%s pl, tb_eventbricks%s br\
             where pl.id_eventbrick=%d and pl.id=%d and br.id=pl.id_eventbrick",eRTS.Data(),eRTS.Data(),
            id_eventbrick, id_plate);
 
    fStmt->setSQL(query);
    Log(2,"ReadZplate_nominal","execute sql query: %s ...",query);
    fStmt->execute();
    ResultSet *rs = fStmt->getResultSet();
    while (rs->next()){
      Z = rs->getFloat(1);
    }
    delete rs;
    pat.SetZ(Z);
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE", "ReadBasetracksPattern; Affine failed: (error: %s)", (oraex.getMessage()).c_str());
    return false;
  }
  return true;
}

Member Data Documentation

eRTS

TString TOracleServerE2::eRTS

---

The documentation for this class was generated from the following files:

• /home/antonio/fedra_doxygen/src/libEOracle/TOracleServerE2.h
• /home/antonio/fedra_doxygen/src/libEOracle/TOracleServerE2.cxx