<?php
/**
* This file is to be used if your codebase still
* uses mysql_* functions in a PHP version that
* doesn't declare those functions (>PHP 5.5.5)
*
* Note: Since this is handled by our object, the DB
* resource link will be the subscript of the database
* connection, 0-X, where X is INT. If not passed, assumed
* subscript last connection.
*
* @author Aziz S. Hussain <azizsaleh@gmail.com>
* @copyright GPL license
* @license http://www.gnu.org/copyleft/gpl.html
* @link http://www.AzizSaleh.com
*/
/**
* MySQL
*
* This object will replicate MySQL functions
* http://www.php.net/manual/en/ref.mysql.php
*
* @author Aziz S. Hussain <azizsaleh@gmail.com>
* @copyright GPL license
* @license http://www.gnu.org/copyleft/gpl.html
* @link http://www.AzizSaleh.com
*/
class MySQL
{
/**
* Object instance
*
* @var MySQL
*/
protected static $_instance;
/**
* Instances of the Db
*
* Start position @ 1
*
* @array PDO
*/
protected $_instances = array(array());
/**
* Db Instances params
*
* @var array
*/
protected $_params = array();
/**
* Next offset used by mysql_field_seek
*
* @var int
*/
protected $_nextOffset = false;
/**
* Row seek
*
* @var int
*/
protected $_rowSeek = array();
/**
* Get singelton instance
*
* @return MySQL
*/
public static function getInstance()
{
if (!isset(self::$_instance)) {
self::$_instance = new self();
}
return self::$_instance;
}
/**
* Load an existing connection you have into the object
*
* @author Matthew Baggett
* @email matthew@baggett.me
*
* @param PDO $dbh
* @return int
*/
public function mysql_add_existing_connection(PDO $dbh)
{
$usePosition = count($this->_instances) + 1;
// Set connection params
$this->_params[$usePosition] = array (
'server' => '',
'username' => '',
'password' => '',
'newLink' => true,
'clientFlags' => array(),
'errno' => 0,
'error' => "",
'rowCount' => -1,
'lastQuery' => false,
);
$this->_instances[$usePosition] = $dbh;
return $usePosition;
}
/**
* mysql_connect
* http://www.php.net/manual/en/function.mysql-connect.php
*/
public function mysql_connect($server, $username, $password, $newLink = false, $clientFlags = false, $usePosition = false)
{
// If we aren't forcing a new link and connection exist, use it
if ($newLink == false && count($this->_instances) > 1) {
foreach ($this->_params as $position => $params) {
if ($params['server'] == $server &&
$params['username'] == $username &&
$params['clientFlags'] == $clientFlags) {
return $position;
}
}
}
$flags = $this->_translateFlags($clientFlags);
// Set connection element
if ($usePosition === false) {
$usePosition = count($this->_instances) + 1;
}
// Set connection params
$this->_params[$usePosition] = array (
'server' => $server,
'username' => $username,
'password' => $password,
'newLink' => $newLink,
'clientFlags' => $clientFlags,
'errno' => 0,
'error' => "",
'rowCount' => -1,
'lastQuery' => false,
);
// Create new instance
$dsn = "mysql:host={$server}";
try {
// Add instance
$this->_instances[$usePosition] = new Pdo($dsn, $username, $password, $flags);
return $usePosition;
} catch (PDOException $e) {
// Mock the instance for error reporting
$this->_instances[$usePosition] = array();
$this->_loadError($usePosition, $e);
return false;
}
return false;
}
/**
* mysql_pconnect
* http://www.php.net/manual/en/function.mysql-pconnect.php
*/
public function mysql_pconnect($server, $username, $password, $newLink = false, $clientFlags = false)
{
$persistent = PDO::ATTR_PERSISTENT;
$clientFlags = ($clientFlags !== false) ? array_merge($clientFlags, $persistent) : $persistent;
return $this->mysql_connect($server, $username, $password, $newLink, $clientFlags);
}
/**
* mysql_select_db
* http://www.php.net/manual/en/function.mysql-select-db.php
*/
public function mysql_select_db($databaseName, $link = false)
{
$link = $this->_getLastLink($link);
// Select the DB
try {
$this->_params[$link]['databaseName'] = $databaseName;
return $this->mysql_query("USE {$databaseName}", $link);
} catch (PDOException $e) {
return false;
}
return false;
}
/**
* mysql_query
* http://www.php.net/manual/en/function.mysql-query.php
*/
public function mysql_query($query, $link = false, $buffered = true)
{
$link = $this->_getLastLink($link);
try {
if ($res = $this->_instances[$link]->query($query)) {
$this->_params[$link]['rowCount'] = $res->rowCount();
$this->_params[$link]['lastQuery'] = $res;
$this->_loadError($link, false);
if (!$buffered) {
$this->_instances[$link]->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
}
return $res;
}
} catch (PDOException $e) {
$this->_loadError($link, $e);
}
$this->_params[$link]['rowCount'] = -1;
$this->_params[$link]['lastQuery'] = false;
// Set query error
$errorCode = $this->_instances[$link]->errorInfo();
$this->_params[$link]['errno'] = $errorCode[1];
$this->_params[$link]['error'] = $errorCode[2];
if (!$buffered) {
$this->_instances[$link]->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
}
return false;
}
/**
* mysql_unbuffered_query
* http://www.php.net/manual/en/function.mysql-unbuffered-query.php
*/
public function mysql_unbuffered_query($query, $link = false)
{
$link = $this->_getLastLink($link);
$this->_instances[$link]->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, false);
return $this->mysql_query($query, $link, false);
}
/**
* mysql_fetch_array
* http://www.php.net/manual/en/function.mysql-fetch-array.php
*/
public function mysql_fetch_array(&$result, $resultType = 3, $doCounts = false, $elementId = false)
{
static $last = null;
if ($result === false) {
trigger_error('mysql_fetch_*(): supplied argument is not a valid MySQL result resource', E_USER_WARNING);
return false;
}
// Are we only doing length counts?
if ($doCounts === true) {
return $this->_mysqlGetLengths($last, $elementId);
}
$hash = false;
// Set retrieval type
if (!is_array($result)) {
$hash = spl_object_hash($result);
switch ($resultType) {
case 1:
// by field names only as array
$result = $result->fetchAll(PDO::FETCH_ASSOC);
break;
case 2:
// by field position only as array
$result = $result->fetchAll(PDO::FETCH_NUM);
break;
case 3:
// by both field name/position as array
$result = $result->fetchAll();
break;
case 4:
// by field names as object
$result = $result->fetchAll(PDO::FETCH_OBJ);
break;
}
}
// Row seek
if ($hash !== false && isset($this->_rowSeek[$hash])) {
// Check valid skip
$rowNumber = $this->_rowSeek[$hash];
if ($rowNumber > count($result) - 1) {
trigger_error("mysql_data_seek(): Offset $rowNumber is invalid for MySQL result (or the query data is unbuffered)", E_USER_WARNING);
}
while($rowNumber > 0) {
next($result);
$rowNumber--;
}
unset($this->_rowSeek[$hash]);
}
$last = current($result);
next($result);
return $last;
}
/**
* mysql_fetch_assoc
* http://www.php.net/manual/en/function.mysql-fetch-assoc.php
*/
public function mysql_fetch_assoc(&$result)
{
return $this->mysql_fetch_array($result, 1);
}
/**
* mysql_fetch_row
* http://www.php.net/manual/en/function.mysql-fetch-row.php
*/
public function mysql_fetch_row(&$result)
{
return $this->mysql_fetch_array($result, 2);
}
/**
* mysql_fetch_object
* http://www.php.net/manual/en/function.mysql-fetch-object.php
*/
public function mysql_fetch_object(&$result)
{
return $this->mysql_fetch_array($result, 4);
}
/**
* mysql_num_fields
* http://www.php.net/manual/en/function.mysql-num-fields.php
*/
public function mysql_num_fields($result)
{
if (is_array($result)) {
return count($result);
}
$data = $result->fetch(PDO::FETCH_NUM);
return count($data);
}
/**
* mysql_num_rows
* http://www.php.net/manual/en/function.mysql-num-rows.php
*/
public function mysql_num_rows($result)
{
if (is_array($result)) {
return count($result);
}
if ($result instanceof PDOStatement) {
return $result->rowCount();
}
return false;
}
/**
* mysql_ping
* http://www.php.net/manual/en/function.mysql-ping.php
*/
public function mysql_ping($link = false)
{
$link = $this->_getLastLink($link);
try {
$this->_instances[$link]->query('SELECT 1');
$this->_loadError($link, false);
} catch (PDOException $e) {
try {
// Reconnect
$set = $this->mysql_connect(
$this->_params[$link]['server'],
$this->_params[$link]['username'],
$this->_params[$link]['password'],
$this->_params[$link]['newLink'],
$this->_params[$link]['clientFlags'],
$link
);
} catch (PDOException $e) {
$this->_loadError($link, $e);
return false;
}
// Select db if any
if (isset($this->_params[$link]['databaseName'])) {
$set = $this->mysql_select_db($this->_params[$link]['databaseName'], $link);
if (!$set) {
return false;
}
}
}
return true;
}
/**
* mysql_affected_rows
* http://www.php.net/manual/en/function.mysql-affected-rows.php
*/
public function mysql_affected_rows($link = false)
{
$link = $this->_getLastLink($link);
return $this->_params[$link]['rowCount'];
}
/**
* mysql_client_encoding
* http://www.php.net/manual/en/function.mysql-client-encoding.php
*/
public function mysql_client_encoding($link = false)
{
$link = $this->_getLastLink($link);
$res = $this->_instances[$link]->query('SELECT @@character_set_database')->fetch(PDO::FETCH_NUM);
return $res[0];
}
/**
* mysql_close
* http://www.php.net/manual/en/function.mysql-close.php
*/
public function mysql_close($link = false)
{
$link = $this->_getLastLink($link);
if (isset($this->_instances[$link])) {
$this->_instances[$link] = null;
unset($this->_instances[$link]);
return true;
}
return false;
}
/**
* mysql_create_db
* http://www.php.net/manual/en/function.mysql-create-db.php
*/
public function mysql_create_db($databaseName, $link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->prepare('CREATE DATABASE ' . $databaseName)->execute();
}
/**
* mysql_data_seek
* http://www.php.net/manual/en/function.mysql-data-seek.php
*/
public function mysql_data_seek($result, $rowNumber)
{
// Set seek
$this->_rowSeek[spl_object_hash($result)] = $rowNumber;
return true;
}
/**
* mysql_list_dbs
* http://www.php.net/manual/en/function.mysql-list-dbs.php
*/
public function mysql_list_dbs($link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->query('SHOW DATABASES');
}
/**
* mysql_db_name
* http://www.php.net/manual/en/function.mysql-db-name.php
*/
public function mysql_db_name(&$result, $row, $field = 'Database')
{
// Get list if not gotten yet (still PDOStatement)
if (!is_array($result)) {
$result = $result->fetchAll(PDO::FETCH_ASSOC);
}
if (isset($result[$row][$field])) {
return $result[$row][$field];
}
return '';
}
/**
* mysql_db_query
* http://www.php.net/manual/en/function.mysql-db-query.php
*/
public function mysql_db_query($databaseName, $query, $link = false)
{
$link = $this->_getLastLink($link);
$this->mysql_select_db($databaseName, $link);
return $this->mysql_query($query, $link);
}
/**
* mysql_drop_db
* http://www.php.net/manual/en/function.mysql-drop-db.php
*/
public function mysql_drop_db($databaseName, $link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->prepare('DROP DATABASE ' . $databaseName)->execute();
}
/**
* mysql_thread_id
* http://www.php.net/manual/en/function.mysql-thread-id.php
*/
public function mysql_thread_id($link = false)
{
$link = $this->_getLastLink($link);
$res = $this->_instances[$link]
->query('SELECT CONNECTION_ID()')->fetch(PDO::FETCH_NUM);
return $res[0];
}
/**
* mysql_list_tables
* http://www.php.net/manual/en/function.mysql-list-tables.php
*/
public function mysql_list_tables($databaseName, $link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->query('SHOW TABLES FROM ' . $databaseName);
}
/**
* mysql_tablename
* http://www.php.net/manual/en/function.mysql-tablename.php
*/
public function mysql_tablename(&$result, $row)
{
// Get list if not gotten yet (still PDOStatement)
if (!is_array($result)) {
$result = $result->fetchAll(PDO::FETCH_NUM);
}
$counter = count($result);
for ($x = 0; $x < $counter; $x++) {
if ($x == $row) {
return $result[$row][0];
}
}
return '';
}
/**
* mysql_fetch_lengths
* http://www.php.net/manual/en/function.mysql-fetch-lengths.php
*/
public function mysql_fetch_lengths(&$result)
{
// Get list if not gotten yet (still PDOStatement)
return $this->mysql_fetch_array($result, false, true);
}
/**
* mysql_field_len
* http://www.php.net/manual/en/function.mysql-field-len.php
*/
public function mysql_field_len(&$result, $fieldOffset = false)
{
if (!is_array($result)) {
$result = $result->fetchAll(PDO::FETCH_NUM);
$result = current($result);
}
return $this->_mysqlGetLengths($result, $fieldOffset);
}
/**
* mysql_field_flags
* http://www.php.net/manual/en/function.mysql-field-flags.php
*/
public function mysql_field_flags(&$result, $fieldOffset = false)
{
return $this->_getColumnMeta($result, 'flags', $fieldOffset);
}
/**
* mysql_field_name
* http://www.php.net/manual/en/function.mysql-field-name.php
*/
public function mysql_field_name(&$result, $fieldOffset = false)
{
return $this->_getColumnMeta($result, 'name', $fieldOffset);
}
/**
* mysql_field_type
* http://www.php.net/manual/en/function.mysql-field-type.php
*/
public function mysql_field_type(&$result, $fieldOffset = false)
{
return $this->_getColumnMeta($result, 'type', $fieldOffset);
}
/**
* mysql_field_table
* http://www.php.net/manual/en/function.mysql-field-table.php
*/
public function mysql_field_table(&$result, $fieldOffset = false)
{
return $this->_getColumnMeta($result, 'table', $fieldOffset);
}
/**
* mysql_fetch_field
* http://www.php.net/manual/en/function.mysql-fetch-field.php
*/
public function mysql_fetch_field(&$result, $fieldOffset = false)
{
return $this->_getColumnMeta($result, false, $fieldOffset);
}
/**
* mysql_field_seek
* http://www.php.net/manual/en/function.mysql-field-seek.php
*/
public function mysql_field_seek(&$result, $fieldOffset = false)
{
$this->_nextOffset = $fieldOffset;
}
/**
* mysql_stat
* http://www.php.net/manual/en/function.mysql-stat.php
*/
public function mysql_stat($link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->getAttribute(PDO::ATTR_SERVER_INFO);
}
/**
* mysql_get_server_info
* http://www.php.net/manual/en/function.mysql-get-server-info.php
*/
public function mysql_get_server_info($link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->getAttribute(PDO::ATTR_SERVER_VERSION);
}
/**
* mysql_get_proto_info
* http://www.php.net/manual/en/function.mysql-get-proto-info.php
*/
public function mysql_get_proto_info($link = false)
{
$link = $this->_getLastLink($link);
$res = $this->_instances[$link]
->query("SHOW VARIABLES LIKE 'protocol_version'")->fetch(PDO::FETCH_NUM);
return (int) $res[1];
}
/**
* mysql_get_host_info
* http://www.php.net/manual/en/function.mysql-get-server-info.php
*/
public function mysql_get_host_info($link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->getAttribute(PDO::ATTR_CONNECTION_STATUS);
}
/**
* mysql_get_client_info
* http://www.php.net/manual/en/function.mysql-get-client-info.php
*/
public function mysql_get_client_info($link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->getAttribute(PDO::ATTR_CLIENT_VERSION);
}
/**
* mysql_free_result
* http://www.php.net/manual/en/function.mysql-free-result.php
*/
public function mysql_free_result(&$result)
{
if (is_array($result)) {
$result = false;
return true;
}
if (get_class($result) != 'PDOStatement') {
return false;
}
return $result->closeCursor();
}
/**
* mysql_result
* http://www.php.net/manual/en/function.mysql-result.php
*/
public function mysql_result(&$result, $row, $field = false)
{
// Get list if not gotten yet (still PDOStatement)
if (!is_array($result)) {
$result = $result->fetchAll(PDO::FETCH_ASSOC);
}
$counter = count($result);
for ($x = 0; $x < $counter; $x++) {
if ($x == $row) {
if ($field === false) {
return current($result[$row]);
} else {
return $result[$row][$field];
}
}
}
return '';
}
/**
* mysql_list_processes
* http://www.php.net/manual/en/function.mysql-list-processes.php
*/
public function mysql_list_processes($link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->query("SHOW PROCESSLIST");
}
/**
* mysql_set_charset
* http://www.php.net/manual/en/function.mysql-set-charset.php
*/
public function mysql_set_charset($charset, $link = false)
{
$link = $this->_getLastLink($link);
$set = "SET character_set_results = '$charset', character_set_client = '$charset', character_set_connection = '$charset', character_set_database = '$charset', character_set_server = '$charset'";
return $this->_instances[$link]->query($set);
}
/**
* mysql_insert_id
* http://www.php.net/manual/en/function.mysql-insert-id.php
*/
public function mysql_insert_id($link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->lastInsertId();
}
/**
* mysql_list_fields
* http://www.php.net/manual/en/function.mysql-list-fields.php
*/
public function mysql_list_fields($databaseName, $tableName, $link = false)
{
$link = $this->_getLastLink($link);
return $this->_instances[$link]->query("SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = '$databaseName' AND TABLE_NAME = '$tableName'")->fetchAll();
}
/**
* mysql_errno
* http://www.php.net/manual/en/function.mysql-errno.php
*/
public function mysql_errno($link = false)
{
$link = $this->_getLastLink($link, false);
return $this->_params[$link]['errno'];
}
/**
* mysql_error
* http://www.php.net/manual/en/function.mysql-error.php
*/
public function mysql_error($link = false)
{
$link = $this->_getLastLink($link, false);
return $this->_params[$link]['error'];
}
/**
* mysql_real_escape_string
* http://www.php.net/manual/en/function.mysql-real-escape-string.php
*/
public function mysql_real_escape_string($string, $link = false)
{
$link = $this->_getLastLink($link);
try {
$string = $this->_instances[$link]->quote($string);
$this->_loadError($link, false);
return substr($string, 1, -1);
} catch (PDOException $e) {
$this->_loadError($link, $e);
return false;
}
return false;
}
/**
* mysql_escape_string
* http://www.php.net/manual/en/function.mysql-escape-string.php
*/
public function mysql_escape_string($string, $link = false)
{
$link = $this->_getLastLink($link, false);
return $this->mysql_real_escape_string($string, $link);
}
/**
* mysql_info
*
* Not sure how to get the actual result message from MySQL
* so the best I could do was to get the affected rows
* and construct a message that way. If you have a better way
* or know of a more accurate method, send it to me @
* azizsaleh@gmail.com and I'll update the code with it. All I got is
* the affected rows, so it will be missing changed, warnings,
* skipped, and rows matched
*
* http://www.php.net/manual/en/function.mysql-escape-string.php
*/
public function mysql_info($link = false)
{
$link = $this->_getLastLink($link);
$query = $this->_params[$link]['lastQuery'];
if (!isset($query->queryString)) {
return false;
}
$affected = $this->_params[$link]['rowCount'];
if (strtoupper(substr($query->queryString, 0, 5)) == 'INSERT INTO') {
return "Records: {$affected} Duplicates: 0 Warnings: 0";
}
if (strtoupper(substr($query->queryString, 0, 9)) == 'LOAD DATA') {
return "Records: {$affected} Deleted: 0 Skipped: 0 Warnings: 0";
}
if (strtoupper(substr($query->queryString, 0, 11)) == 'ALTER TABLE') {
return "Records: {$affected} Duplicates: 0 Warnings: 0";
}
if (strtoupper(substr($query->queryString, 0, 6)) == 'UPDATE') {
return "Rows matched: {$affected} Changed: {$affected} Warnings: 0";
}
if (strtoupper(substr($query->queryString, 0, 6)) == 'DELETE') {
return "Records: 0 Deleted: {$affected} Skipped: 0 Warnings: 0";
}
return false;
}
/**
* Close all connections
*
* @return void
*/
public function mysql_close_all()
{
// Free connections
foreach ($this->_instances as $id => $pdo) {
$this->_instances[$id] = null;
}
// Reset arrays
$this->_instances = array(array());
$this->_params = array();
}
/**
* is_resource function over ride
*
* @param RESOURCE $resource
*
* @return boolean
*/
public function is_resource($resource)
{
// Check for a mysql result
if (is_object($resource) && $resource instanceof PDOStatement) {
return true;
// Check if it is a mysql instance
} else if (isset($this->_instances[$resource]) && !empty($this->_instances[$resource])) {
return true;
}
return is_resource($resource);
}
/**
* get_resource_type function over ride
*
* @param RESOURCE $resource
*
* @return boolean
*/
public function get_resource_type($resource)
{
// mysql result resource type
if (is_object($resource) && $resource instanceof PDOStatement) {
return 'mysql result';
}
// Check if it is a mysql instance
if (isset($this->_instances[$resource]) && !empty($this->_instances[$resource])) {
// Check type
if ($this->_params[$resource]['clientFlags'] == PDO::ATTR_PERSISTENT){
return 'mysql link persistent';
} else {
return 'mysql link';
}
}
return get_resource_type($resource);
}
/**
* Get column meta information
*
* @param object $result
* @param enum|boolean $type flags|name|type|table|len
* @param int $index
*
* @return mixed
*/
protected function _getColumnMeta(&$result, $type, $index)
{
// No index, but seek index
if ($index === false && $this->_nextOffset !== false) {
$index = $this->_nextOffset;
// Reset
$this->_nextOffset = false;
}
// No index, start @ 0 by default
if ($index === false) {
$index = 0;
}
if (is_array($result)) {
return $result[$index][0];
}
$data = $result->getColumnMeta($index);
switch ($type) {
case 'flags':
// Flags in PDO getColumMeta() is incomplete, so we will get flags manually
return $this->_getAllColumnData($data, true);
case 'name':
return $data['name'];
case 'type':
return $this->_mapPdoType($data['native_type']);
case 'table':
return $data['table'];
// Getting all data (mysql_fetch_field)
case false:
// Calculate max_length of all field in the resultset
$rows = $result->fetchAll(PDO::FETCH_NUM);
$counter = count($rows);
$maxLength = 0;
for ($x = 0; $x < $counter; $x++) {
$len = strlen($rows[$x][$index]);
if ($len > $maxLength) {
$maxLength = $len;
}
}
return $this->_getAllColumnData($data, false, $maxLength);
default:
return null;
}
}
/**
* Get all field data, mimick mysql_fetch_field functionality
*
* @param array $data
* @param boolean $simple
* @param int $maxLength
*
* @return object
*/
protected function _getAllColumnData($data, $simple = false, $maxLength = 0)
{
$type = $this->_mapPdoType($data['native_type']);
// for zerofill/unsigned, we do a describe
$query = $this->mysql_query("DESCRIBE `{$data['table']}` `{$data['name']}`");
$typeInner = $this->mysql_fetch_assoc($query);
// Flags
if ($simple === true) {
$string = in_array('not_null', $data['flags']) ? 'not_null' : 'null';
$string .= in_array('primary_key', $data['flags']) ? ' primary_key' : '';
$string .= in_array('unique_key', $data['flags']) ? ' unique_key' : '';
$string .= in_array('multiple_key', $data['flags']) ? ' multiple_key' : '';
$unSigned = strpos($typeInner['Type'], 'unsigned');
if ($unSigned !== false) {
$string .= ' unsigned';
} else {
$string .= strpos($typeInner['Type'], 'signed') !== false ? ' signed' : '';
}
$string .= strpos($typeInner['Type'], 'zerofill') !== false ? ' zerofill' : '';
$string .= isset($typeInner['Extra']) ? ' ' . $typeInner['Extra'] : '';
return $string;
}
$return = array (
'name' => $data['name'],
'table' => $data['table'],
'def' => $typeInner['Default'],
'max_length' => $maxLength,
'not_null' => in_array('not_null', $data['flags']) ? 1 : 0,
'primary_key' => in_array('primary_key', $data['flags']) ? 1 : 0,
'multiple_key' => in_array('multiple_key', $data['flags']) ? 1 : 0,
'unique_key' => in_array('unique_key', $data['flags']) ? 1 : 0,
'numeric' => ($type == 'int') ? 1: 0,
'blob' => ($type == 'blob') ? 1: 0,
'type' => $type,
'unsigned' => strpos($typeInner['Type'], 'unsigned') !== false ? 1 : 0,
'zerofill' => strpos($typeInner['Type'], 'zerofill') !== false ? 1 : 0,
);
return (object) $return;
}
/**
* Map PDO::TYPE_* to MySQL Type
*
* @param int $type PDO::TYPE_*
*
* @return string
*/
protected function _mapPdoType($type)
{
// Types enum defined @ http://lxr.php.net/xref/PHP_5_4/ext/mysqlnd/mysqlnd_enum_n_def.h#271
$type = strtolower($type);
switch ($type) {
case 'tiny':
case 'short':
case 'long':
case 'longlong';
case 'int24':
return 'int';
case 'null':
return null;
case 'varchar':
case 'var_string':
case 'string':
return 'string';
case 'blob':
case 'tiny_blob':
case 'long_blob':
return 'blob';
default:
return $type;
}
}
/**
* For now we handle single flags, future feature
* is to handle multiple flags with pipe |
*
* @param string
*
* @return array
*/
protected function _translateFlags($mysqlFlags)
{
if ($mysqlFlags == false || empty($mysqlFlags)) {
return array();
}
// Array it
if (!is_array($mysqlFlags)) {
$mysqlFlags = array($mysqlFlags);
}
/*
* I am only adding flags that are mappable in PDO
* unfortunatly if you were using MySQL SSL, you will
* need to manually add that flag in using PDO constants
* located here: http://php.net/manual/en/ref.pdo-mysql.php
*/
$pdoParams = array();
foreach ($mysqlFlags as $flag) {
switch ($flag)
{
// CLIENT_FOUND_ROWS (found instead of affected rows)
case 2:
$params = array(PDO::MYSQL_ATTR_FOUND_ROWS => true);
break;
// CLIENT_COMPRESS (can use compression protocol)
case 32:
$params = array(PDO::MYSQL_ATTR_COMPRESS => true);
break;
// CLIENT_LOCAL_FILES (can use load data local)
case 128:
$params = array(PDO::MYSQL_ATTR_LOCAL_INFILE => true);
break;
// CLIENT_IGNORE_SPACE (ignore spaces before '(')
case 256:
$params = array(PDO::MYSQL_ATTR_IGNORE_SPACE => true);
break;
// Persistent connection
case 12:
$params = array(PDO::ATTR_PERSISTENT => true);
break;
}
$pdoParams[] = $params;
}
return $pdoParams;
}
/**
* Load data into array
*
* @param int $link
* @param PDO|PDOException|false $object
*
* @return void
*/
protected function _loadError($link, $object)
{
// Reset errors
if ($object === false || is_null($object)) {
$this->_params[$link]['errno'] = 0;
$this->_params[$link]['error'] = "";
return;
}
// Set error
$this->_params[$link]['errno'] = $object->getCode();
$this->_params[$link]['error'] = $object->getMessage();
}
/**
* get last db connection
*
* @param int $link
* @param boolean $validate
*
* @return int
*/
protected function _getLastLink($link, $validate = true)
{
if ($link === false) {
$link = count($this->_instances);
}
if ($validate === true && !isset($this->_instances[$link]) || empty($this->_instances[$link])) {
if (isset($this->_instances[$link])) {
throw new MySQL2PDOException($this->_params[$link]['error'], $this->_params[$link]['errno']);
} else {
throw new MySQL2PDOException('No db at instance #' . ($link - 1));
}
}
return $link;
}
/**
* Get result set and turn them into lengths
*
* @param array|object|null $resultSet
* @param boolean $elementId
*
* @return array
*/
protected function _mysqlGetLengths(&$resultSet = false, $elementId = false)
{
// If we don't have data
if (empty($resultSet) || is_null($resultSet)) {
if ($elementId === false) {
return null;
}
return 0;
}
// Make sure it is an array
if (!is_array($resultSet)) {
$resultSet = (array) $resultSet;
}
// Return lengths
$resultSet = array_map('strlen', $resultSet);
if ($elementId === false) {
return $resultSet;
}
return $resultSet[$elementId];
}
}
|
Download
