summaryrefslogtreecommitdiff
path: root/ext/pdo_mysql/mysql_statement.c
diff options
context:
space:
mode:
Diffstat (limited to 'ext/pdo_mysql/mysql_statement.c')
-rwxr-xr-xext/pdo_mysql/mysql_statement.c9
1 files changed, 4 insertions, 5 deletions
diff --git a/ext/pdo_mysql/mysql_statement.c b/ext/pdo_mysql/mysql_statement.c
index 0bd3cb31a6..6f8d70a06a 100755
--- a/ext/pdo_mysql/mysql_statement.c
+++ b/ext/pdo_mysql/mysql_statement.c
@@ -65,13 +65,11 @@ static int mysql_stmt_execute(pdo_stmt_t *stmt TSRMLS_DC)
if(mysql_real_query(H->server, stmt->active_query_string,
stmt->active_query_stringlen) != 0)
{
- H->last_err = S->last_err = mysql_errno(H->server);
- pdo_mysql_error("execute failed", S->last_err);
+ pdo_mysql_error(H);
return 0;
}
if((S->result = mysql_use_result(H->server)) == NULL) {
- H->last_err = S->last_err = mysql_errno(H->server);
- pdo_mysql_error("mysql_use_result() failed", S->last_err);
+ pdo_mysql_error(H);
return 0;
}
if(!stmt->executed) {
@@ -94,6 +92,7 @@ static int mysql_stmt_fetch(pdo_stmt_t *stmt TSRMLS_DC)
if((S->current_data = mysql_fetch_row(S->result)) == NULL) {
/* there seems to be no way of distinguishing 'no data' from 'error' */
+ pdo_mysql_error(S->H);
return 0;
}
S->current_lengths = mysql_fetch_lengths(S->result);
@@ -137,7 +136,7 @@ static int mysql_stmt_get_col(pdo_stmt_t *stmt, int colno, char **ptr, unsigned
}
if(colno >= mysql_num_fields(S->result)) {
/* error invalid column */
- pdo_mysql_error("invalid column", 0);
+ pdo_mysql_error(S->H);
return 0;
}
*ptr = estrndup(S->current_data[colno], S->current_lengths[colno] +1);