TOracleServerE2WFB Class Reference

#include <TOracleServerE2WFB.h>

Inheritance diagram for TOracleServerE2WFB:

Collaboration diagram for TOracleServerE2WFB:

Public Member Functions
Int_t	AddEventBrick (const char *databrick)
ULong64_t	AddFeedbackReconstruction (ULong64_t id_eventbrick, ULong64_t id_processoperation)
ULong64_t	AddFeedbackReconstructionTest (ULong64_t id_eventbrick, ULong64_t id_processoperation)
Int_t	AddFeedbackSegment (ULong64_t id_eventbrick, ULong64_t id_reconstruction, Int_t id_plate, Int_t id_track, const char *tracktype, Float_t posx, Float_t posy, Float_t posz, Float_t slopex, Float_t slopey, Int_t grains, const char *trackmode)
Int_t	AddFeedbackTrack (ULong64_t id_eventbrick, ULong64_t id_reconstruction, Int_t id_track, Int_t id_upvtx, Int_t id_downvtx, Float_t x, Float_t y, Float_t z, Float_t sx, Float_t sy, const char *manual, const char *particle, const char *scanback, const char *darkness, Float_t upip, Float_t downip, Float_t p, Float_t pmin, Float_t pmax, const char *outofbrick, Int_t lastplate, Float_t rslopet, Float_t rslopel, Float_t rmsslopet, Float_t rmsslopel, Int_t kinkplatedown, Int_t kinkplateup, const char *decaysearch, ULong64_t event)
Int_t	AddFeedbackVertex (ULong64_t id_eventbrick, ULong64_t id_reconstruction, Int_t id_vertex, Float_t posx, Float_t posy, Float_t posz, const char *isprimary, const char *ischarm, const char *istau, const char *outofbrick)
Int_t	AddPlate (ULong64_t id_eventbrick, const char *dataplate)
ULong64_t	AddProcessOperationBrick (ULong64_t id_machine, ULong64_t id_programsettings, ULong64_t id_requester, ULong64_t id_eventbrick, ULong64_t id_parent_operation, const char *starttime, const char *notes)
Int_t	AddTemplateMarkSets (const char *datamarks)
Int_t	CloseFeedbackDataset (ULong64_t id_operation, const char *endtime)
Bool_t	FinishTransaction ()
ULong64_t	IfEventBrick (ULong64_t id_eventbrick, const char *id_set)
ULong64_t	IfEventRec (ULong64_t id_eventbrick)
Int_t	MyQuery (const char *sqlquery)
const char *	Ostr (Int_t num)
const char *	Ostr (ULong64_t num)
void	Print ()
void	Set0 ()
Int_t	SetTransactionRW ()
const char *	Timestamp ()
	TOracleServerE2WFB (const char *db, const char *uid, const char *pw)
	as "NA" More...
	~TOracleServerE2WFB ()
Public Member Functions inherited from TOracleServerE2
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
Bool_t	eDoCommit
TString	eLa
	as "NAPOLI" More...
TString	eLab
Public Attributes inherited from TOracleServerE2
TString	eRTS

Constructor & Destructor Documentation

TOracleServerE2WFB()

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

inline

as "NA"

:TOracleServerE2(db, uid, pw) {Set0();}

~TOracleServerE2WFB()

TOracleServerE2WFB::~TOracleServerE2WFB ( )

inline

{}

Member Function Documentation

AddEventBrick()

Int_t TOracleServerE2WFB::AddEventBrick

(

const char *

databrick

)

{
  // Adds a brick into the DB
  
  if(!MyQuery(Form( "\
      INSERT INTO OPERA.PV_%s_EVENTBRICKS \
      (ID, MINX, MAXX, MINY, MAXY, MINZ, MAXZ, ID_SET, ID_BRICK, ZEROX, ZEROY, ZEROZ) VALUES (%s)", eLa.Data(),
  databrick )))  return 0;
  Log(2,"TOracleServerE2WFB:AddEventBrick","Brick added");
  return 1;
}

AddFeedbackReconstruction()

ULong64_t TOracleServerE2WFB::AddFeedbackReconstruction	(	ULong64_t	id_eventbrick,
		ULong64_t	id_processoperation
	)

{
    if(!MyQuery( Form
        (
        "INSERT INTO %s.VW_FEEDBACK_RECONSTRUCTIONS_J(id_eventbrick,id_processoperation) values(%s,%s)", eLab.Data(),
    Ostr(id_eventbrick),
    Ostr(id_processoperation)
        ))) return 0;
    if(!MyQuery( Form
        (
        "select id_reconstruction from %s.VW_FEEDBACK_RECONSTRUCTIONS_J where  id_eventbrick=%s and id_processoperation=%s", eLab.Data(),
    Ostr(id_eventbrick),
    Ostr(id_processoperation)
        ))) return 0;
    ULong64_t id=0;
    if(fStmt) {
      ResultSet *rs = fStmt->getResultSet();
      if(rs) 
        if(rs->next()) {
          sscanf( (rs->getString(1)).c_str(),"%lld",&id);
          Log(2,"TOracleServerE2WFB::AddFeedbackReconstructionOld","added, id = %lld",id);
        }
    }
    return id;
}

AddFeedbackReconstructionTest()

ULong64_t TOracleServerE2WFB::AddFeedbackReconstructionTest	(	ULong64_t	id_eventbrick,
		ULong64_t	id_processoperation
	)

{
  ULong64_t id=0;
  try{
    TString s=Form(
        "BEGIN INSERT INTO %s.VW_FEEDBACK_RECONSTRUCTIONS_J(id_eventbrick,id_processoperation) values(%s,%s) returning id_reconstruction into :1; END;",
    eLab.Data(),
    Ostr(id_eventbrick),
    Ostr(id_processoperation)
                  );
    Log(2,"","%s",s.Data() );
    fStmt->setSQL( s.Data() );
    fStmt->registerOutParam(1, OCCISTRING,64);
    fStmt->executeUpdate();
    if(!(fStmt->getString(1)).c_str()) {
      Log(2,"TOracleServerE2WFB::AddProcessOperationBrick","ERROR! empty operation returned!");
      eDoCommit=0;
      return 0;
    }
    Log(2,"","%s", (fStmt->getString(1)).c_str() );
    sscanf( (fStmt->getString(1)).c_str(),"%lld",&id);
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WFB::AddFeedbackReconstruction", "failed: (error: %s)", (oraex.getMessage()).c_str());
    eDoCommit=0;
  }
  return id;
}

AddFeedbackSegment()

Int_t TOracleServerE2WFB::AddFeedbackSegment	(	ULong64_t	id_eventbrick,
		ULong64_t	id_reconstruction,
		Int_t	id_plate,
		Int_t	id_track,
		const char *	tracktype,
		Float_t	posx,
		Float_t	posy,
		Float_t	posz,
		Float_t	slopex,
		Float_t	slopey,
		Int_t	grains,
		const char *	trackmode
	)

{
  TString query;
  query+=Form("insert into %s.vw_feedback_segments_j",eLab.Data());
  query+="(id_eventbrick, id_reconstruction, id_plate,id_track,tracktype,posx, posy, posz, slopex, slopey, grains,trackmode) ";
  query+=Form("values(\
      %s, %s, %s, %s, %s,\
      %12.2f, %12.2f, %12.2f, %8.5f, %8.5f,\
      %d, %s)",
  Ostr(id_eventbrick), 
  Ostr(id_reconstruction), 
  Ostr(id_plate),
  Ostr(id_track),
  tracktype,posx, posy, posz, slopex, slopey, grains,trackmode);
  
  if(!MyQuery(query.Data())) { return 0;}
  Log(3,"TOracleServerE2WFB::AddFeedbackTrack","ok");
  return 1;
}

AddFeedbackTrack()

Int_t TOracleServerE2WFB::AddFeedbackTrack	(	ULong64_t	id_eventbrick,
		ULong64_t	id_reconstruction,
		Int_t	id_track,
		Int_t	id_upvtx,
		Int_t	id_downvtx,
		Float_t	x,
		Float_t	y,
		Float_t	z,
		Float_t	sx,
		Float_t	sy,
		const char *	manual,
		const char *	particle,
		const char *	scanback,
		const char *	darkness,
		Float_t	upip,
		Float_t	downip,
		Float_t	p,
		Float_t	pmin,
		Float_t	pmax,
		const char *	outofbrick,
		Int_t	lastplate,
		Float_t	rslopet,
		Float_t	rslopel,
		Float_t	rmsslopet,
		Float_t	rmsslopel,
		Int_t	kinkplatedown,
		Int_t	kinkplateup,
		const char *	decaysearch,
		ULong64_t	event
	)

{
  TString query;
  query+=Form("insert into %s.vw_feedback_tracks_j (",eLab.Data());
  query+="id_eventbrick, id_reconstruction, id_track, id_upvtx, id_downvtx,";
  query+="x, y, z, sx, sy, manual, particle, scanback, darkness,upip, downip, p, pmin, pmax,outofbrick,lastplate,";
  query+="rslopet,rslopel,rmsslopet,rmsslopel,kinkplatedown,kinkplateup,decaysearch,event";
  query+=Form(") values(\
      %s, %s, %s, %s, %s, \
      %12.2f, %12.2f, %12.2f, %8.5f, %8.5f, %s, %s, %s, %s, \
      %10.3f, %10.3f, %10.3f, %10.3f, %10.3f, %s, %d, %8.5f, %8.5f, %8.5f, %8.5f, \
      %s, %s, %s, %lld )",
  Ostr(id_eventbrick), 
  Ostr(id_reconstruction), 
  Ostr(id_track), 
  Ostr(id_upvtx), 
  Ostr(id_downvtx),
  x, y, z, sx, sy, 
  manual, particle, scanback, darkness,
  upip,downip, p, pmin, pmax,outofbrick,lastplate,rslopet,rslopel,rmsslopet,rmsslopel,
  Ostr(kinkplatedown),
  Ostr(kinkplateup),
  decaysearch,
  event
             );
 
  if(!MyQuery(query.Data())) { return 0;}
  Log(3,"TOracleServerE2WFB::AddFeedbackTrack","ok");
  return 1;
}

AddFeedbackVertex()

Int_t TOracleServerE2WFB::AddFeedbackVertex	(	ULong64_t	id_eventbrick,
		ULong64_t	id_reconstruction,
		Int_t	id_vertex,
		Float_t	posx,
		Float_t	posy,
		Float_t	posz,
		const char *	isprimary,
		const char *	ischarm,
		const char *	istau,
		const char *	outofbrick
	)

{
  TString query;
  query+=Form("insert into %s.vw_feedback_vertices_j ", eLab.Data());
  query+="(id_eventbrick,id_reconstruction,id_vertex,posx,posy,posz,isprimary,ischarm,istau, outofbrick) ";
  query+=Form("values(%s, %s, %s, %12.2f, %12.2f, %12.2f, %s, %s, %s, %s)",
              Ostr(id_eventbrick),
              Ostr(id_reconstruction),
              Ostr(id_vertex),
              posx,posy,posz,isprimary,ischarm,istau, outofbrick);
  if(!MyQuery(query.Data())) { return 0;}
  Log(3,"TOracleServerE2WFB::AddFeedbackVertex","ok");
  return 1;
}

AddPlate()

Int_t TOracleServerE2WFB::AddPlate	(	ULong64_t	id_eventbrick,
		const char *	dataplate
	)

{
  // Adds a plate into the DB
  // Table involved: TB_PLATE
 
  if(!MyQuery(Form( "\
      INSERT INTO OPERA.PV_%s_PLATES (ID_EVENTBRICK, ID, Z) \
      VALUES (%s, %s)", eLa.Data(),
  Ostr(id_eventbrick),
  dataplate)))   return 0;
  Log(2,"TOracleServerE2WFB::AddPlate","Plate added");
  return 1;
}

AddProcessOperationBrick()

ULong64_t TOracleServerE2WFB::AddProcessOperationBrick	(	ULong64_t	id_machine,
		ULong64_t	id_programsettings,
		ULong64_t	id_requester,
		ULong64_t	id_eventbrick,
		ULong64_t	id_parent_operation,
		const char *	starttime,
		const char *	notes
	)

{
  ULong64_t id=0;
  try{
    TString s;
    s+=Form(
        "BEGIN  %s.PC_ADD_PROC_OPERATION_BRICK(%s, %s, %s, %s, %s, %s, '%s', :1); END;", eLab.Data(),
    Ostr(id_machine), 
    Ostr(id_programsettings), 
    Ostr(id_requester), 
    Ostr(id_eventbrick), 
    Ostr(id_parent_operation),
    starttime, 
    notes
           );
    
    printf("%s\n",s.Data() );
    if (!fStmt)  fStmt = fConn->createStatement();
    fStmt->setSQL( s.Data() );
    fStmt->registerOutParam(1, OCCISTRING,64);
    fStmt->execute();
    if(!(fStmt->getString(1)).c_str()) {
      Log(2,"TOracleServerE2WFB::AddProcessOperationBrick","ERROR! empty operation returned!");
      return 0;    eDoCommit=0;
    }
    Log(2,"TOracleServerE2WFB::AddProcessOperationBrick","returned string is: %s",(fStmt->getString(1)).c_str());
    sscanf( (fStmt->getString(1)).c_str(),"%lld",&id);
    Log(2,"TOracleServerE2WFB::AddProcessOperation","output: %lld",id);
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WFB", "AddProcessOperation failed: (error: %s)", (oraex.getMessage()).c_str());
    eDoCommit=0;
  }
  return id;
}

AddTemplateMarkSets()

Int_t TOracleServerE2WFB::AddTemplateMarkSets

(

const char *

datamarks

)

{
  // Adds a mark into the DB
  // Table involved: TB_TEMPLATEMARKSETS
 
  if(!MyQuery(Form( "\
      INSERT INTO OPERA.PV_%s_TEMPLATEMARKSETS\
      (ID_EVENTBRICK, ID_MARK, POSX, POSY, MARKROW, MARKCOL, SHAPE, SIDE)\
      VALUES (%s)", eLa.Data(),
  datamarks)))  return 0;
  Log(2,"TOracleServerE2WFB::AddTemplateMarkSets","TemplateMarkSets added");
  return 1;
}

CloseFeedbackDataset()

Int_t TOracleServerE2WFB::CloseFeedbackDataset	(	ULong64_t	id_operation,
		const char *	endtime
	)

{
  try{
    if (!fStmt)  fStmt = fConn->createStatement();
    fStmt->setSQL( Form(
        "begin %s.PC_SUCCESS_OPERATION( %s, %s ); end;", eLab.Data(),
    Ostr(id_operation),
    endtime
                       )
                 );
    printf("%s\n",fStmt->getSQL().c_str() );
    fStmt->execute();
    return 1;
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WFB", "CloseFeedbackDataset failed: (error: %s)", (oraex.getMessage()).c_str());
    eDoCommit=0;
  }
  return 0;
}

FinishTransaction()

Bool_t TOracleServerE2WFB::FinishTransaction

(

)

{
  try{
    if(eDoCommit) return MyQuery("COMMIT"); 
    else          return MyQuery("ROLLBACK");
  } catch (SQLException &oraex) {
    Log(1,"TOracleServerE2WFB::FinishTransaction","failed: (error: %s)",(oraex.getMessage()).c_str());
    return 0;
  }
  return 1;
}

IfEventBrick()

ULong64_t TOracleServerE2WFB::IfEventBrick	(	ULong64_t	id_eventbrick,
		const char *	id_set
	)

{
  // Check if brick structure is in DB
  
  if(MyQuery(Form( "\
     SELECT * FROM OPERA.PV_%s_EVENTBRICKS \
     WHERE ID=%lld and ID_SET=%s", 
  eLa.Data(),  id_eventbrick,id_set))) {
    if(fStmt) {
      ResultSet *rs = fStmt->getResultSet();
      if(rs) {
        TString result;
        int nrows = PrintResultStr(result);
        if(nrows>0) {
          Log(2,"TOracleServerE2WFB::IfEventBrick","brick %lld of set %s is found in DB!",id_eventbrick,id_set);
          printf( "%s",result.Data() );
          return nrows;
        }
      }
    }
  }
  Log(1,"TOracleServerE2WFB::IfEventBrick","brick %lld of set %s is not found in DB!",id_eventbrick,id_set);
  return 0;
}

IfEventRec()

ULong64_t TOracleServerE2WFB::IfEventRec

(

ULong64_t

id_eventbrick

)

{
  // Check if reconstruction was already published
  
  if(MyQuery(Form( "select * from vw_feedback_reconstructions where id_eventbrick=%lld",
  id_eventbrick))) {
    if(fStmt) {
      ResultSet *rs = fStmt->getResultSet();
      if(rs) {
        TString result;
        int nrows = PrintResultStr(result);
        if(nrows>0) {
          Log(2,"TOracleServerE2WFB::IfEventRec","%d reconstructions are found for brick %lld in DB!", nrows, id_eventbrick);
          printf( "%s",result.Data() );
          return nrows;
        }
      }
    }
  }
  Log(1,"TOracleServerE2WFB::IfEventBrick","brick %lld is not found in DB!",id_eventbrick);
  return 0;
}

MyQuery()

Int_t TOracleServerE2WFB::MyQuery

(

const char *

sqlquery

)

{
  try{
    if (!fStmt)   fStmt = fConn->createStatement();
    fStmt->setSQL(query);
    Log(2,"TOracleServerE2WFB::MyQuery","execute sql query: %s ...",query);
    fStmt->execute();
  } catch (SQLException &oraex) {
    Log(1,"TOracleServerE2WFB::MyQuery","failed: (error: %s)",(oraex.getMessage()).c_str());
    eDoCommit=0;
    return 0;
  }
  return 1;
}

Ostr() [1/2]

const char * TOracleServerE2WFB::Ostr

(

Int_t

num

)

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

Ostr() [2/2]

const char * TOracleServerE2WFB::Ostr

(

ULong64_t

num

)

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

Print()

void TOracleServerE2WFB::Print

(

)

{
  TOracleServerE2::Print();
  printf( " eDoCommit = %d  \n eLab = %s   \n eLa = %s\n", eDoCommit, eLab.Data(), eLa.Data() );
}

Set0()

void TOracleServerE2WFB::Set0

(

)

SetTransactionRW()

Int_t TOracleServerE2WFB::SetTransactionRW ( )

inline

{return MyQuery("SET TRANSACTION READ WRITE");}

Timestamp()

const char * TOracleServerE2WFB::Timestamp

(

)

{
  TTimeStamp timestamp;
  return Form("timestamp'%s'",timestamp.AsString("s"));
}

Member Data Documentation

eDoCommit

Bool_t TOracleServerE2WFB::eDoCommit

eLa

TString TOracleServerE2WFB::eLa

as "NAPOLI"

eLab

TString TOracleServerE2WFB::eLab

---

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

• src/libEOracle/TOracleServerE2WFB.h
• src/libEOracle/TOracleServerE2WFB.cxx