脣脛隆壟脢媒戮脻驢芒 · tp5文檔

# 快速入門（四）：數據庫本章我們來學習下如何使用`Db`類操作數據庫，主要包含： - - [準備](http://www.hmoore.net/thinkphp/thinkphp5_quickstart/147279#u51C6u5907) - [數據庫配置](http://www.hmoore.net/thinkphp/thinkphp5_quickstart/147279#u6570u636Eu5E93u914Du7F6E) - [原生查詢](http://www.hmoore.net/thinkphp/thinkphp5_quickstart/147279#u539Fu751Fu67E5u8BE2) - [查詢構造器](http://www.hmoore.net/thinkphp/thinkphp5_quickstart/147279#u67E5u8BE2u6784u9020u5668) - [鏈式操作](http://www.hmoore.net/thinkphp/thinkphp5_quickstart/147279#u94FEu5F0Fu64CDu4F5C) - [事務支持](http://www.hmoore.net/thinkphp/thinkphp5_quickstart/147279#u4E8Bu52A1u652Fu6301) ## 準備 `5.0`的數據查詢由低到高分三個層次： 1. 數據庫原生查詢（SQL查詢）； 2. 數據庫鏈式查詢（查詢構造器）； 3. 模型的對象化查詢；本章會涉及到前面兩個，模型的查詢會在第六章進行講解。在第一章已經提到，在使用`Db`類進行數據庫查詢之前，首先必須先創建一個控制器類，以及一個操作方法用于測試，類似于： ``` <pre class="calibre18"> ``` <?phpnamespace app\index\controller; use think\Db; class Index{ public function index(){ // 后面的數據庫查詢代碼都放在這個位置 } } ``` ``` 然后，要查看數據庫執行結果的話，訪問下面的URL地址： ``` <pre class="calibre18"> ``` http: //tp5.com/ ``` ``` ## 數據庫配置我們給應用定義數據庫配置文件（`appliation/database.php`），里面設置了應用的全局數據庫配置信息。該數據庫配置文件的基本定義如下： ``` <pre class="calibre18"> ``` return [ // 數據庫類型'type' => 'mysql', // 服務器地址'hostname' => '127.0.0.1', // 數據庫名'database' => 'test', // 數據庫用戶名'username' => 'root', // 數據庫密碼'password' => '', // 數據庫連接端口'hostport' => '', // 數據庫連接參數'params' => [], // 數據庫編碼默認采用utf8'charset' => 'utf8', // 數據庫表前綴'prefix' => '', // 數據庫調試模式'debug' => true, ]; ``` ``` 如果你使用了多個模塊，并且不同的模塊采用不同的數據庫連接，那么可以在每個模塊的目錄下面單獨定義數據庫配置。后面的例子，我們都采用`index`模塊的數據庫配置文件（`application/index/database.php`），配置如下（模塊數據庫配置中我們使用了長連接）： ``` <pre class="calibre18"> ``` return [ // 數據庫名'database' => 'demo', // 數據庫表前綴'prefix' => 'think_', // 數據庫連接參數'params' => [ // 使用長連接 \PDO::ATTR_PERSISTENT => true, ], ]; ``` ``` > #### 提示： > > - - - - - - > > 模塊的數據庫配置文件中只需要配置和全局數據庫配置文件差異的部分，相同的不需要重復配置。也可以在調用`Db`類的時候，使用`connect`方法動態連接或者切換不同的數據庫，這個我們會在后面提到。 ## 原生查詢設置好數據庫連接信息后，我們就可以直接進行原生的SQL查詢操作了，包括`query`和`execute`兩個方法，分別用于查詢和寫入，下面我們來實現數據表`think_user`的CURD操作。在開始之前，我們首先在數據庫`demo`中創建一個`think_data`數據表（這里以`mysql`數據庫為例），SQL代碼如下： ``` <pre class="calibre18"> ``` CREATE TABLE IF NOT EXISTS `think_data`( `id` int(8) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(255) NOT NULL COMMENT '名稱', `status` tinyint(2) NOT NULL DEFAULT '0' COMMENT '狀態', PRIMARY KEY (`id`) ) ENGINE=MyISAM DEFAULT CHARSET=utf8 ; INSERT INTO `think_data`(`id`,`name`,`status`) VALUES (1,'thinkphp',1), (2,'onethink',1), (3,'topthink',1); ``` ``` ### 創建（create） ``` <pre class="calibre18"> ``` // 插入記錄$result = Db::execute('insert into think_data (id, name ,status) values (5, "thinkphp",1)'); dump($result); ``` ``` ### 更新（update） ``` <pre class="calibre18"> ``` // 更新記錄$result = Db::execute('update think_data set name = "framework" where id = 5 '); dump($result); ``` ``` ### 讀取（read） ``` <pre class="calibre18"> ``` // 查詢數據$result = Db::query('select * from think_data where id = 5'); dump($result); ``` ``` > query方法返回的結果是一個數據集（數組），如果沒有查詢到數據則返回空數組。 ### 刪除（delete） ``` <pre class="calibre18"> ``` // 刪除數據$result = Db::execute('delete from think_data where id = 5 '); dump($result); ``` ``` ### 其它操作可以執行一些其他的數據庫操作，原則上，讀操作都使用`query`方法，寫操作使用`execute`方法即可，例如： ``` <pre class="calibre18"> ``` // 顯示數據庫列表$result = Db::query('show tables from demo'); dump($result); // 清空數據表$result = Db::execute('TRUNCATE table think_data'); dump($result); ``` ``` > `query`方法用于查詢，默認情況下返回的是數據集（二維數組），`execute`方法的返回值是影響的行數。 ### 切換數據庫在進行數據庫查詢的時候，支持切換數據庫進行查詢，例如： ``` <pre class="calibre18"> ``` $result = Db::connect([ // 數據庫類型'type' => 'mysql', // 服務器地址'hostname' => '127.0.0.1', // 數據庫名'database' => 'thinkphp', // 數據庫用戶名'username' => 'root', // 數據庫密碼'password' => '123456', // 數據庫連接端口'hostport' => '', // 數據庫連接參數'params' => [], // 數據庫編碼默認采用utf8'charset' => 'utf8', // 數據庫表前綴'prefix' => 'think_', ])->query('select * from think_data'); dump($result); ``` ``` 或者采用字符串方式定義（字符串方式無法定義數據表前綴和連接參數），如下： ``` <pre class="calibre18"> ``` $result = Db::connect('mysql://root:123456@127.0.0.1:3306/thinkphp#utf8')->query('select * from think_data where id = 1'); dump($result); ``` ``` 為了簡化代碼，通常的做法是事先在配置文件中定義好多個數據庫的連接配置，例如，我們在應用配置文件（`application/config.php`）中添加配置如下： ``` <pre class="calibre18"> ``` // 數據庫配置1'db1' => [ // 數據庫類型'type' => 'mysql', // 服務器地址'hostname' => '127.0.0.1', // 數據庫名'database' => 'thinkphp', // 數據庫用戶名'username' => 'root', // 數據庫密碼'password' => '123456', // 數據庫連接端口'hostport' => '', // 數據庫連接參數'params' => [], // 數據庫編碼默認采用utf8'charset' => 'utf8', // 數據庫表前綴'prefix' => 'think_', ], // 數據庫配置2'db2' => [ // 數據庫類型'type' => 'mysql', // 服務器地址'hostname' => '127.0.0.1', // 數據庫名'database' => 'test', // 數據庫用戶名'username' => 'root', // 數據庫密碼'password' => '', // 數據庫連接端口'hostport' => '', // 數據庫連接參數'params' => [], // 數據庫編碼默認采用utf8'charset' => 'utf8', // 數據庫表前綴'prefix' => 'test_', ], ``` ``` 然后就可以直接在`connect`方法中傳入配置參數進行切換數據庫連接，例如： ``` <pre class="calibre18"> ``` $result = Db::connect('db1')->query('select * from think_data where id = 1'); $result = Db::connect('db2')->query('select * from think_data where id = 1'); ``` ``` `connect`方法中的配置參數需要完整定義，并且僅僅對當此查詢有效，下次調用`Db`類的時候還是使用默認的數據庫連接。如果需要多次切換數據庫查詢，可以使用： ``` <pre class="calibre18"> ``` $db1 = Db::connect('db1'); $db2 = Db::connect('db2'); $db1->query('select * from think_data where id = 1'); $db2->query('select * from think_data where id = 1'); ``` ``` ### 參數綁定實際開發中，可能某些數據使用的是外部傳入的變量，為了讓查詢操作更加安全，我們建議使用參數綁定機制，例如上面的操作可以改為： ``` <pre class="calibre18"> ``` Db::execute('insert into think_data (id, name ,status) values (?, ?, ?)', [8, 'thinkphp', 1]); $result = Db::query('select * from think_data where id = ?', [8]); dump($result); ``` ``` 也支持命名占位符綁定，例如： ``` <pre class="calibre18"> ``` Db::execute('insert into think_data (id, name , status) values (:id, :name, :status)', ['id' => 10, 'name' => 'thinkphp', 'status' => 1]); $result = Db::query('select * from think_data where id=:id', ['id' => 10]); dump($result); ``` ``` ## 查詢構造器除了原生查詢外，5.0還提供了數據庫查詢構造器，可以更方便執行數據庫操作，查詢構造器基于PDO實現，對不同的數據庫驅動都是統一的語法。 > #### 注意： > > - - - - - - > > ThinkPHP `5.0`查詢構造器使用 `PDO`參數綁定，以保護應用程序免于 `SQL`注入，因此傳入的參數不需額外轉義特殊字符。同樣是實現上面的功能，我們可以改成： ``` <pre class="calibre18"> ``` // 插入記錄 Db::table('think_data') ->insert(['id' => 18, 'name' => 'thinkphp', 'status' => 1]); // 更新記錄 Db::table('think_data') ->where('id', 18) ->update(['name' => "hello"]); // 查詢數據$list = Db::table('think_data') ->where('id', 18) ->select(); // 刪除數據 Db::table('think_data') ->where('id', 18) ->delete(); ``` ``` 由于我們在數據庫配置文件中設置了數據表的前綴為`think_`，因此，`table`方法可以改成`name`方法，這樣就不會因為數據表前綴的修改而改動`CURD`代碼，例如： ``` <pre class="calibre18"> ``` // 插入記錄 Db::name('data') ->insert(['id' => 18, 'name' => 'thinkphp']); // 更新記錄 Db::name('data') ->where('id', 18) ->update(['name' => "framework"]); // 查詢數據$list = Db::name('data') ->where('id', 18) ->select(); dump($list); // 刪除數據 Db::name('data') ->where('id', 18) ->delete(); ``` ``` 如果使用系統提供的助手函數`db`則可以進一步簡化查詢代碼如下： ``` <pre class="calibre18"> ``` $db = db('data'); // 插入記錄$db->insert(['id' => 20, 'name' => 'thinkphp']); // 更新記錄$db->where('id', 20)->update(['name' => "framework"]); // 查詢數據$list = $db->where('id', 20)->select(); dump($list); // 刪除數據$db->where('id', 20)->delete(); ``` ``` > `db`助手函數默認會每次重新連接數據庫，因此應當盡量避免多次調用。關于更多的查詢條件和查詢語法，會在后面一章查詢語言中詳細講述。 ## 鏈式操作使用鏈式操作可以完成復雜的數據庫查詢操作，例如： ``` <pre class="calibre18"> ``` // 查詢十個滿足條件的數據并按照id倒序排列 $list = Db::name('data') ->where('status', 1) ->field('id,name') ->order('id', 'desc') ->limit(10) ->select(); dump($list); ``` ``` 鏈式操作不分先后，只要在查詢方法（這里是`select`方法）之前調用就行，所以，下面的查詢是等效的： ``` <pre class="calibre18"> ``` // 查詢十個滿足條件的數據并按照id倒序排列 $list = Db::name('data') ->field('id,name') ->order('id', 'desc') ->where('status', 1) ->limit(10) ->select(); dump($list); ``` ``` 支持鏈式操作的查詢方法包括：方法名描述 select 查詢數據集 find 查詢單個記錄 insert 插入記錄 update 更新記錄 delete 刪除記錄 value 查詢值 column 查詢列 chunk 分塊查詢 count等聚合查詢> 更多的鏈式操作方法可以參考官方的完全開發手冊。 ## 事務支持 > #### 注意： > > - - - - - - > > 由于需要用到事務的功能，請先修改數據表的類型為`InnoDB`，而不是`MyISAM`。對于事務的支持，最簡單的方法就是使用`transaction`方法，只需要把需要執行的事務操作封裝到閉包里面即可自動完成事務，例如： ``` <pre class="calibre18"> ``` Db::transaction(function () { Db::table('think_user') ->delete(1); Db::table('think_data') ->insert(['id' => 28, 'name' => 'thinkphp', 'status' => 1]); }); ``` ``` 一旦`think_data`表寫入失敗的話，系統會自動回滾，寫入成功的話系統會自動提交當前事務。也可以手動控制事務的提交，上面的實現代碼可以改成： ``` <pre class="calibre18"> ``` // 啟動事務 Db::startTrans(); try { Db::table('think_user') ->delete(1); Db::table('think_data') ->insert(['id' => 28, 'name' => 'thinkphp', 'status' => 1]); // 提交事務 Db::commit(); } catch (\Exception $e) { // 回滾事務 Db::rollback(); } ``` ``` > #### 注意： > > - - - - - - > > 事務操作只對支持事務的數據庫，并且設置了數據表為事務類型才有效，在Mysql數據庫中請設置表類型為`InnoDB`。并且事務操作必須使用同一個數據庫連接。