vendor/doctrine/dbal/lib/Doctrine/DBAL/Driver/SQLAnywhere/SQLAnywhereConnection.php

   1 <?php
   2 /*
   3  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
   4  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
   5  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
   6  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
   7  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
   8  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
   9  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  10  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  11  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  12  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  13  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  14  *
  15  * This software consists of voluntary contributions made by many individuals
  16  * and is licensed under the MIT license. For more information, see
  17  * <http://www.doctrine-project.org>.
  18  */
  19
  20 namespace Doctrine\DBAL\Driver\SQLAnywhere;
  21
  22 use Doctrine\DBAL\Driver\Connection;
  23 use Doctrine\DBAL\Driver\ServerInfoAwareConnection;
  24
  25 /**
  26  * SAP Sybase SQL Anywhere implementation of the Connection interface.
  27  *
  28  * @author Steve Müller <st.mueller@dzh-online.de>
  29  * @link   www.doctrine-project.org
  30  * @since  2.5
  31  */
  32 class SQLAnywhereConnection implements Connection, ServerInfoAwareConnection
  33 {
  34     /**
  35      * @var resource The SQL Anywhere connection resource.
  36      */
  37     private $connection;
  38
  39     /**
  40      * Constructor.
  41      *
  42      * Connects to database with given connection string.
  43      *
  44      * @param string  $dsn        The connection string.
  45      * @param boolean $persistent Whether or not to establish a persistent connection.
  46      *
  47      * @throws SQLAnywhereException
  48      */
  49     public function __construct($dsn, $persistent = false)
  50     {
  51         $this->connection = $persistent ? @sasql_pconnect($dsn) : @sasql_connect($dsn);
  52
  53         if ( ! is_resource($this->connection)) {
  54             throw SQLAnywhereException::fromSQLAnywhereError();
  55         }
  56
  57         // Disable PHP warnings on error.
  58         if ( ! sasql_set_option($this->connection, 'verbose_errors', false)) {
  59             throw SQLAnywhereException::fromSQLAnywhereError($this->connection);
  60         }
  61
  62         // Enable auto committing by default.
  63         if ( ! sasql_set_option($this->connection, 'auto_commit', 'on')) {
  64             throw SQLAnywhereException::fromSQLAnywhereError($this->connection);
  65         }
  66
  67         // Enable exact, non-approximated row count retrieval.
  68         if ( ! sasql_set_option($this->connection, 'row_counts', true)) {
  69             throw SQLAnywhereException::fromSQLAnywhereError($this->connection);
  70         }
  71     }
  72
  73     /**
  74      * {@inheritdoc}
  75      *
  76      * @throws SQLAnywhereException
  77      */
  78     public function beginTransaction()
  79     {
  80         if ( ! sasql_set_option($this->connection, 'auto_commit', 'off')) {
  81             throw SQLAnywhereException::fromSQLAnywhereError($this->connection);
  82         }
  83
  84         return true;
  85     }
  86
  87     /**
  88      * {@inheritdoc}
  89      *
  90      * @throws SQLAnywhereException
  91      */
  92     public function commit()
  93     {
  94         if ( ! sasql_commit($this->connection)) {
  95             throw SQLAnywhereException::fromSQLAnywhereError($this->connection);
  96         }
  97
  98         $this->endTransaction();
  99
 100         return true;
 101     }
 102
 103     /**
 104      * {@inheritdoc}
 105      */
 106     public function errorCode()
 107     {
 108         return sasql_errorcode($this->connection);
 109     }
 110
 111     /**
 112      * {@inheritdoc}
 113      */
 114     public function errorInfo()
 115     {
 116         return sasql_error($this->connection);
 117     }
 118
 119     /**
 120      * {@inheritdoc}
 121      */
 122     public function exec($statement)
 123     {
 124         $stmt = $this->prepare($statement);
 125
 126         $stmt->execute();
 127
 128         return $stmt->rowCount();
 129     }
 130
 131     /**
 132      * {@inheritdoc}
 133      */
 134     public function getServerVersion()
 135     {
 136         return $this->query("SELECT PROPERTY('ProductVersion')")->fetchColumn();
 137     }
 138
 139     /**
 140      * {@inheritdoc}
 141      */
 142     public function lastInsertId($name = null)
 143     {
 144         if (null === $name) {
 145             return sasql_insert_id($this->connection);
 146         }
 147
 148         return $this->query('SELECT ' . $name . '.CURRVAL')->fetchColumn();
 149     }
 150
 151     /**
 152      * {@inheritdoc}
 153      */
 154     public function prepare($prepareString)
 155     {
 156         return new SQLAnywhereStatement($this->connection, $prepareString);
 157     }
 158
 159     /**
 160      * {@inheritdoc}
 161      */
 162     public function query()
 163     {
 164         $args = func_get_args();
 165         $stmt = $this->prepare($args[0]);
 166
 167         $stmt->execute();
 168
 169         return $stmt;
 170     }
 171
 172     /**
 173      * {@inheritdoc}
 174      */
 175     public function quote($input, $type = \PDO::PARAM_STR)
 176     {
 177         if (is_int($input) || is_float($input)) {
 178             return $input;
 179         }
 180
 181         return "'" . sasql_escape_string($this->connection, $input) . "'";
 182     }
 183
 184     /**
 185      * {@inheritdoc}
 186      */
 187     public function requiresQueryForServerVersion()
 188     {
 189         return true;
 190     }
 191
 192     /**
 193      * {@inheritdoc}
 194      *
 195      * @throws SQLAnywhereException
 196      */
 197     public function rollBack()
 198     {
 199         if ( ! sasql_rollback($this->connection)) {
 200             throw SQLAnywhereException::fromSQLAnywhereError($this->connection);
 201         }
 202
 203         $this->endTransaction();
 204
 205         return true;
 206     }
 207
 208     /**
 209      * Ends transactional mode and enables auto commit again.
 210      *
 211      * @throws SQLAnywhereException
 212      *
 213      * @return boolean Whether or not ending transactional mode succeeded.
 214      */
 215     private function endTransaction()
 216     {
 217         if ( ! sasql_set_option($this->connection, 'auto_commit', 'on')) {
 218             throw SQLAnywhereException::fromSQLAnywhereError($this->connection);
 219         }
 220
 221         return true;
 222     }
 223 }