db_base.php

Ir a la documentación de este archivo.

<?php
class DbBase
{

    public $debug = false;
    public $logger = false;
    protected $last_query;

    public function find($table, $where="1=1", $fields="*", $orderBy="1")
    {
        ActiveRecord::sql_item_sanitize($table);
        ActiveRecord::sql_sanitize($fields);
        ActiveRecord::sql_sanitize($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::info($sql);
        }
    }
    
    public function query($sql)
    {
    }
    
    public function fetch_array($resultQuery = NULL, $opt = '')
    {
    }
}