mysql_save()

int mysql_save

(

COMPLEX

cfreq

)

                             {

   int i;
   char *query = "insert into runinfo(categoryid,username,title,program,version,datestart,dateend,elapsed,notes,hostname,hostos,totnelm,totncntr,totmics,nnodes) values (%d,'%s','%s','%s','%s','%s','%s',%f,'%s','%s','%s',%d,%d,%d,%d)";
   char* sql;
   char hostname[256];
   char hostos[256];
   struct utsname u_name;       
   char starttime[80];
   char endtime[80];
   struct passwd* pwd;
   int mpi_ncntr;

   FILE* tmpfile;
   char* buffer;
   long filesize;
   char* tmp;

   char* dataquery= "INSERT INTO rundata (runid,name,description,data) values (%d,'%s','%s','%s')";
   char* datasql;
   char datadesc[256];
   

   Vec gPhinc;
   Vec gPhitot;

   Vec gPhiscm;
   Vec gPhincm;
   Vec gPhimtot;

  int locRows;
  int gRows,gCRows;
  int mm,nn;
  int descl[9];
  int descg[9];
  int izero=0;
  int ione=1;
  int info;


  gPhiscm  = calloc(modgeominfo->nmics,sizeof(COMPLEX));
  gPhincm  = calloc(modgeominfo->nmics,sizeof(COMPLEX));
  gPhimtot = calloc(modgeominfo->nmics,sizeof(COMPLEX));

  gRows = modgeominfo->nmics;
  locRows  = numroc_(&gRows  ,&runinfo->mics_block_size,&runinfo->myrow,&izero,&runinfo->nprows);


  // Gathering vectors on node 0 
  mm = gRows;// * runinfo->nprows;
  nn = runinfo->npcols;
  descinit_(descl   , &gRows  ,&ione, &runinfo->mics_block_size ,&ione,&izero,&izero,&runinfo->ctxt,&locRows  ,&info);
  descinit_(descg   , &mm     ,&ione, &gRows                    ,&ione,&izero,&izero,&runinfo->ctxt,&gRows  ,&info);

  pzgemr2d_(&gRows,&ione,solution->vecPhium  ,&ione, &ione,descl, gPhiscm ,&ione,&ione,descg,&runinfo->ctxt);
  pzgemr2d_(&gRows,&ione,solution->vecPhincm ,&ione, &ione,descl, gPhincm ,&ione,&ione,descg,&runinfo->ctxt);

  gCRows = modgeominfo->ncntr;
  gPhinc = calloc(modgeominfo->ncntr,sizeof(COMPLEX));
  gPhitot = calloc(modgeominfo->ncntr,sizeof(COMPLEX));
  mm = gCRows;
  descinit_(descl  , &mm     ,&ione, &runinfo->row_block_size,&ione,&izero,&izero,&runinfo->ctxt,&gCRows  ,&info);
  descinit_(descg  , &mm     ,&ione, &gCRows,                 &ione,&izero,&izero,&runinfo->ctxt,&gCRows  ,&info);
  pzgemr2d_(&gCRows,&ione,solution->vecPhinc ,&ione, &ione,descl, gPhinc ,&ione,&ione,descg,&runinfo->ctxt);

  logger(LOG_DEBUG, "gathered vectors\n");
  /* Evaluating totals */
  /* body */
  if(modsolinfo->knw == 1){
    for(i=0;i<modgeominfo->ncntr;i++){
      gPhitot[i] = solution->sol[i] - gPhinc[i]; // scattering
    }
  }else{
    for(i=0;i<modgeominfo->ncntr;i++){
      gPhitot[i] = solution->sol[i] + gPhinc[i]; // total
    }
  }

  for(i=0;i<modgeominfo->nmics;i++){
    gPhimtot[i] = gPhincm[i] + gPhiscm[i];
  }

  /* DB SAVING is on Master */
  if(rank == 0){ 

   open_connection();
   logger(LOG_DEBUG,"opened connection\n");

   if(mysqlinfo->runid == -1){ //first save for this run
     sql = (char*) malloc(512*sizeof(char));

     gethostname(hostname,255);
     uname(&u_name);
     sprintf(hostos,"%s %s %s %s %s",&u_name.sysname[0],&u_name.nodename[0],&u_name.release[0],&u_name.version[0],&u_name.machine[0]);
     strftime(starttime,sizeof(starttime),"%Y-%m-%d %H:%M:%S",localtime(&rundetails->starttime));
     strftime(endtime  ,sizeof(endtime  ),"%Y-%m-%d %H:%M:%S",localtime(&rundetails->endtime  ));
  
     pwd = getpwuid(getuid());
     sprintf(sql,query,
           1, // defaults to first category
           pwd->pw_name,
           rundetails->title,
           "acousto",
           ACOUSTO_VERSION,
           starttime,
           endtime,
           rundetails->elapsed,
           "",
           hostname,
           hostos,
           modgeominfo->nelmb,
           modgeominfo->ncntr,
           modgeominfo->nmics,
           size
           );
     logger(LOG_DEBUG,"executing query %s\n",sql);
  
     if(mysql_query(connection,sql)){
       printf("%s\n",mysql_error(connection));
       return -1;
     }
     mysqlinfo->runid = (int)mysql_insert_id(connection);
  
     logger(LOG_INFO," Run was stored with id -> %d\n",mysqlinfo->runid);


      /* --------------------------------------
         Reading and storing configuration file
         --------------------------------------*/
      tmpfile = fopen(rundetails->cfg_filename,"r");
      fseek(tmpfile,0L,SEEK_END);
      filesize = ftell(tmpfile);
      buffer = calloc(filesize,sizeof(char));
      rewind(tmpfile);
      fread(buffer,sizeof(char),filesize,tmpfile);
      fclose(tmpfile);
      
      datasql = (char*) malloc((255+filesize*2+1)*sizeof(char));
      tmp     = (char*) malloc((filesize*2+1)*sizeof(char));
      
      mysql_real_escape_string(connection,tmp,buffer,filesize);
      sprintf(datasql,dataquery,mysqlinfo->runid,"ACOUSTO_CONFIG","",tmp);
      if(mysql_query(connection,datasql)){
        printf("%s\n",mysql_error(connection));
        return -1;
      }
      logger(LOG_DEBUG,"stored configuration file\n");

      free(buffer);
      free(datasql);
      free(tmp);
      free(sql);
   }



   /* Storing solution */
   mpi_ncntr  = modgeominfo->ncntr + modgeominfo->nchief;
   sprintf(datadesc,"freq: %f +i %f",CREAL(cfreq),CIMAG(cfreq));
   if(modsolinfo->knw == 1){
    store_data(solution->sol,datadesc,"ACOUSTO_BODY_TOT",mpi_ncntr,mysqlinfo->runid,geometry->cntr);
    store_data(gPhinc       ,datadesc,"ACOUSTO_BODY_INC",mpi_ncntr,mysqlinfo->runid,geometry->cntr);
    store_data(gPhitot      ,datadesc,"ACOUSTO_BODY_SCA",mpi_ncntr,mysqlinfo->runid,geometry->cntr);
   }else{
    store_data(solution->sol,datadesc,"ACOUSTO_BODY_SCA",mpi_ncntr,mysqlinfo->runid,geometry->cntr);
    store_data(gPhinc       ,datadesc,"ACOUSTO_BODY_INC",mpi_ncntr,mysqlinfo->runid,geometry->cntr);
    store_data(gPhitot      ,datadesc,"ACOUSTO_BODY_TOT",mpi_ncntr,mysqlinfo->runid,geometry->cntr);
   }
   logger(LOG_DEBUG,"stored solution\n");




   /* Storing Pressure fields and Phiu*/
   store_data(gPhincm  ,datadesc,"ACOUSTO_MICS_INC",modgeominfo->nmics,mysqlinfo->runid,geometry->mics);
   store_data(gPhiscm  ,datadesc,"ACOUSTO_MICS_SCA",modgeominfo->nmics,mysqlinfo->runid,geometry->mics);
   store_data(gPhimtot ,datadesc,"ACOUSTO_MICS_TOT",modgeominfo->nmics,mysqlinfo->runid,geometry->mics);
   logger(LOG_DEBUG,"stored additional data\n");

   close_connection();



  }

   free(gPhiscm);
   free(gPhinc);
   free(gPhincm);
   free(gPhimtot);
   free(gPhitot);


   return 1;


                 
}