Yii 학습 요약 데이터 액세스 개체(DAO)

이 글은 YII 학습 요약 시리즈 중 두 번째 글입니다. 주로 DAO(Data Access Object)에 대해 소개하고 있으며, 필요한 친구들이 참고할 수 있습니다.

Yii는 강력한 데이터베이스. 프로그래밍 지원. Yii 데이터 액세스 개체(DAO)는 PHP 데이터 개체(PDO) 확장을 기반으로 구축되어 단일 통합 인터페이스를 통해 다양한 데이터베이스 관리 시스템(DBMS)에 액세스할 수 있습니다. Yii의 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 인스턴스를 생성한 후 Call 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();