Code: Select all

void LastCandle()   
   {
     Print("Last candle");
           string query =StringConcatenate("Select concat ('->',concat_ws ('->',CAST(MQLTime as char))) from eurusd_m1 ORDER BY MQLTime DESC LIMIT 1;"); // take the first candle latest DB
     Print("query = ",query);
       
       int row="";
       string ultimacandela="";
       int length = 0;
       
       uchar queryChar[];
       StringToCharArray(query, queryChar);
       
       length = StringLen (query);
       mysql_real_query (dbConnectId, queryChar, length);
  
       int myerr = mysql_errno (dbConnectId);
       if (myerr> 0)
           Print ("error =", myerr);

       int result = mysql_store_result (dbConnectId);
       Print("result=",result);
       int numOfRows = mysql_num_rows (result);
       Print("numrows=",numOfRows);
       if (numOfRows> 0)
       {
             row = mysql_fetch_row (result);
             Print("row=",row);
             row = mql4_mysql_ansi2unicode(row);
             Print("ansiiRow=",row);
             row = StringTrimLeft(row);
             Print("TrimmedANSI=",row);
             row = StringSubstr(row,8,80);
             Print("row2 = ",row);
      } 
      mysql_free_result (result);
      return;
    }

Code: Select all

             row = mql4_mysql_ansi2unicode(row);

Code: Select all

ArrayResize(data, num_rows);
    
    for ( int i = 0; i < num_rows; i++ ) {
    
      int row_ptr = mysql_fetch_row(resultStruct);
      int len_ptr = mysql_fetch_lengths(resultStruct);
      
      for ( int j = 0; j < num_fields; j++ ) {
         int leng;
         memcpy(leng, len_ptr + j*sizeof(int), sizeof(int));
         
         ArrayResize(byte,leng+1);
         ArrayInitialize(byte,0);
         
         int row_ptr_pos;
         memcpy(row_ptr_pos, row_ptr + j*sizeof(int), sizeof(int));
         memcpy(byte, row_ptr_pos, leng);
         
         string s = CharArrayToString(byte);
         data[i][j] = s;
         
         LocalFree(leng);
         LocalFree(row_ptr_pos);
      }
    }

Code: Select all

void MySQLConnect(){
goodConnect = init_MySQL(dbConnectId, host, user, pass, "", port, socket, client);    
   if (goodConnect) 
    Print("Good connection; ID=",dbConnectId);
   else
    {Print("Shite Connection");
    return;} // bad connect
    
    
    string dbquery=StringConcatenate("use ",dbName,";");
    MySQL_Query(dbConnectId, dbquery);
        Print("DB " ,dbName," found and connected");
    mysql_select_db (dbConnectId, dbName);  //select the db for future operations
    int myerr = mysql_errno (dbConnectId); // note the presence of errors
    if (myerr> 0)
        Print ("errore =", myerr); // record errors in log
   }

Code: Select all

void GetData() {

/*   dbConnectId = MySqlConnect (host, user, pass, dbName, port, socket, client);
   
   if (dbConnectId <0) {
      Print("Connection failed; error = ",MySqlErrorDescription);
      return;}
   else {
      Print ("Connected as ", dbConnectId); }*/
////////////////////////////////////////////////////////////////////////////      
   string query;
   int i, Cursor, Rows;
   
   int vId;
   string vCode;
   datetime vStartTime;
   
   query = "select MQLTime, RTime, High from eurusd_m1 order by MQLTime desc limit 1";
      Print ("SQL > ", query);
   Cursor = MySqlCursorOpen(dbConnectId, query);
////////////////////////////////////////////////////////////////////////////
   if (Cursor >= 1) {
      Rows = MySqlCursorRows(Cursor);
         Print (Rows, " row(s) selected");
      for (i = 0; i < Rows; i++)
         if (MySqlCursorFetchRow(Cursor)) {           
            vStartTime = MySqlGetFieldAsDatetime(Cursor, 0);      //MQLTime
            vCode = MySqlGetFieldAsString(Cursor, 1);    //RTime
            vId = MySqlGetFieldAsInt(Cursor, 2);      //High
            Print ("Row[",i,"]: id = ",vId, ", code = ", vCode, ", start_time = ", TimeToString(vStartTime, TIME_DATE|TIME_SECONDS)); }
        
         MySqlCursorClose(Cursor); }
      else {
         Print("Cursor close failed; error = ",MySqlErrorDescription); }
////////////////////////////////////////////////////////////////////////////
   MySqlDisconnect(dbConnectId);
   Print("Disconnected biatch");
}

Code: Select all

#property strict

#import "libmysql.dll"

#include<MQLMySQL.mqh>
#include<mql4-mysql.mqh>

extern string  Host     = "127.0.0.1";
extern string  User     = "root";
extern string  Password     = "password";
extern string  Database   = "mt76";       
extern string  Socket   = "";

extern int     Port     = 3306;
extern int     ClientFlag   = 0;

extern int    DB = 0;
extern bool   goodConnect=false;
//+------------------------------------------------------------------+
//| Expert initialization function                                   |
//+------------------------------------------------------------------+
int OnInit()
  {
//---
   mysqlconnect();
   GetData();
//---
   return(INIT_SUCCEEDED);
  }
//+------------------------------------------------------------------+
//| Expert deinitialization function                                 |
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
  {
//---
   
  }
//+------------------------------------------------------------------+
//| Expert tick function                                             |
//+------------------------------------------------------------------+
void OnTick()
  {
//---
   
  }
//+------------------------------------------------------------------+
void mysqlconnect(){
   Print ("Connecting...");

   DB = MySqlConnect(Host, User, Password, Database, Port, Socket, ClientFlag);    
   
   if (DB == -1) { Print ("Connection failed! Error: "+MySqlErrorDescription); } 
   else { 
   Print ("Connected! DBID#",DB);}
}
////////////////////////////////////////////////////////////////////////////
void GetData() {

   string query;
   int i, Cursor, Rows;
   
   double high;
   string RTime;
   datetime MQLTime;
   
   query = "select * from `eurusd_m1` order by MQLTime desc limit 1;";
      Print ("SQL > ", query);
   Cursor = MySqlCursorOpen(DB, query);
////////////////////////////////////////////////////////////////////////////
   if (Cursor >= 0) {
      Rows = MySqlCursorRows(Cursor);
         Print (Rows, " row(s) selected");
      for (i = 0; i < Rows; i++)
         if (MySqlCursorFetchRow(Cursor)) {           
            MQLTime = MySqlGetFieldAsDatetime(Cursor, 0);      //MQLTime
            RTime = MySqlGetFieldAsString(Cursor, 1);    //RTime
            high = MySqlGetFieldAsDouble(Cursor, 2);      //High
            Print ("Row[",i,"]: High = ",high, ", R_time = ", RTime, ", MQL_time = ", TimeToString(MQLTime, TIME_DATE|TIME_SECONDS)); }
        
         MySqlCursorClose(Cursor); }
      else {
         Print("Cursor close failed; error = ",MySqlErrorDescription); }
////////////////////////////////////////////////////////////////////////////
   MySqlDisconnect(DB);
   Print("Disconnected biatch");
}