TOracleServerE2WX Class Reference

#include <TOracleServerE2WX.h>

Inheritance diagram for TOracleServerE2WX:

Collaboration diagram for TOracleServerE2WX:

Public Member Functions
Int_t	AddBaseTrack (const char *data)
Int_t	AddBaseTracks (EdbPattern &pat, ULong64_t id_eventbrick, ULong64_t id_zone)
Int_t	AddBaseTracks (TTree *tree, ULong64_t id_eventbrick, ULong64_t id_zone, Int_t nvpa, bool usebuffer)
Int_t	AddBrick_Set (char *id, char *idrange_min, char *idrange_max, char *id_partition)
Int_t	AddBrick_Space (char *id_brick, char *id_set)
Int_t	AddBSBpathsVolumes (char *databsbpathsvolumes)
Int_t	AddEventBrick (const char *str)
Int_t	AddMicroTrack (char *datamicro)
Int_t	AddMicroTrack (ULong64_t eventbrick, ULong64_t zone, int side, int id_view, EdbSegP &s)
Int_t	AddPlate (ULong64_t id_eventbrick, const char *dataplate)
Int_t	AddPlateCalibration (ULong64_t id_eventbrick, ULong64_t id_process_operation, EdbPlateP *plate)
ULong64_t	AddProcessOperation (ULong64_t id_machine, ULong64_t id_programsettings, ULong64_t id_requester, ULong64_t id_parent_operation, ULong64_t id_eventbrick, Int_t id_plate, Int_t driverlevel, ULong64_t id_calibration, const char *starttime, const char *finishtime, const char *success, const char *notes)
Int_t	AddScanbackPath (ULong64_t id_eventbrick, ULong64_t id_header_operation, int id_path, int id_start_plate, int skipCSconnection)
Int_t	AddScanbackPrediction (char *dataprediciton)
Int_t	AddTemplateMarkSets (char *datamarks)
Int_t	AddView (EdbView *view, int id_view, ULong64_t id_eventbrick, ULong64_t id_zone, bool usebuffer=true)
Int_t	AddViews (EdbRunTracking &rt, ULong64_t id_eventbrick, ULong64_t id_zone, bool usebuffer=true)
ULong64_t	AddVolume (ULong64_t id_eventbrick, ULong64_t id_process_operation, int ivolume)
Int_t	DeleteBrick (char *id_eventbrick)
Int_t	DeleteBrickSpace (char *id_brick)
Int_t	DeleteOperation (char *id_brick, char *id_process_operation)
Int_t	DeletePlateOperation (char *id_brick, char *id_process_operation, char *id_plate)
void	FinishTransaction ()
int	GetDBErrors ()
ULong64_t	IfEventBrick (ULong64_t id_eventbrick, const char *id_set)
Int_t	MyQuery (const char *sqlquery)
ULong64_t	MyQueryInsertReturning (const char *query, const char *var)
Int_t	NviewsPerArea ()
void	Print ()
Int_t	ROLLBACK ()
void	Set0 ()
void	SetCommit (bool i)
void	SetTestLoad (int n)
Int_t	SetTransactionRW ()
Bool_t	TestLoad ()
const char *	Timestamp ()
	TOracleServerE2WX (const char *db, const char *uid, const char *pw)
	as "NA" More...
	~TOracleServerE2WX ()
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
TString	eLa
	as "NAPOLI" More...
TString	eLab
Int_t	eNviewsPerArea
Public Attributes inherited from TOracleServerE2
TString	eRTS

Private Attributes
Bool_t	eDoCommit
Int_t	eERROR
Int_t	eNTestLoad
Bool_t	eTestLoad

Constructor & Destructor Documentation

TOracleServerE2WX()

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

inline

as "NA"

                                                                    :
    TOracleServerE2(db, uid, pw){eNviewsPerArea=0;}

~TOracleServerE2WX()

TOracleServerE2WX::~TOracleServerE2WX ( )

inline

{}

Member Function Documentation

AddBaseTrack()

Int_t TOracleServerE2WX::AddBaseTrack

(

const char *

data

)

{
  return MyQuery( Form( "\
      INSERT INTO OPERA.TB_MIPBASETRACKS(\
      ID_EVENTBRICK, ID_ZONE, ID, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM, SIGMA,\
      ID_DOWNSIDE, ID_DOWNTRACK, ID_UPSIDE, ID_UPTRACK) \
      VALUES (%s)", data) );
}

AddBaseTracks() [1/2]

Int_t TOracleServerE2WX::AddBaseTracks	(	EdbPattern &	pat,
		ULong64_t	id_eventbrick,
		ULong64_t	id_zone
	)

{
  // Adds a basetrack into the DB
  // Table involved: TB_MIPBASETRACKS
  Int_t nseg = pat.N();
  if(eTestLoad) nseg = Min(nseg,eNTestLoad);   // load only few segments
  for(int i=0; i<nseg; i++)
  {
    EdbSegP *s = pat.GetSegment(i);
    if(s) {
      MyQuery(Form("\
          INSERT INTO OPERA.TB_MIPBASETRACKS (\
          ID_EVENTBRICK, ID_ZONE, POSX, POSY, SLOPEX, SLOPEY, GRAINS,\
          AREASUM, PH, SIGMA, ID_DOWNSIDE, ID_DOWNTRACK, ID_UPSIDE, ID_UPTRACK) \
          VALUES (%s, %s, %.2f, %.2f, %.2f, %.2f, %d, %d, %d, %d, %d, %d, %d, %d)",
      Ostr(id_eventbrick),
      Ostr(id_zone), 
      s->X(), s->Y(), s->TX(), s->TY(), (int)s->W(), (int)s->Volume(),
      0, 0, 0, 0, 0, 0)
             );
    }
  }
  return pat.N();
}

AddBaseTracks() [2/2]

Int_t TOracleServerE2WX::AddBaseTracks	(	TTree *	tree,
		ULong64_t	id_eventbrick,
		ULong64_t	id_zone,
		Int_t	nvpa,
		bool	usebuffer
	)

Warning! inverted definition to make it compatible with the DB

Int_t id_up = s1->Vid(0)*100000 + s1->Vid(1); Int_t id_down = s2->Vid(0)*100000 + s2->Vid(1); !! the above convention used by VT should always work but probably some service is lost (to check) !! the below convention used by L.Scotto but it's rely on eNviewsPerArea which not always defined correctly

Int_t id_up = s1->Vid(0)*100000 + s1->Vid(1)%100000; Int_t id_down = s2->Vid(0)*100000 + s2->Vid(1)%100000;

{
  // Adds a set of basetracks from a TTree (cp.root file) into the DB,
  // assuming that the corresponding microtracks are already added into the DB
  // Table involved: TB_MIPBASETRACKS through AddBaseTrack(...)
  // Details: no queries directly executed
 
  if(!tree)  return(0);
 
  EdbSegP *s1=0, *s2=0, *s=0;
  TBranch *b_s=0, *b_s1=0, *b_s2=0;
  b_s  = tree->GetBranch("s.");
  b_s1 = tree->GetBranch("s1.");
  b_s2 = tree->GetBranch("s2.");
  b_s->SetAddress(  &s   );
  b_s1->SetAddress( &s2  );
  b_s2->SetAddress( &s1  );
 
  int nentr = (int)(tree->GetEntries());
  if(eTestLoad) nentr = Min(nentr,eNTestLoad);   // load only few segments
 
  if (!usebuffer) {
    for(int i=0; i<nentr; i++ ) {
      b_s->GetEntry(i);
      b_s1->GetEntry(i);
      b_s2->GetEntry(i);
 
      //printf("nvpa=%d  s1->Aid(0)=%d  s1->Aid(1)=%d  s1->Vid(1)=%d \n", nvpa, s1->Aid(0),s1->Aid(1), s1->Vid(1)%100000 );
      int id_view_up   = (s1->Aid(0))*nvpa+s1->Aid(1);
      int id_view_down = (s2->Aid(0))*nvpa+s2->Aid(1);
      int id_up   = id_view_up  *100000 + 10000*2 + s1->Vid(1)%100000;
      int id_down = id_view_down*100000 + 10000*1 + s2->Vid(1)%100000;
 
      MyQuery( Form("\
          INSERT INTO OPERA.TB_MIPBASETRACKS(\
          ID_EVENTBRICK, ID_ZONE, ID, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM,\
          SIGMA, ID_DOWNSIDE, ID_DOWNTRACK, ID_UPSIDE, ID_UPTRACK) \
          VALUES \
          (%s, %s, %d, %2f, %2f, %2f, %2f, %2f, %2f, %2f, %d, %d, %d, %d)",
      Ostr(id_eventbrick), 
      Ostr(id_zone), 
      i, s->X(), s->Y(), s->TX(), s->TY(), s->W(), s->Volume(), s->Chi2(),
      1, id_down, 2, id_up
                   ));
    }
 
    Log(2,"AddBaseTracks","Basetracks added (without buffering): %d basetracks added assuming microtracks previously added",nentr);
 
  } else {
    
    try{
      if (!fStmt)
        fStmt = fConn->createStatement();
      
      char ID_EVENTBRICK[10000][50],ID_ZONE[10000][50];
      int ID[10000];
      float POSX[10000],POSY[10000],SLOPEX[10000],SLOPEY[10000];
      int GRAINS[10000],AREASUM[10000];
      float SIGMA[10000];
      int ID_DOWNSIDE[10000],ID_DOWNTRACK[10000],ID_UPSIDE[10000],ID_UPTRACK[10000];
      ub2 SINT[10000],SFLOAT[10000],SID_EVENTBRICK[10000],SID_ZONE[10000];
 
      int nstep = nentr/10000+1;
      for(int istep=0; istep<nstep; istep++ ) {
  
        char query[2048];
        sprintf(query,"\
            INSERT INTO OPERA.TB_MIPBASETRACKS         \
                (ID_EVENTBRICK, ID_ZONE, ID, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM, SIGMA, ID_DOWNSIDE, ID_DOWNTRACK, ID_UPSIDE, ID_UPTRACK) \
                VALUES (:1, :2, :3, :4, :5, :6, :7, :8, :9, :10, :11, :12, :13, :14)");
        fStmt->setSQL(query);
 
        int ibt=0;
 
        for(int ibasetrack=10000*istep; (ibasetrack<nentr && ibasetrack<10000*(istep+1)); ibasetrack++ ) {
    
          b_s->GetEntry(ibasetrack);
          b_s1->GetEntry(ibasetrack);
          b_s2->GetEntry(ibasetrack);
    
          
          int id_view_up   = (s1->Aid(0))*nvpa+s1->Aid(1);
          int id_view_down = (s2->Aid(0))*nvpa+s2->Aid(1);
          int id_up   = id_view_up  *100000 + 10000*2 + s1->Vid(1)%100000;
          int id_down = id_view_down*100000 + 10000*1 + s2->Vid(1)%100000;
    
          sprintf(ID_EVENTBRICK[ibt],"%s%c",Ostr(id_eventbrick),0);  //  1
          sprintf(ID_ZONE[ibt],"%s%c",Ostr(id_zone),0);              //  2
          ID[ibt]=ibasetrack;               //  3
          POSX[ibt]=s->X();                 //  4
          POSY[ibt]=s->Y();                 //  5
          SLOPEX[ibt]=s->TX();              //  6
          SLOPEY[ibt]=s->TY();              //  7
          GRAINS[ibt]=(int)s->W();          //  8
          AREASUM[ibt]=(int)s->Volume();    //  9
          SIGMA[ibt]=s->Chi2();             // 10
          ID_DOWNSIDE[ibt]=1;               // 11
          ID_DOWNTRACK[ibt]=id_down;        // 12
          ID_UPSIDE[ibt]=2;                 // 13
          ID_UPTRACK[ibt]=id_up;            // 14
    
          SID_EVENTBRICK[ibt]=strlen(ID_EVENTBRICK[ibt])+1;
          SID_ZONE[ibt]=strlen(ID_ZONE[ibt])+1;
          SINT[ibt]=sizeof(int);
          SFLOAT[ibt]=sizeof(float);
          ibt++;
        }
        fStmt->setDataBuffer( 1, ID_EVENTBRICK, OCCI_SQLT_STR, sizeof(ID_EVENTBRICK[0]), (unsigned short *) &SID_EVENTBRICK);
        fStmt->setDataBuffer( 2, ID_ZONE, OCCI_SQLT_STR, sizeof(ID_ZONE[0]), (unsigned short *) &SID_ZONE);
        fStmt->setDataBuffer( 3, ID,      OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
        fStmt->setDataBuffer( 4, POSX,    OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
        fStmt->setDataBuffer( 5, POSY,    OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
        fStmt->setDataBuffer( 6, SLOPEX,  OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
        fStmt->setDataBuffer( 7, SLOPEY,  OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
        fStmt->setDataBuffer( 8, GRAINS,  OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
        fStmt->setDataBuffer( 9, AREASUM, OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
        fStmt->setDataBuffer(10, SIGMA,   OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
        fStmt->setDataBuffer(11, ID_DOWNSIDE,  OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
        fStmt->setDataBuffer(12, ID_DOWNTRACK, OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
        fStmt->setDataBuffer(13, ID_UPSIDE,    OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
        fStmt->setDataBuffer(14, ID_UPTRACK,   OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
        fStmt->executeArrayUpdate(ibt);
      } // istep
 
    } catch (SQLException &oraex) {
      Error("TOracleServerE2WX", "AddBaseTracksWithBuffer; failed: (error: %s)", (oraex.getMessage()).c_str());
    }
    
    Log(2,"AddBaseTracksWithBuffer","Basetracks added (with buffering): %d basetracks added assuming microtracks previously added",nentr);
    
  }
 
  return nentr;
}

AddBrick_Set()

Int_t TOracleServerE2WX::AddBrick_Set	(	char *	id,
		char *	idrange_min,
		char *	idrange_max,
		char *	id_partition
	)

{
  // Adds a brick-set into the DB
  // Procedure involved: PC_ADD_BRICK_SET (it fills TB_BRICK_SETS)
 
  char query[2048];
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    /*sprintf(query,"\
 INSERT INTO OPERA.TB_BRICK_SETS (ID, IDRANGE_MIN, IDRANGE_MAX, ID_PARTITION) \
 VALUES (%s, %s, %s, %s)", */
      sprintf(query,"CALL PC_ADD_BRICK_SET(%s, %s, %s, %s)",
        id, idrange_min, idrange_max, id_partition);
 
    fStmt->setSQL(query);
    Log(2,"AddBrick_Set","execute sql query: %s ...",query);
    fStmt->execute();
 
    Log(2,"AddBrick_Set","Brick_Set added, partition created");
    return 0;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WX", "AddBrick_Set; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
 
  return 1;
}

AddBrick_Space()

Int_t TOracleServerE2WX::AddBrick_Space	(	char *	id_brick,
		char *	id_set
	)

{
  // Adds a brick-space into the DB
  // Procedure involved: PC_ADD_BRICK_SPACE
 
  char query[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"CALL PC_ADD_BRICK_SPACE(%s, %s)",
        id_brick, id_set);
 
    fStmt->setSQL(query);
    Log(2,"AddBrick_Space","execute sql query: %s ...",query);
    fStmt->executeUpdate();
 
    Log(2,"AddBrick_Space","Brick_Space mapped");
    return 0;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WX", "AddBrick_Space; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
 
  return 1;
}

AddBSBpathsVolumes()

Int_t TOracleServerE2WX::AddBSBpathsVolumes

(

char *

databsbpathsvolumes

)

{
  // Adds a connection between brick, sbpath and volume into the DB
  // Table involved: TB_B_SBPATHS_VOLUMES
 
  return MyQuery( Form(
      "INSERT INTO OPERA.TB_B_SBPATHS_VOLUMES \
       (ID_EVENTBRICK, ID_SCANBACK_PROCOPID, PATH, ID_VOLUMESCAN_PROCOPID, VOLUME, ID_PLATE) \
        VALUES (%s)", 
       databsbpathsvolumes
                      ));
}

AddEventBrick()

Int_t TOracleServerE2WX::AddEventBrick

(

const char *

str

)

{
  // Adds a brick into the DB
  // Table involved: TB_EVENTBRICKS
 
  return MyQuery(
      Form( "\
      INSERT INTO OPERA.TB_EVENTBRICKS \
      (ID, MINX, MAXX, MINY, MAXY, MINZ, MAXZ, ID_SET, ID_BRICK, ZEROX, ZEROY, ZEROZ) VALUES (%s)", 
  databrick
          ));
}

AddMicroTrack() [1/2]

Int_t TOracleServerE2WX::AddMicroTrack

(

char *

datamicro

)

{
  return MyQuery( Form( "\
      INSERT INTO OPERA.TB_MIPMICROTRACKS(ID_EVENTBRICK, ID_ZONE, SIDE, ID, ID_VIEW, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM, SIGMA) \
            VALUES (%s)", datamicro
                      ));
}

AddMicroTrack() [2/2]

Int_t TOracleServerE2WX::AddMicroTrack	(	ULong64_t	eventbrick,
		ULong64_t	zone,
		int	side,
		int	id_view,
		EdbSegP &	s
	)

{
  return AddMicroTrack( Form(
      "%s, %s ,%d, %d, %d, %2f, %2f, %2f, %2f, %2f, %2f, %2f",
  Ostr(eventbrick),
  Ostr(zone),
  side,
  s.ID(), id_view,
  s.X(), s.Y(), s.TX(), s.TY(), s.W(), s.Volume(), s.Chi2()
                            ) );
}

AddPlate()

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

{
  // Adds a plate into the DB
  // Table involved: TB_PLATE
 
  return MyQuery(Form( "\
      INSERT INTO OPERA.TB_PLATES (ID_EVENTBRICK, ID, Z) \
      VALUES (%s, %s)",  Ostr(id_eventbrick),  dataplate));
}

AddPlateCalibration()

Int_t TOracleServerE2WX::AddPlateCalibration	(	ULong64_t	id_eventbrick,
		ULong64_t	id_process_operation,
		EdbPlateP *	plate
	)

{
  // Adds a plate calibration into the DB
  // Table involved: TB_PLATE_CALIBRATIONS
  EdbAffine2D *a = plate->GetAffineXY();
  if(a) 
  {
    if(!MyQuery(Form( "\
        INSERT INTO OPERA.TB_PLATE_CALIBRATIONS \
        (ID_EVENTBRICK, ID_PROCESSOPERATION, ID_PLATE, Z, MAPXX, MAPXY, MAPYX, MAPYY, MAPDX, MAPDY) \
        VALUES (%s, %s, %d, %.2f, %f, %f, %f, %f, %f, %f)", 
    Ostr(id_eventbrick),
    Ostr(id_process_operation),
    plate->ID(), plate->Z(),
    a->A11(), a->A12(), a->A21(), a->A22(), a->B1(), a->B2() )))    return 0;
  
    Log(3,"TOracleServerE2WX:AddPlateCalibration","ok");
    return 1;
  }
  return 0;
}

AddProcessOperation()

ULong64_t TOracleServerE2WX::AddProcessOperation	(	ULong64_t	id_machine,
		ULong64_t	id_programsettings,
		ULong64_t	id_requester,
		ULong64_t	id_parent_operation,
		ULong64_t	id_eventbrick,
		Int_t	id_plate,
		Int_t	driverlevel,
		ULong64_t	id_calibration,
		const char *	starttime,
		const char *	finishtime,
		const char *	success,
		const char *	notes
	)

{
  // Adds a process operation into the DB
  // Table involved: TB_PROC_OPERATIONS
  
  return MyQueryInsertReturning(
      Form(
        "INSERT INTO OPERA.TB_PROC_OPERATIONS ( \
        ID_MACHINE, ID_PROGRAMSETTINGS, ID_REQUESTER, \
        ID_PARENT_OPERATION, ID_EVENTBRICK, ID_PLATE, DRIVERLEVEL, ID_CALIBRATION_OPERATION, \
        STARTTIME, FINISHTIME, SUCCESS, NOTES) \
        VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, '%s' )",
    Ostr(id_machine),
    Ostr(id_programsettings),
    Ostr(id_requester),
    Ostr(id_parent_operation),
    Ostr(id_eventbrick),
    Ostr(id_plate),
    Ostr(driverlevel),
    Ostr(id_calibration),
    starttime,
    finishtime,
    success,
    notes
          ), "ID" );
}

AddScanbackPath()

Int_t TOracleServerE2WX::AddScanbackPath	(	ULong64_t	id_eventbrick,
		ULong64_t	id_header_operation,
		int	id_path,
		int	id_start_plate,
		int	skipCSconnection
	)

{
  // Adds a scanback path into the DB and connects it with the CS prediction
  // Table involved: TB_SCANBACK_PATHS, TB_B_CSCANDS_SBPATHS
  
  MyQuery( Form("\
      INSERT INTO OPERA.TB_SCANBACK_PATHS (ID_EVENTBRICK, ID_PROCESSOPERATION, PATH, ID_START_PLATE, ID_FORK_PATH, ID_CANCEL_PLATE) VALUES (%s, %s, %d, %d, NULL, NULL)",
  Ostr(id_eventbrick), 
  Ostr(id_header_operation), 
  id_path, 
  id_start_plate
               ));
 
  if (!skipCSconnection) {
    ULong64_t id_cs_eventbrick = 3000000 + id_eventbrick%1000000;
    if(MyQuery( Form(
       "SELECT ID FROM OPERA.TB_CS_CANDIDATES WHERE ID_EVENTBRICK=%s and CANDIDATE=%d",
    Ostr(id_cs_eventbrick),
    id_path%10000
                    )))
    {
      ResultSet *rs = fStmt->getResultSet();
      ULong64_t id_candidate=0;
      int icopy=0;
      while (rs->next()){
        sscanf(rs->getString(1).c_str(),"%lld",&id_candidate);
        icopy++;
      }
      delete rs;
      MyQuery(Form("\
          INSERT INTO OPERA.TB_B_CSCANDS_SBPATHS \
          (ID_CS_EVENTBRICK, ID_CANDIDATE, ID_EVENTBRICK, ID_SCANBACK_PROCOPID, PATH) VALUES (%s, %s, %s, %s, %d)",
      Ostr(id_cs_eventbrick),
      Ostr(id_candidate), 
      Ostr(id_eventbrick), 
      Ostr(id_header_operation), 
      id_path
             ));
    }
  } // end !skipCSconnection
 
  return 0;
}

AddScanbackPrediction()

Int_t TOracleServerE2WX::AddScanbackPrediction

(

char *

dataprediciton

)

{
  return MyQuery( Form( "\
      INSERT INTO OPERA.TB_SCANBACK_PREDICTIONS(\
      ID_EVENTBRICK,ID_PATH,ID_PLATE,POSX,POSY,SLOPEX,SLOPEY,\
      POSTOL1,POSTOL2,SLOPETOL1,SLOPETOL2,\
      FRAME,ID_ZONE,ID_CANDIDATE,DAMAGED,ISMANUAL)VALUES (%s)"
      ,dataprediction
                      ));
}

AddTemplateMarkSets()

Int_t TOracleServerE2WX::AddTemplateMarkSets

(

char *

datamarks

)

{
  return MyQuery( Form(
      "INSERT INTO OPERA.TB_TEMPLATEMARKSETS\
      (ID_EVENTBRICK, ID_MARK, POSX, POSY, MARKROW, MARKCOL, SHAPE, SIDE)\
      VALUES (%s)", datamarks
                      ));
}

AddView()

Int_t TOracleServerE2WX::AddView	(	EdbView *	view,
		int	id_view,
		ULong64_t	id_eventbrick,
		ULong64_t	id_zone,
		bool	usebuffer = true
	)

id_microtrack = id_view*100000+isegment;

ID[isegment]=id_view*100000 + isegment; // 4

{
  // Adds a view and all its microtracks from an EdbView object into the DB
  // Tables involved: TB_VIEWS through AddView(...) and TB_MIPMICROTRACKS through AddMicroTrack(...)
  // Details: no queries directly executed
 
  time_t ti_v = time(NULL);
  
  int side;
// Warning! inverted definition to make it compatible with the DB
  if(view->GetNframesTop()==0) side=2;
  else side=1;
 
  EdbSegP sview(0,0,0,0,0);
  sview.Transform(view->GetHeader()->GetAffine());
  float xview = sview.X();
  float yview = sview.Y();
  
  int AreaID = view->GetAreaID();
  int ViewID = view->GetViewID();
  int nsegV  = view->Nsegments();
  if(eTestLoad) nsegV = Min(nsegV,eNTestLoad);   // load only few segments
  Log(2,"TOracleServerE2WX::AddView","Area %d, View %d is in the (DB) side %d and contains %d segments",AreaID,ViewID,side,nsegV);
  
  float z1,z2;
  if (side==1) { z1 = view->GetHeader()->GetZ1(); z2 = view->GetHeader()->GetZ2(); }
  else         { z1 = view->GetHeader()->GetZ4(); z2 = view->GetHeader()->GetZ3(); }
 
  MyQuery(
      Form(
      "INSERT INTO OPERA.TB_VIEWS (ID_EVENTBRICK, ID_ZONE, SIDE, ID, DOWNZ, UPZ, POSX, POSY) VALUES (%s, %s, %d, %d, %.2f, %.2f, %.2f, %.2f)",
  Ostr(id_eventbrick),
  Ostr(id_zone),
  side,
  id_view,
  z1,
  z2,
  xview,
  yview
          ));
  
  if (nsegV<=0) return(-1);
  if (!usebuffer) 
  {
    EdbSegment *seg;
    int id_microtrack;
    
    //if(nsegV>10) nsegV =10; //!!!!!!!!!!!!!!
    
    for(int isegment=0;isegment<nsegV;isegment++) {
      seg = view->GetSegment(isegment);
      seg->Transform(view->GetHeader()->GetAffine());
      id_microtrack = id_view*100000 + side*10000 + isegment;
      MyQuery( Form("\
          INSERT INTO OPERA.TB_MIPMICROTRACKS(ID_EVENTBRICK, ID_ZONE, SIDE, ID, ID_VIEW, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM, SIGMA) \
          VALUES (%s, %s ,%d, %d, %d, %f, %f, %f, %f, %d, %d, %f)",
      Ostr(id_eventbrick), 
      Ostr(id_zone), 
      side, id_microtrack, id_view, seg->GetX0(), seg->GetY0(),
      seg->GetTx(), seg->GetTy(), seg->GetPuls(), seg->GetVolume(), seg->GetSigmaX()
                   ));
    }
    
    time_t tf_v = time(NULL);
    Log(2,"TOracleServerE2WX::AddView","View added (without buffering): %d microtracks added in %ld s",nsegV, tf_v-ti_v );
 
  } else {
 
    try{
      if (!fStmt) fStmt = fConn->createStatement();
      
      char query[2048];
      sprintf(query,"\
          INSERT INTO OPERA.TB_MIPMICROTRACKS          \
              (ID_EVENTBRICK, ID_ZONE, SIDE, ID, ID_VIEW, POSX, POSY, SLOPEX, SLOPEY, GRAINS, AREASUM, SIGMA) \
              VALUES (:1, :2, :3, :4, :5, :6, :7, :8, :9, :10, :11, :12)");
      fStmt->setSQL(query);
      
      char ID_EVENTBRICK[10000][50],ID_ZONE[10000][50];
      int SIDE[10000],ID[10000],ID_VIEW[10000];
      float POSX[10000],POSY[10000],SLOPEX[10000],SLOPEY[10000];
      int GRAINS[10000],AREASUM[10000];
      float SIGMA[10000];
      ub2 SINT[10000],SFLOAT[10000],SID_EVENTBRICK[10000],SID_ZONE[10000];
      
      if (nsegV>10000) {
        Log(1,"AddViewWithBuffer","Error! Number of segments (%d) in the view is greater than 10000",nsegV);
        exit(1);
      }
      
      EdbSegment *seg;
      for(int isegment=0;isegment<nsegV;isegment++) {
        seg = view->GetSegment(isegment);
        seg->Transform(view->GetHeader()->GetAffine());
        sprintf(ID_EVENTBRICK[isegment],"%s%c",Ostr(id_eventbrick),0);  //  1
        sprintf(ID_ZONE[isegment],"%s%c",Ostr(id_zone),0);              //  2
        SIDE[isegment]=side;                   //  3
        ID[isegment]=id_view*100000 + side*10000 + isegment; // 4
        ID_VIEW[isegment]=id_view;             //  5
        POSX[isegment]=seg->GetX0();           //  6
        POSY[isegment]=seg->GetY0();           //  7
        SLOPEX[isegment]=seg->GetTx();         //  8
        SLOPEY[isegment]=seg->GetTy();         //  9
        GRAINS[isegment]=seg->GetPuls();       // 10
        AREASUM[isegment]=seg->GetVolume();    // 11
        SIGMA[isegment]=seg->GetSigmaX();      // 13
  
        SID_EVENTBRICK[isegment]=strlen(ID_EVENTBRICK[isegment])+1;
        SID_ZONE[isegment]=strlen(ID_ZONE[isegment])+1;
        SINT[isegment]=sizeof(int);
        SFLOAT[isegment]=sizeof(float);
      }
      
      fStmt->setDataBuffer( 1, ID_EVENTBRICK, OCCI_SQLT_STR, sizeof(ID_EVENTBRICK[0]), (unsigned short *) &SID_EVENTBRICK);
      fStmt->setDataBuffer( 2, ID_ZONE, OCCI_SQLT_STR, sizeof(ID_ZONE[0]), (unsigned short *) &SID_ZONE);
      fStmt->setDataBuffer( 3, SIDE,    OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
      fStmt->setDataBuffer( 4, ID,      OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
      fStmt->setDataBuffer( 5, ID_VIEW, OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
      fStmt->setDataBuffer( 6, POSX,    OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
      fStmt->setDataBuffer( 7, POSY,    OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
      fStmt->setDataBuffer( 8, SLOPEX,  OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
      fStmt->setDataBuffer( 9, SLOPEY,  OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
      fStmt->setDataBuffer(10, GRAINS,  OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
      fStmt->setDataBuffer(11, AREASUM, OCCIINT,   sizeof(int),   (unsigned short *) &SINT);
      fStmt->setDataBuffer(12, SIGMA,   OCCIFLOAT, sizeof(float), (unsigned short *) &SFLOAT);
      fStmt->executeArrayUpdate(nsegV);
    } catch (SQLException &oraex) {
      Error("TOracleServerE2WX", "AddView; failed: (error: %s)", (oraex.getMessage()).c_str());
    }
    time_t tf_v = time(NULL);
    Log(2,"AddView","View added (with buffering): %d microtracks added in %ld s",nsegV, tf_v-ti_v );
  }
 
  return 0;
}

AddViews()

Int_t TOracleServerE2WX::AddViews	(	EdbRunTracking &	rt,
		ULong64_t	id_eventbrick,
		ULong64_t	id_zone,
		bool	usebuffer = true
	)

int id_view = iview; AddView(view, id_view, id_eventbrick, id_zone, usebuffer);

{
  // Adds all views stored in a EdbRun object (== raw.root file) and all their microtracks into the DB
  // Tables involved: TB_VIEWS through AddView(EdbView,...)
  // Details: no queries directly executed
 
  EdbRun *r = rt.GetRun();       if (!r)      return 0;
  int nviews = r->GetEntries();  if (!nviews) return 0;
  int nvpa=rt.GetNviewsPerArea();
 
  if(eTestLoad) nviews = Min(nviews,eNTestLoad);   // load only few views
  for(int iview=0; iview<nviews; iview++) {
    EdbView *view = r->GetEntry(iview);
    if(view) 
    {
      Log(2,"TOracleServerE2WX::AddView","%d/%d",iview+1,nviews);
      
      int id_view = (view->GetAreaID())*nvpa+view->GetViewID();
      AddView(view, id_view, id_eventbrick, id_zone, usebuffer);
      
    
    }
    else Log(1,"TOracleServerE2WX::AddView","Error! view=0");
  }
  return 0;
}

AddVolume()

ULong64_t TOracleServerE2WX::AddVolume	(	ULong64_t	id_eventbrick,
		ULong64_t	id_process_operation,
		int	ivolume
	)

{
  return MyQueryInsertReturning(
      Form("\
      INSERT INTO OPERA.TB_VOLUMES (ID_EVENTBRICK, ID_PROCESSOPERATION, VOLUME) \
      VALUES (%s, %s, %d)",
  Ostr(id_eventbrick),
  Ostr(id_process_operation),
  ivolume
          ), "ID" );
}

DeleteBrick()

Int_t TOracleServerE2WX::DeleteBrick

(

char *

id_eventbrick

)

{
  // Delete all informations related to a brick from the DB
  // Tables involved: ... a lot, look at the code...
 
  char query[16][2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query[0], "delete from Tb_B_SBPATHS_VOLUMES    where id_eventbrick=%s",id_eventbrick);
    sprintf(query[1], "delete from Tb_Volume_Slices        where id_eventbrick=%s",id_eventbrick);
    sprintf(query[2], "delete from Tb_Volumes              where id_eventbrick=%s",id_eventbrick);
    sprintf(query[3], "delete from Tb_Scanback_Predictions where id_eventbrick=%s",id_eventbrick);
    sprintf(query[4], "delete from Tb_B_CSCANDS_SBPATHS    where id_eventbrick=%s",id_eventbrick);
    sprintf(query[5], "delete from Tb_Scanback_Paths       where id_eventbrick=%s",id_eventbrick);
    sprintf(query[6], "delete from Tb_MipBasetracks        where id_eventbrick=%s",id_eventbrick);
    sprintf(query[7], "delete from Tb_MipMicrotracks       where id_eventbrick=%s",id_eventbrick);
    sprintf(query[8], "delete from Tb_Views                where id_eventbrick=%s",id_eventbrick);
    sprintf(query[9], "delete from Tb_Zones                where id_eventbrick=%s",id_eventbrick);
    sprintf(query[10],"delete from tb_proc_operations where id_eventbrick=%s and id_calibration_operation in (select id_processoperation from tb_plate_calibrations where id_eventbrick=%s)",id_eventbrick,id_eventbrick);
    sprintf(query[11],"delete from Tb_Plate_calibrations   where id_eventbrick=%s",id_eventbrick);
    sprintf(query[12],"delete from Tb_Proc_operations      where id_eventbrick=%s",id_eventbrick);
    sprintf(query[13],"delete from Tb_Plates               where id_eventbrick=%s",id_eventbrick);
    sprintf(query[14],"delete from Tb_TemplateMarkSets     where id_eventbrick=%s",id_eventbrick);
    sprintf(query[15],"delete from Tb_Eventbricks          where id=%s",id_eventbrick);
 
    for (int i=0;i<16;i++) {
    fStmt->setSQL(query[i]);
    Log(2,"DeleteBrick","execute sql query: %s ...",query[i]);
    fStmt->execute();
    }
 
    Log(2,"DeleteBrick","Brick deleted");
    return 0;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WX", "DeleteBrick; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
 
  return 1;
}

DeleteBrickSpace()

Int_t TOracleServerE2WX::DeleteBrickSpace

(

char *

id_brick

)

{
  // Delete a brick space related to a brick from the DB
  // Procedure involved: PC_REMOVE_BRICK_SPACE
 
  char query[2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query,"call pc_remove_brick_space(%s,'OPERA NA BK01')",id_brick);
 
    fStmt->setSQL(query);
    Log(2,"DeleteBrickSpace","execute sql query: %s ...",query);
    fStmt->execute();
 
    Log(2,"DeleteBrickSpace","BrickSpace deleted");
    return 0;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WX", "DeleteBrickSpace; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
 
  return 1;
}

DeleteOperation()

Int_t TOracleServerE2WX::DeleteOperation	(	char *	id_brick,
		char *	id_process_operation
	)

{
  // Delete all informations related to a process operation of a brick from the DB
  // Tables involved: ... a lot, look at the code...
  // Details: DELETE queries
 
  char query[13][2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query[0], "delete from Tb_Scanback_Predictions where (id_path) in (select id from tb_scanback_paths where id_processoperation=%s) and id_eventbrick=%s",id_process_operation,id_brick);    
    sprintf(query[1], "delete from Tb_B_CSCANDS_SBPATHS where id_scanback_procopid=%s and id_eventbrick=%s",id_process_operation,id_brick);
    sprintf(query[2], "delete from Tb_Scanback_Paths where id_processoperation=%s and id_eventbrick=%s",id_process_operation,id_brick);
    sprintf(query[3], "delete from Tb_MipBasetracks where (id_zone) in (select id from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s) and id_eventbrick=%s) and id_eventbrick=%s",id_process_operation,id_brick,id_brick);
    sprintf(query[4], "delete from Tb_MipMicrotracks where (id_zone) in (select id from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s) and id_eventbrick=%s) and id_eventbrick=%s",id_process_operation,id_brick,id_brick);
    sprintf(query[5], "delete from tb_views where (id_zone) in (select id from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s) and id_eventbrick=%s) and id_eventbrick=%s",id_process_operation,id_brick,id_brick);
    sprintf(query[6], "delete from tb_b_sbpaths_volumes where id_eventbrick=%s and id_volumescan_procopid=%s",id_brick,id_process_operation);
    sprintf(query[7], "delete from tb_volume_slices where (id_zone) in (select id from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s))",id_process_operation);
    sprintf(query[8], "delete from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s) and id_eventbrick=%s",id_process_operation,id_brick);
    sprintf(query[9], "delete from tb_volumes where id_processoperation=%s",id_process_operation);
    sprintf(query[10], "delete from tb_plate_calibrations where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s)",id_process_operation);
    sprintf(query[11],"delete from tb_proc_operations where id_parent_operation=%s",id_process_operation);
    sprintf(query[12],"delete from tb_proc_operations where id=%s",id_process_operation);
 
    for (int i=0;i<13;i++) {
    fStmt->setSQL(query[i]);
    Log(2,"DeleteOperation","execute sql query: %s ...",query[i]);
    fStmt->execute();
    }
 
    Log(2,"DeleteOperation","Operation deleted");
    return 0;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WX", "DeleteOperation; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
 
  return 1;
}

DeletePlateOperation()

Int_t TOracleServerE2WX::DeletePlateOperation	(	char *	id_brick,
		char *	id_process_operation,
		char *	id_plate
	)

{
  // Delete all informations related to a plate of a process operation of a brick from the DB
  // Tables involved: ... a lot, look at the code...
  // Details: DELETE queries
 
  char query[7][2048];
 
  try{
    if (!fStmt)
      fStmt = fConn->createStatement();
 
    sprintf(query[0], "delete from Tb_Scanback_Predictions where (id_path) in (select id from tb_scanback_paths where id_processoperation=%s) and id_eventbrick=%s and id_plate=%s",id_process_operation,id_brick,id_plate);
    sprintf(query[1], "delete from Tb_MipBasetracks where (id_zone) in (select id from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s and id_plate=%s)) and id_eventbrick=%s",id_process_operation,id_plate,id_brick);
    sprintf(query[2], "delete from Tb_MipMicrotracks where (id_zone) in (select id from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s and id_plate=%s)) and id_eventbrick=%s",id_process_operation,id_plate,id_brick);
    sprintf(query[3], "delete from tb_views where (id_zone) in (select id from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s and id_plate=%s))",id_process_operation,id_plate);
    sprintf(query[4], "delete from tb_zones where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s and id_plate=%s)",id_process_operation,id_plate);
    sprintf(query[5], "delete from tb_plate_calibrations where (id_processoperation) in (select id from tb_proc_operations where id_parent_operation=%s and id_plate=%s)",id_process_operation,id_plate);
    sprintf(query[6], "delete from tb_proc_operations where id_parent_operation=%s and id_plate=%s",id_process_operation,id_plate);
 
    for (int i=0;i<7;i++) {
    fStmt->setSQL(query[i]);
    Log(2,"DeletePlateOperation","execute sql query: %s ...",query[i]);
    fStmt->execute();
    }
 
    Log(2,"DeletePlateOperation","Plate operation deleted");
    return 0;
 
  } catch (SQLException &oraex) {
    Error("TOracleServerE2WX", "DeletePlateOperation; failed: (error: %s)", (oraex.getMessage()).c_str());
  }
 
  return 1;
}

FinishTransaction()

void TOracleServerE2WX::FinishTransaction

(

)

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

GetDBErrors()

int TOracleServerE2WX::GetDBErrors ( )

inline

{return eERROR;}

IfEventBrick()

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

{
  // Check if brick structure is in DB
  ULong64_t id = 0, id_brick = 0;
  if(MyQuery(Form( "\
     SELECT ID, ID_BRICK FROM OPERA.TB_EVENTBRICKS \
     WHERE ID=%lld and ID_SET=%s",  id_eventbrick,id_set))) 
  {
    if(fStmt) {
      ResultSet *rs = fStmt->getResultSet();
      if(rs) {
        while (rs->next()){
          sscanf( (rs->getString(1)).c_str(),"%lld",&id);
          sscanf( (rs->getString(2)).c_str(),"%lld",&id_brick);
        }
        delete rs;
      }
    }
  }
  if(id)  Log(1,"TOracleServerE2WFB::IfEventBrick","brick ID=%lld of set=%s is found in DB with ID_BRICK=%lld",id_eventbrick,id_set,id_brick);
  else    Log(1,"TOracleServerE2WFB::IfEventBrick","brick ID=%lld of set=%s is not found in DB!",id_eventbrick,id_set);
  return id;
}

MyQuery()

Int_t TOracleServerE2WX::MyQuery

(

const char *

sqlquery

)

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

MyQueryInsertReturning()

ULong64_t TOracleServerE2WX::MyQueryInsertReturning	(	const char *	query,
		const char *	var
	)

{
  ULong64_t  id=0;
  try{
    if (!fStmt)   fStmt = fConn->createStatement();
    TString s=Form("BEGIN %s returning %s into :1; END;",query,var);
    Log(2,"TOracleServerE2WX::MyQueryInsertReturning","%s",s.Data());
    fStmt->setSQL(s.Data());
    fStmt->registerOutParam(1, OCCISTRING,64);
    fStmt->executeUpdate();
    if(!(fStmt->getString(1)).c_str()) {
      Log(2,"TOracleServerE2WX::MyQueryInsertReturning","ERROR! empty operation returned!");
      eDoCommit=0; eERROR++;
      return 0;
    }
    Log(2,"","%s", (fStmt->getString(1)).c_str() );
    sscanf( (fStmt->getString(1)).c_str(),"%lld",&id);
  } catch (SQLException &oraex) {
    Log(1,"TOracleServerE2WX::MyQuery","failed: (error: %s)",(oraex.getMessage()).c_str());
    eDoCommit=0; eERROR++;
    return 0;
  }
  return id;
}

NviewsPerArea()

Int_t TOracleServerE2WX::NviewsPerArea ( )

inline

{return eNviewsPerArea;};

Print()

void TOracleServerE2WX::Print

(

)

{
  TOracleServerE2::Print();
  printf( " eDoCommit  = %d  \n", eDoCommit );
  printf( " eERROR     = %d  \n", eERROR );
  printf( " eTestLoad  = %d  \n", eTestLoad );
  printf( " eNTestLoad = %d  \n", eNTestLoad );
  if(eTestLoad) printf( " eNTestLoad = %d  \n", eNTestLoad );
}

ROLLBACK()

Int_t TOracleServerE2WX::ROLLBACK ( )

inline

{return MyQuery("ROLLBACK");}

Set0()

void TOracleServerE2WX::Set0

(

)

SetCommit()

void TOracleServerE2WX::SetCommit ( bool  i )

inline

{eTestLoad=false; eDoCommit=i; eNTestLoad=kMaxInt;}

SetTestLoad()

void TOracleServerE2WX::SetTestLoad ( int  n )

inline

{eTestLoad=true; eDoCommit=0; eNTestLoad=n;}

SetTransactionRW()

Int_t TOracleServerE2WX::SetTransactionRW ( )

inline

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

TestLoad()

Bool_t TOracleServerE2WX::TestLoad ( )

inline

{return eTestLoad;}

Timestamp()

const char * TOracleServerE2WX::Timestamp

(

)

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

Member Data Documentation

eDoCommit

Bool_t TOracleServerE2WX::eDoCommit

private

eERROR

Int_t TOracleServerE2WX::eERROR

private

eLa

TString TOracleServerE2WX::eLa

as "NAPOLI"

eLab

TString TOracleServerE2WX::eLab

eNTestLoad

Int_t TOracleServerE2WX::eNTestLoad

private

eNviewsPerArea

Int_t TOracleServerE2WX::eNviewsPerArea

eTestLoad

Bool_t TOracleServerE2WX::eTestLoad

private

---

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

• src/libEOracle/TOracleServerE2WX.h
• src/libEOracle/TOracleServerE2WX.cxx