mirror of
https://github.com/kamilwylegala/cakephp2-php8.git
synced 2025-01-31 17:16:18 +00:00
93a6fd5648
When using subqueries or joining against tables containing FROM the results were bizzare and unexpected. By tokenizing the entire query we can more accurately grab the fields. Refs #3972
585 lines
16 KiB
PHP
585 lines
16 KiB
PHP
<?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('String', '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 = String::tokenize($selectpart, ',', '(', ')');
|
|
$last = count($selects) - 1;
|
|
$selects[$last] = trim(substr($selects[$last], 0, stripos($selects[$last], 'FROM')));
|
|
} 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\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', '>=');
|
|
}
|
|
|
|
}
|