// CustResultSet.cpp: implementation of the CCustResultSet class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "OilTrans.h"
#include "CustResultSet.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CCustResultSet::CCustResultSet()
{
    m_iRecordNum = 0;
}

CCustResultSet::~CCustResultSet()
{

}

BOOL CCustResultSet::Next()
{
	if ( m_rRow = mysql_fetch_row( m_rResult ) ){
		for (int  k = 0 ; k < m_iRecordNum ; k++ )
		{
		   m_cTemp[k][1] = m_rRow[k];			
		}
		return TRUE;
    }
	return FALSE;
}
void CCustResultSet::SetRes(MYSQL_RES *res)
{
  
  m_rResult =  res ;
  m_iRecordNum = mysql_num_fields( m_rResult ) ;
  if((int) mysql_num_rows( res )>0) m_bNULL = FALSE;
  for (int x = 0 ; m_rField = mysql_fetch_field( m_rResult ) ; x++ ){
	  m_cTemp[x][0]=m_rField->name;
                
  }
   
}

float CCustResultSet::GetFloat(CString str)
{
    
  for (int  k = 0 ; k < m_iRecordNum ; k++ )
  {
	  if(str.Compare(m_cTemp[k][0]) ==0)
	  {
		  
		 return (float)atof(m_cTemp[k][1]);
	  }			
  }
  return 0;
}

int CCustResultSet::GetInt(CString str)
{
  for (int  k = 0 ; k < m_iRecordNum ; k++ )
  {
	  if(str.Compare(m_cTemp[k][0]) ==0)
	  {  
		 return (int)atoi(m_cTemp[k][1]);
	  }			
  }
  return 0;
}

double CCustResultSet::GetDouble(CString str)
{
  for (int  k = 0 ; k < m_iRecordNum ; k++ )
  {
	  if(str.Compare(m_cTemp[k][0]) ==0)
	  {
		 //AfxMessageBox(m_cTemp[k][1]);
		 return atof(m_cTemp[k][1]);
	  }			
  }
  return 0.0;
}

CString CCustResultSet::GetString(CString str)
{
  CString temp = "";
  for (int  k = 0 ; k < m_iRecordNum ; k++ )
  {
	  if(str.Compare(m_cTemp[k][0]) ==0)
	  {
		 temp.Format("%s",m_cTemp[k][1]);
		 return temp;
	  }			
  }
  return "ERROR";
}
void CCustResultSet::First()
{
  int t =  mysql_num_fields(m_rResult);
  mysql_data_seek(m_rResult,t);
}