#include "php.h"
#include "php_ini.h"
#include "ext/standard/info.h"
+#include "ext/standard/php_string.h"
#include "php_mysqli.h"
static zend_object_handlers mysqli_object_handlers;
/* {{{ php_clear_stmt_bind */
-void php_clear_stmt_bind(STMT *stmt) {
- int i;
-
+void php_clear_stmt_bind(STMT *stmt)
+{
+ unsigned int i;
- if (stmt->stmt && stmt->stmt->mysql->host)
+ if (stmt->stmt && stmt->stmt->mysql->host) {
mysql_stmt_close(stmt->stmt);
+ }
if (stmt->var_cnt) {
-
- for (i=0; i < stmt->var_cnt; i++) {
+ for (i = 0; i < stmt->var_cnt; i++) {
if (stmt->type == FETCH_RESULT) {
if (stmt->bind[i].type == IS_STRING) {
efree(stmt->bind[i].buffer);
if (mysql) {
mysql_close(mysql);
}
- }
- /* stmt object */
- else if (intern->zo.ce == mysqli_stmt_class_entry) {
+ } else if (intern->zo.ce == mysqli_stmt_class_entry) { /* stmt object */
STMT *stmt = (STMT *)intern->ptr;
if (stmt) {
php_clear_stmt_bind(stmt);
}
- }
- /* result object */
- else if (intern->zo.ce == mysqli_result_class_entry) {
+ } else if (intern->zo.ce == mysqli_result_class_entry) { /* result object */
MYSQL_RES *res = (MYSQL_RES *)intern->ptr;
if (res) {
mysql_free_result(res);
*/
PHP_RINIT_FUNCTION(mysqli)
{
+ MyG(error_msg) = NULL;
+ MyG(error_no) = 0;
+
return SUCCESS;
}
/* }}} */
*/
PHP_RSHUTDOWN_FUNCTION(mysqli)
{
+ if (MyG(error_msg)) {
+ efree(MyG(error_msg));
+ }
+
return SUCCESS;
}
/* }}} */
{
MYSQL_RES *result;
zval *mysql_result;
- int fetchtype;
+ int fetchtype;
int copyflag, i;
MYSQL_FIELD *fields;
MYSQL_ROW row;
MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result");
- if (array_init(return_value) == FAILURE) {
- RETURN_FALSE;
- }
+ array_init(return_value);
fields = mysql_fetch_fields(result);
row = mysql_fetch_row(result);
field_len = mysql_fetch_lengths(result);
- for (i=0; i < mysql_num_fields(result); i++){
+ for (i = 0; i < mysql_num_fields(result); i++) {
if (row[i]) {
char *column;
- int column_len;
+ int column_len;
/* check if we need magic quotes */
if (PG(magic_quotes_runtime)) {
column = php_addslashes(row[i], field_len[i], &column_len, 0 TSRMLS_CC);
copyflag = 0;
- }
- else {
+ } else {
column = row[i];
column_len = field_len[i];
copyflag = 1;
if (fetchtype & MYSQLI_ASSOC) {
add_assoc_stringl(return_value, fields[i].name, column, column_len, copyflag);
}
-
- }
- else {
+ } else {
if (fetchtype & MYSQLI_NUM) {
add_index_null(return_value, i);
}
}
/* }}} */
+/* {{{ php_mysqli_set_error
+ */
+PHP_MYSQLI_API void php_mysqli_set_error(long mysql_errno, char *mysql_err TSRMLS_DC)
+{
+ MyG(error_no) = mysql_errno;
+ if (MyG(error_msg)) {
+ efree(MyG(error_msg));
+ }
+ MyG(error_msg) = estrdup(mysql_err);
+}
+/* }}} */
+
/*
* Local variables:
* tab-width: 4
zval ***args;
int argc = ZEND_NUM_ARGS();
int i;
- int num_vars;
- int start = 0;
- int ofs;
+ int num_vars;
+ int start = 0;
+ int ofs;
STMT *stmt;
MYSQL_BIND *bind;
zval **object;
/* check if number of parameters > 2 and odd */
if (argc < 3 || !(argc & 1)) {
WRONG_PARAM_COUNT;
+ } else {
+ num_vars = (argc - 1) / 2;
}
- else
- num_vars = (argc - 1) / 2;
-
args = (zval ***)emalloc(argc * sizeof(zval **));
}
if (mysql_bind_param(stmt->stmt, bind)) {
+ efree(args);
efree(bind);
RETURN_FALSE;
}
if (Z_LVAL_PP(args[i+1+start]) != MYSQLI_BIND_SEND_DATA) {
ZVAL_ADDREF(*args[i+start]);
stmt->vars[i/2] = *args[i+start];
- }
- else
+ } else {
stmt->vars[i/2] = NULL;
+ }
}
efree(args);
efree(bind);
int argc = ZEND_NUM_ARGS();
zval **object;
int i;
- int start = 0;
- int var_cnt;
- int ofs;
+ int start = 0;
+ int var_cnt;
+ int ofs;
long col_type;
STMT *stmt;
MYSQL_BIND *bind;
if (!getThis()) {
if (Z_TYPE_PP(args[0]) != IS_OBJECT) {
+ efree(args);
RETURN_FALSE;
}
MYSQLI_FETCH_RESOURCE(stmt, STMT *, args[0], "mysqli_stmt");
start = 1;
- }
- else {
+ } else {
object = &(getThis());
MYSQLI_FETCH_RESOURCE(stmt, STMT *, object, "mysqli_stmt");
}
efree(bind);
efree(args);
php_clear_stmt_bind(stmt);
- return;
+ RETURN_FALSE;
}
stmt->var_cnt = var_cnt;
MYSQL *mysql;
zval *mysql_link = NULL;
char *user, *password, *dbname;
- int user_len, password_len, dbname_len;
+ int user_len, password_len, dbname_len;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "Osss", &mysql_link, mysqli_link_class_entry, &user, &user_len, &password, &password_len, &dbname, &dbname_len) == FAILURE) {
return;
PHP_FUNCTION(mysqli_character_set_name)
{
MYSQL *mysql;
- zval *mysql_link;
+ zval *mysql_link;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
return;
/* {{{ proto bool mysqli_close(resource link)
close connection */
-PHP_FUNCTION(mysqli_close){
+PHP_FUNCTION(mysqli_close)
+{
zval *mysql_link;
MYSQL *mysql;
MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result");
if (result->handle && result->handle->status == MYSQL_STATUS_USE_RESULT) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "(%s:) Function cannot be used with MYSQL_USE_RESULT");
+ php_error_docref(NULL TSRMLS_CC, E_WARNING, "Function cannot be used with MYSQL_USE_RESULT");
RETURN_LONG(0);
}
- mysql_data_seek (result, offset);
+ mysql_data_seek(result, offset);
return;
}
/* }}} */
/* {{{ proto void mysqli_disable_reads_from_master(resource link)
*/
-PHP_FUNCTION(mysqli_disable_reads_from_master) {
+PHP_FUNCTION(mysqli_disable_reads_from_master)
+{
MYSQL *mysql;
zval *mysql_link;
/* {{{ proto void mysqli_disable_rpl_parse(resource link)
*/
-PHP_FUNCTION(mysqli_disable_rpl_parse) {
+PHP_FUNCTION(mysqli_disable_rpl_parse)
+{
MYSQL *mysql;
zval *mysql_link;
/* {{{ proto void mysqli_enable_reads_from_master(resource link)
*/
-PHP_FUNCTION(mysqli_enable_reads_from_master) {
+PHP_FUNCTION(mysqli_enable_reads_from_master)
+{
MYSQL *mysql;
zval *mysql_link;
/* {{{ proto void mysqli_enable_rpl_parse(resource link)
*/
-PHP_FUNCTION(mysqli_enable_rpl_parse) {
+PHP_FUNCTION(mysqli_enable_rpl_parse)
+{
MYSQL *mysql;
zval *mysql_link;
PHP_FUNCTION(mysqli_errno)
{
MYSQL *mysql;
- zval *mysql_link;
+ zval *mysql_link;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
return;
{
STMT *stmt;
zval *mysql_stmt;
- int i;
+ unsigned int i;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_stmt, mysqli_stmt_class_entry) == FAILURE) {
return;
MYSQLI_FETCH_RESOURCE(stmt, STMT *, &mysql_stmt, "mysqli_stmt");
if (stmt->type == FETCH_SIMPLE) {
- for (i=0; i < stmt->var_cnt; i++) {
+ for (i = 0; i < stmt->var_cnt; i++) {
if (stmt->vars[i]) {
stmt->is_null[i] = (stmt->vars[i]->type == IS_NULL);
stmt->stmt->params[i].buffer = (gptr)&Z_LVAL_PP(&stmt->vars[i]);
break;
default:
- break;
+ break;
}
}
}
{
STMT *stmt;
zval *mysql_stmt;
- int i;
+ unsigned int i;
ulong ret;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_stmt, mysqli_stmt_class_entry) == FAILURE) {
/* reset buffers */
- for (i=0; i < stmt->var_cnt; i++) {
- if (stmt->bind[i].type == IS_STRING)
+ for (i = 0; i < stmt->var_cnt; i++) {
+ if (stmt->bind[i].type == IS_STRING) {
memset(stmt->bind[i].buffer, 0, stmt->bind[i].buflen);
+ }
}
- ret = mysql_fetch(stmt->stmt);
-
- if (ret) {
+ if (!(ret = mysql_fetch(stmt->stmt))) {
RETURN_FALSE;
}
- for (i=0; i < stmt->var_cnt; i++) {
-
+ for (i = 0; i < stmt->var_cnt; i++) {
if (!stmt->is_null[i]) {
switch (stmt->bind[i].type) {
case IS_LONG:
if (lval != (long)lval) {
sprintf((char *)&tmp, "%lld", lval);
ZVAL_STRING(stmt->vars[i], tmp, 1);
- }
- else
+ } else {
ZVAL_LONG(stmt->vars[i], lval);
- }
- else {
+ }
+ } else {
stmt->bind[i].type = IS_STRING;
ZVAL_STRING(stmt->vars[i], stmt->bind[i].buffer, 1);
}
break;
default:
- break;
+ break;
}
- }
- else
+ } else {
stmt->vars[i]->type = IS_NULL;
+ }
}
RETURN_LONG(ret);
RETURN_FALSE;
}
- if (object_init(return_value) == FAILURE){
- RETURN_FALSE;
- }
+ object_init(return_value);
add_property_string(return_value, "name",(field->name ? field->name : ""), 1);
add_property_string(return_value, "orgname",(field->org_name ? field->org_name : ""), 1);
MYSQL_FIELD *field;
zval *obj;
- int i;
+ unsigned int i;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_result, mysqli_result_class_entry) == FAILURE) {
return;
RETURN_FALSE;
}
- if (array_init(return_value) == FAILURE) {
- RETURN_FALSE;
- }
+ array_init(return_value);
- for (i=0; i < mysql_num_fields(result); i++) {
+ for (i = 0; i < mysql_num_fields(result); i++) {
field = mysql_fetch_field_direct(result, i);
MAKE_STD_ZVAL(obj);
- if (object_init(obj) == FAILURE){
- RETURN_FALSE;
- }
+ object_init(obj);
add_property_string(obj, "name",(field->name ? field->name : ""), 1);
add_property_string(obj, "orgname",(field->org_name ? field->org_name : ""), 1);
RETURN_FALSE;
}
- if (object_init(return_value) == FAILURE){
- RETURN_FALSE;
- }
+ object_init(return_value);
add_property_string(return_value, "name",(field->name ? field->name : ""), 1);
add_property_string(return_value, "orgname",(field->org_name ? field->org_name : ""), 1);
{
MYSQL_RES *result;
zval *mysql_result;
- int i;
+ unsigned int i;
unsigned long *ret;
MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result");
- ret = mysql_fetch_lengths(result);
-
- if (ret == NULL) {
+ if (!(ret = mysql_fetch_lengths(result))) {
RETURN_FALSE;
}
- if (array_init(return_value) == FAILURE) {
- RETURN_FALSE;
- }
+ array_init(return_value);
- for (i=0; i < mysql_num_fields(result); i++) {
+ for (i = 0; i < mysql_num_fields(result); i++) {
add_index_long(return_value, i, ret[i]);
}
}
{
MYSQL_RES *result;
zval *mysql_result;
- int fieldnr;
+ unsigned int fieldnr;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "Ol", &mysql_result, mysqli_result_class_entry, &fieldnr) == FAILURE) {
return;
MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result");
if (fieldnr < 0 || fieldnr >= mysql_num_fields(result)) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "(%s:) Field offset is invalid for resultset");
+ php_error_docref(NULL TSRMLS_CC, E_WARNING, "Field offset is invalid for resultset");
RETURN_FALSE;
}
}
MYSQLI_FETCH_RESOURCE(mysql, MYSQL *, &mysql_link, "mysqli_link");
- info = (char *)mysql_info(mysql);
-
- if (!info){
- return;
+ if (!(info = (char *)mysql_info(mysql))) {
+ RETURN_FALSE;
}
+
RETURN_STRING(info, 1);
}
/* }}} */
if (rc != (long)rc) {
sprintf((char *)&ret, "%lld", rc);
RETURN_STRING(ret,1);
- }
- else
+ } else {
RETURN_LONG(rc);
+ }
}
/* }}} */
MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result");
if (result->handle && result->handle->status == MYSQL_STATUS_USE_RESULT) {
- php_error_docref(NULL TSRMLS_CC, E_WARNING, "(%s:) Function cannot be used with MYSQL_USE_RESULT");
+ php_error_docref(NULL TSRMLS_CC, E_WARNING, "Function cannot be used with MYSQL_USE_RESULT");
RETURN_LONG(0);
}
switch (Z_TYPE_PP(&mysql_value)) {
case IS_STRING:
ret = mysql_options(mysql, mysql_option, Z_STRVAL_PP(&mysql_value));
- break;
+ break;
default:
convert_to_long_ex(&mysql_value);
l_value = Z_LVAL_PP(&mysql_value);
ret = mysql_options(mysql, mysql_option, (char *)&l_value);
- break;
+ break;
}
if (ret != 0) {
- RETVAL_FALSE;
+ RETURN_FALSE;
} else {
- RETVAL_TRUE;
+ RETURN_TRUE;
}
}
/* }}} */
/* {{{ proto int mysqli_param_count(resource stmt) {
return the number of parameter for the given statement */
-PHP_FUNCTION(mysqli_param_count) {
+PHP_FUNCTION(mysqli_param_count)
+{
STMT *stmt;
zval *mysql_stmt;
}
MYSQLI_FETCH_RESOURCE(stmt, STMT *, &mysql_stmt, "mysqli_stmt");
- result = mysql_prepare_result(stmt->stmt);
-
- if (!result) {
+ if (!(result = mysql_prepare_result(stmt->stmt))){
RETURN_FALSE;
}
+
MYSQLI_RETURN_RESOURCE(result, mysqli_result_class_entry);
}
/* }}} */
/* {{{ proto bool mysqli_read_query_result(resource link)
*/
-PHP_FUNCTION(mysqli_read_query_result) {
+PHP_FUNCTION(mysqli_read_query_result)
+{
MYSQL *mysql;
zval *mysql_link;
+
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
return;
}
MYSQLI_FETCH_RESOURCE(mysql, MYSQL *, &mysql_link, "mysqli_link");
- if (mysql_read_query_result(mysql))
+ if (mysql_read_query_result(mysql)) {
RETURN_FALSE;
+ }
+
RETURN_TRUE;
}
/* }}} */
}
/* TODO: safe mode handling */
- if (PG(sql_safe_mode)){
+ if (PG(sql_safe_mode)) {
} else {
if (!passwd) {
passwd = MyG(default_pw);
if (mysql_real_connect(mysql,hostname,username,passwd,dbname,port,socket,flags) == NULL) {
/* Save error messages */
- MyG(error_no) = mysql_errno(mysql);
- MyG(error_msg) = estrdup(mysql_error(mysql));
+ php_mysqli_set_error(mysql_errno(mysql), mysql_error(mysql) TSRMLS_CC);
php_error_docref(NULL TSRMLS_CC, E_WARNING, "%s", mysql_error(mysql));
RETURN_FALSE;
MYSQL *mysql;
zval *mysql_link = NULL;
char *escapestr, *newstr;
- int escapestr_len, newstr_len;
+ int escapestr_len, newstr_len;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "Os", &mysql_link, mysqli_link_class_entry, &escapestr, &escapestr_len) == FAILURE) {
return;
MYSQLI_FETCH_RESOURCE(mysql, MYSQL *, &mysql_link, "mysqli_link");
- if (mysql_rpl_probe(mysql))
+ if (mysql_rpl_probe(mysql)) {
RETURN_FALSE;
+ }
RETURN_TRUE;
}
/* }}} */
}
MYSQLI_FETCH_RESOURCE(mysql, MYSQL *, &mysql_link, "mysqli_link");
- result = mysql_store_result(mysql);
-
- if (!result) {
+ if (!(result = mysql_store_result(mysql))) {
RETURN_FALSE;
}
MYSQLI_RETURN_RESOURCE(result, mysqli_result_class_entry);
*/
PHP_FUNCTION(mysqli_stat)
{
- MYSQL *mysql;
+ MYSQL *mysql;
zval *mysql_link;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_link, mysqli_link_class_entry) == FAILURE) {
PHP_FUNCTION(mysqli_stmt_errno)
{
STMT *stmt;
- zval *mysql_stmt;
+ zval *mysql_stmt;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_stmt, mysqli_stmt_class_entry) == FAILURE) {
return;
PHP_FUNCTION(mysqli_stmt_error)
{
STMT *stmt;
- zval *mysql_stmt;
+ zval *mysql_stmt;
if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_stmt, mysqli_stmt_class_entry) == FAILURE) {
return;
}
MYSQLI_FETCH_RESOURCE(mysql, MYSQL *, &mysql_link, "mysqli_link");
- result = mysql_use_result(mysql);
-
- if (!result) {
+ if (!(result = mysql_use_result(mysql))) {
RETURN_FALSE;
}
MYSQLI_RETURN_RESOURCE(result, mysqli_result_class_entry);