Yii 프레임워크 공식 가이드 시리즈 23 - 데이터베이스 사용: 데이터 액세스 개체(DAO)

DAO(데이터 액세스 개체)는 다양한 데이터베이스 관리 시스템(DBMS)에 저장된 데이터에 액세스하기 위한 공통 API를 제공합니다. 따라서 기본 DBMS를 다른 DBMS로 변경할 때 DAO를 사용하여 데이터에 접근하는 코드를 수정할 필요가 없습니다. Yii DAO는 PHP 데이터 개체(PDO)를 기반으로 구축되었습니다. MySQL, PostgreSQL 등을 포함하여 널리 사용되는 많은 DBMS에 대한 통합 데이터 액세스를 제공하는 확장입니다. 따라서 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(또는 다른 이름) 애플리케이션 구성 요소를 다음과 같이 구성합니다.

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

그러면 Yii::app()->db을 통해 데이터베이스 연결에 접근할 수 있습니다. 특별히 CDbConnection::autoConnect를 false로 구성하지 않으면 자동으로 활성화됩니다. 이렇게 하면 이 단일 DB 연결을 코드의 여러 위치에서 공유할 수 있습니다.

2. SQL 문 실행

데이터베이스 연결이 완료된 후 CDbCommand를 사용하여 SQL 문을 실행할 수 있습니다. 지정된 SQL 문을 인수로 사용하여 CDbConnection::createCommand()를 호출하여 CDbCommand 인스턴스를 만들 수 있습니다.

$connection=Yii::app()->db;   // 假设你已经建立了一个 "db" 连接
// 如果没有，你可能需要显式建立一个连接：
// $connection=new CDbConnection($dsn,$username,$password);
$command=$connection->createCommand($sql);
// 如果需要，此 SQL 语句可通过如下方式修改：
// $command->text=$newSQL;

SQL 문은 다음 두 가지 방법으로 CDbCommand를 통해 실행됩니다.

• execute(): INSERT, UPDATE, DELETE 등 쿼리가 아닌 SQL 문을 실행합니다. 성공하면 이 실행의 영향을 받은 행 수를 반환합니다.

• query(): SELECT과 같이 여러 행의 데이터를 반환하는 SQL 문을 실행합니다. 성공하면 결과 데이터 행을 반복할 수 있는 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();

참고: 는 query()와 다릅니다. 모두 queryXXX() 이 메서드는 데이터를 직접 반환합니다. 예를 들어 queryRow()는 쿼리 결과의 첫 번째 행을 나타내는 배열을 반환합니다.

4. 트랜잭션 사용

애플리케이션이 여러 쿼리를 실행해야 하고 각 쿼리가 데이터베이스에 대한 정보를 읽거나 써야 하는 경우 데이터베이스가 매우 더 이상 쿼리가 남아 있지 않고 다른 쿼리만 실행된다는 점이 중요합니다. Yii에서 CDbTransaction 인스턴스로 표현되는 트랜잭션은 다음과 같은 상황에서 시작될 수 있습니다:

• 트랜잭션 시작.

• 쿼리를 하나씩 실행합니다. 데이터베이스에 대한 업데이트는 외부 세계에 표시되지 않습니다.

• 提交事务。如果事务成功，更新变为可见。

• 如果查询中的一个失败，整个事务回滚。

上述工作流可以通过如下代码实现：

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

5. 绑定参数

要避免 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文档。

6. 绑定列

当获取查询结果时，你也可以使用 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 
}

7. 使用表前缀

从版本 1.1.0 起， Yii 提供了集成了对使用表前缀的支持。 表前缀是指在当前连接的数据库中的数据表的名字前面添加的一个字符串。 它常用于共享的服务器环境，这种环境中多个应用可能会共享同一个数据库，要使用不同的表前缀以相互区分。 例如，一个应用可以使用 tbl_ 作为表前缀而另一个可以使用 yii_。 要使用表前缀，配置 CDbConnection::tablePrefix 属性为所希望的表前缀。 然后，在 SQL 语句中使用{{TableName}} 代表表的名字，其中的 TableName 是指不带前缀的表名。 例如，如果数据库含有一个名为tbl_user 的表，而 tbl_ 被配置为表前缀，那我们就可以使用如下代码执行用户相关的查询：

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

以上就是Yii框架官方指南系列23——使用数据库：数据访问对象（DAO）的内容，更多相关内容请关注PHP中文网（www.php.cn）！