1 files changed, 156 insertions, 0 deletions
diff --git a/core/Db/Adapter/Mysqli.php b/core/Db/Adapter/Mysqli.php
new file mode 100644
index 0000000000..37bb46540f
--- /dev/null
+++ b/core/Db/Adapter/Mysqli.php
@@ -0,0 +1,156 @@
+<?php
+/**
+ * Piwik - Open source web analytics
+ * 
+ * @link http://piwik.org
+ * @license http://www.gnu.org/licenses/gpl-3.0.html Gpl v3 or later
+ * @version $Id$
+ * 
+ * @category Piwik
+ * @package Piwik
+ */
+
+/**
+ * @package Piwik
+ * @subpackage Piwik_Db
+ */
+class Piwik_Db_Adapter_Mysqli extends Zend_Db_Adapter_Mysqli implements Piwik_Db_Adapter_Interface
+{
+	public function __construct($config)
+	{
+		parent::__construct($config);
+	}
+
+	/**
+	 * Reset the configuration variables in this adapter.
+	 */
+	public function resetConfig()
+	{
+		$this->_config = array();
+	}
+
+	/**
+	 * Return default port.
+	 *
+	 * @return int
+	 */
+	public static function getDefaultPort()
+	{
+		return 3306;
+	}
+
+	/**
+	 * Check MySQL version
+	 */
+	public function checkServerVersion()
+	{
+		$serverVersion = $this->getServerVersion();
+                $requiredVersion = Zend_Registry::get('config')->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
+	 */
+	public function checkClientVersion()
+	{
+		$serverVersion = $this->getServerVersion();
+		$clientVersion = $this->getClientVersion();
+		if(version_compare($serverVersion, '5') >= 0
+			&& version_compare($clientVersion, '5') < 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 supports blobs as fields
+	 *
+	 * @return bool
+	 */
+	public function hasBlobDataType()
+	{
+		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;
+		}
+
+		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;
+	}
+
+	/**
+	 * 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;
+	}
+}