portal/patient/fwk/libs/verysimple/DB/DataDriver/MySQLi.php

   1 <?php
   2 /** @package verysimple::DB::DataDriver */
   3 require_once("IDataDriver.php");
   4 require_once("verysimple/DB/ISqlFunction.php");
   5 require_once("verysimple/DB/DatabaseException.php");
   6 require_once("verysimple/DB/DatabaseConfig.php");
   7
   8 /**
   9  * An implementation of IDataDriver that communicates with
  10  * a MySQL server.
  11  * This is one of the native drivers
  12  * supported by Phreeze
  13  *
  14  * @package verysimple::DB::DataDriver
  15  * @author VerySimple Inc. <noreply@verysimple.com>
  16  * @copyright 1997-2010 VerySimple Inc.
  17  * @license http://www.gnu.org/licenses/lgpl.html LGPL
  18  * @version 1.0
  19  */
  20 class DataDriverMySQLi implements IDataDriver
  21 {
  22     /** @var characters that will be escaped */
  23     static $BAD_CHARS = array (
  24             "\\",
  25             "\0",
  26             "\n",
  27             "\r",
  28             "\x1a",
  29             "'",
  30             '"'
  31     );
  32
  33     /** @var characters that will be used to replace bad chars */
  34     static $GOOD_CHARS = array (
  35             "\\\\",
  36             "\\0",
  37             "\\n",
  38             "\\r",
  39             "\Z",
  40             "\'",
  41             '\"'
  42     );
  43
  44     /**
  45      * @inheritdocs
  46      */
  47     function GetServerType()
  48     {
  49         return "MySQLi";
  50     }
  51     function Ping($connection)
  52     {
  53         return mysqli_ping($connection);
  54     }
  55
  56     /**
  57      * @inheritdocs
  58      */
  59     function Open($connectionstring, $database, $username, $password, $charset = '', $bootstrap = '')
  60     {
  61         if (! function_exists("mysqli_connect")) {
  62             throw new DatabaseException('mysqli extension is not enabled on this server.', DatabaseException::$CONNECTION_ERROR);
  63         }
  64
  65             // if the port is provided in the connection string then strip it out and provide it as a separate param
  66         $hostAndPort = explode(":", $connectionstring);
  67         $host = $hostAndPort [0];
  68         $port = count($hostAndPort) > 1 ? $hostAndPort [1] : null;
  69
  70         $connection = mysqli_connect($host, $username, $password, $database, $port);
  71
  72         if (mysqli_connect_errno()) {
  73             throw new DatabaseException("Error connecting to database: " . mysqli_connect_error(), DatabaseException::$CONNECTION_ERROR);
  74         }
  75
  76         if ($charset) {
  77             mysqli_set_charset($connection, $charset);
  78
  79             if (mysqli_connect_errno()) {
  80                 throw new DatabaseException("Unable to set charset: " . mysqli_connect_error(), DatabaseException::$CONNECTION_ERROR);
  81             }
  82         }
  83
  84         if ($bootstrap) {
  85             $statements = explode(';', $bootstrap);
  86             foreach ($statements as $sql) {
  87                 try {
  88                     $this->Execute($connection, $sql);
  89                 } catch (Exception $ex) {
  90                     throw new DatabaseException("problem with bootstrap sql: " . $ex->getMessage(), DatabaseException::$ERROR_IN_QUERY);
  91                 }
  92             }
  93         }
  94
  95         return $connection;
  96     }
  97
  98     /**
  99      * @inheritdocs
 100      */
 101     function Close($connection)
 102     {
 103         @mysqli_close($connection); // ignore warnings
 104     }
 105
 106     /**
 107      * @inheritdocs
 108      */
 109     function Query($connection, $sql)
 110     {
 111         if (! $rs = @mysqli_query($connection, $sql)) {
 112             throw new DatabaseException(mysqli_error($connection), DatabaseException::$ERROR_IN_QUERY);
 113         }
 114
 115         return $rs;
 116     }
 117
 118     /**
 119      * @inheritdocs
 120      */
 121     function Execute($connection, $sql)
 122     {
 123         if (! $result = @mysqli_query($connection, $sql)) {
 124             throw new DatabaseException(mysqli_error($connection), DatabaseException::$ERROR_IN_QUERY);
 125         }
 126
 127         return mysqli_affected_rows($connection);
 128     }
 129
 130     /**
 131      * @inheritdocs
 132      */
 133     function Fetch($connection, $rs)
 134     {
 135         return mysqli_fetch_assoc($rs);
 136     }
 137
 138     /**
 139      * @inheritdocs
 140      */
 141     function GetLastInsertId($connection)
 142     {
 143         return (mysqli_insert_id($connection));
 144     }
 145
 146     /**
 147      * @inheritdocs
 148      */
 149     function GetLastError($connection)
 150     {
 151         return mysqli_error($connection);
 152     }
 153
 154     /**
 155      * @inheritdocs
 156      */
 157     function Release($connection, $rs)
 158     {
 159         mysqli_free_result($rs);
 160     }
 161
 162     /**
 163      * @inheritdocs
 164      * this method currently uses replacement and not mysqli_real_escape_string
 165      * so that a database connection is not necessary in order to escape.
 166      * this way cached queries can be used without connecting to the DB server
 167      */
 168     function Escape($val)
 169     {
 170         return str_replace(self::$BAD_CHARS, self::$GOOD_CHARS, $val);
 171         // return mysqli_real_escape_string($val);
 172     }
 173
 174     /**
 175      * @inheritdocs
 176      */
 177     public function GetQuotedSql($val)
 178     {
 179         if ($val === null) {
 180             return DatabaseConfig::$CONVERT_NULL_TO_EMPTYSTRING ? "''" : 'NULL';
 181         }
 182
 183         if ($val instanceof ISqlFunction) {
 184             return $val->GetQuotedSql($this);
 185         }
 186
 187         return "'" . $this->Escape($val) . "'";
 188     }
 189
 190     /**
 191      * @inheritdocs
 192      */
 193     function GetTableNames($connection, $dbname, $ommitEmptyTables = false)
 194     {
 195         $sql = "SHOW TABLE STATUS FROM `" . $this->Escape($dbname) . "`";
 196         $rs = $this->Query($connection, $sql);
 197
 198         $tables = array ();
 199
 200         while ($row = $this->Fetch($connection, $rs)) {
 201             if ($ommitEmptyTables == false || $rs ['Data_free'] > 0) {
 202                 $tables [] = $row ['Name'];
 203             }
 204         }
 205
 206         return $tables;
 207     }
 208
 209     /**
 210      * @inheritdocs
 211      */
 212     function Optimize($connection, $table)
 213     {
 214         $result = "";
 215         $rs = $this->Query($connection, "optimize table `" . $this->Escape($table) . "`");
 216
 217         while ($row = $this->Fetch($connection, $rs)) {
 218             $tbl = $row ['Table'];
 219             if (! isset($results [$tbl])) {
 220                 $results [$tbl] = "";
 221             }
 222
 223             $result .= trim($results [$tbl] . " " . $row ['Msg_type'] . "=\"" . $row ['Msg_text'] . "\"");
 224         }
 225
 226         return $result;
 227     }
 228
 229     /**
 230      * @inheritdocs
 231      */
 232     function StartTransaction($connection)
 233     {
 234         $this->Execute($connection, "SET AUTOCOMMIT=0");
 235         $this->Execute($connection, "START TRANSACTION");
 236     }
 237
 238     /**
 239      * @inheritdocs
 240      */
 241     function CommitTransaction($connection)
 242     {
 243         $this->Execute($connection, "COMMIT");
 244         $this->Execute($connection, "SET AUTOCOMMIT=1");
 245     }
 246
 247     /**
 248      * @inheritdocs
 249      */
 250     function RollbackTransaction($connection)
 251     {
 252         $this->Execute($connection, "ROLLBACK");
 253         $this->Execute($connection, "SET AUTOCOMMIT=1");
 254     }
 255 }