Skip to content

Commit

Permalink
mxq_mysql: Remove unused functions
Browse files Browse the repository at this point in the history
  • Loading branch information
mariux committed May 22, 2015
1 parent 538850d commit ffc0ecb
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 109 deletions.
101 changes: 0 additions & 101 deletions mxq_mysql.c
Original file line number Diff line number Diff line change
Expand Up @@ -61,65 +61,6 @@ void mxq_mysql_close(MYSQL *mysql) {
mysql_library_end();
}

int mxq_mysql_query(MYSQL *mysql, const char *fmt, ...)
{
va_list ap;
_mx_cleanup_free_ char *query = NULL;
int res;
size_t len;

va_start(ap, fmt);
len = vasprintf(&query, fmt, ap);
va_end(ap);

if (len == -1)
return 0;

assert(len == strlen(query));

//printf("QUERY(%d): %s;\n", (int)len, query);

res = mysql_real_query(mysql, query, len);

return res;
}

MYSQL_RES *mxq_mysql_query_with_result(MYSQL *mysql, const char *fmt, ...)
{
va_list ap;
_mx_cleanup_free_ char *query = NULL;
MYSQL_RES *mres;
size_t len;
int res;

va_start(ap, fmt);
len = vasprintf(&query, fmt, ap);
va_end(ap);

if (len == -1)
return 0;

assert(len == strlen(query));

//printf("QUERY(%d): %s;\n", (int)len, query);

res = mysql_real_query(mysql, query, len);
if (res) {
mx_log_err("mysql_real_query() failed. Error: %s", mysql_error(mysql));
mx_log_info("query was: %s", query);
return NULL;
}

mres = mysql_store_result(mysql);
if (!mres) {
mx_log_err("mysql_store_result() failed. Error: %s", mysql_error(mysql));
mx_log_info("query was: %s", query);
return NULL;
}

return mres;
}

MYSQL_STMT *mxq_mysql_stmt_do_query(MYSQL *mysql, char *stmt_str, int field_count, MYSQL_BIND *param, MYSQL_BIND *result)
{
MYSQL_STMT *stmt;
Expand Down Expand Up @@ -242,42 +183,6 @@ int mxq_mysql_stmt_fetch_row(MYSQL_STMT *stmt)
return 1;
}


char *mxq_mysql_escape_str(MYSQL *mysql, char *s)
{
char *quoted = NULL;
size_t len;

len = strlen(s);
quoted = malloc(len*2 + 1);
if (!quoted)
return NULL;

mysql_real_escape_string(mysql, quoted, s, len);

return quoted;
}

char *mxq_mysql_escape_strvec(MYSQL *mysql, char **sv)
{
char *quoted = NULL;
_mx_cleanup_free_ char *s = NULL;
size_t len;

s = strvec_to_str(sv);
if (!s)
return NULL;

len = strlen(s);
quoted = malloc(len*2 + 1);
if (!quoted)
return NULL;

mysql_real_escape_string(mysql, quoted, s, len);

return quoted;
}

int mxq_mysql_do_update(MYSQL *mysql, char* query, MYSQL_BIND *param)
{
MYSQL_STMT *stmt;
Expand All @@ -300,9 +205,3 @@ int mxq_mysql_do_update(MYSQL *mysql, char* query, MYSQL_BIND *param)

return res;
}


char *mxq_mysql_escape_string(MYSQL *mysql, char *s)
{
return mxq_mysql_escape_str(mysql, s);
}
8 changes: 0 additions & 8 deletions mxq_mysql.h
Original file line number Diff line number Diff line change
Expand Up @@ -17,14 +17,6 @@ struct mxq_mysql {
MYSQL *mxq_mysql_connect(struct mxq_mysql *mmysql);
void mxq_mysql_close(MYSQL *mysql);

int mxq_mysql_query(MYSQL *mysql, const char *fmt, ...) __attribute__ ((format(printf, 2, 3)));

MYSQL_RES *mxq_mysql_query_with_result(MYSQL *mysql, const char *fmt, ...) __attribute__ ((format(printf, 2, 3)));

char *mxq_mysql_escape_string(MYSQL *mysql, char *s);
char *mxq_mysql_escape_str(MYSQL *mysql, char *s);
char *mxq_mysql_escape_strvec(MYSQL *mysql, char **s);

int mxq_mysql_stmt_fetch_string(MYSQL_STMT *stmt, MYSQL_BIND *bind, int col, char **buf, unsigned long len);
int mxq_mysql_stmt_fetch_row(MYSQL_STMT *stmt);

Expand Down

0 comments on commit ffc0ecb

Please sign in to comment.