KarmaFW/src/Database/Sql/SqlTableModel.php

<?php

namespace KarmaFW\Database\Sql;

use \KarmaFW\App;


class SqlTableModel
{
	public static $table_name = '';
	public static $primary_key = [];
	protected static $default_item = [];


	public static function getDb()
	{
		return App::getDb();
	}


	public static function checkTable()
	{
		if (empty(static::$table_name)) {
			throw new \Exception("no table_name defined in " . get_called_class(), 1);
		}
	}

	public static function tableExists()
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->exists();
	}


	public static function getEmpty()
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->getEmpty();
	}


	public static function all($where=[], $options=[])
	{
		// Alias of getAll
		return static::getAll($where, $options);
	}

	public static function select($where=[], $options=[])
	{
		// Alias of getAll
		return static::getAll($where, $options);
	}

	public static function selectAll($where=[], $options=[])
	{
		// Alias of getAll
		return static::getAll($where, $options);
	}

	public static function get($where=[], $options=[])
	{
		// Alias of getAll
		return static::getAll($where, $options);
	}

	public static function getAll($where=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->getAll($where, $options);
	}



	public static function count($where=[], $options=[])
	{
		// Alias of selectCount
		return self::selectCount($where, $options);
	}

	public static function selectCount($where=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->selectCount($where, $options);
	}


	public static function getAllWithFoundRows($where=null, $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		$tuple = $db->getTable(static::$table_name)->getAllWithFoundRows($where, $options);
		return $tuple;
	}


	public static function getAllPagination($where=null, $nb_per_page=10, $page_idx=1, $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		$tuple = $db->getTable(static::$table_name)->getAllPagination($where, $nb_per_page, $page_idx, $options);
		return $tuple;
	}


	public static function one($where=[], $options=[])
	{
		// Alias of getOne
		return static::getOne($where, $options);
	}

	public static function selectOne($where=[], $options=[])
	{
		// Alias of getOne
		return static::getOne($where, $options);
	}

	public static function getOne($where=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->selectOne($where, $options);
	}


	
	public static function insert($values=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->insert($values, $options);
	}
	
	public static function insertAll($rows=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->insertAll($rows, $options);
	}

	public static function insertSelect($insert_table, $insert_keys=null, $rows=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->insertSelect($insert_table, $insert_keys, $rows, $options);
	}

	public static function update($updates=[], $where=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->update($updates, $where, $options);
	}
		
	public static function delete($where=[], $options=[])
	{
		$db = static::getDb();
		static::checkTable();
		return $db->getTable(static::$table_name)->delete($where, $options);
	}



	// load a table row by his primary key. (usage: `$user = User::load($user_id);` )
	public static function load($pk_where=[], $where=[], $options=[])
	{
		if (empty($pk_where)) {
			return null;
		}

		if (count(static::$primary_key) == 1 && is_scalar($pk_where)) {
			$pk_where = [ static::$primary_key[0] => $pk_where ];
		}

		if (empty(static::$primary_key)) {
			throw new \Exception("no primary_key defined in " . get_called_class(), 1);
		}

		if (! is_array($where)) {
			$where = [];
		}

		foreach (static::$primary_key as $key_idx => $key) {
			if (! array_key_exists($key, $pk_where)) {
				//if (count($pk_where) == count(static::$primary_key) && isset($pk_where[$key_idx])) {
				if (count($pk_where) == count(static::$primary_key) && array_key_exists($key_idx, $pk_where)) {
					//pre(static::$primary_key);
					$pk_where = array_combine(static::$primary_key, $pk_where);
					//pre($pk_where, 0, 'pk_where updated: ');
				} else {
					//pre($key_idx, 0, 'key_idx: ');
					//pre($pk_where, 0, 'pk_where KO: ');
				}
			}
			if (! array_key_exists($key, $pk_where)) {
				//exit;
				//pre(static::$primary_key); pre($pk_where, 1);
				throw new \Exception("missing value for primary_key " . $key . " in " . get_called_class(), 1);
			}
			$value = $pk_where[$key];

			$where[$key] = $value;
		}

		return static::getOne($where, $options);

	}


	public static function where($where=[])
	{
		static::checkTable();
		return (new WhereQuery(static::$table_name))->where($where);
	}

	/*
	public static function select($select=[])
	{
		static::checkTable();
		return (new WhereQuery(static::$table_name))->select($select);
	}
	*/


	public static function getDefaultItem()
	{
		return array_slice(static::$default_item, 0);
	}

}