#include <stdio.h>

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <windows.h>
#include <mysql.h>
#include "sqllib.h"

char errmsg[1000];

MYSQLCONN conn[SQL_COMMANDS];

/*******************************************************************/
/* miscellaneous support routines (error handling etc) */
/*******************************************************************/

void output_error(int sql_num) {
sprintf(errmsg,"Error %u (%s)",
mysql_errno(&conn[sql_num].mysql),
mysql_error(&conn[sql_num].mysql));
printf("%s\n", errmsg);
}

/*******************************************************************/
/* sql connect */
/*******************************************************************/

int sql_connect(int sql_num, char *host, char *user, char *passwd) {
/* check not already connected? */
if (conn[sql_num].connected) {
printf("sql connect; already connected.");
return 0;
}
if (! (mysql_connect(&conn[sql_num].mysql, host, user, passwd))) {
output_error(sql_num);
return 0;
} else {
conn[sql_num].connected = 1;
return 1;
}
}

int sql_disconnect(int sql_num) {
/* check that we are connected? */
if (! conn[sql_num].connected) {
printf("sql disconnect; not connected.");
return 0;
}
mysql_close(&conn[sql_num].mysql);
conn[sql_num].connected = 0;
return 1;
}

/*******************************************************************/
/* sql general commands */
/*******************************************************************/

int sql_selectdb(int sql_num, char *database) {
/* check that we are connected to a mysql server */
if (!conn[sql_num].connected) {
printf("sql query statement; you are not connected to a mysql server yet (sql connect).");
return 0;
}

if (mysql_select_db(&conn[sql_num].mysql, database)) {
output_error(sql_num);
return 0;
} else {
return 1;
}
}

/*******************************************************************/
/* sql query command */
/*******************************************************************/

int sql_query(int sql_num, char *query) {
if (! conn[sql_num].connected) {
printf("sql query statement; you are not connected to a mysql server yet");
return 0;
}

/* check there is no other active query? */
if (conn[sql_num].qflag) {
printf("Another query cannot be made until the current query has been finished with \"sql endquery\".");
return 0;
}

/* execute the sql query statement */
if (mysql_query(&conn[sql_num].mysql, query)) {
output_error(sql_num);
return 0;
}

conn[sql_num].result = mysql_use_result(&conn[sql_num].mysql);
conn[sql_num].nfields = mysql_field_count(&conn[sql_num].mysql);

/* if no results were found and none expected then all ok */
/* otherwise we assume the query worked ok, now get the results */
if (conn[sql_num].result == NULL) {
if (conn[sql_num].nfields) {
output_error(sql_num);
return 0;
}
// show_msg("sql startquery; query executed ok but returned no results.");
return 1;
}

/* return all ok now, see fetchrow & endquery for more details */
conn[sql_num].qflag = 1;
return 1;
}

MYSQL_FIELD *sql_fetchfield(int sql_num)
{
/* check we are connected? */
if (! conn[sql_num].connected) {
printf("Not connected to a server.");
return NULL;
}
/* check we had a query started? */
if (! conn[sql_num].qflag) {
printf("No query has been started.");
return NULL;
}
return mysql_fetch_field(conn[sql_num].result);
}

MYSQL_ROW sql_fetchrow(int sql_num)
{
/* check we are connected? */
if (! conn[sql_num].connected) {
printf("Not connected to a server.");
return NULL;
}
/* check we had a query started? */
if (! conn[sql_num].qflag) {
printf("No query has been started.");
return NULL;
}
return mysql_fetch_row(conn[sql_num].result);
}

int sql_endquery(int sql_num) {
/* check we are connected? */
if (! conn[sql_num].connected) {
printf("Not connected to a server.");
return 0;
}

/* check we had a query started? */
if (! conn[sql_num].qflag) {
printf("No query has been started.");
return 0;
}

mysql_free_result(conn[sql_num].result);
conn[sql_num].qflag = 0;
return 1;
}