MysqlResults.cxx

Go to the documentation of this file.

// $Header: /bes/bes/BossCvs/Calibration/rdbModel/src/Db/MysqlResults.cxx,v 1.6 2011/02/22
// 06:16:29 maqm Exp $
#ifdef WIN32
#  include <windows.h>
#endif
 
#include "facilities/Util.h"
#include "mysql.h"
#include "rdbModel/Db/MysqlResults.h"
#include <cstring>
#include <iostream>
 
namespace rdbModel {
 
  MysqlResults::MysqlResults( MYSQL_RES* results ) : m_myres( results ) {}
 
  MysqlResults::~MysqlResults() { mysql_free_result( m_myres ); }
 
  unsigned int MysqlResults::getNRows() const { return mysql_num_rows( m_myres ); }
 
  bool MysqlResults::getRow( std::vector<std::string>& fields, unsigned int i, bool clear ) {
    mysql_data_seek( m_myres, i );
    MYSQL_ROW myRow = mysql_fetch_row( m_myres );
 
    unsigned nFields = mysql_num_fields( m_myres );
 
    if ( clear ) fields.clear();
 
    for ( unsigned int iField = 0; iField < nFields; iField++ )
    {
      if ( myRow[iField] ) fields.push_back( std::string( myRow[iField] ) );
      else fields.push_back( "" );
    }
 
    return true;
  }
 
  bool MysqlResults::getRowPtrs( std::vector<std::string*>& fields, unsigned int i,
                                 bool clear ) {
 
    mysql_data_seek( m_myres, i );
    MYSQL_ROW myRow = mysql_fetch_row( m_myres );
 
    unsigned nFields = mysql_num_fields( m_myres );
 
    if ( clear ) fields.clear();
 
    for ( unsigned int iField = 0; iField < nFields; iField++ )
    {
      if ( myRow[iField] ) fields.push_back( new std::string( myRow[iField] ) );
      else fields.push_back( 0 );
    }
 
    return true;
  }
 
  bool MysqlResults::getRowCon( char* par, unsigned long* treesize, unsigned int* runFrm,
                                unsigned int* runTo, unsigned int i, bool clear ) {
    mysql_data_seek( m_myres, i );
    MYSQL_ROW      myRow   = mysql_fetch_row( m_myres );
    unsigned       nFields = mysql_num_fields( m_myres );
    unsigned long* lengths;
    lengths = mysql_fetch_lengths( m_myres );
 
    for ( unsigned int iField = 0; iField < nFields; iField++ )
    {
      if ( myRow[iField] && iField < ( nFields - 4 ) )
      {
        memcpy( par + 1024000 * iField, myRow[iField], lengths[iField] );
        treesize[iField] = lengths[iField];
      }
    }
 
    *runFrm = facilities::Util::stringToInt( myRow[nFields - 4] );
    *runTo  = facilities::Util::stringToInt( myRow[nFields - 3] );
    std::cout << " CalVerSft is " << myRow[nFields - 2] << "  File name  is "
              << myRow[nFields - 1] << std::endl;
 
    return true;
  }
 
  // May also want to do
  //  MYSQL_FIELD* fields = mysql_fetch_fields(m_myres);
  // and make these available to client, especially for select * queries
} // namespace rdbModel