mirror of
https://github.com/php/php-src.git
synced 2024-09-23 02:47:26 +00:00
322 lines
8.2 KiB
C
Executable File
322 lines
8.2 KiB
C
Executable File
/*
|
|
+----------------------------------------------------------------------+
|
|
| PHP Version 5 |
|
|
+----------------------------------------------------------------------+
|
|
| Copyright (c) 1997-2004 The PHP Group |
|
|
+----------------------------------------------------------------------+
|
|
| This source file is subject to version 3.0 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_0.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 |
|
|
| license@php.net so we can mail you a copy immediately. |
|
|
+----------------------------------------------------------------------+
|
|
| Author: George Schlossnagle <george@omniti.com> |
|
|
+----------------------------------------------------------------------+
|
|
*/
|
|
|
|
/* $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"
|
|
#include "zend_exceptions.h"
|
|
|
|
int _pdo_mysql_error(pdo_dbh_t *dbh, pdo_stmt_t *stmt, const char *file, int line TSRMLS_DC) /* {{{ */
|
|
{
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
pdo_error_type *pdo_err = stmt ? &stmt->error_code : &dbh->error_code;
|
|
pdo_mysql_error_info *einfo = &H->einfo;
|
|
|
|
einfo->errcode = mysql_errno(H->server);
|
|
einfo->file = file;
|
|
einfo->line = line;
|
|
|
|
if (einfo->errmsg) {
|
|
pefree(einfo->errmsg, dbh->is_persistent);
|
|
einfo->errmsg = NULL;
|
|
}
|
|
|
|
if (einfo->errcode) {
|
|
einfo->errmsg = pestrdup(mysql_error(H->server), dbh->is_persistent);
|
|
} else { /* no error */
|
|
strcpy(*pdo_err, PDO_ERR_NONE);
|
|
return 0;
|
|
}
|
|
|
|
/* mapping taken from:
|
|
http://dev.mysql.com/doc/mysql/en/Error-handling.html
|
|
*/
|
|
switch (einfo->errcode) {
|
|
default:
|
|
case 1000: case 1001: case 1002: case 1003:
|
|
case 1004: case 1005: case 1006: case 1007:
|
|
case 1008: case 1009: case 1010: case 1011:
|
|
case 1012: case 1013: case 1014: case 1015:
|
|
case 1016: case 1017: case 1018: case 1019:
|
|
case 1020: case 1021: case 1023: case 1024:
|
|
case 1025: case 1026: case 1027: case 1028:
|
|
case 1029: case 1030: case 1031: case 1032:
|
|
case 1034: case 1035: case 1036: case 1039:
|
|
case 1041:
|
|
strcpy(*pdo_err, "HY000");
|
|
break;
|
|
case 1022:
|
|
strcpy(*pdo_err, "23000");
|
|
break;
|
|
case 1037: case 1038:
|
|
strcpy(*pdo_err, "HY001");
|
|
break;
|
|
case 1040:
|
|
strcpy(*pdo_err, "08004");
|
|
break;
|
|
case 1042: case 1043:
|
|
strcpy(*pdo_err, "08S01");
|
|
break;
|
|
case 1044:
|
|
strcpy(*pdo_err, "42000");
|
|
break;
|
|
case 1045:
|
|
strcpy(*pdo_err, "28000");
|
|
break;
|
|
|
|
/* TODO: someone with more time on their hands
|
|
* needs to complete this list */
|
|
}
|
|
|
|
if (!dbh->methods) {
|
|
zend_throw_exception_ex(php_pdo_get_exception(), 0 TSRMLS_CC, "SQLSTATE[%s] [%d] %s",
|
|
*pdo_err, einfo->errcode, einfo->errmsg);
|
|
}
|
|
|
|
return einfo->errcode;
|
|
}
|
|
/* }}} */
|
|
|
|
static int pdo_mysql_fetch_error_func(pdo_dbh_t *dbh, pdo_stmt_t *stmt, zval *info TSRMLS_DC)
|
|
{
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
pdo_mysql_error_info *einfo = &H->einfo;
|
|
|
|
if (einfo->errcode) {
|
|
add_next_index_long(info, einfo->errcode);
|
|
add_next_index_string(info, einfo->errmsg, 1);
|
|
}
|
|
|
|
return 1;
|
|
}
|
|
|
|
static int mysql_handle_closer(pdo_dbh_t *dbh TSRMLS_DC) /* {{{ */
|
|
{
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
if (H) {
|
|
if (H->server) {
|
|
mysql_close(H->server);
|
|
H->server = NULL;
|
|
}
|
|
if (H->einfo.errmsg) {
|
|
pefree(H->einfo.errmsg, dbh->is_persistent);
|
|
H->einfo.errmsg = NULL;
|
|
}
|
|
pefree(H, dbh->is_persistent);
|
|
dbh->driver_data = NULL;
|
|
}
|
|
return 0;
|
|
}
|
|
/* }}} */
|
|
|
|
static int mysql_handle_preparer(pdo_dbh_t *dbh, const char *sql, long sql_len, pdo_stmt_t *stmt, long options, zval *driver_options TSRMLS_DC)
|
|
{
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
pdo_mysql_stmt *S = ecalloc(1, sizeof(pdo_mysql_stmt));
|
|
|
|
S->H = H;
|
|
stmt->driver_data = S;
|
|
stmt->methods = &mysql_stmt_methods;
|
|
|
|
return 1;
|
|
}
|
|
|
|
static long mysql_handle_doer(pdo_dbh_t *dbh, const char *sql, long sql_len TSRMLS_DC)
|
|
{
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
if (mysql_real_query(H->server, sql, sql_len)) {
|
|
pdo_mysql_error(dbh);
|
|
return -1;
|
|
} else {
|
|
return mysql_affected_rows(H->server);
|
|
}
|
|
}
|
|
|
|
static long pdo_mysql_last_insert_id(pdo_dbh_t *dbh TSRMLS_DC)
|
|
{
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
|
|
return (long) mysql_insert_id(H->server);
|
|
}
|
|
|
|
static int mysql_handle_quoter(pdo_dbh_t *dbh, const char *unquoted, int unquotedlen, char **quoted, int *quotedlen TSRMLS_DC)
|
|
{
|
|
pdo_mysql_db_handle *H = (pdo_mysql_db_handle *)dbh->driver_data;
|
|
*quoted = emalloc(2*unquotedlen + 3);
|
|
(*quoted)[0] = '"';
|
|
*quotedlen = mysql_real_escape_string(H->server, *quoted + 1, unquoted, unquotedlen);
|
|
(*quoted)[*quotedlen + 1] = '"';
|
|
(*quoted)[*quotedlen + 2] = '\0';
|
|
*quotedlen += 2;
|
|
return 1;
|
|
}
|
|
|
|
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;
|
|
|
|
default:
|
|
return 0;
|
|
}
|
|
|
|
return 1;
|
|
}
|
|
|
|
static struct pdo_dbh_methods mysql_methods = {
|
|
mysql_handle_closer,
|
|
mysql_handle_preparer,
|
|
mysql_handle_doer,
|
|
mysql_handle_quoter,
|
|
NULL,
|
|
NULL,
|
|
NULL,
|
|
NULL,
|
|
pdo_mysql_last_insert_id,
|
|
pdo_mysql_fetch_error_func,
|
|
pdo_mysql_get_attribute,
|
|
NULL /* check_liveness: TODO: ping */
|
|
};
|
|
|
|
#ifndef PDO_MYSQL_UNIX_ADDR
|
|
# define PDO_MYSQL_UNIX_ADDR "MySQL"
|
|
#endif
|
|
|
|
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;
|
|
unsigned int port;
|
|
char *dbname;
|
|
struct pdo_data_src_parser vars[] = {
|
|
{ "charset", NULL, 0 },
|
|
{ "dbname", "", 0 },
|
|
{ "host", "localhost", 0 },
|
|
{ "port", "3306", 0 },
|
|
{ "unix_socket", PDO_MYSQL_UNIX_ADDR, 0 },
|
|
};
|
|
|
|
php_pdo_parse_data_source(dbh->data_source, dbh->data_source_len, vars, 4);
|
|
|
|
H = pecalloc(1, sizeof(pdo_mysql_db_handle), dbh->is_persistent);
|
|
|
|
H->einfo.errcode = 0;
|
|
H->einfo.errmsg = NULL;
|
|
|
|
/* allocate an environment */
|
|
|
|
/* handle for the server */
|
|
H->server = mysql_init(NULL);
|
|
dbh->driver_data = H;
|
|
|
|
/* handle MySQL options */
|
|
if (driver_options) {
|
|
long connect_timeout = pdo_attr_lval(driver_options, PDO_ATTR_TIMEOUT, 30 TSRMLS_CC);
|
|
|
|
if (mysql_options(H->server, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&connect_timeout)) {
|
|
pdo_mysql_error(dbh);
|
|
goto cleanup;
|
|
}
|
|
}
|
|
|
|
if (vars[2].optval && strcmp("localhost", vars[2].optval)) {
|
|
host = vars[2].optval;
|
|
port = atoi(vars[3].optval);
|
|
} else {
|
|
host = ".";
|
|
unix_socket = vars[4].optval;
|
|
}
|
|
dbname = vars[1].optval;
|
|
if (mysql_real_connect(H->server, host, dbh->username, dbh->password, dbname, port, unix_socket, 0) == NULL) {
|
|
pdo_mysql_error(dbh);
|
|
goto cleanup;
|
|
}
|
|
|
|
H->attached = 1;
|
|
|
|
dbh->alloc_own_columns = 1;
|
|
dbh->supports_placeholders = 0;
|
|
dbh->max_escaped_char_length = 2;
|
|
dbh->methods = &mysql_methods;
|
|
|
|
ret = 1;
|
|
|
|
cleanup:
|
|
for (i = 0; i < sizeof(vars)/sizeof(vars[0]); i++) {
|
|
if (vars[i].freeme) {
|
|
efree(vars[i].optval);
|
|
}
|
|
}
|
|
|
|
dbh->methods = &mysql_methods;
|
|
|
|
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
|
|
*/
|