msd_data.cc

//-----------------------------------------------------
// msd_data.cc
// 
// Project: PDBe API Framework, EBI 
// Module: DATA Layer Classes
// To build:
//    make -f msd_api_fw.mk buildc++ NAME=msd_data
//
// Last updated: 25 February 2004 10:17
// (C) Siamak Sobhany
//------------------------------------------------------

#ifndef __MSD_DATA_H__
#include "msd_data.h"
#endif
#include <cstdio>


// MSDSelect class methods.
 
 
void MSDSelect::SetCriteria(char* strCVal){
 *((msdbStream *) pos) << strCVal;
}
void MSDSelect::SetCriteria(double  dfCVal){
 *((msdbStream *) pos) << dfCVal;
}
void MSDSelect::SetCriteria(float fCVal){
 *((msdbStream *) pos) << fCVal;
}
void MSDSelect::SetCriteria(int iCVal){
 *((msdbStream *) pos) << iCVal;
}
void MSDSelect::SetCriteria(unsigned int uiCVal){
 *((msdbStream *) pos) << uiCVal;
}
void MSDSelect::SetCriteria(short int shiCVal){
 *((msdbStream *) pos) << shiCVal;
}
void MSDSelect::SetCriteria(long int liCVal){
 *((msdbStream *) pos) << liCVal;
}

MSDSelect::MSDSelect(){
}

void MSDSelect::InitSql(msdbConnect& r_db, char* stm){
 j=0;
 buff=50;
 pos=NULL;
 char bufs[3072];
 sprintf(bufs, stm);
 
 try
{
   pos= new msdbStream (buff, bufs, r_db); //
}
catch(msdbException& p){ // intercept OTL exceptions
   cerr<<p.msg<<endl; // print out error message
   cerr<<p.stm_text<<endl; // print out SQL that caused the error
   cerr<<p.var_info<<endl; // print out the variable that caused the error
}
 
  if (pos == NULL) {
     cerr<< "Error: msdbStream can not initialize." << endl;
     return;
 }
}

void MSDSelect::MakeRecord(){
 try
{
 desc=pos->describe_select(desc_len);  
}
catch(msdbException& p){ // intercept OTL exceptions
   cerr<<p.msg<<endl; // print out error message
   cerr<<p.stm_text<<endl; // print out SQL that caused the error
   cerr<<p.var_info<<endl; // print out the variable that caused the error
} 
 let collist = listEM( msdEnd);
 let colliststr = msdConst("(");

 
 p = new msd_array(desc_len);
 for(int n=0;n<desc_len;++n){
          switch (desc[n].dbtype){                                                                     
         case 1 : {(*p)[n] = new msd_string(desc[n].dbsize+1);} break;       // desc[n].dbsize+1                  
         case 2 : {if (desc[n].scale == 129) 
                        (*p)[n] = new msd_float;
                    else if (desc[n].scale==0)
                                {if ((desc[n].prec <= 10 && desc[n].prec != 0) || has_integer_name(desc[n].name)==1) // (desc[n].prec==10 ||desc[n].prec==0)
                                          (*p)[n] = new msd_int;
                                     else
                                          (*p)[n] = new msd_float;
                                                }
                                else 
                                   (*p)[n] = new msd_int;
                          } break;      
                          
         case 3 : {(*p)[n] = new msd_float;} break;                                
         case 4 : {(*p)[n] = new msd_int;} break;                                  
         case 5 : {(*p)[n] = new msd_int;} break;       // msd_unsignedint;                      
         case 6 : {(*p)[n] = new msd_short;} break;                          
         case 7 : {(*p)[n] = new msd_int;} break; // msd_long(0);
         case 12: {(*p)[n] = new msd_datetime;} break; // 93 in Oracle 9i
         case 96: {(*p)[n] = new msd_string(desc[n].dbsize+1);} break;
        
         default: {(*p)[n] = new msd_string(desc[n].dbsize+1);} 
    } // switch case
    (*p)[n]->msd_sym=intern( msdConst(desc[n].name));

                 colliststr = stringConcat(colliststr, msdConst(" "));
             colliststr = stringConcat(colliststr , msdConst(desc[n].name));


 } // end for   
 colliststr = stringConcat(colliststr, msdConst(")"));
 collist = readFromString(colliststr);
 
 
}


void MSDSelect::GetNext(){
if (!((msdbStream *) pos)->eof())
{
        p->getst(*((msdbStream *) pos));
                        
++j;
}
}

int MSDSelect::GetRowNum(){
 return j;
}
  
int MSDSelect::GetVal(int col, float& f){
 f = ((msd_float*)(*p)[col])->msd_item;
 return 0;
}

int MSDSelect::GetVal(int col, int& i){
 i = ((msd_int*)(*p)[col])->msd_item;
return 0;
}

int MSDSelect::GetVal(int col, char*& val){
 val = ((msd_string*)(*p)[col])->msd_item;
 return 0;
}


int MSDSelect::GetVal(int col, double& d){
 d = ((msd_double*)(*p)[col])->msd_item;
return 0;
}

// End of MSDSelect calss methods.

 void genselect(msdbConnect& r_db, char* stm){
   MSDSelect mselect;
   mselect.InitSql(r_db, stm);
   mselect.SetCriteria(1);
   mselect.MakeRecord();
   while (mselect.GetRowNum()<2)
   {
           mselect.GetNext();
   }
 }
  


void new_exec_query (int bf, msdbConnect& r_db, char* stm, MSDDataSet& rs)
{
 r_db.set_max_long_size(MAXBLOBSIZE); // set maximum long string size for connect object
  //ostream o;
  int j=0;
  int desc_len;
  char* stmnt=(char*)malloc(strlen(stm)+1);
  sprintf(stmnt,"%s",stm);
 
  char rowitem[16];
  
  
  
  otl_column_desc* desc;
  msdbStream ins; 
  ins.open(bf, stmnt, r_db);
  ins<<1;
  desc=ins.describe_select(desc_len);
  
  msd_array * p;
  p = new msd_array(desc_len);
  
  stringstream rowliststr;
  let colliststr = msdConst("(");
  let collist = listEM( msdEnd);
  rowliststr << "(";
  let rowlist = listEM( msdEnd);
  
  for(int n=0;n<desc_len;++n){
    switch (desc[n].dbtype){                                                                   
         case 1 : {(*p)[n] = new msd_string(desc[n].dbsize+1);} break;       // desc[n].dbsize+1                  
         case 2 : {if (desc[n].scale == 129) 
                        (*p)[n] = new msd_float;
                    else if (desc[n].scale==0)
                                {if ((desc[n].prec <= 10 && desc[n].prec != 0) || has_integer_name(desc[n].name)==1) // (desc[n].prec==10 ||desc[n].prec==0)
                                          (*p)[n] = new msd_int;
                                     else
                                          (*p)[n] = new msd_float;
                                                }
                                else 
                                   (*p)[n] = new msd_int;
                          } break;      // sprintf(type, "long int");   
                          
         case 3 : {(*p)[n] = new msd_float;} break;                                
         case 4 : {(*p)[n] = new msd_int;} break;                                  
         case 5 : {(*p)[n] = new msd_int;} break;       // msd_unsignedint;                      
         case 6 : {(*p)[n] = new msd_short;} break;                          
         case 7 : {(*p)[n] = new msd_int;} break; // msd_long(0);
         case 12: {(*p)[n] = new msd_datetime;} break; // 93 in Oracle 9i
         case 96: {(*p)[n] = new msd_string(desc[n].dbsize+1);} break;
        
         default: {(*p)[n] = new msd_string(desc[n].dbsize+1);} 
         
    } // switch case
    (*p)[n]->msd_sym=intern( msdConst(desc[n].name));

                 colliststr = stringConcat(colliststr, msdConst(" "));
             colliststr = stringConcat(colliststr , msdConst(desc[n].name));
  }      // for loop
 


 colliststr = stringConcat(colliststr, msdConst(")"));
 collist = readFromString(colliststr);
 rs.addEntity( msdSymbol(colset));
 rs.setValue( msdSymbol(colset), msdSymbol(cols), collist);
 
      while(!ins.eof()){ // while not end-of-data
        sprintf(rowitem,"R%d",j);                                      
                let rowname = intern( msdConst(rowitem));                             
                rowliststr << " ";                                            
                rowliststr << rowitem;                                        
                rs.addEntity(rowname);                                        
                rs.setValue(rowname, msdSymbol(rowno), msdConst(j));                         
                p->getst(ins);
                for(int n=0;n<desc_len;++n){                                  
                        //(*p)[n]->getst(i);
                                cout << "Column name: " << (*p)[n]->msd_sym << " ";
                                cout << "Value: " << (*p)[n]->getval() << endl;
                                
                
                                rs.setValue(rowname, (*p)[n]->msd_sym, (*p)[n]->getval());  
                } // enf for loop                                                                              
                ++j;                                                          
      }          // end while loop                                            
      j=j-1;
        rowliststr << ")";
        rowlist = read(rowliststr);
          //let ll = length(rowlist);
          //prin1(ll);
          rs.addEntity( msdSymbol(rowset));
          rs.setValue( msdSymbol(rowset), msdSymbol(rows), rowlist);
            gc(colliststr); 
          
           free(stmnt);
 }



int msd_exec_query (int bf, msdbConnect& r_db, char* stm, MSDDataSet& rs, char* rs_table, const char* argtype, ...)
{
 r_db.set_max_long_size(MAXBLOBSIZE); // set maximum long string size for connect object
  int i,j,desc_len;
  float f;
  double d;
  //otl_datetime dt;
  char rowitem[64];
  char tblname[64];
  char* s;
  const char *a=argtype;
  va_list ap;
  va_start(ap,argtype); // point to first element after fmt
  char stmnt[4096]; // =(char*)malloc(strlen(stm)+1);
  sprintf(stmnt,"%s",stm);
  //char* tblname=(char*)malloc(strlen(rs_table)+1);
  sprintf(tblname,"%s",rs_table);                                      
  let table = intern( msdConst(tblname)); 
  otl_column_desc* desc;
  j = rs.getSize()+1;
  msdbStream ins;
  ins.open(bf, stmnt, r_db);
  while(*a)
  {
   if (*a=='i') //int
   {
    i=va_arg(ap,int);
         ins<<i;
   }
   else if (*a=='d') //double or float
   {
    d=va_arg(ap,double);
   ins<<d;
   }
   else if (*a=='s') //string
   {
    s=va_arg(ap,char*);
        ins<<s;
   }
   else 
   {
    printf("unsupported format flag");
    break;
   }
   ++a; // get the next char of the format string 
  }// while
  va_end(ap); //cleanup
  desc=ins.describe_select(desc_len);
  msd_array * p;
  p = new msd_array(desc_len);
  stringstream rowliststr;
  let colliststr = msdConst("(");
  let collist = listEM( msdEnd);
 
  for(int n=0;n<desc_len;++n){
    switch (desc[n].dbtype){                                                                   
         case 1 : {(*p)[n] = new msd_string(desc[n].dbsize+1);} break;       // desc[n].dbsize+1                  
         case 2 : {if (desc[n].scale == 129) 
                        (*p)[n] = new msd_float;
                    else if (desc[n].scale==0)
                                {if ((desc[n].prec <= 10 && desc[n].prec != 0) || has_integer_name(desc[n].name)==1) // (desc[n].prec==10 ||desc[n].prec==0)
                                          (*p)[n] = new msd_int;
                                     else
                                          (*p)[n] = new msd_float;
                                                }
                                else 
                                   (*p)[n] = new msd_int;
                          } break;      // sprintf(type, "long int");   
                          
         case 3 : {(*p)[n] = new msd_float;} break;                                
         case 4 : {(*p)[n] = new msd_int;} break;                                  
         case 5 : {(*p)[n] = new msd_int;} break;       // msd_unsignedint;                      
         case 6 : {(*p)[n] = new msd_short;} break;                          
         case 7 : {(*p)[n] = new msd_int;} break; // msd_long(0);
         case 12: {(*p)[n] = new msd_datetime;} break; // 93 in Oracle 9i
         case 96: {(*p)[n] = new msd_string(desc[n].dbsize+1);} break;
        
         default: {(*p)[n] = new msd_string(desc[n].dbsize+1);} 
    } // switch case
    (*p)[n]->msd_sym=intern( msdConst(desc[n].name));

                 colliststr = stringConcat(colliststr, msdConst(" "));
             colliststr = stringConcat(colliststr , msdConst(desc[n].name));
  }      // for loop
 colliststr = stringConcat(colliststr, msdConst(")"));
 collist = readFromString(colliststr);

 int st=j;
      while(!ins.eof()){ // while not end-of-data
        sprintf(rowitem,"R%d",j);                                      
                let rowname = intern( msdConst(rowitem));                             
                //rowliststr << " ";                                            
                //rowliststr << rowitem;                                        
                rs.addEntity(rowname);                                        
                rs.setValue(rowname, msdSymbol(rowno), msdConst(j));                         
                p->getst(ins);
                for(int n=0;n<desc_len;++n){                                  
                                rs.setValue(rowname, (*p)[n]->msd_sym, (*p)[n]->getval());  
                } // enf for loop                                                                              
                ++j;                                                          
      }          // end while loop                                            
     j=j-1;
        
          let rowlist = listEM( msdConst(st),msdConst(j),msdEnd);
          rs.addEntity(table);
          rs.setValue(table, msdSymbol(rows), rowlist);
          rs.setValue(table, msdSymbol(cols), collist);
        
          gc(colliststr);
        
          return (0);
 }

let msd_make_rowlist(let se){
 int s,e;
 char rowitem[16];
 stringstream rowliststr;
 s = iC(nth(0,se));
 e = iC(nth(1,se));
 rowliststr << "(";
 let rowlist = listEM( msdEnd);
 int j = s;
 while(j<=e){ // while not end-of-data
        sprintf(rowitem,"R%d",j);                                      
                let rowname = intern( msdConst(rowitem));                             
                rowliststr << " ";                                            
                rowliststr << rowitem;                                        
                ++j;                                                          
 }               // end while loop  
 rowliststr << ")";
 rowlist = read(rowliststr);
 return rowlist;
}

---