YiiFramework开发教程(24)数据库-DAO示例
数据访问对象（DAO）对访问存储在不同数据库管理系统（DBMS）中的数据提供了一个通用的API。因此，在将底层DBMS更换为另一个时，无需修改使用了DAO访问数据的代码。
YiiDAO基于
PHPDataObjects(PDO)构建。它是一个为众多流行的DBMS提供统一数据访问的扩展，这些DBMS包括MySQL，PostgreSQL等等。因此，要使用YiiDAO，PDO扩展和特定的PDO数据库驱动(例如PDO_MYSQL
)必须安装。
YiiDAO主要包含如下四个类：
CDbConnection:代表一个数据库连接。
CDbCommand:代表一条通过数据库执行的SQL语句。
CDbDataReader:代表一个只向前移动的，来自一个查询结果集中的行的流。
CDbTransaction:代表一个数据库事务。
下面，我们介绍YiiDAO在不同场景中的应用。
1.建立数据库连接
要建立一个数据库连接，创建一个CDbConnection实例并将其激活。连接到数据库需要一个数据源的名字（DSN）以指定连接信息。用户名和密码也可能会用到。当连接到数据库的过程中发生错误时(例如，错误的DSN或无效的用户名/密码)，将会抛出一个异常。
1 | $connection = new CDbConnection( $dsn , $username , $password ); |
2 | //建立连接。你可以使用try...catch捕获可能抛出的异常 |
3 | $connection ->active=true; |
5 | $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
SQLServer:mssql:host=localhost;dbname=testdb
Oracle:oci:dbname=//localhost:1521/testdb
由于CDbConnection继承自CApplicationComponent，我们也可以将其作为一个应用组件使用。要这样做的话，
请在应用配置中配置一个db
（或其他名字）应用组件如下：
本例使用MySQLchinook数据库，修改protected/config/main.php
3 | 'class' => 'CDbConnection' , |
4 | 'connectionString' => 'mysql:host=localhost;dbname=chinook' , |
7 | 'emulatePrepare' =>true, //neededbysomeMySQLinstallations |
然后我们就可以通过Yii::app()->db
访问数据库连接了。它已经被自动激活了，除非我们特意配置了CDbConnection::autoConnect为false。通过这种方式，这个单独的DB连接就可以在我们代码中的很多地方共享。
2.执行SQL语句
数据库连接建立后，SQL语句就可以通过使用CDbCommand执行了。你可以通过使用指定的SQL语句作为参数调用CDbConnection::createCommand()创建一个CDbCommand实例。
为简单起见，我们使用Chinook数据库中的Employee表，修改DataModel
注：创建DataModel这一步可以选。
修改SiteController的indexAction方法：
1 | public function actionIndex() |
5 | $sql = 'SELECT*FROMEmployee' ; |
7 | $connection =Yii::app()->db; |
9 | //$connection=newCDbConnection($dsn,$username,$password); |
10 | $command = $connection ->createCommand( $sql ); |
11 | //如果需要，此SQL语句可通过如下方式修改： |
12 | //$command->text=$newSQL; |
14 | $dataReader = $command ->query(); |
16 | //each$rowisanarrayrepresentingarowofdata |
17 | foreach ( $dataReader as $row ) |
19 | $employee = new
DataModel(); |
20 | $employee ->employeeId= $row [ 'EmployeeId' ]; |
21 | $employee ->firstName= $row [ 'FirstName' ]; |
22 | $employee ->lastName= $row [ 'LastName' ]; |
23 | $employee ->title= $row [ 'Title' ]; |
24 | $employee ->address= $row [ 'Address' ]; |
25 | $employee ->email= $row [ 'Email' ]; |
30 | $this ->render( 'index' , array ( |
一条SQL语句会通过CDbCommand以如下两种方式被执行：
execute():执行一个无查询（non-query）SQL语句，例如INSERT
,UPDATE
和DELETE
。如果成功，它将返回此执行所影响的行数。
query():执行一条会返回若干行数据的SQL语句，例如SELECT
。如果成功，它将返回一个CDbDataReader实例，通过此实例可以遍历数据的结果行。为简便起见，（Yii）还实现了一系列queryXXX()
方法以直接返回查询结果。
执行SQL语句时如果发生错误，将会抛出一个异常。
$rowCount=$command->execute();//执行无查询SQL除select外
$dataReader=$command->query();//执行一个SQL查询mysql_fetch_assoc
$rows=$command->queryAll();//查询并返回结果中的所有行mysql_fetch_assoc获得全部行二维数组
$row=$command->queryRow();//查询并返回结果中的第一行mysql_fetch_row获得总行数用$rows['count[*]']和获得一行[code]
$column=$command->queryColumn();//查询并返回结果中的第一列$value=$command->queryScalar();//查询并返回结果中第一行的第一个字段[/code]
3.获取查询结果
在CDbCommand::query()生成CDbDataReader实例之后，你可以通过重复调用CDbDataReader::read()获取结果中的行。你也可以在
PHP的foreach
语言结构中使用CDbDataReader一行行检索数据。
$dataReader=$command->query();
//重复调用read()直到它返回false
while(($row=$dataReader->read())!==false){...}
//使用foreach遍历数据中的每一行
foreach($dataReaderas$row){...}
//一次性提取所有行到一个数组
$rows=$dataReader->readAll();
4.显示查询结果
为简单起见，本例使用echo语句显示Employee的记录，后面可以使用GridView或是ListView来显示数据库的表格。
修改protected/views/site/index.php
1 | <?php foreach ( $model as $employee ) |
4 | echo 'EmployeeId:' . $employee ->employeeId. '<br/>' ; |
5 | echo 'FirstName:' . $employee ->firstName. '<br/>' ; |
6 | echo 'LastName:' . $employee ->lastName. '<br/>' ; |
7 | echo 'Title:' . $employee ->title. '<br/>' ; |
8 | echo 'Address:' . $employee ->address. '<br/>' ; |
9 | echo 'Email:' . $employee ->email. '<br/>' ; |
10 | echo '----------------------<br/>' ; |
本例下载
此外Dao支持事务处理，绑定参数等。
5.使用事务
当一个应用要执行几条查询，每条查询要从数据库中读取并/或向数据库中写入信息时，保证数据库没有留下几条查询而只执行了另外几条查询是非常重要的。事务，在Yii中表现为CDbTransaction实例，可能会在下面的情况中启动：
开始事务.一个个执行查询。任何对数据库的更新对外界不可见。
提交事务。如果事务成功，更新变为可见。
如果查询中的一个失败，整个事务回滚。
上述工作流可以通过如下代码实现：
1 | $transaction = $connection ->beginTransaction(); |
4 | $connection ->createCommand( $sql1 )->execute(); |
5 | $connection ->createCommand( $sql2 )->execute(); |
6 | //....otherSQLexecutions |
9 | catch(Exception $e ) //如果有一条查询失败，则会抛出异常 |
11 | $transaction ->rollBack(); |
6.绑定参数
要避免SQL注入攻击并提高重复执行的SQL语句的效率，你可以“准备（prepare）”一条含有可选参数占位符的SQL语句，在参数绑定时，这些占位符将被替换为实际的参数。
参数占位符可以是命名的(表现为一个唯一的标记)或未命名的(表现为一个问号)。调用CDbCommand::bindParam()或CDbCommand::bindValue()以使用实际参数替换这些占位符。
这些参数不需要使用引号引起来：底层的数据库驱动会为你搞定这个。参数绑定必须在SQL语句执行之前完成。
1 | //一条带有两个占位符":username"和":email"的SQL |
2 | $sql = "INSERTINTOtbl_user(username,email)VALUES(:username,:email)" ; |
3 | $command = $connection ->createCommand( $sql ); |
4 | //用实际的用户名替换占位符":username" |
5 | $command ->bindParam( ":username" , $username ,PDO::PARAM_STR); |
6 | //用实际的Email替换占位符":email" |
7 | $command ->bindParam( ":email" , $email ,PDO::PARAM_STR); |
10 | $command ->bindParam( ":username" , $username2 ,PDO::PARAM_STR); |
11 | $command ->bindParam( ":email" , $email2 ,PDO::PARAM_STR); |
方法bindParam()和bindValue()非常相似。唯一的区别就是前者使用一个PHP变量绑定参数，而后者使用一个值。对于那些内存中的大数据块参数，处于性能的考虑，应优先使用前者。
关于绑定参数的更多信息，请参考相关的PHP文档。
7.绑定列
当获取查询结果时，你也可以使用PHP变量绑定列。这样在每次获取查询结果中的一行时就会自动使用最新的值填充。
1 | $sql = "SELECTusername,emailFROMtbl_user" ; |
2 | $dataReader = $connection ->createCommand( $sql )->query(); |
3 | //使用$username变量绑定第一列(username) |
4 | $dataReader ->bindColumn(1, $username ); |
5 | //使用$email变量绑定第二列(email) |
6 | $dataReader ->bindColumn(2, $email ); |
7 | while ( $dataReader ->read()!==false) |
9 | //$username和$email含有当前行中的username和email |
8.使用表前缀
从版本1.1.0起，Yii提供了集成了对使用表前缀的支持。表前缀是指在当前连接的数据库中的数据表的名字前面添加的一个字符串。它常用于共享的服务器环境，这种环境中多个应用可能会共享同一个数据库，要使用不同的表前缀以相互区分。例如，一个应用可以使用tbl_
作为表前缀而另一个可以使用yii_
。
要使用表前缀，配置CDbConnection::tablePrefix属性为所希望的表前缀。然后，在SQL语句中使用{{TableName}}代表表的名字，其中的TableName
是指不带前缀的表名。例如，如果数据库含有一个名为tbl_user
的表，而tbl_
被配置为表前缀，那我们就可以使用如下代码执行用户相关的查询：
1 | $sql = 'SELECT*FROM{{user}}'; |
2 | $users = $connection ->createCommand( $sql )->queryAll(); |
