FiveTech Support Forums

/* 
 * Fichero: tmysql.prg
 * Descripcion: Clase para acceder a Mysql desde FWPCC
 * Autor: Pablo Alberto Vidal
 * Fecha: 26/10/2009
*/

#include "FWCE.ch"

Class tMySql

 Data cHost     Init "localhost"
 Data nPuerto   Init 3306
 Data cUsuario  Init "root"
 Data cPassword Init ""
 Data cDataBase Init "test"

   Method Conectar()
   Method MsQuery( cQuery ) // Ejecuta un sentencia y devuelve un Array con los datos
   Method MsCommand( cQuery )  // Ejecuta un comando SQL y devuelve .T. o .f.
   Method End() InLine  MySQL_Disconnect()

EndClass

// Conectar a la Base de Datos
Method Conectar() Class tMysql
Local lOk := .F.

If ( MySQL_Connect( ::cHost, ::nPuerto, ::cUsuario, ::cPassword ) == 0 )
  If ( MySQL_Select_DB( ::cDataBase ) == 0 )
   lOk := .T.
  EndIf
EndIf

Return( lOk )

// Ejecuta un comando
Method MsCommand( cQuery )
Local lOk := .F.
 If( MySQL_Execute_Query( cQuery ) == 0 )
  lOk := .T.
 EndIf
Return( lOk )

//Devuelve un array de datos
Method MsQuery( cQuery )
Local aData       := {}
Local nField       := 0
Local nRow        := 0
Local cFieldValue := ""
Local nRet        := 0

  nRet := MySQL_Execute_Query( cQuery )
  If nRet != 0
   MsgInfo( MySQL_Get_Last_Error( nRet ) )
   Return( {} )
  endif

  aData := Array( MySQL_Get_RowCount() )
  For nRow := 1 to MySQL_Get_RowCount()
   aData[nRow] := Array( MySQL_Get_FieldCount() )
   For nField := 1 to MySQL_Get_FieldCount()
    nRet := MySQL_Get_Data( @cFieldValue, nRow, nField )
    If( nRet != 0, MsgInfo( MySQL_Get_Last_Error( nRet ) ),;
     aData[nRow][nField] := AllTrim( Upper( cFieldValue ) ) )
   Next
  Next

Return( aData )


// Codigo C tomado del foro y Escrito por
// Antonio Linares

#pragma BEGINDUMP

// field parameters for mysql_get_field_param() function
#define FIELD_PARAM_CATALOG              1
#define FIELD_PARAM_DB                   2
#define FIELD_PARAM_TABLE                3
#define FIELD_PARAM_ORIGTABLE            4
#define FIELD_PARAM_FIELD                5
#define FIELD_PARAM_ORIGFIELD            6
#define FIELD_PARAM_LENGTH               7
#define FIELD_PARAM_TYPE                 8
#define FIELD_PARAM_FLAGS                9
#define FIELD_PARAM_DECIMALS            10

int  mysql_connect( char * host, int iPort, char * pszUsername, char * pszPassword );
void mysql_get_last_error( int nErrorCode, char * pszError );
int  mysql_disconnect( void );
int  mysql_select_db( char * pszDatabaseName );
int  mysql_execute_query( char * pszQueryString );
int  mysql_get_fieldcount( void );
int  mysql_get_field( char * char_val, int * int_val, int nParam, int nIndex );
int  mysql_get_rowcount( void );
int  mysql_get_data( char * pszElem, int nRow, int nColumn );

#include <hbapi.h>

HB_FUNC( MYSQL_CONNECT ) // cHost, nPort, cUserName, cPassword
{
   hb_retnl( mysql_connect( hb_parc( 1 ), hb_parnl( 2 ), hb_parc( 3 ), hb_parc( 4 ) ) );
}

HB_FUNC( MYSQL_GET_LAST_ERROR ) // nCode --> cError
{
   char error[ 255 ];

   mysql_get_last_error( hb_parnl( 1 ), error );

   hb_retc( error );
}

HB_FUNC( MYSQL_DISCONNECT )
{
   mysql_disconnect();
}

HB_FUNC( MYSQL_SELECT_DB ) // cDataBaseName --> nRet
{
   hb_retnl( mysql_select_db( hb_parc( 1 ) ) );
}

HB_FUNC( MYSQL_EXECUTE_QUERY ) // cSQLQuery --> nRet
{
   hb_retnl( mysql_execute_query( hb_parc( 1 ) ) );
}

HB_FUNC( MYSQL_GET_FIELDCOUNT ) // --> nFields
{
   hb_retnl( mysql_get_fieldcount() );
}

HB_FUNC( MYSQL_GET_FIELD ) // nField, @cName --> nRet
{
   char fieldname[ 255 ];
   int int_buffer;

   hb_retnl( mysql_get_field( fieldname, &int_buffer, FIELD_PARAM_FIELD, hb_parnl( 1 ) - 1 ) );
   hb_storc( fieldname, 2 );
}

HB_FUNC( MYSQL_GET_ROWCOUNT ) // --> nRows
{
   hb_retnl( mysql_get_rowcount() );
}

HB_FUNC( MYSQL_GET_DATA ) // @cFieldData, nRow, nField --> nRet
{
   char buffer[ 8192 ]; // max data size = 8K

   hb_retnl( mysql_get_data( buffer, hb_parnl( 2 ) - 1, hb_parnl( 3 ) - 1 ) );
   hb_storc( buffer, 1 );
}

#pragma ENDDUMP