2004-05-19 02:01:52 +08:00
|
|
|
/*
|
|
|
|
+----------------------------------------------------------------------+
|
|
|
|
| PHP Version 5 |
|
|
|
|
+----------------------------------------------------------------------+
|
2007-12-31 15:17:19 +08:00
|
|
|
| Copyright (c) 1997-2008 The PHP Group |
|
2004-05-19 02:01:52 +08:00
|
|
|
+----------------------------------------------------------------------+
|
2006-01-01 20:51:34 +08:00
|
|
|
| This source file is subject to version 3.01 of the PHP license, |
|
2004-05-19 02:01:52 +08:00
|
|
|
| that is bundled with this package in the file LICENSE, and is |
|
|
|
|
| available through the world-wide-web at the following url: |
|
2006-01-01 20:51:34 +08:00
|
|
|
| http://www.php.net/license/3_01.txt |
|
2004-05-19 02:01:52 +08:00
|
|
|
| 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 |
|
|
|
|
| license@php.net so we can mail you a copy immediately. |
|
|
|
|
+----------------------------------------------------------------------+
|
|
|
|
| Author: George Schlossnagle <george@omniti.com> |
|
2005-07-03 10:20:08 +08:00
|
|
|
| Wez Furlong <wez@php.net> |
|
2004-05-19 02:01:52 +08:00
|
|
|
+----------------------------------------------------------------------+
|
|
|
|
*/
|
|
|
|
|
|
|
|
/* $Id$ */
|
|
|
|
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
|
|
#include "config.h"
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#include "php.h"
|
|
|
|
#include "php_ini.h"
|
|
|
|
#include "ext/standard/info.h"
|
|
|
|
#include "pdo/php_pdo.h"
|
|
|
|
#include "pdo/php_pdo_driver.h"
|
|
|
|
#include "php_pdo_mysql.h"
|
|
|
|
#include "php_pdo_mysql_int.h"
|
2005-02-27 19:39:15 +08:00
|
|
|
#include <mysqld_error.h>
|
2004-07-28 08:03:44 +08:00
|
|
|
#include "zend_exceptions.h"
|
2004-05-19 02:01:52 +08:00
|
|
|
|
2005-02-27 19:39:15 +08:00
|
|
|
|
|
|
|
const char *pdo_mysql_get_sqlstate(unsigned int my_errno) {
|
|
|
|
switch (my_errno) {
|
|
|
|
/* import auto-generated case: code */
|
|
|
|
#include "php_pdo_mysql_sqlstate.h"
|
|
|
|
default: return "HY000";
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2004-05-21 00:13:13 +08:00
|
|
|
int _pdo_mysql_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, const char *file, int line TSRMLS_DC) /* {{{ */
|
2004-05-19 02:01:52 +08:00
|
|
|
{
|
2004-05-20 23:51:25 +08:00
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
2005-02-28 04:34:36 +08:00
|
|
|
pdo_error_type *pdo_err;
|
|
|
|
pdo_mysql_error_info *einfo;
|
2005-07-03 10:20:08 +08:00
|
|
|
pdo_mysql_stmt *S = NULL;
|
2004-05-20 23:51:25 +08:00
|
|
|
|
2005-02-28 04:34:36 +08:00
|
|
|
if (stmt) {
|
2005-07-03 10:20:08 +08:00
|
|
|
S = (pdo_mysql_stmt*)stmt->driver_data;
|
2005-02-28 04:34:36 +08:00
|
|
|
pdo_err = &stmt->error_code;
|
|
|
|
einfo = &S->einfo;
|
|
|
|
} else {
|
|
|
|
pdo_err = &dbh->error_code;
|
|
|
|
einfo = &H->einfo;
|
|
|
|
}
|
|
|
|
|
2005-10-29 10:36:30 +08:00
|
|
|
#if HAVE_MYSQL_STMT_PREPARE
|
|
|
|
if (S && S->stmt) {
|
|
|
|
einfo->errcode = mysql_stmt_errno(S->stmt);
|
|
|
|
}
|
|
|
|
else
|
|
|
|
#endif
|
|
|
|
{
|
|
|
|
einfo->errcode = mysql_errno(H->server);
|
|
|
|
}
|
|
|
|
|
2004-05-20 23:51:25 +08:00
|
|
|
einfo->file = file;
|
|
|
|
einfo->line = line;
|
|
|
|
|
|
|
|
if (einfo->errmsg) {
|
2004-09-24 05:03:41 +08:00
|
|
|
pefree(einfo->errmsg, dbh->is_persistent);
|
2004-05-20 23:51:25 +08:00
|
|
|
einfo->errmsg = NULL;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (einfo->errcode) {
|
2005-06-25 03:45:59 +08:00
|
|
|
if (2014 != einfo->errcode) {
|
|
|
|
einfo->errmsg = pestrdup(mysql_error(H->server), dbh->is_persistent);
|
|
|
|
} else {
|
2005-07-03 10:20:08 +08:00
|
|
|
einfo->errmsg = pestrdup(
|
|
|
|
"Cannot execute queries while other unbuffered queries are active. "
|
|
|
|
"Consider using PDOStatement::fetchAll(). Alternatively, if your code "
|
|
|
|
"is only ever going to run against mysql, you may enable query "
|
2005-10-06 06:14:52 +08:00
|
|
|
"buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute.",
|
2005-07-03 10:20:08 +08:00
|
|
|
dbh->is_persistent);
|
2005-06-25 03:45:59 +08:00
|
|
|
}
|
2004-05-20 23:51:25 +08:00
|
|
|
} else { /* no error */
|
2005-01-07 13:24:21 +08:00
|
|
|
strcpy(*pdo_err, PDO_ERR_NONE);
|
2004-05-20 23:51:25 +08:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2005-07-03 10:20:08 +08:00
|
|
|
#if HAVE_MYSQL_SQLSTATE
|
|
|
|
# if HAVE_MYSQL_STMT_PREPARE
|
|
|
|
if (S && S->stmt) {
|
|
|
|
strcpy(*pdo_err, mysql_stmt_sqlstate(S->stmt));
|
|
|
|
} else
|
|
|
|
# endif
|
|
|
|
{
|
|
|
|
strcpy(*pdo_err, mysql_sqlstate(H->server));
|
|
|
|
}
|
|
|
|
#else
|
2005-02-28 04:34:36 +08:00
|
|
|
strcpy(*pdo_err, pdo_mysql_get_sqlstate(einfo->errcode));
|
2005-07-03 10:20:08 +08:00
|
|
|
#endif
|
2005-02-28 04:34:36 +08:00
|
|
|
|
2004-05-25 20:03:41 +08:00
|
|
|
if (!dbh->methods) {
|
2005-01-07 13:24:21 +08:00
|
|
|
zend_throw_exception_ex(php_pdo_get_exception(), 0 TSRMLS_CC, "SQLSTATE[%s] [%d] %s",
|
|
|
|
*pdo_err, einfo->errcode, einfo->errmsg);
|
2004-05-25 20:03:41 +08:00
|
|
|
}
|
2005-07-14 10:09:08 +08:00
|
|
|
/* printf("** [%s:%d] %s %s\n", file, line, *pdo_err, einfo->errmsg); */
|
2005-02-27 19:39:15 +08:00
|
|
|
|
2004-05-20 23:51:25 +08:00
|
|
|
return einfo->errcode;
|
2004-05-19 02:01:52 +08:00
|
|
|
}
|
|
|
|
/* }}} */
|
|
|
|
|
2004-05-20 23:51:25 +08:00
|
|
|
static int pdo_mysql_fetch_error_func(pdo_dbh_t *dbh, pdo_stmt_t *stmt, zval *info TSRMLS_DC)
|
2004-05-19 02:01:52 +08:00
|
|
|
{
|
2004-05-20 23:51:25 +08:00
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
pdo_mysql_error_info *einfo = &H->einfo;
|
|
|
|
|
2005-02-28 04:34:36 +08:00
|
|
|
if (stmt) {
|
|
|
|
pdo_mysql_stmt *S = (pdo_mysql_stmt*)stmt->driver_data;
|
|
|
|
einfo = &S->einfo;
|
|
|
|
} else {
|
|
|
|
einfo = &H->einfo;
|
|
|
|
}
|
|
|
|
|
2004-05-20 23:51:25 +08:00
|
|
|
if (einfo->errcode) {
|
|
|
|
add_next_index_long(info, einfo->errcode);
|
|
|
|
add_next_index_string(info, einfo->errmsg, 1);
|
|
|
|
}
|
|
|
|
|
|
|
|
return 1;
|
2004-05-19 02:01:52 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
static int mysql_handle_closer(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */
|
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
2004-05-25 22:39:26 +08:00
|
|
|
|
|
|
|
if (H) {
|
|
|
|
if (H->server) {
|
|
|
|
mysql_close(H->server);
|
|
|
|
H->server = NULL;
|
|
|
|
}
|
|
|
|
if (H->einfo.errmsg) {
|
2004-09-24 05:03:41 +08:00
|
|
|
pefree(H->einfo.errmsg, dbh->is_persistent);
|
2004-05-25 22:39:26 +08:00
|
|
|
H->einfo.errmsg = NULL;
|
|
|
|
}
|
2004-09-24 04:43:11 +08:00
|
|
|
pefree(H, dbh->is_persistent);
|
2004-07-28 08:40:01 +08:00
|
|
|
dbh->driver_data = NULL;
|
2004-05-20 01:35:39 +08:00
|
|
|
}
|
2004-05-19 02:01:52 +08:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
/* }}} */
|
|
|
|
|
2005-01-21 08:39:03 +08:00
|
|
|
static int mysql_handle_preparer(pdo_dbh_t *dbh, const char *sql, long sql_len, pdo_stmt_t *stmt, zval *driver_options TSRMLS_DC)
|
2004-05-19 02:01:52 +08:00
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
pdo_mysql_stmt *S = ecalloc(1, sizeof(pdo_mysql_stmt));
|
2005-07-03 10:20:08 +08:00
|
|
|
#if HAVE_MYSQL_STMT_PREPARE
|
|
|
|
char *nsql = NULL;
|
|
|
|
int nsql_len = 0;
|
|
|
|
int ret;
|
2006-04-09 16:11:31 +08:00
|
|
|
int server_version;
|
2005-07-03 10:20:08 +08:00
|
|
|
#endif
|
|
|
|
|
2004-05-19 02:01:52 +08:00
|
|
|
S->H = H;
|
|
|
|
stmt->driver_data = S;
|
|
|
|
stmt->methods = &mysql_stmt_methods;
|
2005-07-03 10:20:08 +08:00
|
|
|
|
2006-03-06 01:18:01 +08:00
|
|
|
if (H->emulate_prepare) {
|
|
|
|
goto end;
|
|
|
|
}
|
|
|
|
|
2005-07-03 10:20:08 +08:00
|
|
|
#if HAVE_MYSQL_STMT_PREPARE
|
2006-04-09 16:11:31 +08:00
|
|
|
server_version = mysql_get_server_version(H->server);
|
|
|
|
if (server_version < 40100) {
|
|
|
|
goto fallback;
|
|
|
|
}
|
2005-07-03 10:20:08 +08:00
|
|
|
stmt->supports_placeholders = PDO_PLACEHOLDER_POSITIONAL;
|
|
|
|
ret = pdo_parse_params(stmt, (char*)sql, sql_len, &nsql, &nsql_len TSRMLS_CC);
|
|
|
|
|
|
|
|
if (ret == 1) {
|
|
|
|
/* query was rewritten */
|
|
|
|
sql = nsql;
|
|
|
|
sql_len = nsql_len;
|
|
|
|
} else if (ret == -1) {
|
|
|
|
/* failed to parse */
|
|
|
|
strcpy(dbh->error_code, stmt->error_code);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2005-07-13 03:32:13 +08:00
|
|
|
if (!(S->stmt = mysql_stmt_init(H->server))) {
|
2005-07-03 10:20:08 +08:00
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
if (nsql) {
|
|
|
|
efree(nsql);
|
|
|
|
}
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (mysql_stmt_prepare(S->stmt, sql, sql_len)) {
|
|
|
|
/* TODO: might need to pull statement specific info here? */
|
2005-08-31 12:06:10 +08:00
|
|
|
/* if the query isn't supported by the protocol, fallback to emulation */
|
|
|
|
if (mysql_errno(H->server) == 1295) {
|
|
|
|
if (nsql) {
|
|
|
|
efree(nsql);
|
|
|
|
}
|
|
|
|
goto fallback;
|
|
|
|
}
|
2005-07-03 10:20:08 +08:00
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
if (nsql) {
|
|
|
|
efree(nsql);
|
|
|
|
}
|
|
|
|
return 0;
|
|
|
|
}
|
2005-07-08 00:27:46 +08:00
|
|
|
if (nsql) {
|
|
|
|
efree(nsql);
|
|
|
|
}
|
2005-07-03 10:20:08 +08:00
|
|
|
|
|
|
|
S->num_params = mysql_stmt_param_count(S->stmt);
|
|
|
|
|
|
|
|
if (S->num_params) {
|
|
|
|
S->params = ecalloc(S->num_params, sizeof(MYSQL_BIND));
|
|
|
|
S->in_null = ecalloc(S->num_params, sizeof(my_bool));
|
|
|
|
S->in_length = ecalloc(S->num_params, sizeof(unsigned long));
|
|
|
|
}
|
|
|
|
|
|
|
|
dbh->alloc_own_columns = 1;
|
|
|
|
|
2005-07-20 11:38:33 +08:00
|
|
|
S->max_length = pdo_attr_lval(driver_options, PDO_ATTR_MAX_COLUMN_LEN, 0 TSRMLS_CC);
|
|
|
|
|
2005-07-03 10:20:08 +08:00
|
|
|
return 1;
|
|
|
|
|
2005-08-31 12:06:10 +08:00
|
|
|
fallback:
|
2005-07-03 10:20:08 +08:00
|
|
|
#endif
|
2006-03-06 01:18:01 +08:00
|
|
|
end:
|
2005-08-31 12:06:10 +08:00
|
|
|
stmt->supports_placeholders = PDO_PLACEHOLDER_NONE;
|
2004-05-19 02:01:52 +08:00
|
|
|
|
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
2004-05-20 03:31:33 +08:00
|
|
|
static long mysql_handle_doer(pdo_dbh_t *dbh, const char *sql, long sql_len TSRMLS_DC)
|
2004-05-19 02:01:52 +08:00
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
|
2004-05-20 01:35:39 +08:00
|
|
|
if (mysql_real_query(H->server, sql, sql_len)) {
|
2004-05-20 23:51:25 +08:00
|
|
|
pdo_mysql_error(dbh);
|
2004-05-20 03:31:33 +08:00
|
|
|
return -1;
|
2004-05-20 01:35:39 +08:00
|
|
|
} else {
|
2005-09-14 23:34:58 +08:00
|
|
|
my_ulonglong c = mysql_affected_rows(H->server);
|
2005-11-25 20:56:04 +08:00
|
|
|
if (c == (my_ulonglong) -1) {
|
2005-09-14 23:34:58 +08:00
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
return (H->einfo.errcode ? -1 : 0);
|
|
|
|
} else {
|
|
|
|
return c;
|
|
|
|
}
|
2004-05-20 01:35:39 +08:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2005-02-27 09:30:58 +08:00
|
|
|
static char *pdo_mysql_last_insert_id(pdo_dbh_t *dbh, const char *name, unsigned int *len TSRMLS_DC)
|
2004-05-20 01:35:39 +08:00
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
2005-07-09 03:25:37 +08:00
|
|
|
char *id = php_pdo_int64_to_str(mysql_insert_id(H->server) TSRMLS_CC);
|
|
|
|
*len = strlen(id);
|
2005-02-27 01:27:51 +08:00
|
|
|
return id;
|
2004-05-19 02:01:52 +08:00
|
|
|
}
|
|
|
|
|
2005-02-07 07:22:37 +08:00
|
|
|
static int mysql_handle_quoter(pdo_dbh_t *dbh, const char *unquoted, int unquotedlen, char **quoted, int *quotedlen, enum pdo_param_type paramtype TSRMLS_DC)
|
2004-05-19 02:01:52 +08:00
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
2005-07-11 22:46:01 +08:00
|
|
|
*quoted = safe_emalloc(2, unquotedlen, 3);
|
2004-05-19 23:12:05 +08:00
|
|
|
*quotedlen = mysql_real_escape_string(H->server, *quoted + 1, unquoted, unquotedlen);
|
2005-12-26 04:30:40 +08:00
|
|
|
(*quoted)[0] =(*quoted)[++*quotedlen] = '\'';
|
2005-07-11 22:46:01 +08:00
|
|
|
(*quoted)[++*quotedlen] = '\0';
|
2004-05-19 02:01:52 +08:00
|
|
|
return 1;
|
|
|
|
}
|
|
|
|
|
2005-02-13 08:51:17 +08:00
|
|
|
static int mysql_handle_begin(pdo_dbh_t *dbh TSRMLS_DC)
|
|
|
|
{
|
|
|
|
return 0 <= mysql_handle_doer(dbh, ZEND_STRL("START TRANSACTION") TSRMLS_CC);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int mysql_handle_commit(pdo_dbh_t *dbh TSRMLS_DC)
|
|
|
|
{
|
|
|
|
return 0 <= mysql_handle_doer(dbh, ZEND_STRL("COMMIT") TSRMLS_CC);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int mysql_handle_rollback(pdo_dbh_t *dbh TSRMLS_DC)
|
|
|
|
{
|
|
|
|
return 0 <= mysql_handle_doer(dbh, ZEND_STRL("ROLLBACK") TSRMLS_CC);
|
|
|
|
}
|
|
|
|
|
|
|
|
static int mysql_handle_autocommit(pdo_dbh_t *dbh TSRMLS_DC)
|
|
|
|
{
|
2005-02-13 08:55:16 +08:00
|
|
|
if (dbh->auto_commit) {
|
2005-02-22 00:10:03 +08:00
|
|
|
return 0 <= mysql_handle_doer(dbh, ZEND_STRL("SET AUTOCOMMIT=1") TSRMLS_CC);
|
2005-02-13 08:55:16 +08:00
|
|
|
} else {
|
2005-02-22 00:10:03 +08:00
|
|
|
return 0 <= mysql_handle_doer(dbh, ZEND_STRL("SET AUTOCOMMIT=0") TSRMLS_CC);
|
2005-02-13 08:55:16 +08:00
|
|
|
}
|
2005-02-13 08:51:17 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
static int pdo_mysql_set_attribute(pdo_dbh_t *dbh, long attr, zval *val TSRMLS_DC)
|
|
|
|
{
|
|
|
|
switch (attr) {
|
|
|
|
case PDO_ATTR_AUTOCOMMIT:
|
|
|
|
|
|
|
|
convert_to_boolean(val);
|
|
|
|
|
|
|
|
/* ignore if the new value equals the old one */
|
|
|
|
if (dbh->auto_commit ^ Z_BVAL_P(val)) {
|
|
|
|
dbh->auto_commit = Z_BVAL_P(val);
|
2005-02-13 14:41:46 +08:00
|
|
|
mysql_handle_autocommit(dbh TSRMLS_CC);
|
2005-02-13 08:51:17 +08:00
|
|
|
}
|
|
|
|
return 1;
|
2005-06-25 03:45:59 +08:00
|
|
|
|
|
|
|
case PDO_MYSQL_ATTR_USE_BUFFERED_QUERY:
|
|
|
|
((pdo_mysql_db_handle *)dbh->driver_data)->buffered = Z_BVAL_P(val);
|
|
|
|
return 1;
|
2006-03-06 01:18:01 +08:00
|
|
|
case PDO_MYSQL_ATTR_DIRECT_QUERY:
|
2006-04-09 16:11:31 +08:00
|
|
|
case PDO_ATTR_EMULATE_PREPARES:
|
2006-03-06 01:18:01 +08:00
|
|
|
((pdo_mysql_db_handle *)dbh->driver_data)->emulate_prepare = Z_BVAL_P(val);
|
|
|
|
return 1;
|
2005-02-13 08:51:17 +08:00
|
|
|
default:
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2004-05-21 03:17:32 +08:00
|
|
|
static int pdo_mysql_get_attribute(pdo_dbh_t *dbh, long attr, zval *return_value TSRMLS_DC)
|
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
|
|
|
|
switch (attr) {
|
|
|
|
case PDO_ATTR_CLIENT_VERSION:
|
|
|
|
ZVAL_STRING(return_value, (char *)mysql_get_client_info(), 1);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case PDO_ATTR_SERVER_VERSION:
|
|
|
|
ZVAL_STRING(return_value, (char *)mysql_get_server_info(H->server), 1);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case PDO_ATTR_CONNECTION_STATUS:
|
|
|
|
ZVAL_STRING(return_value, (char *)mysql_get_host_info(H->server), 1);
|
|
|
|
break;
|
|
|
|
|
|
|
|
case PDO_ATTR_SERVER_INFO: {
|
|
|
|
char *tmp;
|
|
|
|
|
|
|
|
if ((tmp = (char *)mysql_stat(H->server))) {
|
|
|
|
ZVAL_STRING(return_value, tmp, 1);
|
|
|
|
} else {
|
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
|
2005-02-13 08:51:17 +08:00
|
|
|
case PDO_ATTR_AUTOCOMMIT:
|
|
|
|
ZVAL_LONG(return_value, dbh->auto_commit);
|
|
|
|
return 1;
|
2005-07-11 21:52:13 +08:00
|
|
|
|
2005-06-25 03:45:59 +08:00
|
|
|
case PDO_MYSQL_ATTR_USE_BUFFERED_QUERY:
|
|
|
|
ZVAL_LONG(return_value, H->buffered);
|
|
|
|
return 1;
|
|
|
|
|
2006-03-17 08:15:09 +08:00
|
|
|
case PDO_MYSQL_ATTR_DIRECT_QUERY:
|
|
|
|
ZVAL_LONG(return_value, H->emulate_prepare);
|
|
|
|
return 1;
|
|
|
|
|
|
|
|
case PDO_MYSQL_ATTR_MAX_BUFFER_SIZE:
|
|
|
|
ZVAL_LONG(return_value, H->max_buffer_size);
|
|
|
|
return 1;
|
|
|
|
|
2004-05-21 03:17:32 +08:00
|
|
|
default:
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
return 1;
|
|
|
|
}
|
2004-05-19 02:01:52 +08:00
|
|
|
|
2006-10-03 06:09:49 +08:00
|
|
|
static int pdo_mysql_check_liveness(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */
|
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
#if MYSQL_VERSION_ID <= 32230
|
|
|
|
void (*handler) (int);
|
|
|
|
unsigned int my_errno;
|
|
|
|
#endif
|
|
|
|
|
|
|
|
#if MYSQL_VERSION_ID > 32230
|
|
|
|
if (mysql_ping(H->server)) {
|
|
|
|
return FAILURE;
|
|
|
|
}
|
|
|
|
#else /* no mysql_ping() */
|
|
|
|
handler=signal(SIGPIPE, SIG_IGN);
|
|
|
|
mysql_stat(H->server);
|
|
|
|
switch (mysql_errno(H->server)) {
|
|
|
|
case CR_SERVER_GONE_ERROR:
|
|
|
|
/* case CR_SERVER_LOST: I'm not sure this means the same as "gone" for us */
|
|
|
|
signal(SIGPIPE, handler);
|
|
|
|
return FAILURE;
|
|
|
|
default:
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
signal(SIGPIPE, handler);
|
|
|
|
#endif /* end mysql_ping() */
|
|
|
|
return SUCCESS;
|
|
|
|
}
|
|
|
|
/* }}} */
|
2005-02-13 08:51:17 +08:00
|
|
|
|
2004-05-19 02:01:52 +08:00
|
|
|
static struct pdo_dbh_methods mysql_methods = {
|
|
|
|
mysql_handle_closer,
|
|
|
|
mysql_handle_preparer,
|
|
|
|
mysql_handle_doer,
|
2004-05-20 01:35:39 +08:00
|
|
|
mysql_handle_quoter,
|
2005-02-13 08:51:17 +08:00
|
|
|
mysql_handle_begin,
|
|
|
|
mysql_handle_commit,
|
|
|
|
mysql_handle_rollback,
|
|
|
|
pdo_mysql_set_attribute,
|
2004-05-20 23:51:25 +08:00
|
|
|
pdo_mysql_last_insert_id,
|
2004-05-21 03:17:32 +08:00
|
|
|
pdo_mysql_fetch_error_func,
|
2004-09-24 04:20:23 +08:00
|
|
|
pdo_mysql_get_attribute,
|
2006-10-03 06:09:49 +08:00
|
|
|
pdo_mysql_check_liveness
|
2004-05-19 02:01:52 +08:00
|
|
|
};
|
|
|
|
|
2004-05-25 20:44:35 +08:00
|
|
|
|
2004-05-19 02:01:52 +08:00
|
|
|
static int pdo_mysql_handle_factory(pdo_dbh_t *dbh, zval *driver_options TSRMLS_DC) /* {{{ */
|
|
|
|
{
|
|
|
|
pdo_mysql_db_handle *H;
|
|
|
|
int i, ret = 0;
|
|
|
|
char *host = NULL, *unix_socket = NULL;
|
2005-02-13 04:58:29 +08:00
|
|
|
unsigned int port = 3306;
|
2004-05-19 02:01:52 +08:00
|
|
|
char *dbname;
|
|
|
|
struct pdo_data_src_parser vars[] = {
|
|
|
|
{ "charset", NULL, 0 },
|
|
|
|
{ "dbname", "", 0 },
|
|
|
|
{ "host", "localhost", 0 },
|
|
|
|
{ "port", "3306", 0 },
|
2004-05-19 23:12:05 +08:00
|
|
|
{ "unix_socket", PDO_MYSQL_UNIX_ADDR, 0 },
|
2004-05-19 02:01:52 +08:00
|
|
|
};
|
2005-07-03 05:01:38 +08:00
|
|
|
int connect_opts = 0
|
|
|
|
#ifdef CLIENT_MULTI_RESULTS
|
|
|
|
|CLIENT_MULTI_RESULTS
|
|
|
|
#endif
|
|
|
|
#ifdef CLIENT_MULTI_STATEMENTS
|
|
|
|
|CLIENT_MULTI_STATEMENTS
|
|
|
|
#endif
|
|
|
|
;
|
2004-05-19 02:01:52 +08:00
|
|
|
|
2005-08-31 12:06:10 +08:00
|
|
|
php_pdo_parse_data_source(dbh->data_source, dbh->data_source_len, vars, 5);
|
2004-05-19 02:01:52 +08:00
|
|
|
|
|
|
|
H = pecalloc(1, sizeof(pdo_mysql_db_handle), dbh->is_persistent);
|
|
|
|
|
2004-05-20 23:51:25 +08:00
|
|
|
H->einfo.errcode = 0;
|
|
|
|
H->einfo.errmsg = NULL;
|
|
|
|
|
2004-05-19 02:01:52 +08:00
|
|
|
/* allocate an environment */
|
2006-12-04 07:29:03 +08:00
|
|
|
|
2004-05-19 02:01:52 +08:00
|
|
|
/* handle for the server */
|
2005-07-11 21:52:13 +08:00
|
|
|
if (!(H->server = mysql_init(NULL))) {
|
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
|
2004-05-20 01:35:39 +08:00
|
|
|
dbh->driver_data = H;
|
2006-03-23 09:24:36 +08:00
|
|
|
H->max_buffer_size = 1024*1024;
|
2006-12-09 03:50:40 +08:00
|
|
|
H->buffered = H->emulate_prepare = 1;
|
2004-05-20 04:34:57 +08:00
|
|
|
|
|
|
|
/* handle MySQL options */
|
|
|
|
if (driver_options) {
|
|
|
|
long connect_timeout = pdo_attr_lval(driver_options, PDO_ATTR_TIMEOUT, 30 TSRMLS_CC);
|
2005-10-28 01:34:24 +08:00
|
|
|
long local_infile = pdo_attr_lval(driver_options, PDO_MYSQL_ATTR_LOCAL_INFILE, 0 TSRMLS_CC);
|
|
|
|
char *init_cmd = NULL, *default_file = NULL, *default_group = NULL;
|
|
|
|
|
2006-12-04 07:29:03 +08:00
|
|
|
H->buffered = pdo_attr_lval(driver_options, PDO_MYSQL_ATTR_USE_BUFFERED_QUERY, 1 TSRMLS_CC);
|
2006-04-09 16:11:31 +08:00
|
|
|
|
|
|
|
H->emulate_prepare = pdo_attr_lval(driver_options,
|
|
|
|
PDO_MYSQL_ATTR_DIRECT_QUERY, H->emulate_prepare TSRMLS_CC);
|
|
|
|
H->emulate_prepare = pdo_attr_lval(driver_options,
|
|
|
|
PDO_ATTR_EMULATE_PREPARES, H->emulate_prepare TSRMLS_CC);
|
|
|
|
|
2006-03-23 09:24:36 +08:00
|
|
|
H->max_buffer_size = pdo_attr_lval(driver_options, PDO_MYSQL_ATTR_MAX_BUFFER_SIZE, H->max_buffer_size TSRMLS_CC);
|
2006-02-14 22:26:11 +08:00
|
|
|
|
2004-05-20 04:34:57 +08:00
|
|
|
if (mysql_options(H->server, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout)) {
|
2004-05-20 23:51:25 +08:00
|
|
|
pdo_mysql_error(dbh);
|
2004-05-20 04:34:57 +08:00
|
|
|
goto cleanup;
|
|
|
|
}
|
2007-06-19 05:51:32 +08:00
|
|
|
|
|
|
|
if ((PG(open_basedir) && PG(open_basedir)[0] != '\0') || PG(safe_mode)) {
|
|
|
|
local_infile = 0;
|
|
|
|
}
|
|
|
|
|
2005-10-28 01:34:24 +08:00
|
|
|
if (mysql_options(H->server, MYSQL_OPT_LOCAL_INFILE, (const char *)&local_infile)) {
|
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
|
2006-04-09 16:11:31 +08:00
|
|
|
#ifdef MYSQL_OPT_RECONNECT
|
|
|
|
/* since 5.0.3, the default for this option is 0 if not specified.
|
|
|
|
* we want the old behaviour */
|
|
|
|
{
|
|
|
|
long reconnect = 1;
|
|
|
|
mysql_options(H->server, MYSQL_OPT_RECONNECT, (const char*)&reconnect);
|
|
|
|
}
|
|
|
|
#endif
|
|
|
|
|
2005-10-28 01:34:24 +08:00
|
|
|
init_cmd = pdo_attr_strval(driver_options, PDO_MYSQL_ATTR_INIT_COMMAND, NULL TSRMLS_CC);
|
|
|
|
if (init_cmd) {
|
|
|
|
if (mysql_options(H->server, MYSQL_INIT_COMMAND, (const char *)init_cmd)) {
|
|
|
|
efree(init_cmd);
|
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
efree(init_cmd);
|
|
|
|
}
|
|
|
|
|
|
|
|
default_file = pdo_attr_strval(driver_options, PDO_MYSQL_ATTR_READ_DEFAULT_FILE, NULL TSRMLS_CC);
|
|
|
|
if (default_file) {
|
|
|
|
if (mysql_options(H->server, MYSQL_READ_DEFAULT_FILE, (const char *)default_file)) {
|
|
|
|
efree(default_file);
|
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
efree(default_file);
|
|
|
|
}
|
|
|
|
|
|
|
|
default_group= pdo_attr_strval(driver_options, PDO_MYSQL_ATTR_READ_DEFAULT_GROUP, NULL TSRMLS_CC);
|
|
|
|
if (default_group) {
|
|
|
|
if (mysql_options(H->server, MYSQL_READ_DEFAULT_GROUP, (const char *)default_group)) {
|
|
|
|
efree(default_group);
|
|
|
|
pdo_mysql_error(dbh);
|
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
efree(default_group);
|
|
|
|
}
|
2004-05-20 04:34:57 +08:00
|
|
|
}
|
2005-08-31 12:06:10 +08:00
|
|
|
|
|
|
|
dbname = vars[1].optval;
|
|
|
|
host = vars[2].optval;
|
|
|
|
if(vars[3].optval) {
|
|
|
|
port = atoi(vars[3].optval);
|
|
|
|
}
|
2005-02-10 09:34:39 +08:00
|
|
|
if (vars[2].optval && !strcmp("localhost", vars[2].optval)) {
|
2004-05-19 02:01:52 +08:00
|
|
|
unix_socket = vars[4].optval;
|
|
|
|
}
|
2005-07-03 05:01:38 +08:00
|
|
|
if (mysql_real_connect(H->server, host, dbh->username, dbh->password, dbname, port, unix_socket, connect_opts) == NULL) {
|
2004-05-20 23:51:25 +08:00
|
|
|
pdo_mysql_error(dbh);
|
2004-05-19 02:01:52 +08:00
|
|
|
goto cleanup;
|
|
|
|
}
|
|
|
|
|
2006-03-17 08:15:09 +08:00
|
|
|
if (!dbh->auto_commit) {
|
|
|
|
mysql_handle_autocommit(dbh TSRMLS_CC);
|
|
|
|
}
|
2005-02-14 01:16:24 +08:00
|
|
|
|
2004-05-19 02:01:52 +08:00
|
|
|
H->attached = 1;
|
|
|
|
|
|
|
|
dbh->alloc_own_columns = 1;
|
|
|
|
dbh->max_escaped_char_length = 2;
|
2004-07-28 08:10:28 +08:00
|
|
|
dbh->methods = &mysql_methods;
|
2004-05-19 02:01:52 +08:00
|
|
|
|
|
|
|
ret = 1;
|
|
|
|
|
|
|
|
cleanup:
|
|
|
|
for (i = 0; i < sizeof(vars)/sizeof(vars[0]); i++) {
|
|
|
|
if (vars[i].freeme) {
|
|
|
|
efree(vars[i].optval);
|
|
|
|
}
|
|
|
|
}
|
2004-07-28 08:10:28 +08:00
|
|
|
|
|
|
|
dbh->methods = &mysql_methods;
|
2004-05-19 02:01:52 +08:00
|
|
|
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
/* }}} */
|
|
|
|
|
|
|
|
pdo_driver_t pdo_mysql_driver = {
|
|
|
|
PDO_DRIVER_HEADER(mysql),
|
|
|
|
pdo_mysql_handle_factory
|
|
|
|
};
|
|
|
|
|
|
|
|
/*
|
|
|
|
* Local variables:
|
|
|
|
* tab-width: 4
|
|
|
|
* c-basic-offset: 4
|
|
|
|
* End:
|
|
|
|
* vim600: noet sw=4 ts=4 fdm=marker
|
|
|
|
* vim<600: noet sw=4 ts=4
|
|
|
|
*/
|