MySQL 在PHP中设计通用数据库接口

在本文中，我们将介绍如何使用PHP编写通用的数据库接口。具体而言，我们将聚焦于MySQL，并提供示例代码和详细说明。

阅读更多：MySQL 教程

数据库接口概述

数据库接口通常用于将应用程序与底层数据库进行交互，并在应用程序中执行常见操作，例如插入、更新和删除数据。为了使这些操作尽可能通用，我们可以使用一组通用函数封装底层的数据库API。这样，我们可以在不同的应用程序中使用相同的代码来访问不同类型的数据库。

我们的示例代码将使用MySQL作为底层数据库，并采用PHP编写通用模块。在这个例子中，我们将定义一个通用的Database类，用来封装MySQL API。

连接到MySQL数据库

要使用MySQL数据库，我们需要连接到MySQL服务器。在PHP中，我们可以使用mysqli扩展来提供MySQL连接。首先，我们需要使用mysqli_connect()函数建立一个连接：

$mysqli = mysqli_connect('localhost', 'user', 'password', 'database');

在上面的代码中，我们使用mysqli_connect()函数连接到本地MySQL服务器，使用名为’user’的用户名和相应密码，选择名为’database’的数据库。

注意，如果连接失败，函数将返回FALSE。

查询数据库

一旦我们已经连接到MySQL服务器，我们可以使用mysqli_query()函数来查询数据库。这个函数需要两个参数：第一个是数据库连接，第二个是要执行的SQL查询语句。例如：

$result = mysqli_query($mysqli, 'SELECT * FROM users');

在上面的代码中，我们查询了名为’users’的表，并将结果存储在$result变量中。这个结果是一个MySQL结果集，使用mysqli_fetch_assoc()函数可以将它转换为关联数组。

while ( $row = mysqli_fetch_assoc($ result)) {
    echo( $row['id'] . ' ' .$ row['name'] . ' ' . $row['email'] . "\n");
}

我们可以使用循环来遍历这个结果集，并将结果打印到屏幕上。

注意，mysqli_query()函数也会返回FALSE，如果查询失败，我们需要相应处理结果。

数据库事务

在访问数据库时，通常需要执行一系列操作，而这些操作必须按照特定的顺序执行。例如，在银行系统中，我们希望把资金转移操作视为一个事务，确保在转移操作期间，所有必要的检查都已经通过，否则将撤销转移操作。

在MySQL中，我们可以使用事务来执行这些类似的操作。在PHP中，我们可以通过使用mysqli扩展的mysqli_begin_transaction()和mysqli_commit()函数轻松地管理事务：

mysqli_begin_transaction( $mysqli); mysqli_query($ mysqli, 'UPDATE accounts SET balance = balance - 100 WHERE name = "Alice"');
mysqli_query( $mysqli, 'UPDATE accounts SET balance = balance + 100 WHERE name = "Bob"'); mysqli_commit($ mysqli);

在这个例子中，我们首先使用mysqli_begin_transaction()函数开始一个新事务。然后我们进行两个更新操作，并在最后使用mysqli_commit()函数提交这个事务。

如果我们需要取消整个事务，则可以使用mysqli_rollback()函数。例如：

mysqli_begin_transaction( $mysqli); mysqli_query($ mysqli, 'UPDATE accounts SET balance = balance - 100 WHERE name = "Alice"');
mysqli_query( $mysqli, 'UPDATE accounts SET balance = balance + 100 WHERE name = "Bob"'); mysqli_rollback($ mysqli);

在这个例子中，我们将两个更新操作包含在一个事务中，并在最后使用mysqli_rollback()函数来撤销这个事务。这将导致两个更新操作都不会逐步生效。

防止SQL注入

当我们从外部收到数据时，例如用户提交的表单数据，我们需要注意SQL注入攻击。SQL注入攻击是指恶意用户尝试通过提交特定的输入来破坏数据库操作的过程。这些输入通常包含注入攻击代码，导致数据库执行预期之外的操作。

为了避免这种类型的攻击，我们必须保证在输入数据中不包含任何注入代码。我们可以使用mysqli扩展的mysqli_real_escape_string()函数来过滤用户输入。该函数将在输入中查找敏感的SQL字符，并插入转义字符，以避免这些字符在SQL查询中被误解。例如：

$name = mysqli_real_escape_string($mysqli, $_POST['name']);
$email = mysqli_real_escape_string($mysqli, $_POST['email']);
mysqli_query($mysqli, "INSERT INTO users (name, email) VALUES ('$name', '$email')");

在上面的代码中，我们使用了mysqli_real_escape_string()函数来过滤用户输入，并将过滤后的变量插入到INSERT查询中。这样，我们就可以避免任何SQL注入攻击。