/*
 *    The headers need to be added here
 */

#include "include.h"
#include <mysql.h>


/*
 *  Here, there need to be externs to a NEW variable set in merc.h, to check and see if the
 *  mySQL server is open for connections. And a way to check to see if the mysql server is
 *  up and running at any one time.
 *  The variable would be named like: bool sql_on, if it's true, then it works, if it's 
 *  false, then it's not working
 *  Also, there needs to be a variable in the directories include to tell which code we're
 *  running.
 *  Now, here's the functions and how to use them
 *  sql_connect: this is the raw entrance, don't worry too much about it
 *  sql_disconnect: closes connection
 *  boot_database, void function to start the mysql thread
 *  connect_ping: not sure, it was from jason's code, seems useful
 *  sql_parse: parses a value to allow for special characters.
 *  sql_status: returns sql status as a string
 *  
 *  This is the update of an integer field
 *  void sql_update_int(table name,field name,table key name,integer value,row id)
 *
 *  This is the update of a character field
 *  void sql_update_char(table name,field name,table key name,character string,row id)
 *  
 *  This inserts a new row into a table:
 *  void sql_insert_row(table name,table key field,row)
 *
 *  This removes a row from a table:
 *  void sql_delete_row(table name,table key field,row id)
 *
 *  This is the counting routine for locating how many rows are in a table
 *  int sql_count_table(table name,table key)
 * 
 *  This counts the number of returned matches for a search
 *  int sql_count_search_field(table name,field to search,the match string)
 *
 *  This returns the value of an integer
 *  char sql_search_int_field(table name,field name,search number,table key,the match number to return)
 *
 *  This requires an example: 
 *  sql_search_int_field(players,age,17,p_id,2) 
 *  would return the second match (it starts at 1 and goes to the number of return searches)
 *
 *  Same as above, cept returns char value
 *  char sql_search_char_field(table,field,search string,key,match number)
 *
 *  This replaces the char value of a field, with the new string
 *  void sql_update_char_field(table,field,new string,table key,row id)
 *
 *  This replaces the int value of a field, with the new int
 *  void sql_update_int_field(table,field,new integer,table key,row id)
 *
 *  This is the retrieve command for integers
 *  int sql_get_int_field(table,field,table key,row id)
 *
 *  This is the retrieve command for strings
 *  char sql_get_int_field(table,field,table key,row id)
*/

MYSQL * sql_connect( void )
{
    	MYSQL *conn; /* pointer to connection handler */
	char stderr[MSL];
	char buf[MSL];
	
	conn = mysql_init (NULL); /* allocate, initialize connection handler */
	
	if (conn == NULL) 
	{
		sprintf(stderr,"mysql_init() failed (probably out of memory)\r\n");
		log_string(stderr);
		return (NULL);
	}
	
	if (mysql_real_connect (conn, db_host, db_user, db_pass,
		db_name, 0, NULL, 0) == NULL) 
	{
		sprintf(stderr,"mysql_real_connect() failed:\r\nError %u (%s)\r\n",
			mysql_errno (conn), mysql_error (conn));
		log_string(stderr);
		return (NULL);
	}

	sprintf(buf,"MySQL: Connected to the sql server [Thread: %ld]",	mysql_thread_id(conn));
	log_string(buf);

	return (conn);
}

void sql_disconnect(MYSQL *conn)
{
	mysql_close(conn);

	log_string("Disconnected from the sql server.");
}

MYSQL   	*conn;
MYSQL_RES  *res_set;

bool sql_ping(void)
{
	if (conn == NULL)
	{
		log_string("MySQL: Ping.");
		mysql_ping(conn);
		return TRUE;
	}
	
	return FALSE;
}

char *sql_parse(char *name)
{
   char *buf;

	buf = NULL;
	(void) mysql_escape_string (buf, name, strlen(name));
	return buf;
}

void sql_update_char(char *table, char *field,char *key, char *value, long id)
{
   char buf[MSL];

	sprintf(buf, "UPDATE %s SET %s='%s' WHERE %s=%ld",table,field,sql_parse(value),key, id);
	mysql_query(conn, buf);
	return;

}

void sql_update_int(char *table,char *field,char *key, int value, long id)
{
   char buf[MSL];
	sprintf(buf, "UPDATE %s SET %s=%d WHERE %s=%ld",table,field,value,key,id);
	mysql_query(conn, buf);
	return;
}

void sql_insert_row(char *table, char *key, long id)
{
    char buf[MSL];
        sprintf(buf,"INSERT INTO %s (%s) VALUES(%ld)",table,key,id);
        mysql_query(conn,buf);
}

void sql_delete_row(char *table, char *key, long id)
{
    char buf[MSL];
        sprintf(buf,"DELETE FROM %s WHERE %s=%ld",table,key,id);
        mysql_query(conn,buf);
}

int sql_count_table(char *table, char *key)
{
    char buf[MSL];

    int count;
    sprintf(buf,"SELECT COUNT(%s) FROM %s",key,table);
    mysql_query(conn,buf);
    res_set = mysql_store_result(conn);
    count = mysql_num_rows(res_set);
    mysql_free_result(res_set);
    return count;

}
int sql_count_search_field(char *table, char *field, char *search, char *key)
{
    char buf[MSL];

    int count;
    sprintf(buf,"SELECT COUNT(%s) FROM %s WHERE %s='%s'",key,table,field,sql_parse(search));
    mysql_query(conn,buf);
    res_set = mysql_store_result(conn);
    count = mysql_num_rows(res_set);
    mysql_free_result(res_set);
    return count;

}

int sql_search_int_field(char *table, char *field, char *value, char *key, int place)
{
    MYSQL_ROW row;
    char buf[MSL];

    int result;
    int total = 0;
    int i;
    if (place > total)
        place = total;
    if (place < 1)
        place = 1;
    place--;
    sprintf(buf,"SELECT %s FROM %s WHERE %s='%s' ORDER BY %s",field,table,field,sql_parse(value),key);
    mysql_query(conn,buf);
    res_set = mysql_store_result(conn);
    total = mysql_num_rows(res_set);
    for(i = 0; i < total; i++) {
        row = mysql_fetch_row (res_set);
        if (i == place)
            sprintf(buf,"%s",row[0]);
    }
    mysql_free_result(res_set);
    if (!buf)
        sprintf(buf,"0");
    result = atoi(buf);
    return result;
}

char *sql_search_char_field(char *table, char *field, char *value, char *key, int place)
{
    MYSQL_ROW row;
    char buf[MSL];
    char *result = '\0';
    int total = 0;
    int i;

    if (place > total)
        place = total;
    if (place < 1)
        place = 1;
    place--;
    sprintf(buf,"SELECT %s FROM %s WHERE %s='%s' ORDER BY %s",field,table,field,key,sql_parse(value));
    mysql_query(conn,buf);
    res_set = mysql_store_result(conn);
    total = mysql_num_rows(res_set);
    for(i = 0; i < total; i++) {
        row = mysql_fetch_row (res_set);
        if (i == place)
            sprintf(result,"%s",row[0]);
    }
    mysql_free_result(res_set);
    return result;
}

void sql_update_char_field(char *table, char *field, char *value, char *key, long id)
{
    char buf[MSL];

	sprintf(buf, "UPDATE %s SET %s='%s' WHERE %s='%ld'",table, field,sql_parse(value),key,id);
	mysql_query(conn,buf);
	return;
}
void sql_update_int_field(char *table, char *field, int value, char *key, long id)
{
    char buf[MSL];

    sprintf(buf, "UPDATE %s SET %s='%d' WHERE %s='%ld'",table, field,value,key,id);
    mysql_query(conn,buf);
    return;
}

int sql_get_int_field(char *table, char *field, char *key, long id)
{
    MYSQL_ROW row;
    char buf[MSL];

	int ret;
	
	sprintf(buf, "SELECT %s FROM %s WHERE %s=%ld",table,field,key,id);
	mysql_query(conn,buf);
	res_set = mysql_store_result(conn);
	row = mysql_fetch_row(res_set);
	ret = atoi(row[0]);
	mysql_free_result(res_set);
	return (ret);

}

char *sql_get_char_field(char *table, char *field, char *key, long id)
{
    char buf[MSL];
    MYSQL_ROW row;

	char *ret;
	
	sprintf(buf, "SELECT %s FROM %s WHERE %s=%ld",table,field,key,id);
	mysql_query(conn, buf);
	res_set = mysql_store_result(conn);
	row = mysql_fetch_row(res_set);
	if (row[0] != NULL) {
		ret = str_dup(row[0]);
	} else {
	ret = "NULL";
	}
	
	mysql_free_result(res_set);
	
	return ret;
}

char *sql_status( void )
{
	if (conn == NULL)
		return "No Connection";


	return mysql_stat(conn);
}

/* In progress
bool sql_player_full( CHAR_DATA *ch )
{
    if ( !sql_player_save(ch) )
	return;

    if ( !sql_clan_update(ch) )
	return;




bool sql_player_save( CHAR_DATA *ch )
{
    if (conn == NULL)
	return FALSE;

    
*/