You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							350 lines
						
					
					
						
							8.4 KiB
						
					
					
				
			
		
		
	
	
							350 lines
						
					
					
						
							8.4 KiB
						
					
					
				<?php | 
						|
/** | 
						|
 * CodeIgniter | 
						|
 * | 
						|
 * An open source application development framework for PHP | 
						|
 * | 
						|
 * This content is released under the MIT License (MIT) | 
						|
 * | 
						|
 * Copyright (c) 2014 - 2016, British Columbia Institute of Technology | 
						|
 * | 
						|
 * Permission is hereby granted, free of charge, to any person obtaining a copy | 
						|
 * of this software and associated documentation files (the "Software"), to deal | 
						|
 * in the Software without restriction, including without limitation the rights | 
						|
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | 
						|
 * copies of the Software, and to permit persons to whom the Software is | 
						|
 * furnished to do so, subject to the following conditions: | 
						|
 * | 
						|
 * The above copyright notice and this permission notice shall be included in | 
						|
 * all copies or substantial portions of the Software. | 
						|
 * | 
						|
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | 
						|
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | 
						|
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | 
						|
 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | 
						|
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | 
						|
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN | 
						|
 * THE SOFTWARE. | 
						|
 * | 
						|
 * @package	CodeIgniter | 
						|
 * @author	EllisLab Dev Team | 
						|
 * @copyright	Copyright (c) 2008 - 2014, EllisLab, Inc. (https://ellislab.com/) | 
						|
 * @copyright	Copyright (c) 2014 - 2016, British Columbia Institute of Technology (http://bcit.ca/) | 
						|
 * @license	http://opensource.org/licenses/MIT	MIT License | 
						|
 * @link	https://codeigniter.com | 
						|
 * @since	Version 3.0.0 | 
						|
 * @filesource | 
						|
 */ | 
						|
defined('BASEPATH') OR exit('No direct script access allowed'); | 
						|
 | 
						|
/** | 
						|
 * SQLite3 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		Andrey Andreev | 
						|
 * @link		https://codeigniter.com/user_guide/database/ | 
						|
 */ | 
						|
class CI_DB_sqlite3_driver extends CI_DB { | 
						|
 | 
						|
	/** | 
						|
	 * Database driver | 
						|
	 * | 
						|
	 * @var	string | 
						|
	 */ | 
						|
	public $dbdriver = 'sqlite3'; | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * ORDER BY random keyword | 
						|
	 * | 
						|
	 * @var	array | 
						|
	 */ | 
						|
	protected $_random_keyword = array('RANDOM()', 'RANDOM()'); | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Non-persistent database connection | 
						|
	 * | 
						|
	 * @param	bool	$persistent | 
						|
	 * @return	SQLite3 | 
						|
	 */ | 
						|
	public function db_connect($persistent = FALSE) | 
						|
	{ | 
						|
		if ($persistent) | 
						|
		{ | 
						|
			log_message('debug', 'SQLite3 doesn\'t support persistent connections'); | 
						|
		} | 
						|
 | 
						|
		try | 
						|
		{ | 
						|
			return ( ! $this->password) | 
						|
				? new SQLite3($this->database) | 
						|
				: new SQLite3($this->database, SQLITE3_OPEN_READWRITE | SQLITE3_OPEN_CREATE, $this->password); | 
						|
		} | 
						|
		catch (Exception $e) | 
						|
		{ | 
						|
			return FALSE; | 
						|
		} | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Database version number | 
						|
	 * | 
						|
	 * @return	string | 
						|
	 */ | 
						|
	public function version() | 
						|
	{ | 
						|
		if (isset($this->data_cache['version'])) | 
						|
		{ | 
						|
			return $this->data_cache['version']; | 
						|
		} | 
						|
 | 
						|
		$version = SQLite3::version(); | 
						|
		return $this->data_cache['version'] = $version['versionString']; | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Execute the query | 
						|
	 * | 
						|
	 * @todo	Implement use of SQLite3::querySingle(), if needed | 
						|
	 * @param	string	$sql | 
						|
	 * @return	mixed	SQLite3Result object or bool | 
						|
	 */ | 
						|
	protected function _execute($sql) | 
						|
	{ | 
						|
		return $this->is_write_type($sql) | 
						|
			? $this->conn_id->exec($sql) | 
						|
			: $this->conn_id->query($sql); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Begin Transaction | 
						|
	 * | 
						|
	 * @return	bool | 
						|
	 */ | 
						|
	protected function _trans_begin() | 
						|
	{ | 
						|
		return $this->conn_id->exec('BEGIN TRANSACTION'); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Commit Transaction | 
						|
	 * | 
						|
	 * @return	bool | 
						|
	 */ | 
						|
	protected function _trans_commit() | 
						|
	{ | 
						|
		return $this->conn_id->exec('END TRANSACTION'); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Rollback Transaction | 
						|
	 * | 
						|
	 * @return	bool | 
						|
	 */ | 
						|
	protected function _trans_rollback() | 
						|
	{ | 
						|
		return $this->conn_id->exec('ROLLBACK'); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Platform-dependant string escape | 
						|
	 * | 
						|
	 * @param	string | 
						|
	 * @return	string | 
						|
	 */ | 
						|
	protected function _escape_str($str) | 
						|
	{ | 
						|
		return $this->conn_id->escapeString($str); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Affected Rows | 
						|
	 * | 
						|
	 * @return	int | 
						|
	 */ | 
						|
	public function affected_rows() | 
						|
	{ | 
						|
		return $this->conn_id->changes(); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Insert ID | 
						|
	 * | 
						|
	 * @return	int | 
						|
	 */ | 
						|
	public function insert_id() | 
						|
	{ | 
						|
		return $this->conn_id->lastInsertRowID(); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * 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) | 
						|
	{ | 
						|
		return 'SELECT "NAME" FROM "SQLITE_MASTER" WHERE "TYPE" = \'table\'' | 
						|
			.(($prefix_limit !== FALSE && $this->dbprefix != '') | 
						|
				? ' AND "NAME" LIKE \''.$this->escape_like_str($this->dbprefix).'%\' '.sprintf($this->_like_escape_str, $this->_like_escape_chr) | 
						|
				: ''); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Fetch Field Names | 
						|
	 * | 
						|
	 * @param	string	$table	Table name | 
						|
	 * @return	array | 
						|
	 */ | 
						|
	public function list_fields($table) | 
						|
	{ | 
						|
		// Is there a cached result? | 
						|
		if (isset($this->data_cache['field_names'][$table])) | 
						|
		{ | 
						|
			return $this->data_cache['field_names'][$table]; | 
						|
		} | 
						|
 | 
						|
		if (($result = $this->query('PRAGMA TABLE_INFO('.$this->protect_identifiers($table, TRUE, NULL, FALSE).')')) === FALSE) | 
						|
		{ | 
						|
			return FALSE; | 
						|
		} | 
						|
 | 
						|
		$this->data_cache['field_names'][$table] = array(); | 
						|
		foreach ($result->result_array() as $row) | 
						|
		{ | 
						|
			$this->data_cache['field_names'][$table][] = $row['name']; | 
						|
		} | 
						|
 | 
						|
		return $this->data_cache['field_names'][$table]; | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Returns an object with field data | 
						|
	 * | 
						|
	 * @param	string	$table | 
						|
	 * @return	array | 
						|
	 */ | 
						|
	public function field_data($table) | 
						|
	{ | 
						|
		if (($query = $this->query('PRAGMA TABLE_INFO('.$this->protect_identifiers($table, TRUE, NULL, FALSE).')')) === FALSE) | 
						|
		{ | 
						|
			return FALSE; | 
						|
		} | 
						|
 | 
						|
		$query = $query->result_array(); | 
						|
		if (empty($query)) | 
						|
		{ | 
						|
			return FALSE; | 
						|
		} | 
						|
 | 
						|
		$retval = array(); | 
						|
		for ($i = 0, $c = count($query); $i < $c; $i++) | 
						|
		{ | 
						|
			$retval[$i]			= new stdClass(); | 
						|
			$retval[$i]->name		= $query[$i]['name']; | 
						|
			$retval[$i]->type		= $query[$i]['type']; | 
						|
			$retval[$i]->max_length		= NULL; | 
						|
			$retval[$i]->default		= $query[$i]['dflt_value']; | 
						|
			$retval[$i]->primary_key	= isset($query[$i]['pk']) ? (int) $query[$i]['pk'] : 0; | 
						|
		} | 
						|
 | 
						|
		return $retval; | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Error | 
						|
	 * | 
						|
	 * Returns an array containing code and message of the last | 
						|
	 * database error that has occured. | 
						|
	 * | 
						|
	 * @return	array | 
						|
	 */ | 
						|
	public function error() | 
						|
	{ | 
						|
		return array('code' => $this->conn_id->lastErrorCode(), 'message' => $this->conn_id->lastErrorMsg()); | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Replace statement | 
						|
	 * | 
						|
	 * Generates a platform-specific replace string from the supplied data | 
						|
	 * | 
						|
	 * @param	string	$table	Table name | 
						|
	 * @param	array	$keys	INSERT keys | 
						|
	 * @param	array	$values	INSERT values | 
						|
	 * @return	string | 
						|
	 */ | 
						|
	protected function _replace($table, $keys, $values) | 
						|
	{ | 
						|
		return 'INSERT OR '.parent::_replace($table, $keys, $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; | 
						|
	} | 
						|
 | 
						|
	// -------------------------------------------------------------------- | 
						|
 | 
						|
	/** | 
						|
	 * Close DB Connection | 
						|
	 * | 
						|
	 * @return	void | 
						|
	 */ | 
						|
	protected function _close() | 
						|
	{ | 
						|
		$this->conn_id->close(); | 
						|
	} | 
						|
 | 
						|
}
 | 
						|
 |