← Back to branch summary

~pvigo/+junk/owncloud-14.04

« back to all changes in this revision

Viewing changes to share/owncloud/3rdparty/doctrine/dbal/lib/Doctrine/DBAL/Driver/OCI8/OCI8Connection.php

  • Committer: Pablo Vigo
  • Date: 2014-12-15 13:36:46 UTC
  • Revision ID: pvigo@xtec.cat-20141215133646-7d6it90e1dbsijc2
2

Show diffs side-by-side

added added

removed removed

Lines of Context:
share/owncloud/3rdparty/doctrine/dbal/lib/Doctrine/DBAL/Driver/OCI8/OCI8Connection.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\OCI8;
 
21
 
 
22
use Doctrine\DBAL\Platforms\OraclePlatform;
 
23
 
 
24
/**
 
25
 * OCI8 implementation of the Connection interface.
 
26
 *
 
27
 * @since 2.0
 
28
 */
 
29
class OCI8Connection implements \Doctrine\DBAL\Driver\Connection
 
30
{
 
31
    /**
 
32
     * @var resource
 
33
     */
 
34
    protected $dbh;
 
35
 
 
36
    /**
 
37
     * @var int
 
38
     */
 
39
    protected $executeMode = OCI_COMMIT_ON_SUCCESS;
 
40
 
 
41
    /**
 
42
     * Create a Connection to an Oracle Database using oci8 extension.
 
43
     *
 
44
     * @param string $username
 
45
     * @param string $password
 
46
     * @param string $db
 
47
     */
 
48
    public function __construct($username, $password, $db, $charset = null, $sessionMode = OCI_DEFAULT, $persistent = false)
 
49
    {
 
50
        if (!defined('OCI_NO_AUTO_COMMIT')) {
 
51
            define('OCI_NO_AUTO_COMMIT', 0);
 
52
        }
 
53
 
 
54
        $this->dbh = $persistent
 
55
            ? @oci_pconnect($username, $password, $db, $charset, $sessionMode)
 
56
            : @oci_connect($username, $password, $db, $charset, $sessionMode);
 
57
 
 
58
        if ( ! $this->dbh) {
 
59
            throw OCI8Exception::fromErrorInfo(oci_error());
 
60
        }
 
61
    }
 
62
 
 
63
    /**
 
64
     * Create a non-executed prepared statement.
 
65
     *
 
66
     * @param  string $prepareString
 
67
     * @return OCI8Statement
 
68
     */
 
69
    public function prepare($prepareString)
 
70
    {
 
71
        return new OCI8Statement($this->dbh, $prepareString, $this);
 
72
    }
 
73
 
 
74
    /**
 
75
     * @param string $sql
 
76
     * @return OCI8Statement
 
77
     */
 
78
    public function query()
 
79
    {
 
80
        $args = func_get_args();
 
81
        $sql = $args[0];
 
82
        //$fetchMode = $args[1];
 
83
        $stmt = $this->prepare($sql);
 
84
        $stmt->execute();
 
85
        return $stmt;
 
86
    }
 
87
 
 
88
    /**
 
89
     * Quote input value.
 
90
     *
 
91
     * @param mixed $input
 
92
     * @param int $type PDO::PARAM*
 
93
     * @return mixed
 
94
     */
 
95
    public function quote($value, $type=\PDO::PARAM_STR)
 
96
    {
 
97
        if (is_int($value) || is_float($value)) {
 
98
            return $value;
 
99
        }
 
100
        $value = str_replace("'", "''", $value);
 
101
        return "'" . addcslashes($value, "\000\n\r\\\032") . "'";
 
102
    }
 
103
 
 
104
    /**
 
105
     *
 
106
     * @param  string $statement
 
107
     * @return int
 
108
     */
 
109
    public function exec($statement)
 
110
    {
 
111
        $stmt = $this->prepare($statement);
 
112
        $stmt->execute();
 
113
        return $stmt->rowCount();
 
114
    }
 
115
 
 
116
    /**
 
117
     * {@inheritDoc}
 
118
     */
 
119
    public function lastInsertId($name = null)
 
120
    {
 
121
        if ($name === null) {
 
122
            return false;
 
123
        }
 
124
 
 
125
        OraclePlatform::assertValidIdentifier($name);
 
126
 
 
127
        $sql    = 'SELECT ' . $name . '.CURRVAL FROM DUAL';
 
128
        $stmt   = $this->query($sql);
 
129
        $result = $stmt->fetch(\PDO::FETCH_ASSOC);
 
130
 
 
131
        if ($result === false || !isset($result['CURRVAL'])) {
 
132
            throw new OCI8Exception("lastInsertId failed: Query was executed but no result was returned.");
 
133
        }
 
134
 
 
135
        return (int) $result['CURRVAL'];
 
136
    }
 
137
 
 
138
    /**
 
139
     * Return the current execution mode.
 
140
     */
 
141
    public function getExecuteMode()
 
142
    {
 
143
        return $this->executeMode;
 
144
    }
 
145
 
 
146
    /**
 
147
     * Start a transactiom
 
148
     *
 
149
     * Oracle has to explicitly set the autocommit mode off. That means
 
150
     * after connection, a commit or rollback there is always automatically
 
151
     * opened a new transaction.
 
152
     *
 
153
     * @return bool
 
154
     */
 
155
    public function beginTransaction()
 
156
    {
 
157
        $this->executeMode = OCI_NO_AUTO_COMMIT;
 
158
        return true;
 
159
    }
 
160
 
 
161
    /**
 
162
     * @throws OCI8Exception
 
163
     * @return bool
 
164
     */
 
165
    public function commit()
 
166
    {
 
167
        if (!oci_commit($this->dbh)) {
 
168
            throw OCI8Exception::fromErrorInfo($this->errorInfo());
 
169
        }
 
170
        $this->executeMode = OCI_COMMIT_ON_SUCCESS;
 
171
        return true;
 
172
    }
 
173
 
 
174
    /**
 
175
     * @throws OCI8Exception
 
176
     * @return bool
 
177
     */
 
178
    public function rollBack()
 
179
    {
 
180
        if (!oci_rollback($this->dbh)) {
 
181
            throw OCI8Exception::fromErrorInfo($this->errorInfo());
 
182
        }
 
183
        $this->executeMode = OCI_COMMIT_ON_SUCCESS;
 
184
        return true;
 
185
    }
 
186
 
 
187
    public function errorCode()
 
188
    {
 
189
        $error = oci_error($this->dbh);
 
190
        if ($error !== false) {
 
191
            $error = $error['code'];
 
192
        }
 
193
        return $error;
 
194
    }
 
195
 
 
196
    public function errorInfo()
 
197
    {
 
198
        return oci_error($this->dbh);
 
199
    }
 
200
}