diff --git a/src/db_mysql.c b/src/db_mysql.c index 0c1484d..12b19a2 100644 --- a/src/db_mysql.c +++ b/src/db_mysql.c @@ -43,7 +43,7 @@ int db_init() return 0; } -int db_get_dumps(char *user_id, char **user_dump, char **session_dump) +int db_get_dumps(char *user_id, char **identity_dump, char **session_dump) { MYSQL_RES *res; MYSQL_ROW row; @@ -51,7 +51,7 @@ int db_get_dumps(char *user_id, char **user_dump, char **session_dump) int rc; snprintf(query, 500, - "select user_dump, session_dump from users where user_id = '%s'", + "select identity_dump, session_dump from users where user_id = '%s'", user_id); if (mysql_query(sqlconn, query)) { return 1; @@ -59,12 +59,12 @@ int db_get_dumps(char *user_id, char **user_dump, char **session_dump) res = mysql_store_result(sqlconn); if (mysql_num_rows(res) == 0) { mysql_free_result(res); - *user_dump = NULL; + *identity_dump = NULL; *session_dump = NULL; return 0; } row = mysql_fetch_row(res); - *user_dump = strdup(row[0]); + *identity_dump = strdup(row[0]); *session_dump = strdup(row[1]); mysql_free_result(res); return 0; @@ -112,7 +112,7 @@ int db_save_identity(char *user_id, char *identity_dump) query = malloc(500 + strlen(identity_dump)); snprintf(query, 500 + strlen(identity_dump), - "UPDATE users SET user_dump = '%s' where user_id = '%s'", + "UPDATE users SET identity_dump = '%s' where user_id = '%s'", identity_dump, user_id); if (mysql_query(sqlconn, query)) { diff --git a/src/db_postgresql.c b/src/db_postgresql.c index 6b789f3..8cec1f5 100644 --- a/src/db_postgresql.c +++ b/src/db_postgresql.c @@ -45,7 +45,7 @@ int db_init() return 0; } -int db_get_dumps(char *user_id, char **user_dump, char **session_dump) +int db_get_dumps(char *user_id, char **identity_dump, char **session_dump) { PGresult *res; const char *params[1]; @@ -53,16 +53,16 @@ int db_get_dumps(char *user_id, char **user_dump, char **session_dump) params[0] = user_id; res = PQexecParams(sqlconn, - "SELECT user_dump, session_dump FROM users where user_id = $1", + "SELECT identity_dump, session_dump FROM users where user_id = $1", 1, NULL, params, NULL, NULL, 1); if (PQresultStatus(res) != PGRES_TUPLES_OK || PQntuples(res) == 0) { /* error or no tuple for this nameidentifier */ PQclear(res); - *user_dump = NULL; + *identity_dump = NULL; *session_dump = NULL; return 0; } - *user_dump = strdup(PQgetvalue(res, 0, 0)); + *identity_dump = strdup(PQgetvalue(res, 0, 0)); *session_dump = strdup(PQgetvalue(res, 0, 1)); PQclear(res); return 0; @@ -121,7 +121,7 @@ int db_save_identity(char *user_id, char *identity_dump) params[0] = identity_dump; params[1] = user_id; res = PQexecParams(sqlconn, - "UPDATE users SET user_dump = $1 where user_id = $2", + "UPDATE users SET identity_dump = $1 where user_id = $2", 2, NULL, params, NULL, NULL, 1); if (PQresultStatus(res) != PGRES_COMMAND_OK) { PQclear(res);