mysqli_nonapi.c

linux下安装不上mysql5与php5的可用此关联

/*
  +----------------------------------------------------------------------+
  | PHP Version 6                                                        |
  +----------------------------------------------------------------------+
  | Copyright (c) 1997-2007 The PHP Group                                |
  +----------------------------------------------------------------------+
  | This source file is subject to version 3.01 of the PHP license,      |
  | that is bundled with this package in the file LICENSE, and is        |
  | available through the world-wide-web at the following url:           |
  | http://www.php.net/license/3_01.txt                                  |
  | If you did not receive a copy of the PHP license and are unable to   |
  | obtain it through the world-wide-web, please send a note to          |
  | [e-mail] so we can mail you a copy immediately.               |
  +----------------------------------------------------------------------+
  | Authors: Georg Richter <[e-mail]>                               |
  |          Andrey Hristov <[e-mail]>                             |
  |          Ulf Wendel <[e-mail]>                                     |
  +----------------------------------------------------------------------+

  $Id: mysqli_nonapi.c,v 1.68 2007/01/01 09:29:25 sebastian Exp $ 
*/

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#include <signal.h>

#include "php.h"
#include "php_ini.h"
#include "ext/standard/info.h"
#include "php_mysqli.h"

#define SAVE_STR(a) ((a)?a:"")

extern int le_mysqli;

/* {{{ proto object mysqli_connect([string hostname [,string username [,string passwd [,string dbname [,int port [,string socket]]]]]]) U
   Open a connection to a mysql server */ 
PHP_FUNCTION(mysqli_connect)
{
	MY_MYSQL 			*mysql;
	MYSQLI_RESOURCE 	*mysqli_resource;
	zval  				*object = getThis();
	char				*hostname, *username, *passwd, *dbname, *socket;
	int					hostname_len=0, username_len=0, passwd_len = 0, dbname_len=0, socket_len=0;
	zend_bool			persistent = FALSE;
	long				port=0;
	uint				hash_len;
	char				*hash_key = NULL;
	zend_bool			new_connection = FALSE;
	zend_rsrc_list_entry	*le;

	if (getThis() && !ZEND_NUM_ARGS()) {
		RETURN_NULL();
	}

	hostname = username = dbname = passwd = socket = NULL;

	if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "|s&s&s&s&ls&", &hostname, &hostname_len, UG(utf8_conv),
							  &username, &username_len, UG(utf8_conv), &passwd, &passwd_len, UG(utf8_conv), 
							  &dbname, &dbname_len, UG(utf8_conv), &port, &socket, &socket_len, UG(utf8_conv)) == FAILURE) {
		return;
	}

	if (!socket_len) {
		socket = MyG(default_socket);
	}

	if (!passwd) {
		passwd = MyG(default_pw);
		passwd_len = strlen(SAVE_STR(passwd));
	}
	if (!username){
		username = MyG(default_user);
	}
	if (!hostname) {
		hostname = MyG(default_host);
	}

	mysql = (MY_MYSQL *) ecalloc(1, sizeof(MY_MYSQL));

    if (strlen(hostname) > 2 && !strncasecmp(hostname, "p:", 2)) {
		mysql->persistent = persistent = TRUE;
        hostname += 2;

		if (!strlen(hostname)) {
			hostname = MyG(default_host);
		}

		/* caclulate hash length: mysqli_ + Hostname + 5 (Port) + username + dbname + pw */
		hash_len = 7 + strlen(SAVE_STR(hostname)) + 5 + strlen(SAVE_STR(username))
					 + strlen(SAVE_STR(dbname)) + strlen(SAVE_STR(passwd)) + 1;

		hash_key = emalloc(hash_len);
		hash_len = snprintf(hash_key, hash_len, "mysqli_%s%ld%s%s%s", SAVE_STR(hostname), 
							port, SAVE_STR(username), SAVE_STR(dbname), 
							SAVE_STR(passwd));

		/* check if we can reuse exisiting connection ... */
		if (zend_hash_find(&EG(persistent_list), hash_key, hash_len + 1, (void **)&le) == SUCCESS) {
			if (Z_TYPE_P(le) == php_le_pmysqli()) {
				mysql->mysql = (MYSQL *)le->ptr;

				/* reset variables */
				/* todo: option for ping or change_user */
#if G0
				if (!mysql_change_user(mysql->mysql, username, passwd, dbname)) {
#endif
				if (!mysql_ping(mysql->mysql)) {
#ifdef HAVE_MYSQLND
					mysqlnd_restart_psession(mysql->mysql);
#endif
					goto end; 
				}
				/*
				  Here we fall if the connection is not ok.
				  When we update EG(persistent_list) with a new connection, this one will
				  get destructed. No need to do it explicitly.
				*/
			}	
		}
	}

#if !defined(HAVE_MYSQLND)
	if (!(mysql->mysql = mysql_init(NULL)))
#else
	if (!(mysql->mysql = mysql_init(persistent)))
#endif
	{
		efree(mysql);
		if (persistent) {
			efree(hash_key);
		}
		RETURN_FALSE;
	}
	new_connection = TRUE;

#ifdef HAVE_EMBEDDED_MYSQLI
	if (hostname_len) {
		unsigned int external=1;
		mysql_options(mysql->mysql, MYSQL_OPT_USE_REMOTE_CONNECTION, (char *)&external);
	} else {
		mysql_options(mysql->mysql, MYSQL_OPT_USE_EMBEDDED_CONNECTION, 0);
	}
#endif

#if !defined(HAVE_MYSQLND)
	if (mysql_real_connect(mysql->mysql, hostname, username, passwd, dbname, port, socket, CLIENT_MULTI_RESULTS) == NULL)
#else
	if (mysqlnd_connect(mysql->mysql, hostname, username, passwd, passwd_len, dbname, dbname_len,
						  port, socket, CLIENT_MULTI_RESULTS, MyG(mysqlnd_zval_cache) TSRMLS_CC) == NULL)
#endif
	{
		/* Save error messages */
		php_mysqli_set_error(mysql_errno(mysql->mysql), (char *) mysql_error(mysql->mysql) TSRMLS_CC);
		php_mysqli_throw_sql_exception((char *)mysql_sqlstate(mysql->mysql), mysql_errno(mysql->mysql) TSRMLS_CC,
										"%s", mysql_error(mysql->mysql));

		/* free mysql structure */
		mysqli_close(mysql->mysql, MYSQLI_CLOSE_DISCONNECTED);
		efree(mysql);
		if (persistent) {
			efree(hash_key);
		}
		RETURN_FALSE;
	}

#ifdef HAVE_MYSQLI_SET_CHARSET
	/* when PHP runs in unicode, set default character set to utf8 */
	if (UG(unicode)) {
		mysql_set_character_set(mysql->mysql, "utf8");
		mysql->conv = UG(utf8_conv);
	}
#endif

	/* clear error */
	php_mysqli_set_error(mysql_errno(mysql->mysql), (char *) mysql_error(mysql->mysql) TSRMLS_CC);

#if !defined(HAVE_MYSQLND)
	mysql->mysql->reconnect = MyG(reconnect);

	/* set our own local_infile handler */
	php_set_local_infile_handler_default(mysql);
#endif

end:
	mysqli_resource = (MYSQLI_RESOURCE *)ecalloc (1, sizeof(MYSQLI_RESOURCE));
	mysqli_resource->ptr = (void *)mysql;
	mysqli_resource->status = MYSQLI_STATUS_VALID;

	/* store persistent connection */
	if (persistent && new_connection) {
		zend_rsrc_list_entry	le;

		le.type = php_le_pmysqli();
		le.ptr = mysql->mysql;

		/* save persistent connection */
		if (zend_hash_update(&EG(persistent_list), hash_key, hash_len + 1, (void *)&le, 
						 sizeof(le), NULL) == FAILURE) {
			php_error_docref(NULL TSRMLS_CC, E_WARNING, "Can't store persistent connection");
		} 
	}
	if (persistent) {
		efree(hash_key);
	}

#if !defined(HAVE_MYSQLND)
	mysql->multi_query = 0;
#else
	mysql->multi_query = 1;
#endif

	if (!object || !instanceof_function(Z_OBJCE_P(object), mysqli_link_class_entry TSRMLS_CC)) {
		MYSQLI_RETURN_RESOURCE(mysqli_resource, mysqli_link_class_entry);	
	} else {
		((mysqli_object *) zend_object_store_get_object(object TSRMLS_CC))->ptr = mysqli_resource;
	}
}
/* }}} */

/* {{{ proto int mysqli_connect_errno(void) U
   Returns the numerical value of the error message from last connect command */
PHP_FUNCTION(mysqli_connect_errno)
{
	RETURN_LONG(MyG(error_no));
}
/* }}} */

/* {{{ proto string mysqli_connect_error(void) U
   Returns the text of the error message from previous MySQL operation */
PHP_FUNCTION(mysqli_connect_error) 
{
	if (MyG(error_msg)) {
		RETURN_UTF8_STRING((char *)MyG(error_msg), ZSTR_DUPLICATE);
	} else {
		RETURN_NULL();
	}
}
/* }}} */

/* {{{ proto mixed mysqli_fetch_array (object result [,int resulttype]) U
   Fetch a result row as an associative array, a numeric array, or both */
PHP_FUNCTION(mysqli_fetch_array) 
{
#if !defined(HAVE_MYSQLND)
	php_mysqli_fetch_into_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, 0, 0);
#else
	MYSQL_RES		*result;
	zval			*mysql_result;
	long			mode = MYSQLND_FETCH_BOTH;

	if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O|l", &mysql_result, mysqli_result_class_entry, &mode) == FAILURE) {
		return;
	}
	MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result", MYSQLI_STATUS_VALID);

	if (mode < MYSQLI_ASSOC || mode > MYSQLI_BOTH) {
		php_error_docref(NULL TSRMLS_CC, E_WARNING, "The result type should be either MYSQLI_NUM, MYSQLI_ASSOC or MYSQLI_BOTH");
		RETURN_FALSE;
	}

	mysqlnd_fetch_into(result, mode, return_value);
#endif
}
/* }}} */

/* {{{ proto mixed mysqli_fetch_assoc (object result) U
   Fetch a result row as an associative array */
PHP_FUNCTION(mysqli_fetch_assoc) 
{
#if !defined(HAVE_MYSQLND)
	php_mysqli_fetch_into_hash(INTERNAL_FUNCTION_PARAM_PASSTHRU, MYSQLI_ASSOC, 0);
#else
	MYSQL_RES		*result;
	zval			*mysql_result;

	if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O", &mysql_result, mysqli_result_class_entry) == FAILURE) {
		return;
	}
	MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result", MYSQLI_STATUS_VALID);
	mysqlnd_fetch_into(result, MYSQLND_FETCH_ASSOC, return_value);
	
#endif
}
/* }}} */

/* {{{ proto mixed mysqli_fetch_all (object result [,int resulttype]) U
   Fetches all result rows as an associative array, a numeric array, or both */
#if defined(HAVE_MYSQLND)
PHP_FUNCTION(mysqli_fetch_all) 
{
	MYSQL_RES		*result;
	zval			*mysql_result;
	long			mode = MYSQLND_FETCH_NUM;

	if (zend_parse_method_parameters(ZEND_NUM_ARGS() TSRMLS_CC, getThis(), "O|l", &mysql_result, mysqli_result_class_entry, &mode) == FAILURE) {
		return;
	}
	MYSQLI_FETCH_RESOURCE(result, MYSQL_RES *, &mysql_result, "mysqli_result", MYSQLI_STATUS_VALID);

	if (!mode || (mode & ~MYSQLND_FETCH_BOTH)) {
		php_error_docref(NULL TSRMLS_CC, E_WARNING, "Mode can be only MYSQLI_FETCH_NUM, "