#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include "include/mysql.h"

int main(int argc, char *argv[])
{
        MYSQL* mysqlInitStruct = NULL;
        MYSQL_RES* mysqlRes = NULL;
        MYSQL_ROW res;
        char* mysqlErrorText;
        size_t counter = 0;

        if ( (mysqlInitStruct = mysql_init( NULL )) == NULL )
                exit(1);
        if ( mysql_real_connect( mysqlInitStruct, "127.0.0.1", "root", "",
"test", 10070, NULL, 0) == NULL )
        {
	  printf("%s\n", mysql_error(mysqlInitStruct));
                exit(2);
        }
        if( mysql_query(mysqlInitStruct, "select * from t1") )
        {
	  printf("%s\n", mysql_error(mysqlInitStruct));
                exit(3);
        }

        mysqlRes = mysql_use_result( mysqlInitStruct ) ;
        //         ^^^^^ Change this to mysql_store_result
        // mysqlRes = mysql_store_result( mysqlInitStruct ) ;

        for ( counter=0 ; res != NULL ; counter++ )
        {
          usleep(125000);
                if ( (res=mysql_fetch_row( mysqlRes )) == NULL )
                {
                        if(mysql_errno(mysqlInitStruct))
                        {
                                // an error occurred
                                mysqlErrorText = 
strdup(mysql_error(mysqlInitStruct));
                                printf("Error: %s\n",mysqlErrorText);
                                printf("Counter: %lu\n",counter);
                                mysql_free_result( mysqlRes );
                                mysql_close( mysqlInitStruct );
                                exit(4);
                        }
                        else
                        {
                                mysql_free_result( mysqlRes );
                                mysql_close( mysqlInitStruct );
                                printf("Counter: %lu\n",counter);
                                exit(0);
                        }
                }
                printf("Counter: %lu\n",counter);
        }

        mysql_free_result( mysqlRes );
        mysql_close( mysqlInitStruct );

        exit(5);
}