kj/duckbrain
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

- Add option for reset query or not at get, getFirts, buildQuery and count

Browse Source 
- Add sql_calc_found_rows method.
- Add found_rows method.
- Improve count method usind sql_calc_found_rows and found_rows.
This commit is contained in:
kj 2021-08-14 17:30:03 -04:00
parent 9785954870
commit e3b97601e2
1 changed files with 185 additions and 148 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

333
src/Libs/ModelMySQL.php
View File

@ -1,7 +1,7 @@
<?php <?php
/* /*
* DuckBrain - Microframework * DuckBrain - Microframework
* *
* Modelo ORM para objetos que hagan uso de una base de datos MySQL. * Modelo ORM para objetos que hagan uso de una base de datos MySQL.
* Depende de que exista Libs\Database para poder funcionar. * Depende de que exista Libs\Database para poder funcionar.
* *
@ -15,10 +15,10 @@ namespace Libs;
use Libs\Database; use Libs\Database;
class ModelMySQL { class ModelMySQL {
public $id; public $id;
protected $toNull = []; protected $toNull = [];
static protected $primaryKey = 'id'; static protected $primaryKey = 'id';
static protected $ignoreSave = ['id']; static protected $ignoreSave = ['id'];
static protected $forceSave = []; static protected $forceSave = [];
@ -26,20 +26,21 @@ class ModelMySQL {
static protected $tableSufix = 's'; static protected $tableSufix = 's';
static protected $db; static protected $db;
static protected $querySelect = [ static protected $querySelect = [
'select' => ['*'], 'select' => ['*'],
'where' => '', 'where' => '',
'from' => '', 'from' => '',
'leftJoin' => '', 'leftJoin' => '',
'rightJoin' => '', 'rightJoin' => '',
'innerJoin' => '', 'innerJoin' => '',
'AndOr' => '', 'AndOr' => '',
'orderBy' => '', 'orderBy' => '',
'groupBy' => '', 'groupBy' => '',
'limit' => '', 'limit' => '',
'sql_calc_found_rows' => false
]; ];
/* /*
* Sirve para obtener la instancia de la base de datos * Sirve para obtener la instancia de la base de datos
* *
* @return mysqli * @return mysqli
*/ */
@ -49,7 +50,7 @@ class ModelMySQL {
return static::$db; return static::$db;
} }
/* /*
* Ejecuta una sentencia SQL en la base de datos. * Ejecuta una sentencia SQL en la base de datos.
* *
@ -64,7 +65,7 @@ class ModelMySQL {
*/ */
protected static function query($query) { protected static function query($query) {
$db = static::db(); $db = static::db();
$result = $db->query($query); $result = $db->query($query);
if ($db->errno) { if ($db->errno) {
echo '<style>body{white-space: pre-line;}</style>'; echo '<style>body{white-space: pre-line;}</style>';
@ -75,38 +76,45 @@ class ModelMySQL {
"Query: $query\n" "Query: $query\n"
); );
} }
return $result; return $result;
} }
/* /*
* Reinicia la configuración de la sentencia SQL. * Reinicia la configuración de la sentencia SQL.
*/ */
protected static function resetQuery() { protected static function resetQuery() {
static::$querySelect = [ static::$querySelect = [
'select' => ['*'], 'select' => ['*'],
'where' => '', 'where' => '',
'from' => '', 'from' => '',
'leftJoin' => '', 'leftJoin' => '',
'rightJoin' => '', 'rightJoin' => '',
'innerJoin' => '', 'innerJoin' => '',
'AndOr' => '', 'AndOr' => '',
'orderBy' => '', 'orderBy' => '',
'groupBy' => '', 'groupBy' => '',
'limit' => '', 'limit' => '',
'sql_calc_found_rows' => false
]; ];
} }
/* /*
* Construye la sentencia SQL a partir static::$querySelect y una vez * Construye la sentencia SQL a partir static::$querySelect y una vez
* construída, llama a resetQuery. * construída, llama a resetQuery.
* *
* @param boolean $resetQuery
* Indica si el query debe reiniciarse o no (por defecto es true).
*
* @return string * @return string
* Contiene la sentencia SQL. * Contiene la sentencia SQL.
*/ */
protected static function buildQuery() { protected static function buildQuery($resetQuery = true) {
$sql = 'SELECT '.join(', ', static::$querySelect['select']); if (static::$querySelect['sql_calc_found_rows'])
$sql = 'SELECT SQL_CALC_FOUND_ROWS '.join(', ', static::$querySelect['select']);
else
$sql = 'SELECT '.join(', ', static::$querySelect['select']);
if (static::$querySelect['from'] != '') { if (static::$querySelect['from'] != '') {
$sql .= ' FROM '.static::$querySelect['from']; $sql .= ' FROM '.static::$querySelect['from'];
} else { } else {
@ -116,40 +124,41 @@ class ModelMySQL {
if(static::$querySelect['innerJoin'] != '') { if(static::$querySelect['innerJoin'] != '') {
$sql .= static::$querySelect['innerJoin']; $sql .= static::$querySelect['innerJoin'];
} }
if (static::$querySelect['leftJoin'] != '') { if (static::$querySelect['leftJoin'] != '') {
$sql .= static::$querySelect['leftJoin']; $sql .= static::$querySelect['leftJoin'];
} }
if(static::$querySelect['rightJoin'] != '') { if(static::$querySelect['rightJoin'] != '') {
$sql .= static::$querySelect['rightJoin']; $sql .= static::$querySelect['rightJoin'];
} }
if (static::$querySelect['where'] != '') { if (static::$querySelect['where'] != '') {
$sql .= ' WHERE '.static::$querySelect['where']; $sql .= ' WHERE '.static::$querySelect['where'];
if (static::$querySelect['AndOr'] != '') { if (static::$querySelect['AndOr'] != '') {
$sql .= static::$querySelect['AndOr']; $sql .= static::$querySelect['AndOr'];
} }
} }
if (static::$querySelect['groupBy'] != '') { if (static::$querySelect['groupBy'] != '') {
$sql .= ' GROUP BY '.static::$querySelect['groupBy']; $sql .= ' GROUP BY '.static::$querySelect['groupBy'];
} }
if (static::$querySelect['orderBy'] != '') { if (static::$querySelect['orderBy'] != '') {
$sql .= ' ORDER BY '.static::$querySelect['orderBy']; $sql .= ' ORDER BY '.static::$querySelect['orderBy'];
} }
if (static::$querySelect['limit'] != '') { if (static::$querySelect['limit'] != '') {
$sql .= ' LIMIT '.static::$querySelect['limit']; $sql .= ' LIMIT '.static::$querySelect['limit'];
} }
static::resetQuery(); if ($resetQuery)
static::resetQuery();
return $sql; return $sql;
} }
/* /*
* Crea una instancia del objeto actual a partir de un arreglo. * Crea una instancia del objeto actual a partir de un arreglo.
* *
@ -163,11 +172,11 @@ class ModelMySQL {
protected static function getInstance($elem = []) { protected static function getInstance($elem = []) {
$class = get_called_class(); $class = get_called_class();
$instance = new $class; $instance = new $class;
foreach ($elem as $key => $value) { foreach ($elem as $key => $value) {
$instance->$key = $value; $instance->$key = $value;
} }
return $instance; return $instance;
} }
@ -175,27 +184,27 @@ class ModelMySQL {
* @return array * @return array
* Contiene los atributos indexados del objeto actual. * Contiene los atributos indexados del objeto actual.
*/ */
protected function getVars() { protected function getVars() {
$reflection = new \ReflectionClass($this); $reflection = new \ReflectionClass($this);
$properties = $reflection->getProperties(\ReflectionProperty::IS_PUBLIC); $properties = $reflection->getProperties(\ReflectionProperty::IS_PUBLIC);
$result = []; $result = [];
foreach($properties as $property) { foreach($properties as $property) {
$att = $property->name; $att = $property->name;
$result[$att] = $this->$att; $result[$att] = $this->$att;
} }
foreach (static::$ignoreSave as $del) { foreach (static::$ignoreSave as $del) {
unset($result[$del]); unset($result[$del]);
} }
foreach (static::$forceSave as $value) { foreach (static::$forceSave as $value) {
$result[$value] = $this->$value; $result[$value] = $this->$value;
} }
return $result; return $result;
} }
/* /*
* @return string * @return string
* Devuelve el nombre de la clase actual * Devuelve el nombre de la clase actual
@ -203,12 +212,12 @@ class ModelMySQL {
public static function className() { public static function className() {
return strtolower(substr(strrchr(get_called_class(), '\\'), 1)); return strtolower(substr(strrchr(get_called_class(), '\\'), 1));
} }
/* /*
* Construye (a partir del nombre de la clase y el sufijo en static::$tableSufix) * Construye (a partir del nombre de la clase y el sufijo en static::$tableSufix)
* y/o develve el nombre de la tabla de la BD en la que se alojará o * y/o develve el nombre de la tabla de la BD en la que se alojará o
* se aloja el objeto actual. * se aloja el objeto actual.
* *
* @return string * @return string
*/ */
protected static function table() { protected static function table() {
@ -222,7 +231,7 @@ class ModelMySQL {
*/ */
protected function update() { protected function update() {
$atts = $this->getVars(); $atts = $this->getVars();
foreach ($atts as $key => $value) { foreach ($atts as $key => $value) {
if (isset($value)) { if (isset($value)) {
$value = static::db()->real_escape_string($value); $value = static::db()->real_escape_string($value);
@ -235,14 +244,14 @@ class ModelMySQL {
$set[]="$key=NULL"; $set[]="$key=NULL";
} }
} }
$table = static::table(); $table = static::table();
$pk = static::$primaryKey; $pk = static::$primaryKey;
$pkv = $this->$pk; $pkv = $this->$pk;
$sql = "UPDATE $table SET ".join(', ', $set)." WHERE $pk='$pkv'"; $sql = "UPDATE $table SET ".join(', ', $set)." WHERE $pk='$pkv'";
static::query($sql); static::query($sql);
} }
/* /*
* Inserta una nueva fila en la base de datos a partir del * Inserta una nueva fila en la base de datos a partir del
* objeto actual. * objeto actual.
@ -250,22 +259,22 @@ class ModelMySQL {
protected function add() { protected function add() {
$db = static::db(); $db = static::db();
$atts = $this->getVars(); $atts = $this->getVars();
foreach ($atts as $key => $value) { foreach ($atts as $key => $value) {
if (isset($value)) { if (isset($value)) {
$into[] = "`$key`"; $into[] = "`$key`";
$values[] = "'".$db->real_escape_string($value)."'"; $values[] = "'".$db->real_escape_string($value)."'";
} }
} }
$table = static::table(); $table = static::table();
$sql = "INSERT INTO $table (".join(', ', $into).") VALUES (".join(', ', $values).")"; $sql = "INSERT INTO $table (".join(', ', $into).") VALUES (".join(', ', $values).")";
static::query($sql); static::query($sql);
$pk = static::$primaryKey; $pk = static::$primaryKey;
$this->$pk = $db->insert_id; $this->$pk = $db->insert_id;
} }
/* /*
* Revisa si el objeto a guardar es nuevo o no y según el resultado * Revisa si el objeto a guardar es nuevo o no y según el resultado
* llama a update para actualizar o add para insertar una nueva fila. * llama a update para actualizar o add para insertar una nueva fila.
@ -277,25 +286,25 @@ class ModelMySQL {
else else
$this->add(); $this->add();
} }
/* /*
* Elimina el objeto actual de la base de datos. * Elimina el objeto actual de la base de datos.
*/ */
public function delete() { public function delete() {
$atts = $this->getVars(); $atts = $this->getVars();
foreach ($atts as $key => $value) { foreach ($atts as $key => $value) {
$value = static::db()->real_escape_string($value); $value = static::db()->real_escape_string($value);
$set[]="$key='$value'"; $set[]="$key='$value'";
} }
$table = static::table(); $table = static::table();
$pk = static::$primaryKey; $pk = static::$primaryKey;
$pkv = $this->$pk; $pkv = $this->$pk;
$sql = "DELETE FROM $table WHERE $pk='$pkv'"; $sql = "DELETE FROM $table WHERE $pk='$pkv'";
static::query($sql); static::query($sql);
} }
/* /*
* Define SELECT en la sentencia SQL. * Define SELECT en la sentencia SQL.
* *
@ -308,12 +317,12 @@ class ModelMySQL {
foreach($columns as $column) { foreach($columns as $column) {
$select[] = $db->real_escape_string($column); $select[] = $db->real_escape_string($column);
} }
static::$querySelect['select'] = $select; static::$querySelect['select'] = $select;
return new static(); return new static();
} }
/* /*
* Define FROM en la sentencia SQL. * Define FROM en la sentencia SQL.
* *
@ -326,12 +335,12 @@ class ModelMySQL {
foreach($tables as $table) { foreach($tables as $table) {
$from[] = $db->real_escape_string($table); $from[] = $db->real_escape_string($table);
} }
static::$querySelect['from'] = join(', ', $from); static::$querySelect['from'] = join(', ', $from);
return new static(); return new static();
} }
/* /*
* Define el WHERE en la sentencia SQL. * Define el WHERE en la sentencia SQL.
* *
@ -347,7 +356,7 @@ class ModelMySQL {
* @param $no_quote * @param $no_quote
* Se usa cuando $value es una columna o un valor que no requiere comillas * Se usa cuando $value es una columna o un valor que no requiere comillas
* *
* Sintaxis posibles: * Sintaxis posibles:
* - static::where(columna, operador, valor) * - static::where(columna, operador, valor)
* - static::where(columna, valor) // Operador por defecto "=" * - static::where(columna, valor) // Operador por defecto "="
*/ */
@ -356,17 +365,17 @@ class ModelMySQL {
$value = $operator; $value = $operator;
$operator = '='; $operator = '=';
} }
$value = static::db()->real_escape_string($value); $value = static::db()->real_escape_string($value);
if ($no_quote) if ($no_quote)
static::$querySelect['where'] = "$column$operator$value"; static::$querySelect['where'] = "$column$operator$value";
else else
static::$querySelect['where'] = "$column$operator'$value'"; static::$querySelect['where'] = "$column$operator'$value'";
return new static(); return new static();
} }
/* /*
* Define WHERE usando IN en la sentencia SQL. * Define WHERE usando IN en la sentencia SQL.
* *
@ -383,15 +392,15 @@ class ModelMySQL {
foreach($arr as $index => $value) { foreach($arr as $index => $value) {
$arr[$index] = static::db()->real_escape_string($value); $arr[$index] = static::db()->real_escape_string($value);
} }
if ($in) if ($in)
static::$querySelect['where'] = "$column IN (".join(', ',$arr).")"; static::$querySelect['where'] = "$column IN (".join(', ',$arr).")";
else else
static::$querySelect['where'] = "$column NOT IN (".join(', ',$arr).")"; static::$querySelect['where'] = "$column NOT IN (".join(', ',$arr).")";
return new static(); return new static();
} }
/* /*
* Define LEFT JOIN en la sentencia SQL. * Define LEFT JOIN en la sentencia SQL.
* *
@ -407,7 +416,7 @@ class ModelMySQL {
* @param string $columnB * @param string $columnB
* Columna a comparar para hacer el join. * Columna a comparar para hacer el join.
* *
* Sintaxis posibles: * Sintaxis posibles:
* - static::leftJoin(tabla,columnaA, operador, columnB) * - static::leftJoin(tabla,columnaA, operador, columnB)
* - static::leftJoin(tabla,columnaA, columnB) // Operador por defecto "=" * - static::leftJoin(tabla,columnaA, columnB) // Operador por defecto "="
*/ */
@ -416,16 +425,16 @@ class ModelMySQL {
$columnB = $operator; $columnB = $operator;
$operator = '='; $operator = '=';
} }
$columnA = static::db()->real_escape_string($columnA); $columnA = static::db()->real_escape_string($columnA);
$columnB = static::db()->real_escape_string($columnB); $columnB = static::db()->real_escape_string($columnB);
static::$querySelect['leftJoin'] .= ' LEFT JOIN ' . $table . ' ON ' . "$columnA$operator$columnB"; static::$querySelect['leftJoin'] .= ' LEFT JOIN ' . $table . ' ON ' . "$columnA$operator$columnB";
return new static(); return new static();
} }
/* /*
* Define RIGHT JOIN en la sentencia SQL. * Define RIGHT JOIN en la sentencia SQL.
* *
@ -441,7 +450,7 @@ class ModelMySQL {
* @param string $columnB * @param string $columnB
* Columna a comparar para hacer el join. * Columna a comparar para hacer el join.
* *
* Sintaxis posibles: * Sintaxis posibles:
* - static::rightJoin(tabla,columnaA, operador, columnB) * - static::rightJoin(tabla,columnaA, operador, columnB)
* - static::rightJoin(tabla,columnaA, columnB) // Operador por defecto "=" * - static::rightJoin(tabla,columnaA, columnB) // Operador por defecto "="
*/ */
@ -450,15 +459,15 @@ class ModelMySQL {
$columnB = $operator; $columnB = $operator;
$operator = '='; $operator = '=';
} }
$columnA = static::db()->real_escape_string($columnA); $columnA = static::db()->real_escape_string($columnA);
$columnB = static::db()->real_escape_string($columnB); $columnB = static::db()->real_escape_string($columnB);
static::$querySelect['rightJoin'] .= ' RIGHT JOIN ' . $table . ' ON ' . "$columnA$operator$columnB"; static::$querySelect['rightJoin'] .= ' RIGHT JOIN ' . $table . ' ON ' . "$columnA$operator$columnB";
return new static(); return new static();
} }
/* /*
* Define INNER JOIN en la sentencia SQL. * Define INNER JOIN en la sentencia SQL.
* *
@ -474,7 +483,7 @@ class ModelMySQL {
* @param string $columnB * @param string $columnB
* Columna a comparar para hacer el join. * Columna a comparar para hacer el join.
* *
* Sintaxis posibles: * Sintaxis posibles:
* - static::innerJoin(tabla,columnaA, operador, columnB) * - static::innerJoin(tabla,columnaA, operador, columnB)
* - static::innerJoin(tabla,columnaA, columnB) // Operador por defecto "=" * - static::innerJoin(tabla,columnaA, columnB) // Operador por defecto "="
*/ */
@ -483,15 +492,15 @@ class ModelMySQL {
$columnB = $operator; $columnB = $operator;
$operator = '='; $operator = '=';
} }
$columnA = static::db()->real_escape_string($columnA); $columnA = static::db()->real_escape_string($columnA);
$columnB = static::db()->real_escape_string($columnB); $columnB = static::db()->real_escape_string($columnB);
static::$querySelect['innerJoin'] .= ' INNER JOIN ' . $table . ' ON ' . "$columnA$operator$columnB"; static::$querySelect['innerJoin'] .= ' INNER JOIN ' . $table . ' ON ' . "$columnA$operator$columnB";
return new static(); return new static();
} }
/* /*
* Define AND en la sentencia SQL (se puede anidar). * Define AND en la sentencia SQL (se puede anidar).
* *
@ -507,7 +516,7 @@ class ModelMySQL {
* @param $no_quote * @param $no_quote
* Se usa cuando $value es una columna o un valor que no requiere comillas * Se usa cuando $value es una columna o un valor que no requiere comillas
* *
* Sintaxis posibles: * Sintaxis posibles:
* - static::and(columna, operador, valor) * - static::and(columna, operador, valor)
* - static::and(columna, valor) // Operador por defecto "=" * - static::and(columna, valor) // Operador por defecto "="
* - static::and(columna, valor)->and(columna, valor)->and(columna, valor) // anidado * - static::and(columna, valor)->and(columna, valor)->and(columna, valor) // anidado
@ -517,17 +526,17 @@ class ModelMySQL {
$value = $operator; $value = $operator;
$operator = '='; $operator = '=';
} }
$value = static::db()->real_escape_string($value); $value = static::db()->real_escape_string($value);
if ($no_quote) if ($no_quote)
static::$querySelect['AndOr'] .= " AND $column$operator$value"; static::$querySelect['AndOr'] .= " AND $column$operator$value";
else else
static::$querySelect['AndOr'] .= " AND $column$operator'$value'"; static::$querySelect['AndOr'] .= " AND $column$operator'$value'";
return new static(); return new static();
} }
/* /*
* Define OR en la sentencia SQL (se puede anidar). * Define OR en la sentencia SQL (se puede anidar).
* *
@ -543,7 +552,7 @@ class ModelMySQL {
* @param $no_quote * @param $no_quote
* Se usa cuando $value es una columna o un valor que no requiere comillas * Se usa cuando $value es una columna o un valor que no requiere comillas
* *
* Sintaxis posibles: * Sintaxis posibles:
* - static::or(columna, operador, valor) * - static::or(columna, operador, valor)
* - static::or(columna, valor) // Operador por defecto "=" * - static::or(columna, valor) // Operador por defecto "="
* - static::or(columna, valor)->or(columna, valor)->or(columna, valor) // anidado * - static::or(columna, valor)->or(columna, valor)->or(columna, valor) // anidado
@ -553,17 +562,17 @@ class ModelMySQL {
$value = $operator; $value = $operator;
$operator = '='; $operator = '=';
} }
$value = static::db()->real_escape_string($value); $value = static::db()->real_escape_string($value);
if ($no_quote) if ($no_quote)
static::$querySelect['AndOr'] .= " OR $column$operator$value"; static::$querySelect['AndOr'] .= " OR $column$operator$value";
else else
static::$querySelect['AndOr'] .= " OR $column$operator'$value'"; static::$querySelect['AndOr'] .= " OR $column$operator'$value'";
return new static(); return new static();
} }
/* /*
* Define GROUP BY en la sentencia SQL * Define GROUP BY en la sentencia SQL
* *
@ -574,27 +583,27 @@ class ModelMySQL {
static::$querySelect['groupBy'] = join(', ', $arr); static::$querySelect['groupBy'] = join(', ', $arr);
return new static(); return new static();
} }
public static function limit($initial, $final = 0) { public static function limit($initial, $final = 0) {
$initial = (int)$initial; $initial = (int)$initial;
$final = (int)$final; $final = (int)$final;
if ($final==0) if ($final==0)
static::$querySelect['limit'] = $initial; static::$querySelect['limit'] = $initial;
else else
static::$querySelect['limit'] = $initial.', '.$final; static::$querySelect['limit'] = $initial.', '.$final;
return new static(); return new static();
} }
/* /*
* Define ORDER BY en la sentencia SQL * Define ORDER BY en la sentencia SQL
* *
* @param string $value * @param string $value
* Columna por la que se ordenará. * Columna por la que se ordenará.
* *
* @param string $order * @param string $order
* Define si el orden será de manera ascendente (ASC), * Define si el orden será de manera ascendente (ASC),
* descendente (DESC) o aleatorio (RAND). * descendente (DESC) o aleatorio (RAND).
*/ */
public static function orderBy($value, $order = 'ASC') { public static function orderBy($value, $order = 'ASC') {
@ -602,42 +611,64 @@ class ModelMySQL {
static::$querySelect['orderBy'] = 'RAND()'; static::$querySelect['orderBy'] = 'RAND()';
return new static(); return new static();
} }
$value = static::db()->real_escape_string($value); $value = static::db()->real_escape_string($value);
if (!(strtoupper($order) == 'ASC' || strtoupper($order) == 'DESC')) if (!(strtoupper($order) == 'ASC' || strtoupper($order) == 'DESC'))
$order = 'ASC'; $order = 'ASC';
static::$querySelect['orderBy'] = $value.' '.$order; static::$querySelect['orderBy'] = $value.' '.$order;
return new static(); return new static();
} }
/* /*
* Retorna la cantidad de filas que hay en un query. * Retorna la cantidad de filas que hay en un query.
* *
* @param boolean $resetQuery
* Indica si el query debe reiniciarse o no (por defecto es true).
*
* @return int * @return int
*/ */
public static function count() { public static function count($resetQuery = true) {
if (static::$querySelect['select'] == ['*']) static::$querySelect['select'] = ['1'];
static::$querySelect['select'] = ['count(*) as quantity']; static::$querySelect['sql_calc_found_rows'] = true;
else static::$querySelect['limit'] = '1';
static::$querySelect['select'][] = 'count(*) as quantity'; $sql = static::buildQuery($resetQuery);
$sql = static::buildQuery();
$result = static::query($sql)->fetch_assoc(); $result = static::query($sql)->fetch_assoc();
return static::found_row();
}
/*
* Retorna las filas contadas en el último query.
*
* @return int
*/
public static function found_row() {
$result = static::query('SELECT FOUND_ROWS() AS quantity')->fetch_assoc();
return $result['quantity']; return $result['quantity'];
} }
/* /*
* Obtiene una instancia según su id. * Habilita el conteo de todos las coincidencias posibles incluso usando limit.
*
* @return ModelMySQL
*/
public static function sql_calc_found_rows() {
static::$querySelect['sql_calc_found_rows'] = true;
return new static();
}
/*
* Obtiene una instancia según su primary key (generalmente id).
* *
* @param int $id * @param mixed $id
* @return ModelMySQL * @return ModelMySQL
*/ */
public static function getById($id) { public static function getById($id) {
return static::where(static::$primaryKey, $id)->getFirst(); return static::where(static::$primaryKey, $id)->getFirst();
} }
/* /*
* Realiza una búsqueda en la tabla de la instancia actual. * Realiza una búsqueda en la tabla de la instancia actual.
* *
@ -652,52 +683,58 @@ class ModelMySQL {
$className = get_called_class(); $className = get_called_class();
$in = array_keys((new $className())->getVars()); $in = array_keys((new $className())->getVars());
} }
$db = static::db(); $db = static::db();
$search = $db->real_escape_string($search); $search = $db->real_escape_string($search);
$where = []; $where = [];
foreach($in as $row) { foreach($in as $row) {
$where[] = "$row LIKE '%$search%'"; $where[] = "$row LIKE '%$search%'";
} }
if (static::$querySelect['where']=='') if (static::$querySelect['where']=='')
static::$querySelect['where'] = join(' OR ', $where); static::$querySelect['where'] = join(' OR ', $where);
else else
static::$querySelect['where'] = static::$querySelect['where'] .' AND ('.join(' OR ', $where).')'; static::$querySelect['where'] = static::$querySelect['where'] .' AND ('.join(' OR ', $where).')';
return new static(); return new static();
} }
/* /*
* Obtener los resultados de la consulta SQL. * Obtener los resultados de la consulta SQL.
* *
* @param boolean $resetQuery
* Indica si el query debe reiniciarse o no (por defecto es true).
*
* @return ModelMySQL[] * @return ModelMySQL[]
*/ */
public static function get() { // Devuelve array vacío si no encuentra nada public static function get($resetQuery = true) { // Devuelve array vacío si no encuentra nada
$sql = static::buildQuery(); $sql = static::buildQuery($resetQuery);
$result = static::query($sql); $result = static::query($sql);
$instances = []; $instances = [];
while ($row = $result->fetch_assoc()) { while ($row = $result->fetch_assoc()) {
$instances[] = static::getInstance($row); $instances[] = static::getInstance($row);
} }
return $instances; return $instances;
} }
/* /*
* El primer elemento de la consulta SQL. * El primer elemento de la consulta SQL.
* *
* @param boolean $resetQuery
* Indica si el query debe reiniciarse o no (por defecto es true).
*
* @return mixed * @return mixed
* Puede retornar un objeto ModelMySQL o null. * Puede retornar un objeto ModelMySQL o null.
*/ */
public static function getFirst() { // Devuelve null si no encuentra nada public static function getFirst($resetQuery = true) { // Devuelve null si no encuentra nada
static::limit(1); static::limit(1);
$instances = static::get(); $instances = static::get($resetQuery);
return empty($instances) ? null : $instances[0]; return empty($instances) ? null : $instances[0];
} }
@ -708,15 +745,15 @@ class ModelMySQL {
*/ */
public static function all() { public static function all() {
$sql = 'SELECT * FROM '.static::table(); $sql = 'SELECT * FROM '.static::table();
$result = static::query($sql); $result = static::query($sql);
$instances = []; $instances = [];
while ($row = $result->fetch_assoc()) { while ($row = $result->fetch_assoc()) {
$instances[] = static::getInstance($row); $instances[] = static::getInstance($row);
} }
return $instances; return $instances;
} }
@ -731,7 +768,7 @@ class ModelMySQL {
throw new \Exception( throw new \Exception(
"\nEl método setNull sólo funciona para actualizar, no al insertar." "\nEl método setNull sólo funciona para actualizar, no al insertar."
); );
foreach ($atts as $att) { foreach ($atts as $att) {
if (!in_array($att, $this->toNull)) if (!in_array($att, $this->toNull))
$this->toNull[] = $att; $this->toNull[] = $att;