PDO를 사용하여 데이터베이스를 운영하는 PHP 방법 및 기술-PHP 튜토리얼-php.cn

PDO를 사용하여 데이터베이스를 운영하는 PHP 방법 및 기술

PHPz

풀어 주다： 2023-06-08 13:44:02

원래의

1719명이 탐색했습니다.

PHP는 웹 개발에 일반적으로 사용되는 서버 측 프로그래밍 언어입니다. 웹 개발에서 데이터베이스 운영은 매우 일반적인 요구 사항입니다. PDO(PHP Data Objects)는 데이터베이스를 운영하기 위한 PHP용 확장 라이브러리로, MySQL, PostgreSQL, Oracle 등과 같은 주류 데이터베이스 관리 시스템에 연결하는 데 사용할 수 있습니다.

이 기사에서는 데이터베이스 연결, SQL 문 실행, 결과 집합 처리 등을 포함하여 데이터베이스를 운영하기 위해 PDO를 사용하는 PHP의 방법과 기술을 소개합니다.

데이터베이스에 연결

먼저 데이터베이스에 연결해야 합니다. PDO에서는 다음 코드를 사용하여 PDO 객체를 생성할 수 있습니다:

$dbh = new PDO('mysql:host=localhost;dbname=test', $user, $pass);

로그인 후 복사

여기서 localhost는 데이터베이스가 있는 호스트 이름(IP 주소일 수 있음)이고 test 는 연결하는 것입니다. 데이터베이스 이름, $user 및 $pass는 각각 데이터베이스의 사용자 이름과 비밀번호입니다. 필요에 따라 위의 매개변수를 수정할 수 있습니다. localhost是数据库所在的主机名（可以是IP地址），test是要连接的数据库名称，$user和$pass分别是数据库的用户名和密码。我们可以根据需要修改以上参数。

执行SQL语句

连接到数据库后，我们可以执行SQL语句。PDO提供了一些方法来执行SQL语句，下面是一些常用的方法：

exec($query)：执行INSERT、UPDATE、DELETE等操作，返回受影响的行数；
query($query)：执行SELECT语句，返回结果集；
prepare($query)：准备一个SQL语句，返回一个PDOStatement对象，可以通过bindValue()方法绑定参数后执行。

例如，我们可以使用以下代码查询一张users表中的所有记录：

$stmt = $dbh->query("SELECT * FROM users");
while ($row = $stmt->fetch()) {
    echo $row['id'] . "    " . $row['name'] . "
";
}

로그인 후 복사

在以上代码中，$dbh是PDO对象，query()方法用于执行SELECT语句，返回一个PDOStatement对象。我们可以通过fetch()方法循环遍历结果集中的每一行数据，并输出到屏幕上。

处理结果集

在执行SELECT语句后，我们可以通过PDOStatement对象访问结果集中的数据。PDO提供了一些方法来访问结果集，下面是一些常用的方法：

fetch()：获取结果集中的下一行数据，返回一个关联数组；
fetchAll()：获取结果集中的所有数据，返回一个二维关联数组；
rowCount()：获取结果集中的行数。

例如，我们可以使用以下代码查询users表中id为1的用户信息：

$stmt = $dbh->prepare("SELECT * FROM users WHERE id=:id");
$stmt->bindValue(':id', 1, PDO::PARAM_INT);
$stmt->execute();
$row = $stmt->fetch();
if ($row) {
    echo "ID: " . $row['id'] . "
";
    echo "Name: " . $row['name'] . "
";
    echo "Email: " . $row['email'] . "
";
} else {
    echo "Not found.
";
}

로그인 후 복사

在以上代码中，prepare()方法用于准备SQL语句，可以使用:name的形式定义命名参数。我们可以通过bindValue()方法绑定参数值，再执行execute()方法，它们分别对应SQL语句中的占位符。

事务处理

在操作数据库时，我们有时需要执行一系列的SQL语句，并保证它们要么全部执行成功，要么全部不执行。这就需要使用事务。PDO提供了beginTransaction()、commit()、rollBack()等方法来处理事务，例如：

try {
    $dbh->beginTransaction();
    $dbh->exec("INSERT INTO users (name, email) VALUES ('Alice', 'alice@example.com')");
    $dbh->exec("INSERT INTO users (name, email) VALUES ('Bob', 'bob@example.com')");
    $dbh->commit();
} catch (PDOException $e) {
    $dbh->rollBack();
    echo "Transaction failed: " . $e->getMessage();
}

로그인 후 복사

在以上代码中，beginTransaction()方法用于开启事务，commit()方法用于提交事务，如果其中任何一个SQL语句执行失败，则代码会跳转到catch块中，执行rollBack()方法回滚事务。

预处理语句

在执行SQL语句时，我们有时需要使用变量来构造SQL语句，例如：

$name = "Tom";
$stmt = $dbh->query("SELECT * FROM users WHERE name='$name'");

로그인 후 복사

这种方式存在SQL注入的风险，因此应该使用预处理语句。PDO提供了prepare()方法和bindParam()方法来实现预处理语句，例如：

$name = "Tom";
$stmt = $dbh->prepare("SELECT * FROM users WHERE name=:name");
$stmt->bindParam(':name', $name, PDO::PARAM_STR);
$stmt->execute();

로그인 후 복사

在以上代码中，我们使用预处理语句将:name作为占位符，在执行时通过bindParam()方法将$name绑定到:name上，最终执行时:name将被替换为实际的变量值，避免了SQL注入的风险。

调试技巧

在开发过程中，我们经常需要调试SQL语句的执行结果。PDO提供了errorInfo()方法来获取错误信息，例如：

$stmt = $dbh->query("SELECT * FROM users WHERE id=100");
if (!$stmt) {
    $error = $dbh->errorInfo();
    echo "Error: " . $error[2];
}

로그인 후 복사

在以上代码中，如果查询失败，则调用errorInfo()

데이터베이스에 접속한 후 SQL 문을 실행할 수 있습니다. PDO는 SQL 문을 실행하는 몇 가지 방법을 제공합니다. 다음은 일반적으로 사용되는 몇 가지 방법입니다:

exec($query): INSERT, UPDATE, DELETE 및 기타 작업을 수행하고 영향을 받는 수를 반환합니다. 행 ;

query($query)

prepare($query)

🎜예를 들어, 다음 코드를 사용하여 users 테이블의 모든 레코드를 쿼리할 수 있습니다. 🎜rrreee🎜위 코드에서 $dbh는 PDO 개체에서 query() 메서드는 SELECT 문을 실행하고 PDOStatement 개체를 반환하는 데 사용됩니다. fetch() 메서드를 통해 결과 집합의 각 데이터 행을 반복하여 화면에 출력할 수 있습니다. 🎜

🎜결과 집합 처리🎜🎜🎜SELECT 문을 실행한 후 PDOStatement 개체를 통해 결과 집합의 데이터에 액세스할 수 있습니다. PDO는 결과 세트에 액세스하기 위한 몇 가지 메소드를 제공합니다. 다음은 일반적으로 사용되는 메소드입니다: 🎜

fetch()

fetchAll()

rowCount()

🎜예를 들어, 다음 코드를 사용하여 users 테이블에서 ID가 1인 사용자 정보를 쿼리할 수 있습니다. 🎜rrreee🎜위 코드에서 prepare() 방법 SQL 문을 준비하는 데 사용되며 :name 형식을 사용하여 명명된 매개 변수를 정의할 수 있습니다. bindValue() 메서드를 통해 매개변수 값을 바인딩한 후 SQL 문의 자리 표시자에 해당하는 execute() 메서드를 실행할 수 있습니다. 🎜

beginTransaction()

commit()

rollBack()

beginTransaction()

commit()

catch

rollBack()

prepare()

bindParam()

:name

bindParam()

$name