PHP開發框架Yii Framework教學(24) 資料庫-DAO範例

據存取物件（DAO） 對存取儲存在不同資料庫管理系統（DBMS）中的資料提供了一個通用的API。 因此，在將底層 DBMS 更 換為另一個時，無需修改使用了 DAO 存取資料的程式碼。

Yii DAO 是基於 PHP Data Objects (PDO) 建置。它是一個為眾多 流行的DBMS提供統一資料存取的擴展，這些 DBMS 包括 MySQL， PostgreSQL 等等。因此，要使用 Yii DAO，PDO 擴充功能和特定的 PDO 資料庫驅動(例如PDO_MYSQL) 必須安裝。

Yii DAO 主要包含以下四個類別：

CDbConnection: 代表一個資料庫 連線。

CDbCommand: 代表一條透過資料庫執行的 SQL 語句。

CDbDataReader: 代表一個只向前移動的，來自一個查詢結果集中的行的流。

CDbTransaction: 代表一個資料庫事務。

下面，我們介紹 Yii DAO 在不同場景中的應用。

1. 建立資料庫連接

要建立一個資料庫連接，建立一個 CDbConnection 實例並將其啟動。 連接到資料庫需要一個資料來源 的名字（DSN）以指定連接資訊。使用者名稱和密碼也可能會用到。 當連接到資料庫的過程中發生錯誤時 (例如，錯誤的 DSN 或無效的使用者名稱/密碼)，將會拋出一個例外。

$connection=new CDbConnection($dsn,$username,$password);
// 建立连接。你可以使用 try...catch 捕获可能抛出的异常
$connection->active=true;
......

$connection->active=false; // 關閉連接DSN 的格式取決於所使用的 PDO 資料庫驅動程式。整體來說， DSN 要包含 有 PDO 驅動的名字，跟上一個冒號，再跟上驅動特定的連接語法。可查閱 PDO 文件 以取得更多資訊。 下面是一個常用DSN格式 的清單。

SQLite: sqlite:/path/to/dbfile
MySQL: mysql:host=localhost;dbname=testdb
PostgreSQL: pgsql:host=localhost;port=5432;dbname=testdb
SQL Server: mssql:host=localhost;dbname=testdb
Oracle: oci:dbname=//localhost:1521/testdb

由於 CDbConnection 繼承自 CApplicationComponent，我們也可以將其作為一個 應用組件使用。要這樣做的話， 請在應用程式設定中設定一個db （或其他名字）應用程式元件如下：

本例使用MySQL chinook 資料庫，修改protected/config/main.php

'components'=>array(
'db'=>array(
'class'=>'CDbConnection',
'connectionString'=>'mysql:host=localhost;dbname=chinook',
'username'=>'root',
'password'=>'password',
'emulatePrepare'=>true, // needed by some MySQL installations
),
),

然後我們就可以透過Yii:: app()->db 存取資料庫連線了。它已經被自動啟動了，除非我們特意配置了 CDbConnection::autoConnect 為 false。透過這種方式，這個單獨的DB連接就可以在我們程式碼中的許多地方共享。

2. 執行 SQL 語句

資料庫連線建立後，SQL 語句就可以透過使用 CDbCommand 執行了。你可以透過使用指定的SQL語句作為 參數呼叫 CDbConnection::createCommand() 來建立一個 CDbCommand 實例。

為簡單起見，我們使用Chinook資料庫中的 Employee表，修改DataModel

class DataModel
{
public $employeeId;
public $firstName;
public $lastName;
public $title;
public $address;
public $email;
}

註：建立DataModel這一步驟可以選。

修改SiteController的indexAction方法：

public function
actionIndex(){
$model = array();$sql='SELECT * FROM Employee';
// 假设你已经建立了一个 "db" 连接$connection=Yii::app()->db;
// 如果没有，你可能需要显式建立一个连接：
// $connection=new CDbConnection($dsn,$username,$password);
$command=$connection->createCommand($sql);
// 如果需要，此 SQL 语句可通过如下方式修改：
// $command->text=$newSQL;
$dataReader=$command->query();
// each $row is an array representing a row of dataforeach($dataReader as $row){$employee = new DataModel();
$employee->employeeId=$row['EmployeeId'];
$employee->firstName=$row['FirstName'];
$employee->lastName=$row['LastName'];
$employee->title=$row['Title'];
$employee->address=$row['Address'];
$employee->email=$row['Email'];
$model[]=$employee;}
$this->render('index', array('model' => $model,));
}

一條 SQL 語句會透過 CDbCommand 以下列兩種方式執行：

execute(): 執行一個無查詢 （non-query ）SQL語句， INS, UPDATE 和 DELETE 例如。如果成功，它將傳回此執行所影響的行數。 query(): 執行一條會傳回若干行資料的 SQL 語句，例如 SELECT。 如果成功，它將傳回一個CDbDataReader 實 例，透過此實例可以遍歷資料的結果行。為簡便起見， （Yii）也實作了一系列queryXXX() 方法以直接傳回查詢結果。

執行 SQL 語句時如果發生錯誤，將會拋出一個例外。

$rowCount=$command->execute(); // 执行无查询 SQL
$dataReader=$command->query(); // 执行一个 SQL 查询
$rows=$command->queryAll(); // 查询并返回结果中的所有行
$row=$command->queryRow(); // 查询并返回结果中的第一行
$column=$command->queryColumn(); // 查询并返回结果中的第一列
$value=$command->queryScalar(); // 查询并返回结果中第一行的第一个字段

3. 取得查詢結果

在 CDbCommand::query() 產生 CDbDataReader 實例之後，你可以透過重複呼叫 CDbDataReader::read() 來取得結果中的行。你也可以 以在 PHP 的 foreach 語言結構中使用 CDbDataReader 一行行檢索資料。

$dataReader=$command->query();
// 重复调用 read() 直到它返回 false
while(($row=$dataReader->read())!==false) { ... }
// 使用 foreach 遍历数据中的每一行
foreach($dataReader as $row) { ... }
// 一次性提取所有行到一个数组
$rows=$dataReader->readAll();

4. 顯示查詢結果

為簡單起見，本例使用echo語句顯示Employee的記錄， 後面可以使用GridView或是ListView來顯示資料庫的表格。

修改protected/views/site/index.php

foreach($model as $employee)
{
echo 'EmployeeId:' . $employee->employeeId . '
';
echo 'First Name:' . $employee->firstName . '
';
echo 'Last Name:' . $employee->lastName . '
';
echo 'Title:' . $employee->title . '
';
echo 'Address:' . $employee->address . '
';
echo 'Email:' . $employee->email . '
';
echo '----------------------
';
}
?>

5. 使用事務

當一個應用要執行幾個查詢，每個查詢要從資料庫讀取並/或向資料庫寫入資訊時，保證資料庫沒有留下幾個查詢而只執行了另外幾個查詢是非常重要的。 事務，在 Yii 中表現為 CDbTransaction 實例，可能會在下面的情況中啟動：

開始事務. 一個個執行查詢。任何對資料庫的更新對外界不可見。 提交事務。如果事務成功，更新變為可見。 如果查詢中的一個失敗，整個交易回滾。

上述工作流程可以透過以下程式碼實現：

$transaction=$connection->beginTransaction();
try
{
$connection->createCommand($sql1)->execute();
$connection->createCommand($sql2)->execute();
//.... other SQL executions
$transaction->commit();
}
catch(Exception $e) // 如果有一条查询失败，则会抛出异常
{
$transaction->rollBack();
}

6. 綁定參數

要避免SQL 注入攻擊並提高重複執行的SQL 語句的效率， 你可以「準備（prepare）」一條含有可選參數佔位符的SQL 語句，在參數綁定時，這些佔位符將被替換為實際的參數。

參數佔位符可以是命名的 (表現 為一個唯一的標記) 或未命名的 (表現為一個問號)。呼叫CDbCommand::bindParam() 或 CDbCommand::bindValue() 以使用實際 參數取代這些佔位符。 這些參數不需要使用引號引起來：底層的資料庫驅動會為你搞定這個。 參數綁定必須在 SQL 語句執行 之前完成。

// 一条带有两个占位符 ":username" 和 ":email"的 SQL
$sql="INSERT INTO tbl_user (username, email) VALUES(:username,:email)";
$command=$connection->createCommand($sql);
// 用实际的用户名替换占位符 ":username"
$command->bindParam(":username",$username,PDO::PARAM_STR);
// 用实际的 Email 替换占位符 ":email"
$command->bindParam(":email",$email,PDO::PARAM_STR);
$command->execute();
// 使用新的参数集插入另一行
$command->bindParam(":username",$username2,PDO::PARAM_STR);
$command->bindParam(":email",$email2,PDO::PARAM_STR);

$command->execute();方法 bindParam() 和 bindValue() 非常相似。唯一的区别就是前者使用一个 PHP 变量绑 定参数， 而后者使用一个值。对于那些内存中的大数据块参数，处于性能的考虑，应优先使用前者。

关于绑定参数的更 多信息，请参考 相关的PHP文档。

7. 绑定列

当获取查询结果时，你也可以使用 PHP 变量绑定列。 这样在每次获取查询结果中的一行时就会自动使用最新的值填充。

$sql="SELECT username, email FROM tbl_user";
$dataReader=$connection->createCommand($sql)->query();
// 使用 $username 变量绑定第一列 (username)
$dataReader->bindColumn(1,$username);
// 使用 $email 变量绑定第二列 (email)
$dataReader->bindColumn(2,$email);
while($dataReader->read()!==false)
{
// $username 和 $email 含有当前行中的 username 和 email
}

8. 使用表前缀

从版本 1.1.0 起， Yii 提供了集成了对使用表前缀的支持。 表前缀是指在当前连接的数据 库中的数据表的名字前面添加的一个字符串。 它常用于共享的服务器环境，这种环境中多个应用可能会共享同一个数据库，要 使用不同的表前缀以相互区分。 例如，一个应用可以使用 tbl_ 作为表前缀而另一个可以使用 yii_。

要使用表前缀， 配置 CDbConnection::tablePrefix 属性为所希望的表前缀。 然后，在 SQL 语句中使用{{TableName}} 代表表的名字，其中的 TableName 是指不带前缀的表名。 例如，如果数据库含有一个名为tbl_user 的表，而 tbl_ 被配置为表前缀，那我们就可以使 用如下代码执行用户相关的查询：

$sql='SELECT * FROM {{user}}';$users=$connection->createCommand($sql)->queryAll();

以上就是PHP开发框架Yii Framework教程(24) 数据库-DAO示例的内容，更多相关内容请关注PHP中文网（www.php.cn）！