From 57a97eba01156c8ad02debae28620e72217b46bc Mon Sep 17 00:00:00 2001 From: romanb Date: Sun, 8 Nov 2009 11:11:46 +0000 Subject: [PATCH] [2.0][DDC-120] First version of OCI8 driver. --- lib/Doctrine/DBAL/Driver/OCI8/Driver.php | 93 +++++++ .../DBAL/Driver/OCI8/OCI8Connection.php | 99 ++++++++ .../DBAL/Driver/OCI8/OCI8Statement.php | 235 ++++++++++++++++++ 3 files changed, 427 insertions(+) create mode 100644 lib/Doctrine/DBAL/Driver/OCI8/Driver.php create mode 100644 lib/Doctrine/DBAL/Driver/OCI8/OCI8Connection.php create mode 100644 lib/Doctrine/DBAL/Driver/OCI8/OCI8Statement.php diff --git a/lib/Doctrine/DBAL/Driver/OCI8/Driver.php b/lib/Doctrine/DBAL/Driver/OCI8/Driver.php new file mode 100644 index 000000000..c62020ba7 --- /dev/null +++ b/lib/Doctrine/DBAL/Driver/OCI8/Driver.php @@ -0,0 +1,93 @@ +. + */ + +namespace Doctrine\DBAL\Driver\OCI8; + +use Doctrine\DBAL\Platforms; + +/** + * A Doctrine DBAL driver for the Oracle OCI8 PHP extensions. + * + * @author Roman Borschel + * @since 2.0 + */ +class Driver implements \Doctrine\DBAL\Driver +{ + public function connect(array $params, $username = null, $password = null, array $driverOptions = array()) + { + return new OCI8Connection( + $username, + $password, + $this->_constructDsn($params) + ); + } + + /** + * Constructs the Oracle DSN. + * + * @return string The DSN. + */ + private function _constructDsn(array $params) + { + $dsn = ''; + if (isset($params['host'])) { + $dsn .= '(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)' . + '(HOST=' . $params['host'] . ')'; + + if (isset($params['port'])) { + $dsn .= '(PORT=' . $params['port'] . ')'; + } else { + $dsn .= '(PORT=1521)'; + } + + $dsn .= '))(CONNECT_DATA=(SID=' . $params['dbname'] . ')))'; + } else { + $dsn .= $params['dbname']; + } + + if (isset($params['charset'])) { + $dsn .= ';charset=' . $params['charset']; + } + + return $dsn; + } + + public function getDatabasePlatform() + { + return new \Doctrine\DBAL\Platforms\OraclePlatform(); + } + + public function getSchemaManager(\Doctrine\DBAL\Connection $conn) + { + return new \Doctrine\DBAL\Schema\OracleSchemaManager($conn); + } + + public function getName() + { + return 'oci8'; + } + + public function getDatabase(\Doctrine\DBAL\Connection $conn) + { + $params = $conn->getParams(); + return $params['user']; + } +} \ No newline at end of file diff --git a/lib/Doctrine/DBAL/Driver/OCI8/OCI8Connection.php b/lib/Doctrine/DBAL/Driver/OCI8/OCI8Connection.php new file mode 100644 index 000000000..7ab8d117b --- /dev/null +++ b/lib/Doctrine/DBAL/Driver/OCI8/OCI8Connection.php @@ -0,0 +1,99 @@ +. + */ + +namespace Doctrine\DBAL\Driver\OCI8; + +/** + * OCI8 implementation of the Connection interface. + * + * @since 2.0 + */ +class OCI8Connection implements \Doctrine\DBAL\Driver\Connection +{ + private $_dbh; + + public function __construct($username, $password, $db) + { + $this->_dbh = oci_connect($username, $password, $db); + } + + public function prepare($prepareString) + { + return new OCI8Statement($this->_dbh, $prepareString); + } + + public function query() + { + $args = func_get_args(); + $sql = $args[0]; + //$fetchMode = $args[1]; + $stmt = $this->prepare($sql); + $stmt->execute(); + return $stmt; + } + + public function quote($input) + { + return is_numeric($input) ? $input : "'$input'"; + } + + public function exec($statement) + { + $stmt = $this->prepare($statement); + $stmt->execute(); + return $stmt->rowCount(); + } + + public function lastInsertId($name = null) + { + //TODO: throw exception or support sequences? + } + + public function beginTransaction() + { + return true; + } + + public function commit() + { + return oci_commit($this->_dbh); + } + + public function rollBack() + { + return oci_rollback($this->_dbh); + } + + public function errorCode() + { + $error = oci_error($this->_dbh); + if ($error !== false) { + $error = $error['code']; + } + return $error; + } + + public function errorInfo() + { + return oci_error($this->_dbh); + } + +} \ No newline at end of file diff --git a/lib/Doctrine/DBAL/Driver/OCI8/OCI8Statement.php b/lib/Doctrine/DBAL/Driver/OCI8/OCI8Statement.php new file mode 100644 index 000000000..55c03d975 --- /dev/null +++ b/lib/Doctrine/DBAL/Driver/OCI8/OCI8Statement.php @@ -0,0 +1,235 @@ +. + */ + +namespace Doctrine\DBAL\Driver\OCI8; + +use Doctrine\DBAL\Connection; + +/** + * The OCI8 implementation of the Statement interface. + * + * @since 2.0 + * @author Roman Borschel + */ +class OCI8Statement implements \Doctrine\DBAL\Driver\Statement +{ + /** Statement handle. */ + private $_sth; + private $_paramCounter = 0; + private static $_PARAM = ':param'; + private static $fetchStyleMap = array( + Connection::FETCH_BOTH => OCI_BOTH, + Connection::FETCH_ASSOC => OCI_ASSOC, + Connection::FETCH_NUM => OCI_NUM + ); + private $_paramMap = array(); + + public function __construct($dbh, $statement) + { + $this->_sth = oci_parse($dbh, $this->_convertPositionalToNamedPlaceholders($statement)); + } + + private function _convertPositionalToNamedPlaceholders($statement) + { + $count = 1; + while (($pos = strpos($statement, '?')) !== false) { + $this->_paramMap[$count] = ":param$count"; + $statement = substr_replace($statement, ":param$count", $pos, 1); + ++$count; + } + + return $statement; + } + + /** + * {@inheritdoc} + */ + public function bindColumn($column, &$param, $type = null) + { + return oci_define_by_name($this->_sth, strtoupper($column), $param, $type); + } + + /** + * {@inheritdoc} + */ + public function bindValue($param, $value, $type = null) + { + return $this->bindParam($param, $value, $type); + } + + /** + * {@inheritdoc} + */ + public function bindParam($column, &$variable, $type = null, $length = null, $driverOptions = array()) + { + $column = isset($this->_paramMap[$column]) ? $this->_paramMap[$column] : $column; + + return oci_bind_by_name($this->_sth, $column, $variable); + } + + /** + * Closes the cursor, enabling the statement to be executed again. + * + * @return boolean Returns TRUE on success or FALSE on failure. + */ + public function closeCursor() + { + return oci_free_statement($this->_sth); + } + + /** + * {@inheritdoc} + */ + public function columnCount() + { + return oci_num_fields($this->_sth); + } + + /** + * {@inheritdoc} + */ + public function errorCode() + { + $error = oci_error($this->_sth); + if ($error !== false) { + $error = $error['code']; + } + return $error; + } + + /** + * {@inheritdoc} + */ + public function errorInfo() + { + return oci_error($this->_sth); + } + + /** + * {@inheritdoc} + */ + public function execute($params = array()) + { + $hasZeroIndex = isset($params[0]); + foreach ($params as $key => $val) { + if ($hasZeroIndex && is_numeric($key)) { + $this->bindValue($key + 1, $val); + } else { + $this->bindValue($key, $val); + } + } + + return oci_execute($this->_sth, OCI_DEFAULT); + } + + /** + * {@inheritdoc} + */ + public function fetch($fetchStyle = Connection::FETCH_BOTH, $cursorOrientation = \PDO::FETCH_ORI_NEXT, $cursorOffset = 0) + { + if ( ! isset(self::$fetchStyleMap[$fetchStyle])) { + throw new \InvalidArgumentException("Invalid fetch style: " . $fetchStyle); + } + + return oci_fetch_array($this->_sth, self::$fetchStyleMap[$fetchStyle] | OCI_RETURN_NULLS); + } + + /** + * {@inheritdoc} + */ + public function fetchAll($fetchStyle = Connection::FETCH_BOTH) + { + if ( ! isset(self::$fetchStyleMap[$fetchStyle])) { + throw new \InvalidArgumentException("Invalid fetch style: " . $fetchStyle); + } + + $result = array(); + oci_fetch_all($this->_sth, $result, 0, -1, self::$fetchStyleMap[$fetchStyle] | OCI_RETURN_NULLS | OCI_FETCHSTATEMENT_BY_ROW); + + return $result; + } + + /** + * {@inheritdoc} + */ + public function fetchColumn($columnIndex = 0) + { + $row = oci_fetch_row($this->_sth); + return $row[$columnIndex]; + } + + /** + * {@inheritdoc} + */ + public function fetchObject($className = 'stdClass', $args = array()) + { + throw new \Exception(__METHOD__ . " not supported."); + } + + /** + * {@inheritdoc} + */ + public function getAttribute($attribute) + { + throw new \Exception(__METHOD__ . " not supported."); + } + + /** + * {@inheritdoc} + */ + public function getColumnMeta($column) + { + throw new \Exception(__METHOD__ . " not supported."); + } + + /** + * {@inheritdoc} + */ + public function nextRowset() + { + throw new \Exception(__METHOD__ . " not supported."); + } + + /** + * {@inheritdoc} + */ + public function rowCount() + { + return oci_num_rows($this->_sth); + } + + /** + * {@inheritdoc} + */ + public function setAttribute($attribute, $value) + { + throw new \Exception(__METHOD__ . " not supported."); + } + + /** + * {@inheritdoc} + */ + public function setFetchMode($mode, $arg1) + { + throw new \Exception(__METHOD__ . " not supported."); + } + +} \ No newline at end of file