PHP 개발 프레임워크 Yii 프레임워크 튜토리얼(24) Database-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(또는 다른 이름) 애플리케이션 구성 요소를 다음과 같이 구성하십시오.

이 예에서는 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 문 실행

데이터베이스 연결이 완료된 후 CDbCommand를 이용하여 SQL 문을 실행할 수 있습니다. 지정된 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(): 비 쿼리 실행( 쿼리가 아닌) 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();

4. 쿼리 결과 표시

간단함을 위해 이 예제에서는 echo 문을 사용하여 직원 레코드를 표시합니다. 나중에 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 문의 효율성을 높이려면 매개변수가 바인딩될 때 실제 매개변수로 대체될 선택적 매개변수 자리 표시자를 사용하여 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）！