Subversion Repositories SmartDukaan

<?php
/**
 * SQLite layer for DBO
 *
 * CakePHP(tm) : Rapid Development Framework (http://cakephp.org)
 * Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
 *
 * Licensed under The MIT License
 * For full copyright and license information, please see the LICENSE.txt
 * Redistributions of files must retain the above copyright notice.
 *
 * @copyright     Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
 * @link          http://cakephp.org CakePHP(tm) Project
 * @package       Cake.Model.Datasource.Database
 * @since         CakePHP(tm) v 0.9.0
 * @license       http://www.opensource.org/licenses/mit-license.php MIT License
 */

App::uses('DboSource', 'Model/Datasource');
App::uses('CakeText', 'Utility');

/**
 * DBO implementation for the SQLite3 DBMS.
 *
 * A DboSource adapter for SQLite 3 using PDO
 *
 * @package       Cake.Model.Datasource.Database
 */
class Sqlite extends DboSource {

/**
 * Datasource Description
 *
 * @var string
 */
        public $description = "SQLite DBO Driver";

/**
 * Quote Start
 *
 * @var string
 */
        public $startQuote = '"';

/**
 * Quote End
 *
 * @var string
 */
        public $endQuote = '"';

/**
 * Base configuration settings for SQLite3 driver
 *
 * @var array
 */
        protected $_baseConfig = array(
                'persistent' => false,
                'database' => null,
                'flags' => array()
        );

/**
 * SQLite3 column definition
 *
 * @var array
 */
        public $columns = array(
                'primary_key' => array('name' => 'integer primary key autoincrement'),
                'string' => array('name' => 'varchar', 'limit' => '255'),
                'text' => array('name' => 'text'),
                'integer' => array('name' => 'integer', 'limit' => null, 'formatter' => 'intval'),
                'biginteger' => array('name' => 'bigint', 'limit' => 20),
                'float' => array('name' => 'float', 'formatter' => 'floatval'),
                'decimal' => array('name' => 'decimal', 'formatter' => 'floatval'),
                'datetime' => array('name' => 'datetime', 'format' => 'Y-m-d H:i:s', 'formatter' => 'date'),
                'timestamp' => array('name' => 'timestamp', 'format' => 'Y-m-d H:i:s', 'formatter' => 'date'),
                'time' => array('name' => 'time', 'format' => 'H:i:s', 'formatter' => 'date'),
                'date' => array('name' => 'date', 'format' => 'Y-m-d', 'formatter' => 'date'),
                'binary' => array('name' => 'blob'),
                'boolean' => array('name' => 'boolean')
        );

/**
 * List of engine specific additional field parameters used on table creating
 *
 * @var array
 */
        public $fieldParameters = array(
                'collate' => array(
                        'value' => 'COLLATE',
                        'quote' => false,
                        'join' => ' ',
                        'column' => 'Collate',
                        'position' => 'afterDefault',
                        'options' => array(
                                'BINARY', 'NOCASE', 'RTRIM'
                        )
                ),
        );

/**
 * Connects to the database using config['database'] as a filename.
 *
 * @return bool
 * @throws MissingConnectionException
 */
        public function connect() {
                $config = $this->config;
                $flags = $config['flags'] + array(
                        PDO::ATTR_PERSISTENT => $config['persistent'],
                        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION
                );
                try {
                        $this->_connection = new PDO('sqlite:' . $config['database'], null, null, $flags);
                        $this->connected = true;
                } catch(PDOException $e) {
                        throw new MissingConnectionException(array(
                                'class' => get_class($this),
                                'message' => $e->getMessage()
                        ));
                }
                return $this->connected;
        }

/**
 * Check whether the SQLite extension is installed/loaded
 *
 * @return bool
 */
        public function enabled() {
                return in_array('sqlite', PDO::getAvailableDrivers());
        }

/**
 * Returns an array of tables in the database. If there are no tables, an error is raised and the application exits.
 *
 * @param mixed $data Unused.
 * @return array Array of table names in the database
 */
        public function listSources($data = null) {
                $cache = parent::listSources();
                if ($cache) {
                        return $cache;
                }

                $result = $this->fetchAll("SELECT name FROM sqlite_master WHERE type='table' ORDER BY name;", false);

                if (!$result || empty($result)) {
                        return array();
                }

                $tables = array();
                foreach ($result as $table) {
                        $tables[] = $table[0]['name'];
                }
                parent::listSources($tables);
                return $tables;
        }

/**
 * Returns an array of the fields in given table name.
 *
 * @param Model|string $model Either the model or table name you want described.
 * @return array Fields in table. Keys are name and type
 */
        public function describe($model) {
                $table = $this->fullTableName($model, false, false);
                $cache = parent::describe($table);
                if ($cache) {
                        return $cache;
                }
                $fields = array();
                $result = $this->_execute(
                        'PRAGMA table_info(' . $this->value($table, 'string') . ')'
                );

                foreach ($result as $column) {
                        $column = (array)$column;
                        $default = ($column['dflt_value'] === 'NULL') ? null : trim($column['dflt_value'], "'");

                        $fields[$column['name']] = array(
                                'type' => $this->column($column['type']),
                                'null' => !$column['notnull'],
                                'default' => $default,
                                'length' => $this->length($column['type'])
                        );
                        if ($column['pk'] == 1) {
                                $fields[$column['name']]['key'] = $this->index['PRI'];
                                $fields[$column['name']]['null'] = false;
                                if (empty($fields[$column['name']]['length'])) {
                                        $fields[$column['name']]['length'] = 11;
                                }
                        }
                }

                $result->closeCursor();
                $this->_cacheDescription($table, $fields);
                return $fields;
        }

/**
 * Generates and executes an SQL UPDATE statement for given model, fields, and values.
 *
 * @param Model $model The model instance to update.
 * @param array $fields The fields to update.
 * @param array $values The values to set columns to.
 * @param mixed $conditions array of conditions to use.
 * @return array
 */
        public function update(Model $model, $fields = array(), $values = null, $conditions = null) {
                if (empty($values) && !empty($fields)) {
                        foreach ($fields as $field => $value) {
                                if (strpos($field, $model->alias . '.') !== false) {
                                        unset($fields[$field]);
                                        $field = str_replace($model->alias . '.', "", $field);
                                        $field = str_replace($model->alias . '.', "", $field);
                                        $fields[$field] = $value;
                                }
                        }
                }
                return parent::update($model, $fields, $values, $conditions);
        }

/**
 * Deletes all the records in a table and resets the count of the auto-incrementing
 * primary key, where applicable.
 *
 * @param string|Model $table A string or model class representing the table to be truncated
 * @return bool SQL TRUNCATE TABLE statement, false if not applicable.
 */
        public function truncate($table) {
                if (in_array('sqlite_sequence', $this->listSources())) {
                        $this->_execute('DELETE FROM sqlite_sequence where name=' . $this->startQuote . $this->fullTableName($table, false, false) . $this->endQuote);
                }
                return $this->execute('DELETE FROM ' . $this->fullTableName($table));
        }

/**
 * Converts database-layer column types to basic types
 *
 * @param string $real Real database-layer column type (i.e. "varchar(255)")
 * @return string Abstract column type (i.e. "string")
 */
        public function column($real) {
                if (is_array($real)) {
                        $col = $real['name'];
                        if (isset($real['limit'])) {
                                $col .= '(' . $real['limit'] . ')';
                        }
                        return $col;
                }

                $col = strtolower(str_replace(')', '', $real));
                if (strpos($col, '(') !== false) {
                        list($col) = explode('(', $col);
                }

                $standard = array(
                        'text',
                        'integer',
                        'float',
                        'boolean',
                        'timestamp',
                        'date',
                        'datetime',
                        'time'
                );
                if (in_array($col, $standard)) {
                        return $col;
                }
                if ($col === 'bigint') {
                        return 'biginteger';
                }
                if (strpos($col, 'char') !== false) {
                        return 'string';
                }
                if (in_array($col, array('blob', 'clob'))) {
                        return 'binary';
                }
                if (strpos($col, 'numeric') !== false || strpos($col, 'decimal') !== false) {
                        return 'decimal';
                }
                return 'text';
        }

/**
 * Generate ResultSet
 *
 * @param mixed $results The results to modify.
 * @return void
 */
        public function resultSet($results) {
                $this->results = $results;
                $this->map = array();
                $numFields = $results->columnCount();
                $index = 0;
                $j = 0;

                // PDO::getColumnMeta is experimental and does not work with sqlite3,
                // so try to figure it out based on the querystring
                $querystring = $results->queryString;
                if (stripos($querystring, 'SELECT') === 0 && stripos($querystring, 'FROM') > 0) {
                        $selectpart = substr($querystring, 7);
                        $selects = array();
                        foreach (CakeText::tokenize($selectpart, ',', '(', ')') as $part) {
                                $fromPos = stripos($part, ' FROM ');
                                if ($fromPos !== false) {
                                        $selects[] = trim(substr($part, 0, $fromPos));
                                        break;
                                }
                                $selects[] = $part;
                        }
                } elseif (strpos($querystring, 'PRAGMA table_info') === 0) {
                        $selects = array('cid', 'name', 'type', 'notnull', 'dflt_value', 'pk');
                } elseif (strpos($querystring, 'PRAGMA index_list') === 0) {
                        $selects = array('seq', 'name', 'unique');
                } elseif (strpos($querystring, 'PRAGMA index_info') === 0) {
                        $selects = array('seqno', 'cid', 'name');
                }
                while ($j < $numFields) {
                        if (!isset($selects[$j])) {
                                $j++;
                                continue;
                        }
                        if (preg_match('/\bAS(?!.*\bAS\b)\s+(.*)/i', $selects[$j], $matches)) {
                                $columnName = trim($matches[1], '"');
                        } else {
                                $columnName = trim(str_replace('"', '', $selects[$j]));
                        }

                        if (strpos($selects[$j], 'DISTINCT') === 0) {
                                $columnName = str_ireplace('DISTINCT', '', $columnName);
                        }

                        $metaType = false;
                        try {
                                $metaData = (array)$results->getColumnMeta($j);
                                if (!empty($metaData['sqlite:decl_type'])) {
                                        $metaType = trim($metaData['sqlite:decl_type']);
                                }
                        } catch (Exception $e) {
                        }

                        if (strpos($columnName, '.')) {
                                $parts = explode('.', $columnName);
                                $this->map[$index++] = array(trim($parts[0]), trim($parts[1]), $metaType);
                        } else {
                                $this->map[$index++] = array(0, $columnName, $metaType);
                        }
                        $j++;
                }
        }

/**
 * Fetches the next row from the current result set
 *
 * @return mixed array with results fetched and mapped to column names or false if there is no results left to fetch
 */
        public function fetchResult() {
                if ($row = $this->_result->fetch(PDO::FETCH_NUM)) {
                        $resultRow = array();
                        foreach ($this->map as $col => $meta) {
                                list($table, $column, $type) = $meta;
                                $resultRow[$table][$column] = $row[$col];
                                if ($type === 'boolean' && $row[$col] !== null) {
                                        $resultRow[$table][$column] = $this->boolean($resultRow[$table][$column]);
                                }
                        }
                        return $resultRow;
                }
                $this->_result->closeCursor();
                return false;
        }

/**
 * Returns a limit statement in the correct format for the particular database.
 *
 * @param int $limit Limit of results returned
 * @param int $offset Offset from which to start results
 * @return string SQL limit/offset statement
 */
        public function limit($limit, $offset = null) {
                if ($limit) {
                        $rt = sprintf(' LIMIT %u', $limit);
                        if ($offset) {
                                $rt .= sprintf(' OFFSET %u', $offset);
                        }
                        return $rt;
                }
                return null;
        }

/**
 * Generate a database-native column schema string
 *
 * @param array $column An array structured like the following: array('name'=>'value', 'type'=>'value'[, options]),
 *    where options can be 'default', 'length', or 'key'.
 * @return string
 */
        public function buildColumn($column) {
                $name = $type = null;
                $column += array('null' => true);
                extract($column);

                if (empty($name) || empty($type)) {
                        trigger_error(__d('cake_dev', 'Column name or type not defined in schema'), E_USER_WARNING);
                        return null;
                }

                if (!isset($this->columns[$type])) {
                        trigger_error(__d('cake_dev', 'Column type %s does not exist', $type), E_USER_WARNING);
                        return null;
                }

                $isPrimary = (isset($column['key']) && $column['key'] === 'primary');
                if ($isPrimary && $type === 'integer') {
                        return $this->name($name) . ' ' . $this->columns['primary_key']['name'];
                }
                $out = parent::buildColumn($column);
                if ($isPrimary && $type === 'biginteger') {
                        $replacement = 'PRIMARY KEY';
                        if ($column['null'] === false) {
                                $replacement = 'NOT NULL ' . $replacement;
                        }
                        return str_replace($this->columns['primary_key']['name'], $replacement, $out);
                }
                return $out;
        }

/**
 * Sets the database encoding
 *
 * @param string $enc Database encoding
 * @return bool
 */
        public function setEncoding($enc) {
                if (!in_array($enc, array("UTF-8", "UTF-16", "UTF-16le", "UTF-16be"))) {
                        return false;
                }
                return $this->_execute("PRAGMA encoding = \"{$enc}\"") !== false;
        }

/**
 * Gets the database encoding
 *
 * @return string The database encoding
 */
        public function getEncoding() {
                return $this->fetchRow('PRAGMA encoding');
        }

/**
 * Removes redundant primary key indexes, as they are handled in the column def of the key.
 *
 * @param array $indexes The indexes to build.
 * @param string $table The table name.
 * @return string The completed index.
 */
        public function buildIndex($indexes, $table = null) {
                $join = array();

                $table = str_replace('"', '', $table);
                list($dbname, $table) = explode('.', $table);
                $dbname = $this->name($dbname);

                foreach ($indexes as $name => $value) {

                        if ($name === 'PRIMARY') {
                                continue;
                        }
                        $out = 'CREATE ';

                        if (!empty($value['unique'])) {
                                $out .= 'UNIQUE ';
                        }
                        if (is_array($value['column'])) {
                                $value['column'] = implode(', ', array_map(array(&$this, 'name'), $value['column']));
                        } else {
                                $value['column'] = $this->name($value['column']);
                        }
                        $t = trim($table, '"');
                        $indexname = $this->name($t . '_' . $name);
                        $table = $this->name($table);
                        $out .= "INDEX {$dbname}.{$indexname} ON {$table}({$value['column']});";
                        $join[] = $out;
                }
                return $join;
        }

/**
 * Overrides DboSource::index to handle SQLite index introspection
 * Returns an array of the indexes in given table name.
 *
 * @param string $model Name of model to inspect
 * @return array Fields in table. Keys are column and unique
 */
        public function index($model) {
                $index = array();
                $table = $this->fullTableName($model, false, false);
                if ($table) {
                        $indexes = $this->query('PRAGMA index_list(' . $table . ')');

                        if (is_bool($indexes)) {
                                return array();
                        }
                        foreach ($indexes as $info) {
                                $key = array_pop($info);
                                $keyInfo = $this->query('PRAGMA index_info("' . $key['name'] . '")');
                                foreach ($keyInfo as $keyCol) {
                                        if (!isset($index[$key['name']])) {
                                                $col = array();
                                                if (preg_match('/autoindex/', $key['name'])) {
                                                        $key['name'] = 'PRIMARY';
                                                }
                                                $index[$key['name']]['column'] = $keyCol[0]['name'];
                                                $index[$key['name']]['unique'] = (int)$key['unique'] === 1;
                                        } else {
                                                if (!is_array($index[$key['name']]['column'])) {
                                                        $col[] = $index[$key['name']]['column'];
                                                }
                                                $col[] = $keyCol[0]['name'];
                                                $index[$key['name']]['column'] = $col;
                                        }
                                }
                        }
                }
                return $index;
        }

/**
 * Overrides DboSource::renderStatement to handle schema generation with SQLite-style indexes
 *
 * @param string $type The type of statement being rendered.
 * @param array $data The data to convert to SQL.
 * @return string
 */
        public function renderStatement($type, $data) {
                switch (strtolower($type)) {
                        case 'schema':
                                extract($data);
                                if (is_array($columns)) {
                                        $columns = "\t" . implode(",\n\t", array_filter($columns));
                                }
                                if (is_array($indexes)) {
                                        $indexes = "\t" . implode("\n\t", array_filter($indexes));
                                }
                                return "CREATE TABLE {$table} (\n{$columns});\n{$indexes}";
                        default:
                                return parent::renderStatement($type, $data);
                }
        }

/**
 * PDO deals in objects, not resources, so overload accordingly.
 *
 * @return bool
 */
        public function hasResult() {
                return is_object($this->_result);
        }

/**
 * Generate a "drop table" statement for the given table
 *
 * @param type $table Name of the table to drop
 * @return string Drop table SQL statement
 */
        protected function _dropTable($table) {
                return 'DROP TABLE IF EXISTS ' . $this->fullTableName($table) . ";";
        }

/**
 * Gets the schema name
 *
 * @return string The schema name
 */
        public function getSchemaName() {
                return "main"; // Sqlite Datasource does not support multidb
        }

/**
 * Check if the server support nested transactions
 *
 * @return bool
 */
        public function nestedTransactionSupported() {
                return $this->useNestedTransactions && version_compare($this->getVersion(), '3.6.8', '>=');
        }

}