Created
February 7, 2021 15:12
-
-
Save rasxod/3590c813299dbf174d18e77b60d463ff to your computer and use it in GitHub Desktop.
mysqli_db_simple_ping
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <?php | |
| /** | |
| * DbSimple_Mysql: MySQL database. | |
| * (C) Dk Lab, http://en.dklab.ru | |
| * | |
| * This library is free software; you can redistribute it and/or | |
| * modify it under the terms of the GNU Lesser General Public | |
| * License as published by the Free Software Foundation; either | |
| * version 2.1 of the License, or (at your option) any later version. | |
| * See http://www.gnu.org/copyleft/lesser.html | |
| * | |
| * Placeholders end blobs are emulated. | |
| * | |
| * @author Dmitry Koterov, http://forum.dklab.ru/users/DmitryKoterov/ | |
| * @author Konstantin Zhinko, http://forum.dklab.ru/users/KonstantinGinkoTit/ | |
| * | |
| * @version 2.x $Id: Mysqli.php 247 2008-08-18 21:17:08Z dk $ | |
| */ | |
| require_once __DIR__.'/Database.php'; | |
| /** | |
| * Database class for MySQL. | |
| */ | |
| class DbSimple_Mysqli extends DbSimple_Database | |
| { | |
| var $link; | |
| /** | |
| * constructor(string $dsn) | |
| * Connect to MySQL server. | |
| */ | |
| function __construct($dsn) | |
| { | |
| if (!is_callable("mysqli_connect")) | |
| return $this->_setLastError("-1", "MySQLi extension is not loaded", "mysqli_connect"); | |
| if (!empty($dsn["persist"])) { | |
| if (version_compare(PHP_VERSION, '5.3') < 0) { | |
| return $this->_setLastError("-1", "Persistent connections in MySQLi is allowable since PHP 5.3", "mysqli_connect"); | |
| } else { | |
| $dsn["host"] = "p:".$dsn["host"]; | |
| } | |
| } | |
| if ( isset($dsn['socket']) ) { | |
| // Socket connection | |
| $this->link = mysqli_connect( | |
| null // host | |
| ,empty($dsn['user']) ? 'root' : $dsn['user'] // user | |
| ,empty($dsn['pass']) ? '' : $dsn['pass'] // password | |
| ,preg_replace('{^/}s', '', $dsn['path']) // schema | |
| ,null // port | |
| ,$dsn['socket'] // socket | |
| ); | |
| } else if (isset($dsn['host']) ) { | |
| // Host connection | |
| $this->link = mysqli_connect( | |
| $dsn['host'] | |
| ,empty($dsn['user']) ? 'root' : $dsn['user'] | |
| ,empty($dsn['pass']) ? '' : $dsn['pass'] | |
| ,preg_replace('{^/}s', '', $dsn['path']) | |
| ,empty($dsn['port']) ? null : $dsn['port'] | |
| ); | |
| } else { | |
| return $this->_setDbError('mysqli_connect()'); | |
| } | |
| $this->_resetLastError(); | |
| if (!$this->link) return $this->_setDbError('mysqli_connect()'); | |
| mysqli_set_charset($this->link, isset($dsn['enc']) ? $dsn['enc'] : 'UTF8'); | |
| } | |
| protected function _performEscape($s, $isIdent=false) | |
| { | |
| if (!$isIdent) | |
| return "'" . mysqli_real_escape_string($this->link, $s) . "'"; | |
| else | |
| return "`" . str_replace('`', '``', $s) . "`"; | |
| } | |
| protected function _performNewBlob($blobid=null) | |
| { | |
| return new DbSimple_Mysqli_Blob($this, $blobid); | |
| } | |
| protected function _performGetBlobFieldNames($result) | |
| { | |
| $allFields = mysqli_fetch_fields($result); | |
| $blobFields = array(); | |
| if (!empty($allFields)) | |
| { | |
| foreach ($allFields as $field) | |
| if (stripos($field["type"], "BLOB") !== false) | |
| $blobFields[] = $field["name"]; | |
| } | |
| return $blobFields; | |
| } | |
| protected function _performGetPlaceholderIgnoreRe() | |
| { | |
| return ' | |
| " (?> [^"\\\\]+|\\\\"|\\\\)* " | | |
| \' (?> [^\'\\\\]+|\\\\\'|\\\\)* \' | | |
| ` (?> [^`]+ | ``)* ` | # backticks | |
| /\* .*? \*/ # comments | |
| '; | |
| } | |
| protected function _performTransaction($parameters=null) | |
| { | |
| if( function_exists('mysqli_begin_transaction') ) { | |
| return mysqli_begin_transaction($this->link); | |
| } else { | |
| return mysqli_autocommit($this->link, false); | |
| } | |
| } | |
| protected function _performCommit() | |
| { | |
| return mysqli_commit($this->link); | |
| } | |
| protected function _performRollback() | |
| { | |
| return mysqli_rollback($this->link); | |
| } | |
| protected function _performTransformQuery(&$queryMain, $how) | |
| { | |
| // If we also need to calculate total number of found rows... | |
| switch ($how) | |
| { | |
| // Prepare total calculation (if possible) | |
| case 'CALC_TOTAL': | |
| $m = null; | |
| if (preg_match('/^(\s* SELECT)(.*)/six', $queryMain[0], $m)) | |
| $queryMain[0] = $m[1] . ' SQL_CALC_FOUND_ROWS' . $m[2]; | |
| return true; | |
| // Perform total calculation. | |
| case 'GET_TOTAL': | |
| // Built-in calculation available? | |
| $queryMain = array('SELECT FOUND_ROWS()'); | |
| return true; | |
| } | |
| return false; | |
| } | |
| protected function _performQuery($queryMain) | |
| { | |
| $this->_lastQuery = $queryMain; | |
| $this->_expandPlaceholders($queryMain, false); | |
| $result = mysqli_query($this->link, $queryMain[0]); | |
| if ($result === false) | |
| return $this->_setDbError($queryMain[0]); | |
| if (!is_object($result)) { | |
| if (preg_match('/^\s* INSERT \s+/six', $queryMain[0])) | |
| { | |
| // INSERT queries return generated ID. | |
| return mysqli_insert_id($this->link); | |
| } | |
| // Non-SELECT queries return number of affected rows, SELECT - resource. | |
| return mysqli_affected_rows($this->link); | |
| } | |
| return $result; | |
| } | |
| protected function _performFetch($result) | |
| { | |
| $row = mysqli_fetch_assoc($result); | |
| if (mysqli_error($this->link)) return $this->_setDbError($this->_lastQuery); | |
| if ($row === false) return null; | |
| return $row; | |
| } | |
| protected function _setDbError($query) | |
| { | |
| if ($this->link) { | |
| return $this->_setLastError(mysqli_errno($this->link), mysqli_error($this->link), $query); | |
| } else { | |
| return $this->_setLastError(mysqli_connect_errno(), mysqli_connect_error(), $query); | |
| } | |
| } | |
| } | |
| class DbSimple_Mysqli_Blob implements DbSimple_Blob | |
| { | |
| // MySQL does not support separate BLOB fetching. | |
| private $blobdata = null; | |
| private $curSeek = 0; | |
| public function __construct(&$database, $blobdata=null) | |
| { | |
| $this->blobdata = $blobdata; | |
| $this->curSeek = 0; | |
| } | |
| public function read($len) | |
| { | |
| $p = $this->curSeek; | |
| $this->curSeek = min($this->curSeek + $len, strlen($this->blobdata)); | |
| return substr($this->blobdata, $p, $len); | |
| } | |
| public function write($data) | |
| { | |
| $this->blobdata .= $data; | |
| } | |
| public function close() | |
| { | |
| return $this->blobdata; | |
| } | |
| public function length() | |
| { | |
| return strlen($this->blobdata); | |
| } | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment