#ifndef SQL_CRSR
# define SQL_CRSR
struct sql_cursor
{
unsigned int curocn;
void *ptr1;
void *ptr2;
unsigned int magic;
};
typedef struct sql_cursor sql_cursor;
typedef struct sql_cursor SQL_CURSOR;
#endif /* SQL_CRSR */
typedef void * sql_context;
typedef void * SQL_CONTEXT;
struct sqltvn
{
unsigned char *tvnvsn;
unsigned short tvnvsnl;
unsigned char *tvnnm;
unsigned short tvnnml;
unsigned char *tvnsnm;
unsigned short tvnsnml;
};
typedef struct sqltvn sqltvn;
struct sqladts
{
unsigned int adtvsn;
unsigned short adtmode;
unsigned short adtnum;
sqltvn adttvn[1];
};
typedef struct sqladts sqladts;
static struct sqladts sqladt = {
1,1,0,
};
struct sqltdss
{
unsigned int tdsvsn;
unsigned short tdsnum;
unsigned char *tdsval[1];
};
typedef struct sqltdss sqltdss;
static struct sqltdss sqltds =
{
1,
0,
};
struct sqlcxp
{
unsigned short fillen;
char filnam[13];
};
static const struct sqlcxp sqlfpn =
{
12,
"hora2conn.pc"
};
static unsigned int sqlctx = 302475;
static struct sqlexd {
unsigned long sqlvsn;
unsigned int arrsiz;
unsigned int iters;
unsigned int offset;
unsigned short selerr;
unsigned short sqlety;
unsigned int occurs;
const short *cud;
unsigned char *sqlest;
const char *stmt;
sqladts *sqladtp;
sqltdss *sqltdsp;
unsigned char **sqphsv;
unsigned long *sqphsl;
int *sqphss;
short **sqpind;
int *sqpins;
unsigned long *sqparm;
unsigned long **sqparc;
unsigned short *sqpadto;
unsigned short *sqptdso;
unsigned int sqlcmax;
unsigned int sqlcmin;
unsigned int sqlcincr;
unsigned int sqlctimeout;
unsigned int sqlcnowait;
int sqfoff;
unsigned int sqcmod;
unsigned int sqfmod;
unsigned int sqlpfmem;
unsigned char *sqhstv[4];
unsigned long sqhstl[4];
int sqhsts[4];
short *sqindv[4];
int sqinds[4];
unsigned long sqharm[4];
unsigned long *sqharc[4];
unsigned short sqadto[4];
unsigned short sqtdso[4];
} sqlstm = {13,4};
extern "C" {
void sqlcxt (void **, unsigned int *,
struct sqlexd *, const struct sqlcxp *);
void sqlcx2t(void **, unsigned int *,
struct sqlexd *, const struct sqlcxp *);
void sqlbuft(void **, char *);
void sqlgs2t(void **, char *);
void sqlorat(void **, unsigned int *, void *);
}
static const int IAPSUCC = 0;
static const int IAPFAIL = 1403;
static const int IAPFTL = 535;
extern "C" { void sqliem(unsigned char *, signed int *); }
typedef struct { unsigned short len; unsigned char arr[1]; } VARCHAR;
typedef struct { unsigned short len; unsigned char arr[1]; } varchar;
static const short sqlcud0[] =
{13,4130,1,0,0,
5,0,0,0,0,0,27,108,0,0,4,4,0,1,0,1,97,0,0,1,97,0,0,1,10,0,0,1,10,0,0,
36,0,0,2,0,0,32,129,0,0,0,0,0,1,0,
51,0,0,3,0,0,32,145,0,0,0,0,0,1,0,
66,0,0,0,0,0,27,226,0,0,4,4,0,1,0,1,97,0,0,1,97,0,0,1,10,0,0,1,10,0,0,
97,0,0,5,56,0,6,243,0,0,1,1,0,1,0,2,3,0,0,
116,0,0,6,79,0,6,288,0,0,3,3,0,1,0,3,3,0,0,2,3,0,0,2,9,0,0,
143,0,0,7,156,0,6,325,0,0,2,2,0,1,0,1,97,0,0,2,97,0,0,
166,0,0,8,157,0,6,351,0,0,2,2,0,1,0,1,97,0,0,2,97,0,0,
189,0,0,9,163,0,6,378,0,0,2,2,0,1,0,1,3,0,0,2,97,0,0,
};
using namespace std;
#include "hora2conn.h"
#include "TRandom.h"
#include <stdio.h>
#include <iostream>
#include <iomanip>
#include <stddef.h>
#include <stdlib.h>
#include <string.h>
#include <termios.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
#include <oraca.h>
#include <sqlca.h>
#include <sqlcpr.h>
ClassImp(HOra2Conn)
HOra2Conn::HOra2Conn() {
strcpy(dbName,"db-hades");
strcpy(userName,"hades_ana");
isConnected=kFALSE;
actRunId=-1;
runStart=-1;
expLocation[0]='\0';
historyDate[0]='\0';
needsServerCheck=kTRUE;
}
HOra2Conn::~HOra2Conn() {
close();
}
Bool_t HOra2Conn::open() {
Char_t* password = new Char_t[9];
strcpy(password,"hades");
Bool_t rc=openConnection(password);
if (!rc) close();
return rc;
}
Bool_t HOra2Conn::open(Char_t *uName) {
strncpy(userName,uName,20);
Char_t* password=getPassword();
Bool_t rc=openConnection(password);
if (!rc) close();
return rc;
}
Bool_t HOra2Conn::open(Char_t *dbN, Char_t *uN) {
strncpy(dbName,dbN,30);
strncpy(userName,uN,20);
Char_t* password=getPassword();
Bool_t rc=openConnection(password);
if (!rc) close();
return rc;
}
Bool_t HOra2Conn::reconnect() {
if (isConnected) return kTRUE;
if (strcmp(userName,"hades_ana")!=0) return kFALSE;
Char_t connId[80];
Char_t password[]={"hades"};
strcpy(connId,userName);
strcat(connId,"@");
strcat(connId,dbName);
char* uName;
char* pWord;
uName=connId;
pWord=password;
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.iters = (unsigned int )10;
sqlstm.offset = (unsigned int )5;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlstm.sqhstv[0] = (unsigned char *)uName;
sqlstm.sqhstl[0] = (unsigned long )0;
sqlstm.sqhsts[0] = ( int )0;
sqlstm.sqindv[0] = ( short *)0;
sqlstm.sqinds[0] = ( int )0;
sqlstm.sqharm[0] = (unsigned long )0;
sqlstm.sqadto[0] = (unsigned short )0;
sqlstm.sqtdso[0] = (unsigned short )0;
sqlstm.sqhstv[1] = (unsigned char *)pWord;
sqlstm.sqhstl[1] = (unsigned long )0;
sqlstm.sqhsts[1] = ( int )0;
sqlstm.sqindv[1] = ( short *)0;
sqlstm.sqinds[1] = ( int )0;
sqlstm.sqharm[1] = (unsigned long )0;
sqlstm.sqadto[1] = (unsigned short )0;
sqlstm.sqtdso[1] = (unsigned short )0;
sqlstm.sqphsv = sqlstm.sqhstv;
sqlstm.sqphsl = sqlstm.sqhstl;
sqlstm.sqphss = sqlstm.sqhsts;
sqlstm.sqpind = sqlstm.sqindv;
sqlstm.sqpins = sqlstm.sqinds;
sqlstm.sqparm = sqlstm.sqharm;
sqlstm.sqparc = sqlstm.sqharc;
sqlstm.sqpadto = sqlstm.sqadto;
sqlstm.sqptdso = sqlstm.sqtdso;
sqlstm.sqlcmax = (unsigned int )100;
sqlstm.sqlcmin = (unsigned int )2;
sqlstm.sqlcincr = (unsigned int )1;
sqlstm.sqlctimeout = (unsigned int )0;
sqlstm.sqlcnowait = (unsigned int )0;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) showSqlError("openConnection(Char_t*)","Wrong user/password");
}
if (sqlca.sqlcode==0) {
isConnected=kTRUE;
setHistoryDate(historyDate);
} else Error("reconnect()","*** Failed to connect to Oracle ***");
return isConnected;
}
void HOra2Conn::close() {
actRunId=-1;
runStart=-1;
expLocation[0]='\0';
historyDate[0]='\0';
if (isConnected) {
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.iters = (unsigned int )1;
sqlstm.offset = (unsigned int )36;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) showSqlError("close()");
}
isConnected=kFALSE;
cout<<"connection to Oracle closed"<<endl;
}
needsServerCheck=kTRUE;
}
void HOra2Conn::disconnect() {
if (isConnected) {
actRunId=-1;
runStart=-1;
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.iters = (unsigned int )1;
sqlstm.offset = (unsigned int )51;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) showSqlError("disconnect()");
}
isConnected=kFALSE;
cout<<"connection to Oracle closed"<<endl;
needsServerCheck=kTRUE;
}
}
void HOra2Conn::print() {
if (isConnected)
cout<<"Oracle-Database: "<<dbName<<" Username: "<<userName<<'\n';
else cout<<"*** no connection to Oracle established ***\n";
if (strlen(historyDate)==0) cout<<"No history date set\n";
else cout<<"History date: "<<historyDate<<'\n';
}
void HOra2Conn::showSqlError(const Char_t* fctName,const Char_t* msg) {
UChar_t errmsg[513];
size_t buflen, msglen;
buflen=sizeof(errmsg)-1;
sqlglm(errmsg,&buflen,&msglen);
if ((++msglen)<buflen) {
errmsg[msglen]='\0';
} else {
errmsg[buflen]='\0';
}
if (msg) {
Error(fctName,"\n%s\n%s\n",errmsg,msg);
} else {
Error(fctName,"\n%s\n",errmsg);
}
}
Char_t* HOra2Conn::getPassword() {
Char_t* passwd = new Char_t[20];
Char_t buf[20];
Int_t ttyfd = 0;
struct termios tio, itio;
if ((ttyfd = ::open("/dev/tty", O_RDWR)) < 0) {
fprintf(stderr, "cannot open tty, using stdin\n");
ttyfd = 0;
}
if (tcgetattr(ttyfd, &tio) < 0) {
fprintf (stderr, "\nUnable to get terminal characteristics: ");
cout<<"enter password for user "<<userName<<" > ";
scanf("%[^\n]%*c",passwd);
return passwd;
}
itio = tio;
tio.c_lflag &= ~(ECHO|ICANON);
tcsetattr (ttyfd, TCSAFLUSH, &tio);
cout<<"enter password for user "<<userName<<" > ";
fgets(buf, 20, stdin);
tcsetattr (ttyfd, TCSAFLUSH, &itio);
sscanf(buf, "%s", passwd);
cout<<endl;
return passwd;
}
Bool_t HOra2Conn::openConnection(Char_t* password) {
if (isConnected) close();
Char_t connId[80];
strcpy(connId,userName);
strcat(connId,"@");
strcat(connId,dbName);
char* uName;
char* pWord;
uName=connId;
pWord=password;
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.iters = (unsigned int )10;
sqlstm.offset = (unsigned int )66;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlstm.sqhstv[0] = (unsigned char *)uName;
sqlstm.sqhstl[0] = (unsigned long )0;
sqlstm.sqhsts[0] = ( int )0;
sqlstm.sqindv[0] = ( short *)0;
sqlstm.sqinds[0] = ( int )0;
sqlstm.sqharm[0] = (unsigned long )0;
sqlstm.sqadto[0] = (unsigned short )0;
sqlstm.sqtdso[0] = (unsigned short )0;
sqlstm.sqhstv[1] = (unsigned char *)pWord;
sqlstm.sqhstl[1] = (unsigned long )0;
sqlstm.sqhsts[1] = ( int )0;
sqlstm.sqindv[1] = ( short *)0;
sqlstm.sqinds[1] = ( int )0;
sqlstm.sqharm[1] = (unsigned long )0;
sqlstm.sqadto[1] = (unsigned short )0;
sqlstm.sqtdso[1] = (unsigned short )0;
sqlstm.sqphsv = sqlstm.sqhstv;
sqlstm.sqphsl = sqlstm.sqhstl;
sqlstm.sqphss = sqlstm.sqhsts;
sqlstm.sqpind = sqlstm.sqindv;
sqlstm.sqpins = sqlstm.sqinds;
sqlstm.sqparm = sqlstm.sqharm;
sqlstm.sqparc = sqlstm.sqharc;
sqlstm.sqpadto = sqlstm.sqadto;
sqlstm.sqptdso = sqlstm.sqtdso;
sqlstm.sqlcmax = (unsigned int )100;
sqlstm.sqlcmin = (unsigned int )2;
sqlstm.sqlcincr = (unsigned int )1;
sqlstm.sqlctimeout = (unsigned int )0;
sqlstm.sqlcnowait = (unsigned int )0;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) showSqlError("openConnection(Char_t*)","Wrong user/password");
}
if (sqlca.sqlcode==0) isConnected=kTRUE;
else cout<<"*** Failed to connect to Oracle ***"<<endl;
delete [] password;
actRunId=-1;
runStart=0;
expLocation[0]='\0';
historyDate[0]='\0';
alignmentOutVers=-1;
return isConnected;
}
Int_t HOra2Conn::checkServerLoad() {
int retval;
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.stmt = "begin :retval := hanal . check_analysis_sessions ; END ;";
sqlstm.iters = (unsigned int )1;
sqlstm.offset = (unsigned int )97;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlstm.sqhstv[0] = (unsigned char *)&retval;
sqlstm.sqhstl[0] = (unsigned long )sizeof(int);
sqlstm.sqhsts[0] = ( int )0;
sqlstm.sqindv[0] = ( short *)0;
sqlstm.sqinds[0] = ( int )0;
sqlstm.sqharm[0] = (unsigned long )0;
sqlstm.sqadto[0] = (unsigned short )0;
sqlstm.sqtdso[0] = (unsigned short )0;
sqlstm.sqphsv = sqlstm.sqhstv;
sqlstm.sqphsl = sqlstm.sqhstl;
sqlstm.sqphss = sqlstm.sqhsts;
sqlstm.sqpind = sqlstm.sqindv;
sqlstm.sqpins = sqlstm.sqinds;
sqlstm.sqparm = sqlstm.sqharm;
sqlstm.sqparc = sqlstm.sqharc;
sqlstm.sqpadto = sqlstm.sqadto;
sqlstm.sqptdso = sqlstm.sqtdso;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) goto notfound;
}
return retval;
notfound:
showSqlError("checkServerLoad");
return -1;
}
Int_t HOra2Conn::getRunStart(Int_t id) {
if (id==actRunId && runStart!=0) return runStart;
if (needsServerCheck) {
Int_t l=0;
UInt_t nTotWait=0;
l=checkServerLoad();
while (l==0&&nTotWait<86400000) {
UInt_t nWait=10000+gRandom->Integer(20000);
nTotWait+=nWait;
cout<<"Oracle server busy, retry in "<<nWait/1000<<" seconds"<<endl;
usleep(nWait*1000);
l=checkServerLoad();
}
if (l>0) needsServerCheck=kFALSE;
else return -1;
}
if (strlen(historyDate)==0) setParamRelease(id);
actRunId=id;
alignmentOutVers=-1;
runStart=-1;
int ri;
int rs;
struct { unsigned short len; unsigned char arr[11]; } exp_loc;
ri = actRunId;
exp_loc.len=11;
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.stmt = "begin hades_oper . run_query_2 . get_run_start ( :ri , :rs \
, :exp_loc ) ; END ;";
sqlstm.iters = (unsigned int )1;
sqlstm.offset = (unsigned int )116;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlstm.sqhstv[0] = (unsigned char *)&ri;
sqlstm.sqhstl[0] = (unsigned long )sizeof(int);
sqlstm.sqhsts[0] = ( int )0;
sqlstm.sqindv[0] = ( short *)0;
sqlstm.sqinds[0] = ( int )0;
sqlstm.sqharm[0] = (unsigned long )0;
sqlstm.sqadto[0] = (unsigned short )0;
sqlstm.sqtdso[0] = (unsigned short )0;
sqlstm.sqhstv[1] = (unsigned char *)&rs;
sqlstm.sqhstl[1] = (unsigned long )sizeof(int);
sqlstm.sqhsts[1] = ( int )0;
sqlstm.sqindv[1] = ( short *)0;
sqlstm.sqinds[1] = ( int )0;
sqlstm.sqharm[1] = (unsigned long )0;
sqlstm.sqadto[1] = (unsigned short )0;
sqlstm.sqtdso[1] = (unsigned short )0;
sqlstm.sqhstv[2] = (unsigned char *)&exp_loc;
sqlstm.sqhstl[2] = (unsigned long )13;
sqlstm.sqhsts[2] = ( int )0;
sqlstm.sqindv[2] = ( short *)0;
sqlstm.sqinds[2] = ( int )0;
sqlstm.sqharm[2] = (unsigned long )0;
sqlstm.sqadto[2] = (unsigned short )0;
sqlstm.sqtdso[2] = (unsigned short )0;
sqlstm.sqphsv = sqlstm.sqhstv;
sqlstm.sqphsl = sqlstm.sqhstl;
sqlstm.sqphss = sqlstm.sqhsts;
sqlstm.sqpind = sqlstm.sqindv;
sqlstm.sqpins = sqlstm.sqinds;
sqlstm.sqparm = sqlstm.sqharm;
sqlstm.sqparc = sqlstm.sqharc;
sqlstm.sqpadto = sqlstm.sqadto;
sqlstm.sqptdso = sqlstm.sqtdso;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) goto notfound;
}
if (ri==(Int_t)actRunId) {
runStart=rs;
exp_loc.arr[exp_loc.len]='\0';
if (strlen(expLocation)==0) strcpy(expLocation,(Char_t*)exp_loc.arr);
else {
if (strcmp(expLocation,(Char_t*)exp_loc.arr)!=0) {
Error("getRunStart(Int_t)",
"\nA switch from beamtime runs to simulations runs and vice versa is not "
"possible\nwithout the close and reopen of the Oracle connection!\n\n");
runStart=-1;
}
}
return runStart;
}
notfound:
Error("getRunStart(Int_t)","Run not found!\n\n");
return -1;
}
Bool_t HOra2Conn::setHistoryDate(const Char_t* dateString) {
char* d;
char rd[21];
d=(Char_t*)dateString;
rd[0]='\0';
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.stmt = "begin hades_oper . run_query_2 . set_history_date ( :d ) ; \
:rd := to_char ( hades_oper . run_query_2 . get_history_date , 'DD-MON-YYYY HH\
24:MI:SS' ) ; END ;";
sqlstm.iters = (unsigned int )1;
sqlstm.offset = (unsigned int )143;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlstm.sqhstv[0] = (unsigned char *)d;
sqlstm.sqhstl[0] = (unsigned long )0;
sqlstm.sqhsts[0] = ( int )0;
sqlstm.sqindv[0] = ( short *)0;
sqlstm.sqinds[0] = ( int )0;
sqlstm.sqharm[0] = (unsigned long )0;
sqlstm.sqadto[0] = (unsigned short )0;
sqlstm.sqtdso[0] = (unsigned short )0;
sqlstm.sqhstv[1] = (unsigned char *)rd;
sqlstm.sqhstl[1] = (unsigned long )21;
sqlstm.sqhsts[1] = ( int )0;
sqlstm.sqindv[1] = ( short *)0;
sqlstm.sqinds[1] = ( int )0;
sqlstm.sqharm[1] = (unsigned long )0;
sqlstm.sqadto[1] = (unsigned short )0;
sqlstm.sqtdso[1] = (unsigned short )0;
sqlstm.sqphsv = sqlstm.sqhstv;
sqlstm.sqphsl = sqlstm.sqhstl;
sqlstm.sqphss = sqlstm.sqhsts;
sqlstm.sqpind = sqlstm.sqindv;
sqlstm.sqpins = sqlstm.sqinds;
sqlstm.sqparm = sqlstm.sqharm;
sqlstm.sqparc = sqlstm.sqharc;
sqlstm.sqpadto = sqlstm.sqadto;
sqlstm.sqptdso = sqlstm.sqtdso;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) goto notfound;
}
rd[20]='\0';
strcpy(historyDate,rd);
cout<<"*************************************************************\n";
cout<<" Oracle history date: "<<historyDate<<"\n";
cout<<"*************************************************************\n";
return kTRUE;
notfound:
showSqlError("setHistoryDate(Int_t)");
return kFALSE;
}
Bool_t HOra2Conn::setParamRelease(const Char_t* release_name) {
char* r;
char rd[21];
rd[0]='\0';
r=(Char_t*)release_name;
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.stmt = "begin hades_oper . run_query_2 . set_param_release ( :r ) ;\
:rd := to_char ( hades_oper . run_query_2 . get_history_date , 'DD-MON-YYYY H\
H24:MI:SS' ) ; END ;";
sqlstm.iters = (unsigned int )1;
sqlstm.offset = (unsigned int )166;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlstm.sqhstv[0] = (unsigned char *)r;
sqlstm.sqhstl[0] = (unsigned long )0;
sqlstm.sqhsts[0] = ( int )0;
sqlstm.sqindv[0] = ( short *)0;
sqlstm.sqinds[0] = ( int )0;
sqlstm.sqharm[0] = (unsigned long )0;
sqlstm.sqadto[0] = (unsigned short )0;
sqlstm.sqtdso[0] = (unsigned short )0;
sqlstm.sqhstv[1] = (unsigned char *)rd;
sqlstm.sqhstl[1] = (unsigned long )21;
sqlstm.sqhsts[1] = ( int )0;
sqlstm.sqindv[1] = ( short *)0;
sqlstm.sqinds[1] = ( int )0;
sqlstm.sqharm[1] = (unsigned long )0;
sqlstm.sqadto[1] = (unsigned short )0;
sqlstm.sqtdso[1] = (unsigned short )0;
sqlstm.sqphsv = sqlstm.sqhstv;
sqlstm.sqphsl = sqlstm.sqhstl;
sqlstm.sqphss = sqlstm.sqhsts;
sqlstm.sqpind = sqlstm.sqindv;
sqlstm.sqpins = sqlstm.sqinds;
sqlstm.sqparm = sqlstm.sqharm;
sqlstm.sqparc = sqlstm.sqharc;
sqlstm.sqpadto = sqlstm.sqadto;
sqlstm.sqptdso = sqlstm.sqtdso;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) goto notfound;
}
rd[20]='\0';
strcpy(historyDate,rd);
cout<<"*************************************************************\n";
cout<<" Oracle history date: "<<historyDate<<"\n";
cout<<"*************************************************************\n";
return kTRUE;
notfound:
showSqlError("setParamRelease(const Char_t*)");
return kFALSE;
}
Bool_t HOra2Conn::setParamRelease(Int_t run) {
int r;
char rd[21];
r=run;
rd[0]='\0';
{
struct sqlexd sqlstm;
sqlorat((void **)0, &sqlctx, &oraca);
sqlstm.sqlvsn = 13;
sqlstm.arrsiz = 4;
sqlstm.sqladtp = &sqladt;
sqlstm.sqltdsp = &sqltds;
sqlstm.stmt = "begin hades_oper . run_query_2 . set_history_date_by_run ( \
:r ) ; :rd := to_char ( hades_oper . run_query_2 . get_history_date , 'DD-MON-\
YYYY HH24:MI:SS' ) ; END ;";
sqlstm.iters = (unsigned int )1;
sqlstm.offset = (unsigned int )189;
sqlstm.cud = sqlcud0;
sqlstm.sqlest = (unsigned char *)&sqlca;
sqlstm.sqlety = (unsigned short)4352;
sqlstm.occurs = (unsigned int )0;
sqlstm.sqhstv[0] = (unsigned char *)&r;
sqlstm.sqhstl[0] = (unsigned long )sizeof(int);
sqlstm.sqhsts[0] = ( int )0;
sqlstm.sqindv[0] = ( short *)0;
sqlstm.sqinds[0] = ( int )0;
sqlstm.sqharm[0] = (unsigned long )0;
sqlstm.sqadto[0] = (unsigned short )0;
sqlstm.sqtdso[0] = (unsigned short )0;
sqlstm.sqhstv[1] = (unsigned char *)rd;
sqlstm.sqhstl[1] = (unsigned long )21;
sqlstm.sqhsts[1] = ( int )0;
sqlstm.sqindv[1] = ( short *)0;
sqlstm.sqinds[1] = ( int )0;
sqlstm.sqharm[1] = (unsigned long )0;
sqlstm.sqadto[1] = (unsigned short )0;
sqlstm.sqtdso[1] = (unsigned short )0;
sqlstm.sqphsv = sqlstm.sqhstv;
sqlstm.sqphsl = sqlstm.sqhstl;
sqlstm.sqphss = sqlstm.sqhsts;
sqlstm.sqpind = sqlstm.sqindv;
sqlstm.sqpins = sqlstm.sqinds;
sqlstm.sqparm = sqlstm.sqharm;
sqlstm.sqparc = sqlstm.sqharc;
sqlstm.sqpadto = sqlstm.sqadto;
sqlstm.sqptdso = sqlstm.sqtdso;
sqlcxt((void **)0, &sqlctx, &sqlstm, &sqlfpn);
if (sqlca.sqlcode < 0) goto notfound;
}
rd[20]='\0';
strcpy(historyDate,rd);
cout<<"*************************************************************\n";
cout<<" Oracle history date: "<<historyDate<<"\n";
cout<<"*************************************************************\n";
return kTRUE;
notfound:
showSqlError("setParamRelease(Int_t)");
return kFALSE;
}