db_base.php

Ir a la documentación de este archivo.

<?php
class DbBase 
{
        public $debug = false;

        public $logger = false;

        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;
                }
                return $results;
        }

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

        public function fetch_all($sql){
                return $this->in_query($sql);
        }

        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);
                }
        }
}