【PHP7数据库连接实战指南】：一步步建立稳定数据库连接

# 1. PHP 数据库连接基础**

PHP 提供了多种连接数据库的方法，包括：

- **mysqli 函数：**mysqli 扩展提供了面向过程的 MySQL 连接接口，它易于使用且性能良好。
- **PDO 函数：**PDO（PHP 数据对象）扩展提供了一个统一的接口，可用于连接不同的数据库系统，包括 MySQL、PostgreSQL 和 Oracle。PDO 具有面向对象的方法，可提供更好的错误处理和异常处理。

# 2. MySQL 数据库连接

### 2.1 建立 MySQL 连接

MySQL 数据库连接是使用 PHP 与 MySQL 数据库进行交互的第一步。有两种主要的方法可以建立 MySQL 连接：使用 mysqli 函数和使用 PDO 函数。

#### 2.1.1 mysqli 函数

mysqli 函数是 PHP 中用于连接 MySQL 数据库的扩展。它提供了一组函数来执行各种数据库操作，包括连接、查询、更新和删除。

**代码块：使用 mysqli 函数建立 MySQL 连接**

<?php
// 连接到 MySQL 数据库
$mysqli = new mysqli("localhost", "username", "password", "database_name");

// 检查连接是否成功
if ($mysqli->connect_error) {
    die("连接失败： " . $mysqli->connect_error);
}
?>

**逻辑分析：**

* `mysqli` 函数接受四个参数：主机名、用户名、密码和数据库名称。
* `connect_error` 属性用于检查连接是否成功。如果连接失败，它将包含错误消息。

#### 2.1.2 PDO 函数

PDO（PHP 数据对象）是 PHP 中用于连接和操作数据库的另一个扩展。它提供了一个统一的接口来访问不同的数据库系统，包括 MySQL。

**代码块：使用 PDO 函数建立 MySQL 连接**

<?php
// 连接到 MySQL 数据库
try {
    $pdo = new PDO("mysql:host=localhost;dbname=database_name", "username", "password");
} catch (PDOException $e) {
    die("连接失败： " . $e->getMessage());
}
?>

**逻辑分析：**

* `PDO` 函数接受一个数据源名称 (DSN) 作为第一个参数。DSN 指定了数据库类型、主机名、数据库名称、用户名和密码。
* `try...catch` 块用于处理连接错误。如果连接失败，`PDOException` 将被抛出。

### 2.2 查询 MySQL 数据库

建立连接后，就可以使用查询来检索数据。有两种主要的方法可以查询 MySQL 数据库：使用 mysqli_query() 函数和使用 PDO::query() 方法。

#### 2.2.1 mysqli_query() 函数

mysqli_query() 函数用于执行 SQL 查询并返回一个结果集。

**代码块：使用 mysqli_query() 函数查询 MySQL 数据库**

<?php
// 执行 SQL 查询
$result = $mysqli->query("SELECT * FROM users");

// 检查查询是否成功
if (!$result) {
    die("查询失败： " . $mysqli->error);
}
?>

**逻辑分析：**

* `mysqli_query()` 函数接受一个 SQL 查询字符串作为参数。
* `error` 属性用于检查查询是否成功。如果查询失败，它将包含错误消息。

#### 2.2.2 PDO::query() 方法

PDO::query() 方法用于执行 SQL 查询并返回一个 PDOStatement 对象。

**代码块：使用 PDO::query() 方法查询 MySQL 数据库**

<?php
// 执行 SQL 查询
$statement = $pdo->query("SELECT * FROM users");

// 检查查询是否成功
if (!$statement) {
    die("查询失败： " . $pdo->errorInfo()[2]);
}
?>

**逻辑分析：**

* `PDO::query()` 方法接受一个 SQL 查询字符串作为参数。
* `errorInfo()` 方法返回一个包含查询错误信息的数组。

### 2.3 更新 MySQL 数据库

除了查询数据，还可以使用更新语句来修改数据库中的数据。有两种主要的方法可以更新 MySQL 数据库：使用 mysqli_query() 函数和使用 PDO::exec() 方法。

#### 2.3.1 mysqli_query() 函数

mysqli_query() 函数可以用于执行更新语句，例如 INSERT、UPDATE 和 DELETE。

**代码块：使用 mysqli_query() 函数更新 MySQL 数据库**

<?php
// 执行更新语句
$result = $mysqli->query("UPDATE users SET name='John' WHERE id=1");

// 检查更新是否成功
if (!$result) {
    die("更新失败： " . $mysqli->error);
}
?>

**逻辑分析：**

* `mysqli_query()` 函数接受一个更新语句字符串作为参数。
* `error` 属性用于检查更新是否成功。如果更新失败，它将包含错误消息。

#### 2.3.2 PDO::exec() 方法

PDO::exec() 方法可以用于执行更新语句，例如 INSERT、UPDATE 和 DELETE。

**代码块：使用 PDO::exec() 方法更新 MySQL 数据库**

<?php
// 执行更新语句
$rowCount = $pdo->exec("UPDATE users SET name='John' WHERE id=1");

// 检查更新是否成功
if ($rowCount === false) {
    die("更新失败： " . $pdo->errorInfo()[2]);
}
?>

**逻辑分析：**

* `PDO::exec()` 方法接受一个更新语句字符串作为参数。
* `rowCount` 属性返回受更新语句影响的行数。如果更新失败，它将返回 false。

# 3. PostgreSQL 数据库连接

PostgreSQL 是一种功能强大的开源关系型数据库管理系统 (RDBMS)，以其可靠性、可扩展性和功能性而闻名。在本节中，我们将探讨如何使用 PHP 连接到 PostgreSQL 数据库，并执行查询和更新操作。

### 3.1 建立 PostgreSQL 连接

#### 3.1.1 pg_connect() 函数

`pg_connect()` 函数是连接到 PostgreSQL 数据库的最简单方法。它接受一个连接字符串作为参数，该字符串指定数据库服务器、端口、数据库名称、用户名和密码。

$conn = pg_connect("host=localhost port=5432 dbname=my_database user=my_user password=my_password");

if (!$conn) {
    die("Error connecting to PostgreSQL database: " . pg_last_error());
}

#### 3.1.2 PDO 函数

PHP 数据对象 (PDO) 扩展提供了一种面向对象的方式来连接和操作数据库。它支持多种数据库系统，包括 PostgreSQL。要使用 PDO 连接到 PostgreSQL，我们需要创建一个 `PDO` 对象：

$dsn = "pgsql:host=localhost;port=5432;dbname=my_database";
$user = "my_user";
$password = "my_password";

try {
    $conn = new PDO($dsn, $user, $password);
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
} catch (PDOException $e) {
    die("Error connecting to PostgreSQL database: " . $e->getMessage());
}

### 3.2 查询 PostgreSQL 数据库

#### 3.2.1 pg_query() 函数

`pg_query()` 函数用于执行 SQL 查询。它接受一个连接句柄和一个 SQL 查询字符串作为参数。

$result = pg_query($conn, "SELECT * FROM users");

if (!$result) {
    die("Error executing query: " . pg_last_error());
}

#### 3.2.2 PDO::query() 方法

PDO 提供了 `query()` 方法来执行 SQL 查询。它返回一个 `PDOStatement` 对象，表示查询结果。

$stmt = $conn->query("SELECT * FROM users");

if (!$stmt) {
    die("Error executing query: " . $conn->errorInfo()[2]);
}

### 3.3 更新 PostgreSQL 数据库

#### 3.3.1 pg_query() 函数

`pg_query()` 函数也可以用于执行更新操作，例如插入、更新和删除。它接受一个连接句柄和一个 SQL 更新查询字符串作为参数。

$result = pg_query($conn, "INSERT INTO users (name, email) VALUES ('John Doe', 'john.doe@example.com')");

if (!$result) {
    die("Error executing query: " . pg_last_error());
}

#### 3.3.2 PDO::exec() 方法

PDO 提供了 `exec()` 方法来执行更新操作。它返回受影响的行数。

$rowCount = $conn->exec("INSERT INTO users (name, email) VALUES ('Jane Doe', 'jane.doe@example.com')");

if ($rowCount === false) {
    die("Error executing query: " . $conn->errorInfo()[2]);
}

# 4. Oracle 数据库连接

### 4.1 建立 Oracle 连接

#### 4.1.1 oci_connect() 函数

`oci_connect()` 函数用于建立到 Oracle 数据库的连接。其语法如下：

oci_connect(string $username, string $password, string $connection_string, string $character_set = null, int $session_mode = OCI_DEFAULT) : resource|false

| 参数 | 说明 |
|---|---|
| `$username` | Oracle 用户名 |
| `$password` | Oracle 密码 |
| `$connection_string` | 连接字符串，指定数据库服务器地址、端口和服务名 |
| `$character_set` | 可选，指定字符集 |
| `$session_mode` | 可选，指定会话模式 |

**示例：**

$username = 'scott';
$password = 'tiger';
$connection_string = '//localhost/orcl';

$conn = oci_connect($username, $password, $connection_string);

if (!$conn) {
    echo '连接失败！';
} else {
    echo '连接成功！';
}

#### 4.1.2 PDO 函数

也可以使用 PDO (PHP Data Objects) 扩展来建立到 Oracle 数据库的连接。其语法如下：

new PDO('oci:dbname=//localhost/orcl', 'scott', 'tiger')

**示例：**

$dsn = 'oci:dbname=//localhost/orcl';
$username = 'scott';
$password = 'tiger';

try {
    $conn = new PDO($dsn, $username, $password);
    echo '连接成功！';
} catch (PDOException $e) {
    echo '连接失败：' . $e->getMessage();
}

### 4.2 查询 Oracle 数据库

#### 4.2.1 oci_execute() 函数

`oci_execute()` 函数用于执行 Oracle 查询。其语法如下：

oci_execute(resource $statement, int $mode = OCI_COMMIT_ON_SUCCESS) : boolean

| 参数 | 说明 |
|---|---|
| `$statement` | 要执行的查询语句 |
| `$mode` | 可选，指定执行模式 |

**示例：**

$query = 'SELECT * FROM employees';
$stmt = oci_parse($conn, $query);
oci_execute($stmt);

#### 4.2.2 PDO::query() 方法

也可以使用 PDO 的 `query()` 方法来执行 Oracle 查询。其语法如下：

PDO::query(string $statement) : PDOStatement

**示例：**

$query = 'SELECT * FROM employees';
$stmt = $conn->query($query);

### 4.3 更新 Oracle 数据库

#### 4.3.1 oci_execute() 函数

`oci_execute()` 函数也可以用于更新 Oracle 数据库。其语法如下：

oci_execute(resource $statement, int $mode = OCI_COMMIT_ON_SUCCESS) : boolean

**示例：**

$query = 'UPDATE employees SET salary = salary * 1.10';
$stmt = oci_parse($conn, $query);
oci_execute($stmt);

#### 4.3.2 PDO::exec() 方法

也可以使用 PDO 的 `exec()` 方法来更新 Oracle 数据库。其语法如下：

PDO::exec(string $statement) : int

**示例：**

$query = 'UPDATE employees SET salary = salary * 1.10';
$rowCount = $conn->exec($query);

# 5. SQL Server 数据库连接**

**5.1 建立 SQL Server 连接**

SQL Server 是 Microsoft 开发的关系型数据库管理系统 (RDBMS)。它广泛用于企业应用程序、数据仓库和商业智能解决方案。要连接到 SQL Server 数据库，可以使用以下两种方法：

**5.1.1 sqlsrv_connect() 函数**

sqlsrv_connect() 函数是 PHP 中用于连接到 SQL Server 数据库的内置函数。它接受以下参数：

sqlsrv_connect(string $serverName, string $userName, string $password, array $connectionInfo = array());

* **$serverName：**SQL Server 实例的名称或 IP 地址。
* **$userName：**连接到数据库的用户名。
* **$password：**连接到数据库的密码。
* **$connectionInfo：**一个包含其他连接选项的关联数组（可选）。

示例：

$serverName = 'localhost';
$userName = 'sa';
$password = 'your_password';

$connection = sqlsrv_connect($serverName, $userName, $password);

if ($connection === false) {
    die(print_r(sqlsrv_errors(), true));
}

**5.1.2 PDO 函数**

PDO（PHP 数据对象）是 PHP 中用于与不同数据库系统交互的通用接口。它也可以用于连接到 SQL Server 数据库。要使用 PDO 连接到 SQL Server，请执行以下步骤：

1. 创建一个 PDO 对象：

$dsn = 'sqlsrv:Server=localhost;Database=your_database';
$username = 'sa';
$password = 'your_password';

$connection = new PDO($dsn, $username, $password);

2. 设置 PDO 错误模式：

$connection->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

**5.2 查询 SQL Server 数据库**

连接到 SQL Server 数据库后，可以使用以下方法查询数据库：

**5.2.1 sqlsrv_query() 函数**

sqlsrv_query() 函数用于执行 SQL 查询并返回一个结果集。它接受以下参数：

sqlsrv_query(resource $connection, string $sql, array $params = array(), array $options = array());

* **$connection：**与 SQL Server 数据库的连接资源。
* **$sql：**要执行的 SQL 查询。
* **$params：**要绑定到查询的参数数组（可选）。
* **$options：**一个包含其他查询选项的关联数组（可选）。

示例：

$sql = 'SELECT * FROM users';

$stmt = sqlsrv_query($connection, $sql);

if ($stmt === false) {
    die(print_r(sqlsrv_errors(), true));
}

while ($row = sqlsrv_fetch_array($stmt, SQLSRV_FETCH_ASSOC)) {
    echo $row['name'] . '<br>';
}

**5.2.2 PDO::query() 方法**

PDO::query() 方法用于执行 SQL 查询并返回一个 PDOStatement 对象。它接受以下参数：

PDO::query(string $sql, array $options = array());

* **$sql：**要执行的 SQL 查询。
* **$options：**一个包含其他查询选项的数组（可选）。

示例：

$sql = 'SELECT * FROM users';

$stmt = $connection->query($sql);

if ($stmt === false) {
    die(print_r($connection->errorInfo(), true));
}

while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {
    echo $row['name'] . '<br>';
}

**5.3 更新 SQL Server 数据库**

要更新 SQL Server 数据库，可以使用以下方法：

**5.3.1 sqlsrv_query() 函数**

sqlsrv_query() 函数可以用于执行更新、插入和删除查询。它接受与查询相同的参数。

示例：

$sql = 'UPDATE users SET name = ? WHERE id = ?';

$params = array('John Doe', 1);

$stmt = sqlsrv_query($connection, $sql, $params);

if ($stmt === false) {
    die(print_r(sqlsrv_errors(), true));
}

**5.3.2 PDO::exec() 方法**

PDO::exec() 方法用于执行更新、插入和删除查询。它接受以下参数：

PDO::exec(string $sql);

* **$sql：**要执行的 SQL 查询。

示例：

$sql = 'UPDATE users SET name = ? WHERE id = ?';

$stmt = $connection->prepare($sql);
$stmt->execute(array('John Doe', 1));

# 6. 数据库连接最佳实践

### 6.1 连接池的使用

连接池是一种缓存机制，用于存储已建立的数据库连接，以供应用程序重用。使用连接池可以显著提高应用程序的性能，因为它消除了建立新连接的开销。

**优点：**

- 减少建立连接的开销
- 提高应用程序的响应时间
- 降低数据库服务器的负载

**使用步骤：**

1. 创建一个连接池对象
2. 配置连接池参数，例如最大连接数、最小连接数、空闲时间等
3. 从连接池中获取连接
4. 使用连接进行数据库操作
5. 将连接归还给连接池

### 6.2 连接参数的优化

连接参数可以对数据库连接的性能产生重大影响。以下是一些需要考虑的优化参数：

- **连接超时：**指定在建立连接之前等待的时间。
- **查询超时：**指定在执行查询之前等待的时间。
- **最大连接数：**指定连接池中允许的最大连接数。
- **最小连接数：**指定连接池中始终保持的最小连接数。
- **空闲时间：**指定连接在空闲后被关闭之前可以保持空闲的时间。

### 6.3 错误处理和异常处理

数据库连接过程中可能会发生错误。妥善处理这些错误对于应用程序的稳定性和可靠性至关重要。

**错误处理：**

- 使用 `try-catch` 块来捕获错误。
- 检查错误代码和错误消息以确定错误的类型。
- 根据错误类型采取适当的措施，例如重试连接或终止应用程序。

**异常处理：**

- 使用 `PDOException` 类来处理 PDO 异常。
- 检查异常代码和异常消息以确定异常的类型。
- 根据异常类型采取适当的措施，例如重试连接或终止应用程序。