diff --git a/src/server/mysql.h b/src/server/mysql.h
--- a/src/server/mysql.h
+++ b/src/server/mysql.h
@@ -22,10 +22,12 @@
 #ifndef MYSQL_H_
 #define MYSQL_H_
 
-struct distrend_mysql_con;
+#include <stdint.h>
+
+struct distrend_mysql_conn;
 struct distrend_mysql_result;
 
-typedef struct distrend_mysql_con *distrend_mysql_con_t;
+typedef struct distrend_mysql_conn *distrend_mysql_conn_t;
 typedef struct distrend_mysql_result *distrend_mysql_result_t;
 
 /**
@@ -33,27 +35,20 @@ typedef struct distrend_mysql_result *di
    @param conn, pointer will be set to the struct
    @return 0 on success
  */
-int mysqlConnect(distrend_mysql_con_t *conn);
+int mysqlConnect(distrend_mysql_conn_t *conn);
 
 /**
    cleans and disconnects MySQL connection
    @param conn connection to clean
    @return 0 on success
 */
-int mysqlDisconnect(distrend_mysql_con_t conn);
+int mysqlDisconnect(distrend_mysql_conn_t conn);
 
 /**
-   performs mysql query.
-   errors will be logged to the user by this function.
-   @return pointer to query handle on success, NULL on failure
+   Mark a frame as finished in the database.
  */
-distrend_mysql_result_t mysqlQuery(struct distrend_mysql_con *conn, char *query);
+void finish_frame(distrend_mysql_conn_t conn, int32_t jobkey, int32_t framenum);
 
-/**
-   frees mysql query result.
-   @return 0 on success
- */
-int mysqlResultFree(distrend_mysql_result_t result);
 
 
 /** Import */