/*
* Nucleus: PHP/MySQL Weblog CMS (http://nucleuscms.org/)
- * Copyright (C) 2002-2007 The Nucleus Group
+ * Copyright (C) 2002-2011 The Nucleus Group
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
*/
/**
* @license http://nucleuscms.org/license.txt GNU General Public License
- * @copyright Copyright (C) 2002-2007 The Nucleus Group
- * @version $Id: mysql.php 1279 2008-10-23 08:18:26Z shizuki $
+ * @copyright Copyright (C) 2002-2011 The Nucleus Group
+ * @version $Id$
*/
/*
* functions moved from globalfunctions.php: sql_connect, sql_disconnect, sql_query
*/
+
$MYSQL_CONN = 0;
global $SQL_DBH;
$SQL_DBH = NULL;
-if (function_exists('mysql_query') && !function_exists('sql_fetch_assoc'))
+if (!function_exists('sql_fetch_assoc'))
{
- /**
- * Connects to mysql server
- */
- function sql_connect_args($mysql_host, $mysql_user, $mysql_password) {
+/**
+ * Errors before the database connection has been made
+ */
+ function startUpError($msg, $title) {
+ if (!defined('_CHARSET')) {
+ define('_CHARSET', 'UTF-8');
+ }
+ if (!defined('_HTML_XML_NAME_SPACE_AND_LANG_CODE')) {
+ define('_HTML_XML_NAME_SPACE_AND_LANG_CODE', 'xmlns="http://www.w3.org/1999/xhtml" xml:lang="en-us" lang="en-us"');
+ }
+ sendContentType('text/html','',_CHARSET);
+ ?>
+<html <?php echo _HTML_XML_NAME_SPACE_AND_LANG_CODE; ?>>
+ <head><meta http-equiv="Content-Type" content="text/html; charset=<?php echo _CHARSET?>" />
+ <title><?php echo htmlspecialchars($title,ENT_QUOTES)?></title></head>
+ <body>
+ <h1><?php echo htmlspecialchars($title,ENT_QUOTES)?></h1>
+ <?php echo $msg?>
+ </body>
+</html>
+<?php
+ exit;
+ }
+
+/**
+ * Connects to mysql server
+ */
+ function sql_connect_args($mysql_host = 'localhost', $mysql_user = '', $mysql_password = '', $mysql_database = '') {
global $MYSQL_HANDLER;
try {
if (strpos($mysql_host,':') === false) {
$host = $mysql_host;
$port = '';
+ $portnum = '';
}
else {
list($host,$port) = explode(":",$mysql_host);
- if (isset($port))
+ if (isset($port)) {
+ $portnum = $port;
$port = ';port='.trim($port);
- else
+ }
+ else {
$port = '';
+ $portnum = '';
+ }
}
- $DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port, $mysql_user, $mysql_password);
+ switch ($MYSQL_HANDLER[1]) {
+ case 'sybase':
+ case 'dblib':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$mysql_database, $mysql_user, $mysql_password);
+ break;
+ case 'mssql':
+ if (is_numeric($portnum)) $port = ','.intval($portnum);
+ else $port = '';
+ $DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$mysql_database, $mysql_user, $mysql_password);
+ break;
+ case 'oci':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $DBH = new PDO($MYSQL_HANDLER[1].':dbname=//'.$host.$port.'/'.$mysql_database, $mysql_user, $mysql_password);
+ break;
+ case 'odbc':
+ if (is_numeric($portnum)) $port = ';PORT='.intval($portnum);
+ else $port = '';
+ $DBH = new PDO($MYSQL_HANDLER[1].':DRIVER={IBM DB2 ODBC DRIVER};HOSTNAME='.$host.$port.';DATABASE='.$mysql_database.';PROTOCOL=TCPIP;UID='.$mysql_user.';PWD='.$mysql_password);
+
+ break;
+ case 'pgsql':
+ if (is_numeric($portnum)) $port = ';port='.intval($portnum);
+ else $port = '';
+ $DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$mysql_database, $mysql_user, $mysql_password);
+ break;
+ case 'sqlite':
+ case 'sqlite2':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $DBH = new PDO($MYSQL_HANDLER[1].':'.$mysql_database, $mysql_user, $mysql_password);
+ break;
+ default:
+ //mysql
+ $DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$mysql_database, $mysql_user, $mysql_password);
+ break;
+ }
+
+
} catch (PDOException $e) {
- startUpError('<p>Error!: ' . $e->getMessage() . '</p>', 'Connect Error');
+ $DBH =NULL;
+ startUpError('<p>a1 Error!: ' . $e->getMessage() . '</p>', 'Connect Error');
}
-
+//echo '<hr />DBH: '.print_r($DBH,true).'<hr />';
return $DBH;
-
}
- /**
- * Connects to mysql server
- */
+/**
+ * Connects to mysql server
+ */
function sql_connect() {
global $MYSQL_HOST, $MYSQL_USER, $MYSQL_PASSWORD, $MYSQL_DATABASE, $MYSQL_CONN, $MYSQL_HANDLER, $SQL_DBH;
-
+ $SQL_DBH = NULL;
try {
if (strpos($MYSQL_HOST,':') === false) {
$host = $MYSQL_HOST;
}
else {
list($host,$port) = explode(":",$MYSQL_HOST);
- if (isset($port))
+ if (isset($port)) {
+ $portnum = $port;
$port = ';port='.trim($port);
- else
+ }
+ else {
$port = '';
+ $portnum = '';
+ }
}
- $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
-
+ switch ($MYSQL_HANDLER[1]) {
+ case 'sybase':
+ case 'dblib':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'mssql':
+ if (is_numeric($portnum)) $port = ','.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'oci':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':dbname=//'.$host.$port.'/'.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'odbc':
+ if (is_numeric($portnum)) $port = ';PORT='.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':DRIVER={IBM DB2 ODBC DRIVER};HOSTNAME='.$host.$port.';DATABASE='.$MYSQL_DATABASE.';PROTOCOL=TCPIP;UID='.$MYSQL_USER.';PWD='.$MYSQL_PASSWORD);
+
+ break;
+ case 'pgsql':
+ if (is_numeric($portnum)) $port = ';port='.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'sqlite':
+ case 'sqlite2':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':'.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ default:
+ //mysql
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ }
+
+ //$SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$MYSQL_DATABASE, $MYSQL_USER, $MYSQL_PASSWORD);
+
+// <add for garble measure>
+ if (strpos($MYSQL_HANDLER[1], 'mysql') === 0) {
+ if (defined(_CHARSET)){
+ $charset = _CHARSET;
+ }else{
+ $resource = $SQL_DBH->query("show variables LIKE 'character_set_database'");
+ $resource->bindColumn('Value', $charset);
+ $resource->fetchAll();
+ // in trouble of encoding,uncomment the following line.
+ // $charset = "ujis";
+ // $charset = "utf8";
+ }
+ sql_set_charset_jp($charset);
+ }
+// </add for garble measure>*/
} catch (PDOException $e) {
- startUpError('<p>Error!: ' . $e->getMessage() . '</p>', 'Connect Error');
+ $SQL_DBH = NULL;
+ startUpError('<p>a2 Error!: ' . $e->getMessage() . '</p>', 'Connect Error');
}
-
-/*/ <add for garble measure>
- $resource = sql_query("show variables LIKE 'character_set_database'");
- $fetchDat = sql_fetch_assoc($resource);
- $charset = $fetchDat['Value'];
- $mySqlVer = implode('.', array_map('intval', explode('.', sql_get_server_info($MYSQL_CONN))));
- if ($mySqlVer >= '5.0.7' && phpversion() >= '5.2.3') {
- mysql_set_charset($charset);
- } elseif ($mySqlVer >= '4.1.0') {
- sql_query("SET NAMES " . $charset);
- }
-// </add for garble measure>*/
-
- return $MYSQL_CONN;
+// echo '<hr />DBH: '.print_r($SQL_DBH,true).'<hr />';
+ $MYSQL_CONN &= $SQL_DBH;
+ return $SQL_DBH;
}
- /**
- * disconnects from SQL server
- */
- function sql_disconnect() {
+/**
+ * disconnects from SQL server
+ */
+ function sql_disconnect(&$dbh=NULL) {
global $SQL_DBH;
- $SQL_DBH = NULL;
+ if (is_null($dbh)) $SQL_DBH = NULL;
+ else $dbh = NULL;
}
- function sql_close() {
+ function sql_close(&$dbh=NULL) {
global $SQL_DBH;
- $SQL_DBH = NULL;
+ if (is_null($dbh)) $SQL_DBH = NULL;
+ else $dbh = NULL;
}
- /**
- * executes an SQL query
- */
- function sql_query($query) {
+/**
+ * executes an SQL query
+ */
+ function sql_query($query,$dbh=NULL) {
global $SQLCount,$SQL_DBH;
$SQLCount++;
- $res = $SQL_DBH->query($query);
+//echo '<hr />SQL_DBH: ';
+//print_r($SQL_DBH);
+//echo '<hr />DBH: ';
+//print_r($dbh);
+//echo '<hr />';
+//echo $query.'<hr />';
+ if (is_null($dbh)) $res = $SQL_DBH->query($query);
+ else $res = $dbh->query($query);
if ($res->errorCode() != '00000') {
$errors = $res->errorInfo();
+ print("SQL error with query $query: " . $errors[0].'-'.$errors[1].' '.$errors[2] . '<p />');
}
return $res;
}
- /**
- * executes an SQL error
- */
- function sql_error()
+/**
+ * executes an SQL error
+ */
+ function sql_error($dbh=NULL)
{
- return '';
+ global $SQL_DBH;
+ if (is_null($dbh)) $error = $SQL_DBH->errorInfo();
+ else $error = $dbh->errorInfo();
+ if ($error[0] != '00000') {
+ return $error[0].'-'.$error[1].' '.$error[2];
+ }
+ else return '';
}
- /**
- * executes an SQL db select
- */
- function sql_select_db($db)
+/**
+ * executes an SQL db select
+ */
+ function sql_select_db($db,&$dbh=NULL)
{
global $MYSQL_HOST, $MYSQL_USER, $MYSQL_PASSWORD, $MYSQL_DATABASE, $MYSQL_CONN, $MYSQL_HANDLER, $SQL_DBH;
- $SQL_DBH = NULL;
- try {
- list($host,$port) = explode(":",$MYSQL_HOST);
- if (isset($port))
- $port = ';port='.trim($port);
- else
- $port = '';
- $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.trim($host).$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD);
-
- } catch (PDOException $e) {
- startUpError('<p>Error!: ' . $e->getMessage() . '</p>', 'Connect Error');
+//echo '<hr />'.print_r($dbh,true).'<hr />';
+//exit;
+ if (is_null($dbh)) {
+ try {
+ $SQL_DBH = NULL;
+ list($host,$port) = explode(":",$MYSQL_HOST);
+ if (isset($port)) {
+ $portnum = $port;
+ $port = ';port='.trim($port);
+ }
+ else {
+ $port = '';
+ $portnum = '';
+ }
+ //$SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.trim($host).$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD);
+ //$SQL_DBH = sql_connect();
+ switch ($MYSQL_HANDLER[1]) {
+ case 'sybase':
+ case 'dblib':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'mssql':
+ if (is_numeric($portnum)) $port = ','.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'oci':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':dbname=//'.$host.$port.'/'.$db, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'odbc':
+ if (is_numeric($portnum)) $port = ';PORT='.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':DRIVER={IBM DB2 ODBC DRIVER};HOSTNAME='.$host.$port.';DATABASE='.$db.';PROTOCOL=TCPIP;UID='.$MYSQL_USER.';PWD='.$MYSQL_PASSWORD);
+
+ break;
+ case 'pgsql':
+ if (is_numeric($portnum)) $port = ';port='.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ case 'sqlite':
+ case 'sqlite2':
+ if (is_numeric($portnum)) $port = ':'.intval($portnum);
+ else $port = '';
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':'.$db, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ default:
+ //mysql
+ $SQL_DBH = new PDO($MYSQL_HANDLER[1].':host='.$host.$port.';dbname='.$db, $MYSQL_USER, $MYSQL_PASSWORD);
+ break;
+ }
+ return 1;
+ } catch (PDOException $e) {
+ startUpError('<p>a3 Error!: ' . $e->getMessage() . '</p>', 'Connect Error');
+ return 0;
+ }
+ }
+ else {
+ if ($dbh->exec("USE $db") !== false) return 1;
+ else return 0;
}
}
- /**
- * executes an SQL real escape
- */
- function sql_real_escape_string($val)
+/**
+ * executes an SQL real escape
+ */
+ function sql_real_escape_string($val,$dbh=NULL)
{
return addslashes($val);
}
- /**
- * executes an SQL insert id
- */
- function sql_insert_id()
- {
+/**
+ * executes an PDO::quote() like escape, ie adds quotes arround the string and escapes chars as needed
+ */
+ function sql_quote_string($val,$dbh=NULL) {
global $SQL_DBH;
-
- return $SQL_DBH->lastInsertId();
+ if (is_null($dbh))
+ return $SQL_DBH->quote($val);
+ else
+ return $dbh->quote($val);
+ }
+
+/**
+ * executes an SQL insert id
+ */
+ function sql_insert_id($dbh=NULL)
+ {
+ global $SQL_DBH;
+ if (is_null($dbh))
+ return $SQL_DBH->lastInsertId();
+ else
+ return $dbh->lastInsertId();
}
- /**
- * executes an SQL result request
- */
+/**
+ * executes an SQL result request
+ */
function sql_result($res, $row = 0, $col = 0)
{
$results = array();
}
}
- /**
- * frees sql result resources
- */
+/**
+ * frees sql result resources
+ */
function sql_free_result($res)
{
$res = NULL;
return true;
}
- /**
- * returns number of rows in SQL result
- */
+/**
+ * returns number of rows in SQL result
+ */
function sql_num_rows($res)
{
return $res->rowCount();
}
- /**
- * returns number of rows affected by SQL query
- */
+/**
+ * returns number of rows affected by SQL query
+ */
function sql_affected_rows($res)
{
return $res->rowCount();
}
- /**
- * Get number of fields in result
- */
+/**
+ * Get number of fields in result
+ */
function sql_num_fields($res)
{
return $res->columnCount();
}
- /**
- * fetches next row of SQL result as an associative array
- */
+/**
+ * fetches next row of SQL result as an associative array
+ */
function sql_fetch_assoc($res)
{
$results = array();
- $results = $res->fetch(PDO::FETCH_ASSOC);
+ $results = $res->fetch(PDO::FETCH_ASSOC);
return $results;
}
- /**
- * Fetch a result row as an associative array, a numeric array, or both
- */
+/**
+ * Fetch a result row as an associative array, a numeric array, or both
+ */
function sql_fetch_array($res)
{
$results = array();
return $results;
}
- /**
- * fetches next row of SQL result as an object
- */
+/**
+ * fetches next row of SQL result as an object
+ */
function sql_fetch_object($res)
{
$results = NULL;
- $results = $res->fetchObject();
+ $results = $res->fetchObject();
return $results;
}
- /**
- * Get a result row as an enumerated array
- */
+/**
+ * Get a result row as an enumerated array
+ */
function sql_fetch_row($res)
{
$results = array();
- $results = $res->fetch(PDO::FETCH_NUM);
+ $results = $res->fetch(PDO::FETCH_NUM);
return $results;
}
- /**
- * Get column information from a result and return as an object
- */
+/**
+ * Get column information from a result and return as an object
+ */
function sql_fetch_field($res,$offset = 0)
{
$results = array();
return $obj;
}
- /**
- * Get current system status (returns string)
- */
- function sql_stat()
+/**
+ * Get current system status (returns string)
+ */
+ function sql_stat($dbh=NULL)
{
//not implemented
+ global $SQL_DBH;
+ if (is_null($dbh))
+ return '';
+ else
return '';
}
- /**
- * Returns the name of the character set
- */
- function sql_client_encoding()
+/**
+ * Returns the name of the character set
+ */
+ function sql_client_encoding($dbh=NULL)
{
//not implemented
- return '';
+ global $SQL_DBH;
+ if (is_null($dbh))
+ return '';
+ else
+ return '';
}
- /**
- * Get SQL client version
- */
+/**
+ * Get SQL client version
+ */
function sql_get_client_info()
{
global $SQL_DBH;
return $SQL_DBH->getAttribute(constant("PDO::ATTR_CLIENT_VERSION"));
}
- /**
- * Get SQL server version
- */
- function sql_get_server_info()
+/**
+ * Get SQL server version
+ */
+ function sql_get_server_info($dbh=NULL)
{
global $SQL_DBH;
- return $SQL_DBH->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
+ if (is_null($dbh))
+ return $SQL_DBH->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
+ else
+ return $dbh->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
}
- /**
- * Returns a string describing the type of SQL connection in use for the connection or FALSE on failure
- */
- function sql_get_host_info()
+/**
+ * Returns a string describing the type of SQL connection in use for the connection or FALSE on failure
+ */
+ function sql_get_host_info($dbh=NULL)
{
global $SQL_DBH;
- return $SQL_DBH->getAttribute(constant("PDO::ATTR_SERVER_INFO"));
+ if (is_null($dbh))
+ return $SQL_DBH->getAttribute(constant("PDO::ATTR_SERVER_INFO"));
+ else
+ return $dbh->getAttribute(constant("PDO::ATTR_SERVER_INFO"));
}
- /**
- * Returns the SQL protocol on success, or FALSE on failure.
- */
- function sql_get_proto_info()
+/**
+ * Returns the SQL protocol on success, or FALSE on failure.
+ */
+ function sql_get_proto_info($dbh=NULL)
{
//not implemented
- return '';
+ global $SQL_DBH;
+ if (is_null($dbh))
+ return false;
+ else
+ return false;
}
-}
+/**
+ * Get the name of the specified field in a result
+ */
+ function sql_field_name($res, $offset = 0)
+ {
+ $column = $res->getColumnMeta($offset);
+ if ($column) {
+ return $column['name'];
+ }
+ return false;
+ }
/**************************************************************************
Unimplemented mysql_* functions
-# mysql_ change_ user
-# mysql_ create_ db
-# mysql_ data_ seek
-# mysql_ db_ name
-# mysql_ db_ query
-# mysql_ drop_ db
-# mysql_ errno
-# mysql_ escape_ string
-# mysql_ fetch_ lengths
-# mysql_ field_ flags
-# mysql_ field_ len
-# mysql_ field_ name
-# mysql_ field_ seek
-# mysql_ field_ table
-# mysql_ field_ type
-# mysql_ info
-# mysql_ list_ dbs
-# mysql_ list_ fields
-# mysql_ list_ processes
-# mysql_ list_ tables
-# mysql_ pconnect
-# mysql_ ping
-# mysql_ set_ charset
-# mysql_ tablename
-# mysql_ thread_ id
-# mysql_ unbuffered_ query
-*******************************************************************/
+# mysql_ data_ seek (maybe useful)
+# mysql_ errno (maybe useful)
+# mysql_ fetch_ lengths (maybe useful)
+# mysql_ field_ flags (maybe useful)
+# mysql_ field_ len (maybe useful)
+# mysql_ field_ name (maybe useful)
+# mysql_ field_ seek (maybe useful)
+# mysql_ field_ table (maybe useful)
+# mysql_ field_ type (maybe useful)
+# mysql_ info (maybe useful)
+# mysql_ list_ processes (maybe useful)
+# mysql_ ping (maybe useful)
+# mysql_ set_ charset (maybe useful, requires php >=5.2.3 and mysql >=5.0.7)
+# mysql_ thread_ id (maybe useful)
+
+# mysql_ db_ name (useful only if working on multiple dbs which we do not do)
+# mysql_ list_ dbs (useful only if working on multiple dbs which we do not do)
+
+# mysql_ pconnect (probably not useful and could cause some unintended performance issues)
+# mysql_ unbuffered_ query (possibly useful, but complicated and not supported by all database drivers (pdo))
+# mysql_ change_ user (deprecated)
+# mysql_ create_ db (deprecated)
+# mysql_ db_ query (deprecated)
+# mysql_ drop_ db (deprecated)
+# mysql_ escape_ string (deprecated)
+# mysql_ list_ fields (deprecated)
+# mysql_ list_ tables (deprecated)
+# mysql_ tablename (deprecated)
+*******************************************************************/
+ /*
+ * for preventing I/O strings from auto-detecting the charactor encodings by MySQL
+ * since 3.62_beta-jp
+ * Jan.20, 2011 by kotorisan and cacher
+ * refering to their conversation below,
+ * http://japan.nucleuscms.org/bb/viewtopic.php?p=26581
+ *
+ * NOTE: shift_jis is only supported for output. Using shift_jis in DB is prohibited.
+ * NOTE: iso-8859-x,windows-125x if _CHARSET is unset.
+ */
+ function sql_set_charset_jp($charset) {
+ global $MYSQL_HANDLER,$SQL_DBH;
+ if (strpos($MYSQL_HANDLER[1], 'mysql') === 0) {
+ switch(strtolower($charset)){\r
+ case 'utf-8':\r
+ $charset = 'utf8';\r
+ break;\r
+ case 'euc-jp':\r
+ $charset = 'ujis';\r
+ break;\r
+ case 'gb2312':\r
+ $charset = 'gb2312';\r
+ break;\r
+ case 'shift_jis':\r
+ $charset = 'sjis';\r
+ break;\r
+ default:\r
+ break;\r
+ }
+ $mySqlVer = implode('.', array_map('intval', explode('.', sql_get_server_info())));
+ if (version_compare($mySqlVer, '4.1.0', '>=')) {
+ $res = $SQL_DBH->exec("SET CHARACTER SET " . $charset);
+ }
+ }
+ return $res;
+ }
+}
?>
\ No newline at end of file
OSDN Git Service
