Asynchronous mysql queries

[Whiskas]

I am using libcod from 29.01.15 -> http://killtube.org/downloads/libcod/2015_01_29/ To get newer libcod I should compile it myself?

		init()
{
    //get your host, user, pass, db, port here
    level.JH_mysql = mysql_reuse_connection();
    if(!isDefined(level.JH_mysql))
        level.JH_mysql = initMySQL("ip", "user", "password", "db", 3306);
    initAsyncMySQL("ip", "user", "password", "db", 3306);
}

query(query)
{
    if(!isDefined(level.JH_mysql))
        return undefined;
    result = mysql_query(level.JH_mysql, query);
    resettimeout();
    if(result)
    {
        printf("Error in " + query + "\n");
        return undefined;
    }
    result = mysql_store_result(level.JH_mysql);
    rows = getRows(result);
    return rows;
}

queryNosave(query)
{
    if(!isDefined(level.JH_mysql))
        return undefined;
    result = mysql_query(level.JH_mysql, query);
    resettimeout();
    if(result)
    {
        printf("Error in " + query + "\n");
        return undefined;
    }
    return [];
}

getRows(result)
{
    if(!isDefined(result))
        return [];
    rowcount = mysql_num_rows(result);
    fields = [];
    field = mysql_fetch_field(result);
    while(isDefined(field))
    {
        fields[fields.size] = field;
        field = mysql_fetch_field(result);
    }
    rows = [];
    for(i = 0; i < rowcount; i++)
    {
        row = mysql_fetch_row(result);
        rows[rows.size] = [];
        for(j = 0; j < fields.size; j++)
            rows[rows.size - 1][fields[j]] = row[j];
    }
    mysql_free_result(result);
    return rows;
}

asyncQuery(query, function, args)
{
    id = mysql_async_create_Query(query);
    task = spawnstruct();
    task.query = query;
    task.invoker = self;
    task.function = function;
    task.args = args;
    level.JH_mysqlAsync["" + id] = task;
}

asyncQueryNosave(query, function, args)
{
    id = mysql_async_create_Query_Nosave(query);
    task = spawnstruct();
    task.query = query;
    task.invoker = self;
    task.function = function;
    task.args = args;
    level.JH_mysqlAsync["" + id] = task;
}

initAsyncMySQL(host, user, pass, db, port)
{
    mysql_async_initializer(host, user, pass, db, port, 4);
    level.JH_mysqlAsync = [];
    thread loopAsyncMySQL();
}

loopAsyncMySQL()
{
    while(true)
    {
        list = mysql_async_GetDone_List();
        for(i = 0; i < list.size; i++)
        {
            result = mysql_async_getresult_and_free(list[i]);
            if(!isdefined(result))
                continue;
            if(result == 0)
                result = undefined;
            task = "" + list[i];
            if(isDefined(level.JH_mysqlAsync[task]))
            {
                if(isDefined(level.JH_mysqlAsync[task].function))
                {
                    if(isDefined(level.JH_mysqlAsync[task].invoker))
                    {
                        rows = getRows(result);
                        level.JH_mysqlAsync[task].invoker thread [[level.JH_mysqlAsync[task].function]](rows, level.JH_mysqlAsync[task].args);
                    }
                    else if(isDefined(result))
                        mysql_free_result(result);
                }
                else if(isDefined(result))
                    mysql_free_result(result);
            }
            else if(isDefined(result))
                mysql_free_result(result);
            level.JH_mysqlAsync[task] = undefined;
        }
        wait .05;
    }
}

initMySQL(host, user, pass, db, port)
{
    mysql = mysql_init();
    ret = mysql_real_connect(mysql, host, user, pass, db, port);
    if(!ret)
    {
        printf("errno=" + mysql_errno(mysql) + " error= " + mysql_error(mysql) + "\n");
        mysql_close(mysql);
        return undefined;
    }
    return mysql;
}
stripString(string)
{
    if(isDefined(level.JH_mysql))
        return mysql_real_escape_string(level.JH_mysql, string);
    return "";
} 
	

Saved this as _mysql.gsc then in tdm.gsc added

		thread maps\mp\gametypes\_mysql::init(); 
	

in Callback_StartGameType().

Had problems with few undeclared functions :

		id = mysql_async_createQueryNosave(query); 
	

		 id = mysql_async_createQuery(query); 
	

		result = mysql_async_getResultAndFree 
	

So I used these from documentation https://znation.nl/cod4script/ .