/home/joan/000www/repo/spirit/1.0/core/extensions/db/db.php

Ir a la documentación de este archivo.

<?php
require CORE_PATH . 'extensions/db/db_base_interface.php';

require CORE_PATH . 'extensions/db/loader/loader.php';
require CORE_PATH . 'extensions/db/active_record_base/active_record_base.php';

require APP_PATH . 'model_base.php';            
class DbBase 
{
        public $debug = false;

        public $logger;

        static private $raw_connection = null;

        protected static $raw_connections = array();

        public function find($table, $where="1=1", $fields="*", $orderBy="1"){
                ActiveRecord::sql_item_sanizite($table);
                ActiveRecord::sql_sanizite($fields);
                ActiveRecord::sql_sanizite($orderBy);
                $q = $this->query("SELECT $fields FROM $table WHERE $where ORDER BY $orderBy");
                $results = array();
                while($row=$this->fetch_array($q)){
                        $results[] = $row;
                }
                var_dump ($results);
                return $results;
        }

        public function in_query($sql, $type=db::DB_BOTH){
                $q = $this->query($sql);
                $results = array();
                if($q){
                        while($row=$this->fetch_array($q, $type)){
                                $results[] = $row;
                        }
                }
                return $results;
        }

        public function fetch_all($sql, $type=db::DB_BOTH){
                return $this->in_query($sql, $type);
        }

        public function in_query_assoc($sql){
                $q = $this->query($sql);
                $results = array();
                if($q){
                        while($row=$this->fetch_array($q, db::DB_ASSOC)){
                                $results[] = $row;
                        }
                }
                return $results;
        }

        public function in_query_num($sql){
                $q = $this->query($sql);
                $results = array();
                if($q){
                        while($row=$this->fetch_array($q, db::DB_NUM)){
                                $results[] = $row;
                        }
                }
                return $results;
        }

        public function fetch_one($sql){
                $q = $this->query($sql);
                if($q){
                        if($this->num_rows($q)>1){
                                Flash::warning("Una sentencia SQL: \"$sql\" retorno mas de una fila cuando se esperaba una sola");
                        }
                        return $this->fetch_array($q);
                } else {
                        return array();
                }
        }

        public function insert($table, $values, $fields=null){
                $insert_sql = "";
                if(is_array($values)){
                        if(!count($values)){
                                new KumbiaException("Imposible realizar inserci&oacute;n en $table sin datos");
                        }
                        if(is_array($fields)){
                                $insert_sql = "INSERT INTO $table (".join(",", $fields).") VALUES (".join(",", $values).")";
                        } else {
                                $insert_sql = "INSERT INTO $table VALUES (".join(",", $values).")";
                        }
                        return $this->query($insert_sql);
                } else{
                        throw new KumbiaException("El segundo parametro para insert no es un Array");
                }
        }

        public function update($table, $fields, $values, $where_condition=null){
                $update_sql = "UPDATE $table SET ";
                if(count($fields)!=count($values)){
                        throw new KumbiaException('Los n&uacute;mero de valores a actualizar no es el mismo de los campos');
                }
                $i = 0;
                $update_values = array();
                foreach($fields as $field){
                        $update_values[] = $field.' = '.$values[$i];
                        $i++;
                }
                $update_sql.= join(',', $update_values);
                if($where_condition!=null){
                        $update_sql.= " WHERE $where_condition";
                }
                return $this->query($update_sql);
        }

        public function delete($table, $where_condition){
                if(trim($where_condition)){
                        return $this->query("DELETE FROM $table WHERE $where_condition");
                } else {
                        return $this->query("DELETE FROM $table");
                }
        }

        public function begin(){
                return $this->query('BEGIN');
        }


        public function rollback(){
                return $this->query('ROLLBACK');
        }

        public function commit(){
                return $this->query('COMMIT');
        }

        static public function add_quotes($value){
                return "'".addslashes($value)."'";
        }

        protected function log($msg, $type){
                if($this->logger) {
            Logger::log($this->logger, $msg, $type);
                }
        }

        protected function debug($sql){
                if($this->debug){
                        Flash::notice($sql);
                }
        }

        public static function raw_connect($new_connection=false, $database = null){
                if(!$database) {
                        $database = Config::get('config.application.database');
                }
                
                $databases = Config::read('databases.ini');
                $config = $databases[$database];
                
                if(!isset($config['port'])){
                        $config['port'] = 0;
                }
                if(!isset($config['dsn'])){
                        $config['dsn'] = '';
                }
                if(!isset($config['host'])){
                        $config['host'] = '';
                }
                if(!isset($config['username'])){
                        $config['username'] = '';
                }
                if(!isset($config['password'])){
                        $config['password'] = '';
                }

                if(!$new_connection && isset(self::$raw_connections[$database])) {
                        return self::$raw_connections[$database];
                }

                if(isset($config['pdo'])){
                        $dbclass = "DbPDO{$config['type']}";
                        if(!class_exists($dbclass)) {
                                require_once CORE_PATH . 'extensions/db/adapters/pdo.php';
                                require_once CORE_PATH . 'extensions/db/adapters/pdo/' . $config['type'] . '.php';
                        }
                } else {
                        $dbclass = "Db{$config['type']}";
                        if(!class_exists($dbclass)) {
                                require_once CORE_PATH . 'extensions/db/adapters/' . $config['type'] . '.php';
                        }
                }
                if(!class_exists($dbclass)){
                        throw new KumbiaException("No existe la clase {$dbclass}, necesaria para iniciar el adaptador", 0);
                }
                
                $connection = new $dbclass($config);
                
                if(!$new_connection) {
                        self::$raw_connections[$database] = $connection;
                } 
                
                return $connection;
        }
}
return DbLoader::load_driver();

---