diff --git a/src/server/mysql.c b/src/server/mysql.c --- a/src/server/mysql.c +++ b/src/server/mysql.c @@ -53,6 +53,16 @@ distrend_mysql_result_t mysqlQuery(distr */ int mysqlResultFree(distrend_mysql_result_t result); +/** + reads an integer mysql field value + @return 0 on success +*/ +int distrend_mysql_getint(MYSQL_ROW row, MYSQL_FIELD_OFFSET column, int32_t *theint) +{ + *theint = atol(row[column]); + + return 0; +} struct distrend_mysql_conn @@ -228,14 +238,13 @@ int find_jobframe(distrend_mysql_conn_t if(!result) return 1; - if ((row = mysql_fetch_row(res)) != NULL) - { - jobkey = row[1]; - framenum = row[2]; - } - else - return 1; + row = mysql_fetch_row(result->mysqlresult); + if(!row) + return 1; + distrend_mysql_getint(row, 1, &jobkey); + distrend_mysql_getint(row, 2, &framenum); + mysqlResultFree(result); return 0;