Пример MVC в php. Третья статья. Модели. Элементарные действия с записями

Содержание цикла статей:

• 1. Вводная статья
• 2. Маршрутизация, контролеры, экшены, шаблоны
• 3. Модели. Элементарные действия с базой данных
• 4. Проектируем блог
• 5. Исправление неточностей структуры

Введение

В предыдущей статье мы с вами написали каркас сайта, который использует в своей основе MVC подход. На данный момент у нас работает маршрутизация, сделано разделение на модели, контроллеры и отображения(view). Но поскольку предыдущая статья получилась большая, я затронул работу с моделями вскользь, в этой статье мы это наверстаем.
Модели в большинстве случаев используются для работы с базой данных, то есть все запросы для получения, обновления, удаления или записи в БД будут осуществляться в моделях. В контролерах не должно быть работы с базой, вместо запросов должно быть обращение к методам моделей.

Структура моделей

Для удобства работы с базой данных, принято делать для каждой таблицы отдельную модель – класс, а в методах каждой модели уже описывать взаимодействие с таблицами. Давайте это реализуем. Как известно, для обращения к бд, необходимо делать подключение, но так как мы уже создаем соединение в файле index.php будем его использовать и в моделях. Так же для удобства можно создать абстрактный класс, от которого наши модели будут наследовать типовые методы. К таким методам можно отнести элементарные действия с базой данных – получение одной записи по id, получение всех записей таблицы и тд.
Давайте создадим абстрактный класс models_base.php и расположим его в папке classes. Код класса будет выглядеть так:

Abstract Class Model_Base {

	protected $db;
	protected $table;
	private $dataResult;
	
	public function __construct($select = false) {
		// объект бд коннекта
		global $dbObject;
		$this->db = $dbObject;
		
		// имя таблицы
		$modelName = get_class($this);
		$arrExp = explode('_', $modelName);
		$tableName = strtolower($arrExp[1]);
		$this->table = $tableName;
		
		// обработка запроса, если нужно
		$sql = $this->_getSelect($select);
		if($sql) $this->_getResult("SELECT * FROM $this->table" . $sql);
	}	
	
	// получить имя таблицы
	public function getTableName() {
		return $this->table;
	}
	
	// получить все записи
	function getAllRows(){
		if(!isset($this->dataResult) OR empty($this->dataResult)) return false;
		return $this->dataResult;
	}
	
	// получить одну запись
	function getOneRow(){
		if(!isset($this->dataResult) OR empty($this->dataResult)) return false;
		return $this->dataResult[0];
	}	
	
	// извлечь из базы данных одну запись
	function fetchOne(){
		if(!isset($this->dataResult) OR empty($this->dataResult)) return false;
		foreach($this->dataResult[0] as $key => $val){
			$this->$key = $val;
		}
		return true;
	}
	
	// получить запись по id
	function getRowById($id){
		try{
			$db = $this->db;
			$stmt = $db->query("SELECT * from $this->table WHERE id = $id");
			$row = $stmt->fetch();
		}catch(PDOException $e) {
			echo $e->getMessage();
			exit;
		}
		return $row;
	}
	
	// запись в базу данных
	public function save() {
		$arrayAllFields = array_keys($this->fieldsTable());
		$arraySetFields = array();
		$arrayData = array();
		foreach($arrayAllFields as $field){
			if(!empty($this->$field)){
				$arraySetFields[] = $field;
				$arrayData[] = $this->$field;
			}
		}
		$forQueryFields =  implode(', ', $arraySetFields);
		$rangePlace = array_fill(0, count($arraySetFields), '?');
		$forQueryPlace = implode(', ', $rangePlace);
		
		try {
			$db = $this->db;
			$stmt = $db->prepare("INSERT INTO $this->table ($forQueryFields) values ($forQueryPlace)");  
			$result = $stmt->execute($arrayData);
		}catch(PDOException $e){
			echo 'Error : '.$e->getMessage();
			echo '<br/>Error sql : ' . "'INSERT INTO $this->table ($forQueryFields) values ($forQueryPlace)'"; 
			exit();
		}
		
		return $result;
	}
	
	// составление запроса к базе данных
	private function _getSelect($select) {
		if(is_array($select)){
			$allQuery = array_keys($select);
			array_walk($allQuery, function(&$val){
				$val = strtoupper($val);
			});
			
			$querySql = "";
			if(in_array("WHERE", $allQuery)){
				foreach($select as $key => $val){
					if(strtoupper($key) == "WHERE"){
						$querySql .= " WHERE " . $val;					
					}
				}
			}
			
			if(in_array("GROUP", $allQuery)){
				foreach($select as $key => $val){
					if(strtoupper($key) == "GROUP"){
						$querySql .= " GROUP BY " . $val;					
					}
				}
			}
			
			if(in_array("ORDER", $allQuery)){
				foreach($select as $key => $val){
					if(strtoupper($key) == "ORDER"){
						$querySql .= " ORDER BY " . $val;					
					}
				}
			}
			
			if(in_array("LIMIT", $allQuery)){
				foreach($select as $key => $val){
					if(strtoupper($key) == "LIMIT"){
						$querySql .= " LIMIT " . $val;					
					}
				}
			}
			
			return $querySql;
		}		
		return false;
	}
	
	// выполнение запроса к базе данных
	private function _getResult($sql){
		try{
			$db = $this->db;
			$stmt = $db->query($sql);
			$rows = $stmt->fetchAll();
			$this->dataResult = $rows;
		}catch(PDOException $e) {
			echo $e->getMessage();
			exit;
		}
		
		return $rows;
	}
	
	// уделение записей из базы данных по условию
	public function deleteBySelect($select){
		$sql = $this->_getSelect($select);
		try {
			$db = $this->db;
			$result = $db->exec("DELETE FROM $this->table " . $sql);
		}catch(PDOException $e){
			echo 'Error : '.$e->getMessage();
			echo '<br/>Error sql : ' . "'DELETE FROM $this->table " . $sql . "'"; 
			exit();
		}
		return $result;
	}
	
	// уделение строки из базы данных
	public function deleteRow(){
		$arrayAllFields = array_keys($this->fieldsTable());
		array_walk($arrayAllFields, function(&$val){
			$val = strtoupper($val);
		});
		if(in_array('ID', $arrayAllFields)){			
			try {
				$db = $this->db;
				$result = $db->exec("DELETE FROM $this->table WHERE `id` = $this->id");
				foreach($arrayAllFields as $one){
					unset($this->$one);
				}
			}catch(PDOException $e){
				echo 'Error : '.$e->getMessage();
				echo '<br/>Error sql : ' . "'DELETE FROM $this->table WHERE `id` = $this->id'"; 
				exit();
			}			
		}else{
			echo "ID table `$this->table` not found!";
			exit;
		}
		return $result;
	}
	
	// обновление записи. Происходит по ID
	public function update(){
		$arrayAllFields = array_keys($this->fieldsTable());
		$arrayForSet = array();
		foreach($arrayAllFields as $field){
			if(!empty($this->$field)){
				if(strtoupper($field) != 'ID'){
					$arrayForSet[] = $field . ' = "' . $this->$field . '"';
				}else{
					$whereID = $this->$field;
				}
			}
		}
		if(!isset($arrayForSet) OR empty($arrayForSet)){
			echo "Array data table `$this->table` empty!";
			exit;
		}
		if(!isset($whereID) OR empty($whereID)){
			echo "ID table `$this->table` not found!";
			exit;
		}
		
		$strForSet = implode(', ', $arrayForSet);
		
		try {
			$db = $this->db;
			$stmt = $db->prepare("UPDATE $this->table SET $strForSet WHERE `id` = $whereID");  
			$result = $stmt->execute();
		}catch(PDOException $e){
			echo 'Error : '.$e->getMessage();
			echo '<br/>Error sql : ' . "'UPDATE $this->table SET $strForSet WHERE `id` = $whereID'"; 
			exit();
		}
		return $result;
	}
}

Теперь приведу код модели для таблицы с пользователями (в таблице три столбца – id, first_name и last_name).
):

Class Model_Users Extends Model_Base {
	
	public $id;
	public $name;
	public $last_name;
	
	public function fieldsTable(){
		return array(
			'id' => 'Id',
			'first_name' => 'First name',
			'last_name' => 'Last name'
		);
	}
	
}

Теперь подробно рассмотрим код модели и абстрактного класса. С моделью все просто – мы наследуем все методы у Model_Base, создаем свойства с такими же именами, как и имена столбцов в таблице с пользователями. И создаем метод, при обращении к которому возвращается массив с именами всех полей таблицы. Имена полей таблицы нам необходимы при выполнении методом в классе Model_Base – при обращении к базе данных.
Абстрактная модель у нас получилась большая, но и работу она выполняет не маленькую, возможно, что всех ее методов нам будет достаточно для создания блога, но если чего-то будет не хватать, мы всегда можем расширить класс. Этим и хорош ООП – всегда можно без проблем и без вреда для сайта расширять функционал.
На данный момент наши модели умеют получать, обновлять, удалять и создавать записи в таблицах базы данных. Давайте рассмотрим несколько примеров того, что можно делать с бд, используя наши модели.

Получение записей из бд

Получение нескольких строк из таблицы:

// создаем запрос
$select = array(
	'where' => 'id >= 1 AND id <= 5', // условие
	'group' => 'first_name', // группируем
	'order' => 'id DESC', // сортируем
	'limit' => 10 // задаем лимит
);
$model = new Model_Users($select); // создаем объект модели
$usersInfo = $model->getAllRows(); // получаем все строки
var_dump($usersInfo); // выводим данные

Получение одной строки из таблицы:

$select = array(
	'where' => 'id = 2'
);
$model = new Model_Users($select);
$usersInfo = $model->getOneRow();
var_dump($usersInfo);

Помимо получения строк, мы можем получать значения конкретных столбцов:

// запрос
$select = array(
	'where' => 'id = 2'
);
$model = new Model_Users($select); 
$model->fetchOne(); // извлекаем данные
// получаем значения столбцов
$firstName = $model->first_name;
$lastName = $model->last_name;
// выводим
var_dump($firstName);
var_dump($lastName);

Создание записи в бд

Также просто, как и получать, мы можем и записывать данные:

// создаем объект
$model = new Model_Users();
// задаем значения для полей таблицы
$model->id = 10; // id можно и пропустить, если для этого поля настроен авто инкремент 
$model->first_name = 'Иван';
$model->last_name = 'Иванов';
$result = $model->save(); // создаем запись
var_dump($result); // проверяем результат:  true или false

Обновление записи в бд

Обновление записей в таблице тоже не составит проблем, выглядеть это будет так:

// запрос
$select = array(
	'where' => 'id = 10'
);
// модель
$model = new Model_Users($select);
// извлекаем данные
$model->fetchOne(); 
// задаем новые значения
$model->first_name = 'Петр';
$model->last_name = 'Петров';
// обновляем запись
$result = $model->update();
var_dump($result); // проверяем результат:  true или false

Удаление записи в бд

И последнее элементарное действие с базой данных – удаление записей.

// модель
$model = new Model_Users();
// условие удаления
$select = array(
	'where' => 'id > 10'
);
// удаляем
$result = $model->deleteBySelect($select);
var_dump($result); // проверяем результат. Вернется количество удаленных строк

И еще один доступный вариант удаления, для одной записи:

// запрос
$select = array(
	'where' => 'id = 10'
);
// модель
$model = new Model_Users($select);
// извлекаем данные
$model->fetchOne();
// удаляем строку
$result = $model->deleteRow();
var_dump($result);

Я думаю, что на этом стоит закончить сегодняшнюю статью, информации для размышления и осмысления пока достаточно. В следующей статье уже начнем проектировать блог.
Cкачать исходники и дамп тестовой таблицы можно архивом тут.