phalapi-入門篇5(資料庫操作和Model層)
#phalapi-入門篇5(資料庫操作和Model層)#
##前言## 先在這裡感謝phalapi框架創始人@dogstar,為我們提供了這樣一個優秀的開源框架.
本小節主要講解基於notorm的資料庫操作以及使用Model層進行快速的資料層的開發,請確保裝有PDO拓展.
附上:
開源中國Git地址:http://git.oschina.net/dogstar/PhalApi/tree/release
##1. 基於PDO的notorm進行的資料庫操作##
phalapi的資料庫操作是使用的開源的notorm進行的,notorm是基於PDO連結資料庫,在框架內部預設連結的是mysql資料庫,如需修改連結其他資料庫
$dsn = sprintf('mysql:dbname=%s;host=%s;port=%d',
$dbCfg['name'],
isset($dbCfg['host']) ? $dbCfg['host'] : 'localhost',
isset($dbCfg['port']) ? $dbCfg['port'] : 3306
);再講之前其實這裡是有一個坑的,機智的童鞋應該發現了框架自帶的user資料庫裡面有一個以from命名欄位,應為在notorm生成sql語句的時候不會給自動自動加上引號
下面我們正式來講解如何使用,我們先在Demo/Api下面建立一個DB.php檔案作為我們的DB模組,
<?php /** * 資料庫介面服務類 */ class Api_DB extends PhalApi_Api{ public function getRules(){ return array( 'insert' => array( 'id' => array('name' => 'id', 'require' => true, 'desc' => '使用者Id'), 'name' => array('name' => 'name', 'require' => true, 'desc' => '使用者名稱稱'), 'phone' => array('name' => 'phone', 'require' => true, 'desc' => '使用者手機號碼'), ), 'select' => array( 'id' => array('name' => 'id', 'require' => true, 'desc' => '使用者Id'), ), 'update' => array( 'id' => array('name' => 'id', 'require' => true, 'desc' => '使用者Id'), 'name' => array('name' => 'name', 'require' => true, 'desc' => '使用者名稱稱'), 'phone' => array('name' => 'phone', 'require' => true, 'desc' => '使用者手機號碼'), ), 'delete' => array( 'id' => array('name' => 'id', 'require' => true, 'desc' => '使用者Id'), ), ); }
一共是增刪改查四個介面代表四種操作(這裡一定要配置好資料庫,以及執行框架自帶的sql檔案phalapi_test.sql)
###1.1 insert介面###
我們先寫增加介面如下:
/**
* 新增表服務
* @return int id 新增列的Id
*/
public function insert(){
$data = array( //用陣列構成需要插入鍵值一一對應
'id' => $this->id,
'name' => $this->name,
'phone' => $this->phone,
);
$rs = DI()->notorm->user->insert($data); //執行資料庫操作user代表的是表,返回結果是插入成功的值
return $rs['id']; //返回插入的id
}重要的是 $rs = DI()->notorm->user->insert($data); 這段程式碼執行了sql語句,user是表名(這裡的表名會加下在dbs中配置的表字首組成一個完整的表名)我們試著執行一下http://localhost/Public/?service=DB.insert&name=miaomi&phone=13010001000&id=2會得到以下結果
###1.2 select介面###
查詢介面如下:
/**
* 查詢
* @return array data 結果集
*/
public function select(){
$data = array();
$data[] = DI()->notorm->user->select('name,phone')->where('id', $this->id)->fetch();
$data[] = DI()->notorm->user->select('name,phone')->where('id = ?', $this->id)->fetchAll();
$data[] = DI()->notorm->user->select('name,phone')->where('id != ?', $this->id)->fetchRows();
return $data;
}執行http://localhost/Public/?service=DB.select&id=2會得到以下結果
為什麼會有這樣的區別,通過下面的一些小提示大家就能看到區別在哪裡:
####1.2.1 select方法####
select方法主要是用來指定返回值,接受的是一個string他的作用於真正查詢語句select和from之間填充,大家如果把select('name,phone') 改為 select('*') 就會得到包括id的所有欄位的返回
####1.2.2 where方法和排序####
where方法是查詢中的重要的一個環節
where('id', $this->id)等同於where('id = ?', $this->id)
where('id != ?', $this->id)這種方式只要是為了指定條件大於,等於,小於,不等於等
當然如果是需要有多個條件就使用連續的where就可以**->where('id != ?',1)->where('phone','1301000100')**這種形式
關於排序的使用其實和where差不多使用**->order('欄位名')**如果要反排序在欄位名後面加上DESC
####1.2.3 fetch,fetchAll和fetchRows####
大家有看到上面執行的三條查詢語句後面的結束放到都不同這裡講解一下他們的區別和怎麼用他們使用單獨去執行sql語句
fetch方法是獲取單獨的一條資料返回結果是不帶下標的陣列 ,fetchAll和fetchRows不同在於他們返回的是包含多條資料一個帶下標的陣列,可以看到在條件一樣的情況下第一條和第二條查詢出來的結果區別是第二條多了一個0的下標,從此可得到如果是確定返回結果只有一條優先使用fetch,如果是多條結果優先使用fetchAll和fetchRows.
fetchAll和fetchRows還提供了一個功能就是單獨執行sql語句
$sql = 'select * from tbl_user where id = :id';
$params = array(':id' => $this->id); //替換:id為請求引數的id
DI()->notorm->user->queryAll($sql, $params); //或fetchRows($sql, $params)這樣就可以執行sql語句,包括一些複雜的查詢sql可以使用此內方法執行(關聯查詢應當優先使用這種形式)
###1.3 update介面###
修改介面如下:
/**
* 修改
*/
public function update(){
$data = array(
'name' => $this->name,
'phone' => $this->phone,
);
$rs = DI()->notorm->user->where('id', $this->id)->update($data);
if($rs === false){
throw new PhalApi_Exception_BadRequest('修改資料失敗');
}
}大家可以試一試執行之後是否有修改資料庫http://localhost/Public/?service=DB.update&id=2&phone=13011112222&name=wenwenwen
使用其實和新增介面差不多隻是一個是吧id作為值,一個是作為條件
比較值得講一下的是為什麼使用if($rs === false)
原因是這樣的,這裡執行update方法之後獲取得是影響行數,如果原本值就是一樣的那就回返回0,只有在真正語句失敗的時候會返回false所以這裡使用全等於false作為判斷是否執行成功的條件
###1.4 delete介面###
刪除介面如下:
/**
* 刪除
*/
public function delete(){
$rs = DI()->notorm->user->where('id', $this->id)->delete();
if($rs === false){
throw new PhalApi_Exception_BadRequest('刪除資料失敗');
}
}http://localhost/Public/?service=DB.delete&id=2
刪除的操作也很簡單,不過**if($rs === false)**就算沒有刪除到資料也會返回成功,只有當語句失敗會反悔false,如果需要未刪除到資料提示出錯的同學可以把等號減少一個
###1.5 列印sql語句###
有的時候光靠自己去看程式碼很難確定是不是哪裡寫的有問題,但是如果檢視生成出來的sql語句就能很快的確定問題出現在哪裡
大家可以試試在請求引數中加上
就可以打印出來生成的sql語句方便除錯
包括執行時間和先後順序也一同打印出來了,也可以幫助大家找到慢查詢在哪裡
##2. 使用Model進行資料庫操作##
使用Model操作是為了提高開發效率,讓同樣資料庫操作可以進行高度的複用,也便於修改起來改一處則全改這種效果
###2.1 傳統的Model操作###
所謂傳統的Model操作也就是把資料操作封裝起來,方便呼叫比如**/Model/User.php**下面的getByUserId方法
public function getByUserId($userId) {
return DI()->notorm->user->select('*')->where('id = ?', $userId)->fetch();
}在內部直接封裝資料庫操作使用如下程式碼呼叫
$model = new Model_User();
$rs = $model->getByUserId($userId);###2.2 框架自帶的Model操作###
當然這裡介紹model的目的當然是解讀一下phalapi內部提供的model操作
使用自帶model操作只需要繼承**PhalApi_Model_NotORM **在實現如下方法
protected function getTableName($id) {
return 'user';
}這個方法主要作用是為了新增這個model 的表名,其實這兩個操作在**/Model/User.php**中已經實現了,我們來重構一下getByUserId方法如下
public function getByUserId($userId) {
return $this->getORM()->select('*')->where('id = ?', $userId)->fetch();
}$this->getORM()相當於DI()->notorm->(getTableName中設定的表名)
然後我們重寫select介面如下:
public function select(){
$model = new Model_User();
return $model->getByUserId($this->id);
}可以獲得以下結果
在這裡phalapi自帶的model和傳統的model對比起來區別在於,phalapi統一制定表名不會應為方法果斷導致的表名寫錯的失誤
另一方面phalapi自帶的model提供了很多字基礎操作,利用自動提示功能可以看到
我們來再次改造一下selete介面使用model自帶的方法
public function select(){
$model = new Model_User();
return $model->get($this->id);
}執行結果和上面是一樣的,這裡注意一點這裡Id的名字是dbs中配置的**'key' => 'id',**要和資料庫中的ID欄位名對應,但是這樣會有一些問題會在後面進階篇提及到
##3. 總結##
在本小節著重講了CURD操作,以及其中的一些操作的使用和怎麼使用phalapi的model層,希望大家看完本小節之後進行一些練習來熟練的掌握使用phalapi對資料庫的操作,關於資料庫操作的一些小技巧會單獨在進階篇中抽出一小節來講講在實際專案開發中遇到的問題以及如何解決,希望大家進一步關注!
注:筆者能力有限有說的不對的地方希望大家能夠指出,也希望多多交流!
官網QQ交流群:421032344 歡迎大家的加入!