PHP|| PHP访问 MySQL 数据库

作者： 分类：所有,php 字数：9748

'# PHP|| PHP访问 MySQL 数据库

一、背景与问题

在Web开发中，数据库是存储和管理数据的核心组件。PHP作为服务器端脚本语言，其与MySQL数据库的交互能力直接影响应用的性能和安全性。传统开发中，开发者常使用mysql_*系列函数进行数据库操作，但该系列函数已于2018年被官方弃用。随着PHP版本迭代，现代开发中普遍采用PDO（PHP Data Objects）和MySQLi（MySQL Improved）两种扩展。

本篇文章将深入探讨PHP与MySQL的交互原理，分析不同实现方式的优劣，结合真实开发场景，给出完整的代码示例和性能优化方案。重点覆盖以下核心内容：

  1. 不同数据库连接方式的底层机制
  2. SQL注入等安全风险的防范
  3. 高性能数据库查询的优化方法
  4. 实际开发中常见错误的解决方案

二、基本原理

PHP与MySQL的交互主要通过客户端-服务器架构实现。MySQL数据库服务运行在服务器端，PHP通过socket协议与MySQL服务器建立连接，发送SQL查询指令，接收结果集。

1. 数据库连接机制

PHP通过以下方式与MySQL建立连接：

  • mysql_connect()（已弃用）
  • mysqli_connect()（MySQLi扩展）
  • PDO::__construct()（PDO扩展）

以MySQLi为例，其工作流程如下：

  1. 建立连接：mysqli_connect('host', 'user', 'password', 'database')
  2. 选择数据库：mysqli_select_db()
  3. 执行SQL：mysqli_query()
  4. 获取结果：mysqli_fetch_*() 系列函数
  5. 关闭连接：mysqli_close()

2. 数据传输协议

PHP与MySQL通信使用TCP/IP协议，默认端口3306。数据以二进制协议传输，包含：

  • 连接请求包
  • SQL查询包
  • 结果集数据包
  • 错误信息包

3. 查询执行流程

典型查询流程包含：

  1. 构造SQL语句
  2. 通过连接发送查询
  3. 服务器解析SQL
  4. 执行查询
  5. 返回结果集
  6. 客户端处理结果

三、环境准备

在开始开发前，需要完成以下准备：

1. 环境配置

  • 安装MySQL服务器（推荐8.0+版本）
  • 安装PHP并启用MySQLi或PDO扩展

  • 配置php.ini文件：

    extension=mysqli
extension=pdo
extension=pdo_mysql

2. 数据库准备

创建测试数据库和表：

CREATE DATABASE php_test;
USE php_test;

CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    email VARCHAR(100) NOT NULL UNIQUE,
    created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);

四、核心实现

1. 基础连接与查询

<?php
// MySQLi连接示例
$host = 'localhost';
$user = 'root';
$pass = 'password';
$db = 'php_test';

// 建立连接
$conn = mysqli_connect($host, $user, $pass, $db);

if (!$conn) {
    die("连接失败: " . mysqli_connect_error());
}

// 执行查询
$sql = "SELECT * FROM users";
$result = mysqli_query($conn, $sql);

if (mysqli_num_rows($result) > 0) {
    while($row = mysqli_fetch_assoc($result)) {
        echo "ID: " . $row['id'] . " - Name: " . $row['username'] . "<br>";
    }
} else {
    echo "0 结果";
}

// 关闭连接
mysqli_close($conn);
?>

关键代码解析：

  • mysqli_connect()建立连接时，会进行三次握手
  • mysqli_query()执行查询时，会将SQL语句发送到MySQL服务器
  • mysqli_fetch_assoc()将结果集转换为关联数组
  • 需要显式关闭连接，避免资源泄漏

2. 预处理语句（Prepared Statements）

<?php
// PDO预处理语句示例
$dsn = 'mysql:host=localhost;dbname=php_test;charset=utf8mb4';
$username = 'root';
$password = 'password';

try {
    $pdo = new PDO($dsn, $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // 预处理查询
    $stmt = $pdo->prepare("INSERT INTO users (username, email) VALUES (?, ?)");
    $stmt->execute(['JohnDoe', 'john@example.com']);

    echo "插入成功";
} catch (PDOException $e) {
    echo "连接失败: " . $e->getMessage();
}
?>

关键代码解析：

  • 使用prepare()方法编译SQL语句
  • 使用execute()执行时传递参数数组
  • 预处理语句能有效防止SQL注入
  • PDO::ATTR_ERRMODE设置错误处理模式

3. 事务处理

<?php
// MySQLi事务处理示例
$host = 'localhost';
$user = 'root';
$pass = 'password';
$db = 'php_test';

$conn = mysqli_connect($host, $user, $pass, $db);

if (!$conn) {
    die("连接失败: " . mysqli_connect_error());
}

// 开启事务
mysqli_begin_transaction($conn);

try {
    // 插入用户
    $stmt = mysqli_prepare($conn, "INSERT INTO users (username, email) VALUES (?, ?)");
    mysqli_stmt_bind_param($stmt, 'ss', 'Alice', 'alice@example.com');
    mysqli_stmt_execute($stmt);

    // 插入订单
    $stmt = mysqli_prepare($conn, "INSERT INTO orders (user_id, product) VALUES (?, ?)");
    mysqli_stmt_bind_param($stmt, 'is', 1, 'Laptop');
    mysqli_stmt_execute($stmt);

    // 提交事务
    mysqli_commit($conn);
    echo "事务提交成功";
} catch (Exception $e) {
    // 回滚事务
    mysqli_rollback($conn);
    echo "事务回滚: " . $e->getMessage();
}

mysqli_close($conn);
?>

关键代码解析：

  • 使用mysqli_begin_transaction()开启事务
  • 使用mysqli_stmt_bind_param()绑定参数
  • 事务处理确保数据一致性
  • 需要显式提交或回滚事务

五、完整案例

用户管理系统案例

<?php
// 用户管理系统完整案例
$dsn = 'mysql:host=localhost;dbname=php_test;charset=utf8mb4';
$username = 'root';
$password = 'password';

try {
    $pdo = new PDO($dsn, $username, $password);
    $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // 创建用户
    function createUser(PDO $pdo, string $username, string $email): bool {
        $stmt = $pdo->prepare("INSERT INTO users (username, email) VALUES (?, ?)");
        return $stmt->execute([$username, $email]);
    }

    // 获取用户
    function getUser(PDO $pdo, int $id): ?array {
        $stmt = $pdo->prepare("SELECT * FROM users WHERE id = ?");
        $stmt->execute([$id]);
        return $stmt->fetch(PDO::FETCH_ASSOC);
    }

    // 更新用户
    function updateUser(PDO $pdo, int $id, string $username, string $email): bool {
        $stmt = $pdo->prepare("UPDATE users SET username = ?, email = ? WHERE id = ?");
        return $stmt->execute([$username, $email, $id]);
    }

    // 删除用户
    function deleteUser(PDO $pdo, int $id): bool {
        $stmt = $pdo->prepare("DELETE FROM users WHERE id = ?");
        return $stmt->execute([$id]);
    }

    // 示例使用
    if ($_SERVER['REQUEST_METHOD'] === 'POST') {
        if (isset($_POST['action'])) {
            switch ($_POST['action']) {
                case 'create':
                    if (isset($_POST['username'], $_POST['email'])) {
                        if (createUser($pdo, $_POST['username'], $_POST['email'])) {
                            echo "用户创建成功";
                        } else {
                            echo "用户创建失败";
                        }
                    }
                    break;
                case 'get':
                    if (isset($_POST['id'])) {
                        $user = getUser($pdo, (int)$_POST['id']);
                        if ($user) {
                            print_r($user);
                        } else {
                            echo "用户不存在";
                        }
                    }
                    break;
                case 'update':
                    if (isset($_POST['id'], $_POST['username'], $_POST['email'])) {
                        if (updateUser($pdo, (int)$_POST['id'], $_POST['username'], $_POST['email'])) {
                            echo "用户更新成功";
                        } else {
                            echo "用户更新失败";
                        }
                    }
                    break;
                case 'delete':
                    if (isset($_POST['id'])) {
                        if (deleteUser($pdo, (int)$_POST['id'])) {
                            echo "用户删除成功";
                        } else {
                            echo "用户删除失败";
                        }
                    }
                    break;
            }
        }
    }
} catch (PDOException $e) {
    echo "数据库连接失败: " . $e->getMessage();
}
?>

案例说明：

  • 使用PDO实现通用CRUD操作
  • 通过函数封装数据库操作逻辑
  • 包含完整的异常处理机制
  • 支持创建、获取、更新、删除操作

六、源码解析

以MySQLi连接为例，其底层实现涉及：

  1. 套接字连接：php-src/ext/mysqli/mysqli.c中实现TCP连接
  2. 协议解析：php-src/ext/mysqli/mysqli_protocol.c处理MySQL协议
  3. 查询执行：php-src/ext/mysqli/mysqli_api.c处理SQL执行
  4. 结果处理：php-src/ext/mysqli/mysqli_result.c处理结果集

关键性能优化点：

  • 使用mysqlnd（MySQL Native Driver）替代原始驱动
  • 启用PDO::ATTR_DEFAULT_FETCH_MODE设置默认结果集类型
  • 使用mysqlnd提供的连接池功能

七、进阶使用

1. 高性能查询优化

// 使用索引优化查询
$stmt = $pdo->prepare("SELECT * FROM users WHERE email = ? ORDER BY created_at DESC");
$stmt->execute(['user@example.com']);

优化建议：

  • 对常用查询字段建立索引
  • 使用EXPLAIN分析查询计划
  • 避免使用SELECT *
  • 使用覆盖索引（Covering Index）

2. 管理连接池

// 使用PDO连接池
$pdo = new PDO($dsn, $username, $password, [
    PDO::ATTR_PERSISTENT => true
]);

注意事项：

  • 连接池在高并发场景下能显著提升性能
  • 需要合理配置连接池大小
  • 注意连接池的资源回收机制

3. 使用事务的高级场景

// 复杂事务处理
try {
    mysqli_begin_transaction($conn);
    
    // 执行多个操作
    $stmt = mysqli_prepare($conn, "INSERT INTO logs (action, data) VALUES (?, ?)");
    mysqli_stmt_bind_param($stmt, 'ss', 'create_user', json_encode($user));
    mysqli_stmt_execute($stmt);
    
    // 提交事务
    mysqli_commit($conn);
} catch (Exception $e) {
    mysqli_rollback($conn);
    // 记录错误日志
}

八、性能与工程实践

1. 性能优化方案

优化类型方法说明
查询优化使用索引为常用查询字段创建索引
查询优化避免SELECT *只查询需要的字段
查询优化使用覆盖索引索引包含查询所需字段
连接优化连接池复用数据库连接
连接优化管道化使用PDO::ATTR_EMULATE_PREPARES
缓存优化查询缓存使用query_cache或Redis缓存

2. 安全实践

常见安全风险：

  • SQL注入
  • 命令注入
  • 跨站脚本（XSS）
  • 跨站请求伪造（CSRF）

防御措施：

  • 使用预处理语句
  • 对用户输入进行验证
  • 使用参数化查询
  • 设置合适的HTTP头防止XSS
  • 使用CSRF令牌

3. 异常处理

// 异常处理示例
try {
    $pdo->beginTransaction();
    // 执行数据库操作
    $pdo->commit();
} catch (PDOException $e) {
    $pdo->rollBack();
    // 记录日志
    error_log("数据库事务失败: " . $e->getMessage());
}

九、常见问题与踩坑

1. 常见错误

错误类型示例解决方案
SQL注入$stmt = mysqli_query($conn, "SELECT * FROM users WHERE id = $id")使用预处理语句
错误处理未捕获异常使用try-catch块
资源泄漏未关闭连接显式调用mysqli_close()
性能问题未使用索引分析查询计划

2. 典型问题分析

问题：查询速度变慢

原因分析：

  • 索引缺失
  • 查询未使用索引
  • 表数据量过大
  • 查询语句不优化

解决方法：

  • 使用EXPLAIN分析查询
  • 增加合适的索引
  • 优化SQL语句
  • 考虑分库分表

问题：连接数过多

原因分析：

  • 未关闭连接
  • 使用连接池配置不当
  • 未进行连接复用

解决方法：

  • 显式关闭连接
  • 使用连接池配置
  • 使用持久化连接

十、最佳实践

1. 推荐实践

  • 使用PDO或MySQLi扩展
  • 优先使用预处理语句
  • 对用户输入进行验证和过滤
  • 使用事务处理关键操作
  • 启用查询日志进行调试
  • 使用连接池提高性能
  • 对敏感数据进行加密存储

2. 代码规范

  • 使用命名规范（如getUserById）
  • 使用常量表示SQL语句
  • 使用配置文件管理数据库连接信息
  • 使用日志记录错误信息
  • 使用单元测试验证数据库操作

3. 安全建议

  • 禁用mysql_*函数
  • 使用htmlspecialchars()防止XSS
  • 使用CSRF令牌防止跨站攻击
  • 对密码进行加密存储（使用password_hash()）

十一、总结

PHP访问MySQL数据库是Web开发的核心技术之一。本文深入分析了不同连接方式的原理，对比了PDO和MySQLi的优劣，提供了完整的代码示例和性能优化方案。通过实际案例展示了如何在真实开发场景中使用这些技术。

在实际开发中，应根据具体需求选择合适的实现方式：

  • 对于简单场景，可以使用MySQLi
  • 对于需要跨数据库支持的场景，推荐使用PDO
  • 对于高并发场景，需要进行连接池优化
  • 对于需要安全性的场景，必须使用预处理语句

开发过程中需要注意常见错误，如SQL注入、资源泄漏、性能问题等，通过合理的实践和规范可以有效避免这些问题。在实际项目中，建议结合数据库设计、索引优化、缓存策略等综合手段提升整体性能和安全性。

PHP , Mysql , sql
最后修改于：2026年09月22日 16:12

评论已关闭

推荐阅读

AIGC实战——Transformer模型
2024年12月01日
python , AI , 机器学习
Socket TCP 和 UDP 编程基础（Python）
2024年11月30日
python , tcp , udp
如何使用 ChatGPT 进行学术润色？你需要这些指令
2024年12月01日
AI
最新 Python 调用 OpenAi 详细教程实现问答、图像合成、图像理解、语音合成、语音识别（详细教程）
2024年11月24日
python , AI
ChatGPT 和 DALL·E 2 配合生成故事绘本
2024年12月01日
python , AI
omegaconf，一个超强的 Python 库！
2024年11月24日
python
【视觉AIGC识别】误差特征、人脸伪造检测、其他类型假图检测
2024年12月01日
python , AI
［超级详细］如何在深度学习训练模型过程中使用 GPU 加速
2024年11月29日
python , AI , 机器学习
Python 物理引擎pymunk最完整教程
2024年11月27日
python
MediaPipe 人体姿态与手指关键点检测教程
2024年11月27日
python
深入了解 Taipy：Python 打造 Web 应用的全面教程
2024年11月26日
python
基于Transformer的时间序列预测模型
2024年11月25日
python , Matplotlib , 机器学习
Python在金融大数据分析中的AI应用（股价分析、量化交易）实战
2024年11月25日
python , Matplotlib , 机器学习
AIGC Gradio系列学习教程之Components
2024年12月01日
python , AI
Python3 `asyncio` — 异步 I/O，事件循环和并发工具
2024年11月30日
python
llama-factory SFT系列教程：大模型在自定义数据集 LoRA 训练与部署
2024年12月01日
python , AI , 机器学习
Python 多线程和多进程用法
2024年11月24日
python
Python socket详解，全网最全教程
2024年11月27日
python , http , websocket
python之plot()和subplot()画图
2024年11月26日
python , Matplotlib
理解 DALL·E 2、Stable Diffusion 和 Midjourney 工作原理
2024年12月01日
python , AI , 机器学习
Copyright © 2026 Tech Blog
All Right Reserved | 京ICP备19053165号