| <?php |
| /** |
| * CodeIgniter |
| * |
| * An open source application development framework for PHP 5.2.4 or newer |
| * |
| * NOTICE OF LICENSE |
| * |
| * Licensed under the Open Software License version 3.0 |
| * |
| * This source file is subject to the Open Software License (OSL 3.0) that is |
| * bundled with this package in the files license.txt / license.rst. It is |
| * also available through the world wide web at this URL: |
| * http://opensource.org/licenses/OSL-3.0 |
| * If you did not receive a copy of the license and are unable to obtain it |
| * through the world wide web, please send an email to |
| * licensing@ellislab.com so we can send you a copy immediately. |
| * |
| * @package CodeIgniter |
| * @author EllisLab Dev Team |
| * @copyright Copyright (c) 2008 - 2013, EllisLab, Inc. (http://ellislab.com/) |
| * @license http://opensource.org/licenses/OSL-3.0 Open Software License (OSL 3.0) |
| * @link http://codeigniter.com |
| * @since Version 1.0 |
| * @filesource |
| */ |
| defined('BASEPATH') OR exit('No direct script access allowed'); |
| |
| /** |
| * ODBC Database Adapter Class |
| * |
| * Note: _DB is an extender class that the app controller |
| * creates dynamically based on whether the query builder |
| * class is being used or not. |
| * |
| * @package CodeIgniter |
| * @subpackage Drivers |
| * @category Database |
| * @author EllisLab Dev Team |
| * @link http://codeigniter.com/user_guide/database/ |
| */ |
| class CI_DB_odbc_driver extends CI_DB { |
| |
| /** |
| * Database driver |
| * |
| * @var string |
| */ |
| public $dbdriver = 'odbc'; |
| |
| /** |
| * Database schema |
| * |
| * @var string |
| */ |
| public $schema = 'public'; |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Identifier escape character |
| * |
| * Must be empty for ODBC. |
| * |
| * @var string |
| */ |
| protected $_escape_char = ''; |
| |
| /** |
| * ESCAPE statement string |
| * |
| * @var string |
| */ |
| protected $_like_escape_str = " {escape '%s'} "; |
| |
| /** |
| * ORDER BY random keyword |
| * |
| * @var array |
| */ |
| protected $_random_keyword = array('RND()', 'RND(%d)'); |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Class constructor |
| * |
| * @param array $params |
| * @return void |
| */ |
| public function __construct($params) |
| { |
| parent::__construct($params); |
| |
| // Legacy support for DSN in the hostname field |
| if (empty($this->dsn)) |
| { |
| $this->dsn = $this->hostname; |
| } |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Non-persistent database connection |
| * |
| * @return resource |
| */ |
| public function db_connect() |
| { |
| return @odbc_connect($this->dsn, $this->username, $this->password); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Persistent database connection |
| * |
| * @return resource |
| */ |
| public function db_pconnect() |
| { |
| return @odbc_pconnect($this->dsn, $this->username, $this->password); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Execute the query |
| * |
| * @param string $sql an SQL query |
| * @return resource |
| */ |
| protected function _execute($sql) |
| { |
| return @odbc_exec($this->conn_id, $sql); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Begin Transaction |
| * |
| * @param bool $test_mode |
| * @return bool |
| */ |
| public function trans_begin($test_mode = FALSE) |
| { |
| // When transactions are nested we only begin/commit/rollback the outermost ones |
| if ( ! $this->trans_enabled OR $this->_trans_depth > 0) |
| { |
| return TRUE; |
| } |
| |
| // Reset the transaction failure flag. |
| // If the $test_mode flag is set to TRUE transactions will be rolled back |
| // even if the queries produce a successful result. |
| $this->_trans_failure = ($test_mode === TRUE); |
| |
| return odbc_autocommit($this->conn_id, FALSE); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Commit Transaction |
| * |
| * @return bool |
| */ |
| public function trans_commit() |
| { |
| // When transactions are nested we only begin/commit/rollback the outermost ones |
| if ( ! $this->trans_enabled OR $this->_trans_depth > 0) |
| { |
| return TRUE; |
| } |
| |
| $ret = odbc_commit($this->conn_id); |
| odbc_autocommit($this->conn_id, TRUE); |
| return $ret; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Rollback Transaction |
| * |
| * @return bool |
| */ |
| public function trans_rollback() |
| { |
| // When transactions are nested we only begin/commit/rollback the outermost ones |
| if ( ! $this->trans_enabled OR $this->_trans_depth > 0) |
| { |
| return TRUE; |
| } |
| |
| $ret = odbc_rollback($this->conn_id); |
| odbc_autocommit($this->conn_id, TRUE); |
| return $ret; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Escape String |
| * |
| * @param string $str |
| * @param bool $like Whether or not the string will be used in a LIKE condition |
| * @return string |
| */ |
| public function escape_str($str, $like = FALSE) |
| { |
| if (is_array($str)) |
| { |
| foreach ($str as $key => $val) |
| { |
| $str[$key] = $this->escape_str($val, $like); |
| } |
| |
| return $str; |
| } |
| |
| $str = remove_invisible_characters($str); |
| |
| // escape LIKE condition wildcards |
| if ($like === TRUE) |
| { |
| return str_replace(array($this->_like_escape_chr, '%', '_'), |
| array($this->_like_escape_chr.$this->_like_escape_chr, $this->_like_escape_chr.'%', $this->_like_escape_chr.'_'), |
| $str); |
| } |
| |
| return $str; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Affected Rows |
| * |
| * @return int |
| */ |
| public function affected_rows() |
| { |
| return @odbc_num_rows($this->conn_id); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Insert ID |
| * |
| * @return bool |
| */ |
| public function insert_id() |
| { |
| return ($this->db->db_debug) ? $this->db->display_error('db_unsupported_feature') : FALSE; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Show table query |
| * |
| * Generates a platform-specific query string so that the table names can be fetched |
| * |
| * @param bool $prefix_limit |
| * @return string |
| */ |
| protected function _list_tables($prefix_limit = FALSE) |
| { |
| $sql = "SELECT table_name FROM information_schema.tables WHERE table_schema = '".$this->schema."'"; |
| |
| if ($prefix_limit !== FALSE && $this->dbprefix !== '') |
| { |
| return $sql." AND table_name LIKE '".$this->escape_like_str($this->dbprefix)."%' " |
| .sprintf($this->_like_escape_str, $this->_like_escape_chr); |
| } |
| |
| return $sql; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Show column query |
| * |
| * Generates a platform-specific query string so that the column names can be fetched |
| * |
| * @param string $table |
| * @return string |
| */ |
| protected function _list_columns($table = '') |
| { |
| return 'SHOW COLUMNS FROM '.$table; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Field data query |
| * |
| * Generates a platform-specific query so that the column data can be retrieved |
| * |
| * @param string $table |
| * @return string |
| */ |
| protected function _field_data($table) |
| { |
| return 'SELECT TOP 1 FROM '.$table; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Error |
| * |
| * Returns an array containing code and message of the last |
| * database error that has occured. |
| * |
| * @return array |
| */ |
| public function error() |
| { |
| return array('code' => odbc_error($this->conn_id), 'message' => odbc_errormsg($this->conn_id)); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Update statement |
| * |
| * Generates a platform-specific update string from the supplied data |
| * |
| * @param string $table |
| * @param array $values |
| * @return string |
| */ |
| protected function _update($table, $values) |
| { |
| $this->qb_limit = FALSE; |
| $this->qb_orderby = array(); |
| return parent::_update($table, $values); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Truncate statement |
| * |
| * Generates a platform-specific truncate string from the supplied data |
| * |
| * If the database does not support the TRUNCATE statement, |
| * then this method maps to 'DELETE FROM table' |
| * |
| * @param string $table |
| * @return string |
| */ |
| protected function _truncate($table) |
| { |
| return 'DELETE FROM '.$table; |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Delete statement |
| * |
| * Generates a platform-specific delete string from the supplied data |
| * |
| * @param string $table |
| * @return string |
| */ |
| protected function _delete($table) |
| { |
| $this->qb_limit = FALSE; |
| return parent::_delete($table); |
| } |
| |
| // -------------------------------------------------------------------- |
| |
| /** |
| * Close DB Connection |
| * |
| * @return void |
| */ |
| protected function _close() |
| { |
| @odbc_close($this->conn_id); |
| } |
| |
| } |
| |
| /* End of file odbc_driver.php */ |
| /* Location: ./system/database/drivers/odbc/odbc_driver.php */ |