PHP入门指南：PDO数据库

2023-05-20 16:50

短信预约 -IT技能 免费直播动态提醒

PHP是一门非常流行的服务器端编程语言，其灵活性和易用性使其成为Web开发的首选语言之一。在Web应用程序开发中，与数据库交互的过程是非常重要的，PDO(PHP Data Object)是PHP的一个扩展库，用于提供一个通用的接口来与多种关系型数据库进行交互，包括MySQL、PostgreSQL、Oracle等。本文将介绍如何使用PDO操作数据库，适用于初学者。

安装PDO扩展

在使用PDO之前，需要确认PHP是否已经安装PDO扩展。可以通过phpinfo()函数来查看PHP的扩展列表。若扩展列表中没有PDO扩展，需要在php.ini文件中设置extension=pdo.so和extension=pdo_mysql.so，然后重启Web服务器，以启用PDO扩展。

连接数据库

使用PDO连接数据库非常方便，只需要提供数据库的相关信息即可。以下是连接MySQL数据库的示例代码：

$dbname = "test";
$host = "localhost";
$user = "root";
$pass = "password";

$dsn = "mysql:host=" . $host . ";dbname=" . $dbname;
$options = array(PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES utf8");

try {
    $pdo = new PDO($dsn, $user, $pass, $options);
} catch (PDOException $e) {
    echo "Connection failed: " . $e->getMessage();
}

在以上代码中，首先设置了数据库的相关信息，包括数据库名称、主机、用户名及密码。然后，利用DSN(Data Source Name)将数据库信息传递给PDO。在options数组中设置了三个选项：

ATTR_ERRMODE，表示PDO错误处理模式，采用异常的方式抛出错误信息。
ATTR_DEFAULT_FETCH_MODE，表示结果集的获取方式，默认为关联数组。
MYSQL_ATTR_INIT_COMMAND，表示初始化SQL命令，设置字符集为utf8。

try-catch块捕获连接数据库出错的异常，输出错误信息。

执行SQL语句

在连接数据库成功后，就可以执行SQL语句进行数据操作了。PDO提供了三个主要的PDO语句对象：

PDO::query()，执行一条SQL查询语句，并返回结果集。适用于SELECT语句。
PDO::prepare()，预处理SQL语句。适用于SELECT、UPDATE、INSERT、DELETE等语句。
PDO::exec()，执行一条SQL语句，并返回受影响的行数。适用于UPDATE、INSERT、DELETE等语句。

以下是使用PDO::query()查询记录并输出的示例代码：

$sql = "SELECT * FROM user";
try {
    $stmt = $pdo->query($sql);
    while ($row = $stmt->fetch()) {
        echo "Name: " . $row['name'] . "<br>";
        echo "Age: " . $row['age'] . "<br>";
    }
} catch (PDOException $e) {
    echo "Query failed: " . $e->getMessage();
}

在以上代码中，首先定义了一条SQL查询语句，查询用户表中的记录。接着使用query()方法执行SQL语句，$stmt变量返回包含查询结果的PDOStatement对象。然后使用fetch()方法遍历结果集，输出每一行记录的姓名和年龄。如果执行查询出错，try-catch块捕获异常并输出错误信息。

以下是使用PDO::prepare()插入记录的示例代码：

$sql = "INSERT INTO user(name, age) VALUES(:name, :age)";
try {
    $stmt = $pdo->prepare($sql);
    $stmt->bindParam(':name', $name);
    $stmt->bindParam(':age', $age);

    $name = "Alice";
    $age = 30;
    $stmt->execute();

    echo "Record inserted successfully.";
} catch (PDOException $e) {
    echo "Insert failed: " . $e->getMessage();
}

在以上代码中，首先定义了一条SQL插入语句，向用户表中插入一条记录。使用prepare()方法预处理SQL语句，$stmt变量返回包含预处理语句的PDOStatement对象。然后使用bindParam()方法将占位符与实际参数绑定。接着设置参数值，最后使用execute()方法执行SQL语句。如果执行插入出错，try-catch块捕获异常并输出错误信息。