msd_user.cc

//-----------------------------------------------------
// msd_user.cc
//
// Project: PDBe API Framework, EBI  
// Module:  Implementation of User Layer Classes for PDBe API Framework 
//
// 
// User Layer
// Last updated: 25 February 2004 10:17
// (C) Siamak Sobhany
//------------------------------------------------------
#ifndef __MSD_USER_H__
#include "msd_user.h"
#endif
#ifndef __MSD_CHEM_H__
#include "msd_chem.h"
#endif
#ifndef __MSD_METADATA_H__
#include "msd_metadata.h"
#endif

#include <cstdarg>


using namespace std;

        
#define msd_typecast(new_type,old_object) (*((new_type *)&old_object))


size_t getsize(void){
 return sizeof(msdbConnect);
}


int msd_select (pMSDEnv msd, char* stm){
  if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
  genselect(*((msdbConnect *) msd->conn), stm); 
  return(0);
}

int msd_sqlinit (pMSDEnv msd, char* stm){
   if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}

   msd->select=new MSDSelect();
   ((MSDSelect *) msd->select)->InitSql(*((msdbConnect *) msd->conn), stm);
   return (0);
}

int msd_setcriteria(pMSDEnv msd, const char* fmt,...){ 
  int i;
  float f;
  double d;
  char* s;
  const char *p=fmt;
 if (msd->conn==NULL) {return(2);}
  va_list ap;
  va_start(ap,fmt); // point to first element after fmt
  while(*p)
  {
   if (*p=='i') //int
   {
    i=va_arg(ap,int);
        ((MSDSelect *) msd->select)->SetCriteria(i);
   }
   else if (*p=='d') //double or float
   {
    d=va_arg(ap,double);
    ((MSDSelect *) msd->select)->SetCriteria(d);
   }
   else if (*p=='s') //string
   {
    s=va_arg(ap,char*);
        ((MSDSelect *) msd->select)->SetCriteria(s);
   }
   
   else 
   {
    printf("unsupported format flag");
    break;
   }
   ++p; // get the next char of the format string 
  }// while
  va_end(ap); //cleanup
  ((MSDSelect *) msd->select)->MakeRecord();
  return (0);
 }



int msd_getrownum(pMSDEnv msd){
if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
 return ((MSDSelect *) msd->select)->GetRowNum();
}

int msd_getnext(pMSDEnv msd){
 if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
 ((MSDSelect *) msd->select)->GetNext();
 return (0);
}


extern "C"  MSDValue msd_getvfloat(pMSDEnv msd,int col){
  MSDValue msdv= &(msd->node);
  ((MSDSelect *) msd->select)->GetVal(col,msdv->value.vfloat);
 
  return msdv;
}
extern "C"  MSDValue   msd_getvint(pMSDEnv msd,int col){
          MSDValue msdv= &(msd->node);
         ((MSDSelect *) msd->select)->GetVal(col,msdv->value.vint);
         return msdv;
}
extern "C"  MSDValue msd_getvstr(pMSDEnv msd,int col){
        MSDValue msdv= &(msd->node);
        
        msdv->value.vstr = new char[256];
        msdv->value.vstr[0]= '\0';
        ((MSDSelect *) msd->select)->GetVal(col,msdv->value.vstr);
        return msdv;
}


extern "C"  MSDValue msd_getvdouble(pMSDEnv msd,int col){
         MSDValue msdv= &(msd->node);
         ((MSDSelect *) msd->select)->GetVal(col,msdv->value.vdouble);
         return msdv;
}

extern "C"  MSDValue msd_getvalue(pMSDEnv msd,int col, MSDValue (*pGetFunc)(pMSDEnv,int))
   {
      MSDValue result = pGetFunc(msd, col);                         // call using function pointer
      return result;
   }


extern "C"   float msd_ugetfloat(pMSDEnv msd,int col)
{float f;
 ((MSDSelect *) msd->select)->GetVal(col,f);
 return f;
}
extern "C"      int msd_ugetint(pMSDEnv msd,int col)
{int i;
 ((MSDSelect *) msd->select)->GetVal(col,i);
 return i;
}
extern "C"      char* msd_ugetstr(pMSDEnv msd,int col, char* s)
{MSDGetValue (*msd,col,s,vstr); 
return s;

}
extern "C"      double  msd_ugetdouble(pMSDEnv msd,int col)
{double d;
((MSDSelect *) msd->select)->GetVal(col,d);
return d;
}


#ifdef __WITH_XMMDB__

extern "C" int msd_manager(pMSDEnv msd) 
{ msd->manager = NULL;
  msd->manager = (void*)new MSDManager();
  return (0);

}

extern "C" int msd_get_number_of_atoms(pMSDEnv msd) 
{ 
  return ((MSDManager*)msd->manager)->GetNumberOfAtoms(); 
}


extern "C" int msd_get_object_entry (pMSDEnv msd, int n_eID){
 if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
  if (((MSDManager*)msd->manager)->LoadWarehouse(*((msdbConnect *) msd->conn),n_eID) == S_OK)
  {return(0);
  }else
  return(1);
}

#endif

extern "C" int msd_get_entry_id(pMSDEnv msd, char* acc_code){
 return getMSDEntryID(*((msdbConnect *) msd->conn), acc_code);
}

extern "C" char* msd_get_accession_code(pMSDEnv msd, int e_ID){
 char* acc_code;
 getMSDAccessionCode(*((msdbConnect *) msd->conn), e_ID, acc_code);
 return acc_code;
}




extern "C" int  msd_init(pMSDEnv msd){
    msd->ConID=0;
        msd->SqlID=0;
        msd->conn=NULL;
        msd->select=NULL;
        msd->manager=NULL;
        msd->data=NULL;
        for (int i=0;i<MAXRES;i++ )
        {msd->result[i]=NULL;
        }
        msd->conn = new msdbConnect();
        ((msdbConnect *)msd->conn)->msdbInit();
        msd->stat=INIT;
        return (0);

}



#ifdef MSD_ORACLE
 

 int msd_attach(pMSDEnv msd, char* oserver){
        
        if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
        try
 {
  ((msdbConnect *) msd->conn)->server_attach(oserver);
   msd->stat=ATTACHED;
 }
  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
   msd->stat=NOTATTACHED;
  }
  return(0);
 }

 int msd_begin(pMSDEnv msd, char* usern, char* passwd){
if (msd->conn==NULL) {
        msd->stat=NOOBJECT;
        return(2);}
 try
 {
  ((msdbConnect *) msd->conn)->session_begin(usern, passwd);
   msd->stat=LOGGEDIN;
 }
  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
   msd->stat=NOTLOGGEDIN;
  }
  return(0);
 }
int msd_end(pMSDEnv msd){
        if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
try
{
  ((msdbConnect *) msd->conn)->session_end();
   msd->stat=LOGGEDOUT;
}
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
   msd->stat=NOTLOGGEDOUT;
}
return(0);
}
int msd_detach(pMSDEnv msd){
        
        if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
try
{
  ((msdbConnect *)msd->conn)->server_detach();
   msd->stat=DETACHED;
}
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
    msd->stat=NOTDETACHED;
}
return(0);
}
int msd_disconnect(pMSDEnv msd){
        
        if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
        try
{
  ((msdbConnect *) msd->conn)->session_end();
  ((msdbConnect *) msd->conn)->server_detach();
  ((msdbConnect *) msd->conn)->logoff();
   delete  (msdbConnect *)msd->conn;
}
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
}
return(0);
}

#endif //MSD_ORACLE

int msd_rlogin(pMSDEnv msd, char* loginstring){
        if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
        try
{
   ((msdbConnect *) msd->conn)->rlogon(loginstring);
   msd->stat=LOGGEDIN;
}
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
   msd->stat=NOTLOGGEDIN;
}
return (0);
}
 


int msd_logoff(pMSDEnv msd){
        if (msd->conn==NULL) {
                msd->stat=NOOBJECT;
                return(2);}
try
{
  ((msdbConnect *) msd->conn)->logoff();
  msd->stat=LOGGEDOUT;

}
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
   msd->stat=NOTLOGGEDOUT;
}
return (0);
}
int  msd_free(pMSDEnv msd){
   if (msd->conn)
   {delete (msdbConnect *)msd->conn;
   }
   if (msd->select)
   {delete (MSDSelect *)msd->select;
   }
   
   #ifdef __WITH_XMMDB__
   if (msd->manager)
   {delete (MSDManager *)msd->manager;
   }
   #endif
 
  return (0);
}



extern int  msd_write_table_attributes(char* schema, char* connstr, char* fname){
 
 return WriteTableAttributes(schema,  connstr, fname);
}

extern int  msd_soap_data_generator(char* schema, char* connstr, char* fname){
 
 return SoapDataGenerator(schema, connstr, fname);
}

extern int  msd_get_tables_relations(char* schema, char* connstr){
 extern struct TableArray datawarehouse;
 return GetTablesRelations(schema, &datawarehouse, connstr);
}

extern int msd_get_datamodel(char* schema, char* connstr){
 extern struct TableArray datawarehouse;
 return GetDataModel(schema, &datawarehouse, connstr);
}
extern int msd_load_metadata(char* schema, char* connstr){
 
 return LoadMetaData(schema,  connstr);
}

// LISP Evaluator
int msd_lisp_init(int argc, char* argv[]){
  printf("EBI-MSD's API Framework 1.00, 17 January 2002\n");  
  xlCallbacks *callbacks = xlDefaultCallbacks(argv[0]);
  xlInit(callbacks,argc,argv,NULL);
  xlInfo("%s",xlBanner());
  return (0);
}
int msd_lisp_load(char * fn){
        xlLoadFile(fn);
        return (0);
}
int msd_lisp_eval(void){
 xlCallFunctionByName(NULL,0,"*TOPLEVEL*",0); 
 return (0);
}
 

---