diff options
Diffstat (limited to 'core/Db/Adapter/Mysqli.php')
| -rw-r--r-- | core/Db/Adapter/Mysqli.php | 294 |
1 files changed, 145 insertions, 149 deletions
diff --git a/core/Db/Adapter/Mysqli.php b/core/Db/Adapter/Mysqli.php index db38734f81..efb309afa5 100644 --- a/core/Db/Adapter/Mysqli.php +++ b/core/Db/Adapter/Mysqli.php @@ -1,10 +1,10 @@ <?php /** * Piwik - Open source web analytics - * + * * @link http://piwik.org * @license http://www.gnu.org/licenses/gpl-3.0.html GPL v3 or later - * + * * @category Piwik * @package Piwik */ @@ -15,163 +15,159 @@ */ class Piwik_Db_Adapter_Mysqli extends Zend_Db_Adapter_Mysqli implements Piwik_Db_Adapter_Interface { - /** - * Constructor - * - * @param array|Zend_Config $config database configuration - */ - public function __construct($config) - { - // Enable LOAD DATA INFILE - $config['driver_options'][MYSQLI_OPT_LOCAL_INFILE] = true; - parent::__construct($config); - } + /** + * Constructor + * + * @param array|Zend_Config $config database configuration + */ + public function __construct($config) + { + // Enable LOAD DATA INFILE + $config['driver_options'][MYSQLI_OPT_LOCAL_INFILE] = true; + parent::__construct($config); + } - /** - * Reset the configuration variables in this adapter. - */ - public function resetConfig() - { - $this->_config = array(); - } + /** + * Reset the configuration variables in this adapter. + */ + public function resetConfig() + { + $this->_config = array(); + } - /** - * Return default port. - * - * @return int - */ - public static function getDefaultPort() - { - return 3306; - } + /** + * Return default port. + * + * @return int + */ + public static function getDefaultPort() + { + return 3306; + } - /** - * Check MySQL version - * - * @throws Exception - */ - public function checkServerVersion() - { - $serverVersion = $this->getServerVersion(); - $requiredVersion = Piwik_Config::getInstance()->General['minimum_mysql_version']; - if(version_compare($serverVersion, $requiredVersion) === -1) - { - throw new Exception(Piwik_TranslateException('General_ExceptionDatabaseVersion', array('MySQL', $serverVersion, $requiredVersion))); - } - } + /** + * Check MySQL version + * + * @throws Exception + */ + public function checkServerVersion() + { + $serverVersion = $this->getServerVersion(); + $requiredVersion = Piwik_Config::getInstance()->General['minimum_mysql_version']; + if (version_compare($serverVersion, $requiredVersion) === -1) { + throw new Exception(Piwik_TranslateException('General_ExceptionDatabaseVersion', array('MySQL', $serverVersion, $requiredVersion))); + } + } - /** - * Check client version compatibility against database server - * - * @throws Exception - */ - public function checkClientVersion() - { - $serverVersion = $this->getServerVersion(); - $clientVersion = $this->getClientVersion(); - // incompatible change to DECIMAL implementation in 5.0.3 - if(version_compare($serverVersion, '5.0.3') >= 0 - && version_compare($clientVersion, '5.0.3') < 0) - { - throw new Exception(Piwik_TranslateException('General_ExceptionIncompatibleClientServerVersions', array('MySQL', $clientVersion, $serverVersion))); - } - } + /** + * Check client version compatibility against database server + * + * @throws Exception + */ + public function checkClientVersion() + { + $serverVersion = $this->getServerVersion(); + $clientVersion = $this->getClientVersion(); + // incompatible change to DECIMAL implementation in 5.0.3 + if (version_compare($serverVersion, '5.0.3') >= 0 + && version_compare($clientVersion, '5.0.3') < 0 + ) { + throw new Exception(Piwik_TranslateException('General_ExceptionIncompatibleClientServerVersions', array('MySQL', $clientVersion, $serverVersion))); + } + } - /** - * Returns true if this adapter's required extensions are enabled - * - * @return bool - */ - public static function isEnabled() - { - $extensions = @get_loaded_extensions(); - return in_array('mysqli', $extensions); - } + /** + * Returns true if this adapter's required extensions are enabled + * + * @return bool + */ + public static function isEnabled() + { + $extensions = @get_loaded_extensions(); + return in_array('mysqli', $extensions); + } - /** - * Returns true if this adapter supports blobs as fields - * - * @return bool - */ - public function hasBlobDataType() - { - return true; - } + /** + * Returns true if this adapter supports blobs as fields + * + * @return bool + */ + public function hasBlobDataType() + { + return true; + } - /** - * Returns true if this adapter supports bulk loading - * - * @return bool - */ - public function hasBulkLoader() - { - return true; - } + /** + * Returns true if this adapter supports bulk loading + * + * @return bool + */ + public function hasBulkLoader() + { + return true; + } - /** - * Test error number - * - * @param Exception $e - * @param string $errno - * @return bool - */ - public function isErrNo($e, $errno) - { - if(is_null($this->_connection)) - { - if(preg_match('/(?:\[|\s)([0-9]{4})(?:\]|\s)/', $e->getMessage(), $match)) - { - return $match[1] == $errno; - } - return mysqli_connect_errno() == $errno; - } + /** + * Test error number + * + * @param Exception $e + * @param string $errno + * @return bool + */ + public function isErrNo($e, $errno) + { + if (is_null($this->_connection)) { + if (preg_match('/(?:\[|\s)([0-9]{4})(?:\]|\s)/', $e->getMessage(), $match)) { + return $match[1] == $errno; + } + return mysqli_connect_errno() == $errno; + } - return mysqli_errno($this->_connection) == $errno; - } + return mysqli_errno($this->_connection) == $errno; + } - /** - * Execute unprepared SQL query and throw away the result - * - * Workaround some SQL statements not compatible with prepare(). - * See http://framework.zend.com/issues/browse/ZF-1398 - * - * @param string $sqlQuery - * @return int Number of rows affected (SELECT/INSERT/UPDATE/DELETE) - */ - public function exec( $sqlQuery ) - { - $rc = mysqli_query($this->_connection, $sqlQuery); - $rowsAffected = mysqli_affected_rows($this->_connection); - if(!is_bool($rc)) - { - mysqli_free_result($rc); - } - return $rowsAffected; - } + /** + * Execute unprepared SQL query and throw away the result + * + * Workaround some SQL statements not compatible with prepare(). + * See http://framework.zend.com/issues/browse/ZF-1398 + * + * @param string $sqlQuery + * @return int Number of rows affected (SELECT/INSERT/UPDATE/DELETE) + */ + public function exec($sqlQuery) + { + $rc = mysqli_query($this->_connection, $sqlQuery); + $rowsAffected = mysqli_affected_rows($this->_connection); + if (!is_bool($rc)) { + mysqli_free_result($rc); + } + return $rowsAffected; + } - /** - * Is the connection character set equal to utf8? - * - * @return bool - */ - public function isConnectionUTF8() - { - $charset = mysqli_character_set_name($this->_connection); - return $charset === 'utf8'; - } + /** + * Is the connection character set equal to utf8? + * + * @return bool + */ + public function isConnectionUTF8() + { + $charset = mysqli_character_set_name($this->_connection); + return $charset === 'utf8'; + } - /** - * Get client version - * - * @return string - */ - public function getClientVersion() - { - $this->_connect(); - $version = $this->_connection->server_version; - $major = (int) ($version / 10000); - $minor = (int) ($version % 10000 / 100); - $revision = (int) ($version % 100); - return $major . '.' . $minor . '.' . $revision; - } + /** + * Get client version + * + * @return string + */ + public function getClientVersion() + { + $this->_connect(); + $version = $this->_connection->server_version; + $major = (int)($version / 10000); + $minor = (int)($version % 10000 / 100); + $revision = (int)($version % 100); + return $major . '.' . $minor . '.' . $revision; + } } |