sqlite.php

Ir a la documentación de este archivo.

<?php
class DbSQLite extends DbBase implements DbBaseInterface {

        public $id_connection;

        public $last_result_query;

        private $last_query;

        public $last_error;

        const DB_ASSOC = SQLITE_ASSOC;

        const DB_BOTH = SQLITE_BOTH;

        const DB_NUM = SQLITE_NUM;


        const TYPE_INTEGER = 'INTEGER';

        const TYPE_DATE = 'DATE';

        const TYPE_VARCHAR = 'VARCHAR';

        const TYPE_DECIMAL = 'DECIMAL';

        const TYPE_DATETIME = 'DATETIME';

        const TYPE_CHAR = 'CHAR';
        public function connect($config){

                if(!extension_loaded('sqlite')){
                        throw new KumbiaException('Debe cargar la extensión de PHP llamada sqlite');
                }
                if($this->id_connection = sqlite_open(APP_PATH.'config/sql/'.$config['name'])){
                        return true;
                } else {
                        throw new KumbiaException($this->error('No se puede conectar a la base de datos'));
                }
        }

        function query($sqlQuery){
                $this->debug($sqlQuery);
        if($this->logger){
            Logger::debug($sqlQuery);
        }
                if(!$this->id_connection){
                        $this->connect();
                        if(!$this->id_connection){
                                return false;
                        }
                }
                $this->last_query = $sqlQuery;
                if($resultQuery = @sqlite_query($this->id_connection, $sqlQuery)){
                        $this->last_result_query = $resultQuery;
                        return $resultQuery;
                } else {
                        throw new KumbiaException($this->error(" al ejecutar <em>'$sqlQuery'</em>"));
                }
        }

        function close(){
                if($this->id_connection) {
                        return sqlite_close($this->id_connection);
                } else {
                        return false;
                }
        }

        function fetch_array($resultQuery='', $opt=SQLITE_BOTH){
                if(!$this->id_connection){
                        return false;
                }
                if(!$resultQuery){
                        $resultQuery = $this->last_result_query;
                        if(!$resultQuery){
                                return false;
                        }
                }

                return sqlite_fetch_array($resultQuery, $opt);
        }

        function __construct($config){
                $this->connect($config);
        }

        function num_rows($resultQuery=''){
                if(!$this->id_connection){
                        return false;
                }
                if(!$resultQuery){
                        $resultQuery = $this->last_result_query;
                        if(!$resultQuery){
                                return false;
                        }
                }
                if(($numberRows = sqlite_num_rows($resultQuery))!==false){
                        return $numberRows;
                } else {
                        throw new KumbiaException($this->error());
                }
                return false;
        }

        function field_name($number, $resultQuery=''){
                if(!$this->id_connection){
                        return false;
                }
                if(!$resultQuery){
                        $resultQuery = $this->last_result_query;
                        if(!$resultQuery){
                                return false;
                        }
                }
                if(($fieldName = sqlite_field_name($resultQuery, $number))!==false){
                        return $fieldName;
                } else {
                        throw new KumbiaException($this->error());
                }
                return false;
        }


        function data_seek($number, $resultQuery=''){
                if(!$resultQuery){
                        $resultQuery = $this->last_result_query;
                        if(!$resultQuery){
                                return false;
                        }
                }
                if(($success = sqlite_rewind($resultQuery, $number))!==false){
                        return $success;
                } else {
                        throw new KumbiaException($this->error());
                }
                return false;
        }

        function affected_rows($resultQuery=''){
                if(!$this->id_connection){
                        return false;
                }
                if(!$resultQuery){
                        $resultQuery = $this->last_result_query;
                        if(!$resultQuery){
                                return false;
                        }
                }
                if(($numberRows = pg_affected_rows($resultQuery))!==false){
                        return $numberRows;
                } else {
                        throw new KumbiaException($this->error());
                }
                return false;
        }

        function error($err=''){
                if(!$this->id_connection){
                    $this->last_error = sqlite_last_error() ? sqlite_last_error().$err : "[Error Desconocido en SQLite \"$err\"]";
            if($this->logger){
                Logger::error($this->last_error);
            }
                        return $this->last_error;
                }
                $this->last_error = 'SQLite error: '.sqlite_error_string(sqlite_last_error($this->id_connection));
                $this->last_error.= $err;
        if($this->logger){
            Logger::error($this->last_error);
        }
                return $this->last_error;
        }

        function no_error(){
                if(!$this->id_connection){
                        return false;
                }
                return "0"; //Codigo de Error?
        }

        public function last_insert_id($table='', $primary_key=''){
                if(!$this->id_connection){
                        return false;
                }
                $last_id = $this->fetch_one("SELECT COUNT(*) FROM $table");
                return $last_id[0];
        }

        function table_exists($table, $schema=''){
                $table = addslashes(strtolower($table));
                if(strpos($table, ".")){
                        list($schema, $table) = explode(".", $table);
                }
                $num = $this->fetch_one("SELECT COUNT(*) FROM sqlite_master WHERE name = '$table'");
                return $num[0];
        }

        public function limit($sql){
                $params = Util::getParams(func_get_args());
                $sql_new = $sql;

                if(isset($params['limit']) && is_numeric($params['limit'])){
                        $sql_new.=" LIMIT $params[limit]";
                }

                if(isset($params['offset']) && is_numeric($params['offset'])){
                        $sql_new.=" OFFSET $params[offset]";
                }

                return $sql_new;
        }

        public function drop_table($table, $if_exists=true){
                if($if_exists){
                        if($this->table_exists($table)){
                                return $this->query("DROP TABLE $table");
                        } else {
                                return true;
                        }
                } else {
                        return $this->query("DROP TABLE $table");
                }
        }

        public function create_table($table, $definition, $index=array()){

        }

        public function list_tables(){
                return $this->fetch_all("SELECT name FROM sqlite_master WHERE type='table' ".
                                "UNION ALL SELECT name FROM sqlite_temp_master ".
                                "WHERE type='table' ORDER BY name");
        }

    public function describe_table($table, $schema=''){
        $fields = array();
        $results = $this->fetch_all("PRAGMA table_info($table)");
        //var_dump($results); die();
        foreach($results as $field){
            $fields[] = array(
                "Field" => $field["name"],
                "Type" => $field["type"],
                "Null" => $field["notnull"] == '0' ? "YES" : "NO",
                "Key" => $field['pk'] == 1 ? "PRI" : ""
            );
        }
        return $fields;
    }
}