
在php面向对象编程中,频繁地在每个方法中创建新的pdo数据库连接会导致资源浪费和代码冗余。本教程将介绍如何通过在类的构造函数中一次性创建pdo连接,并将其存储为类属性,从而实现连接的复用。通过这种方式,不仅能提高代码效率和可维护性,还能确保数据库资源被有效管理,避免不必要的连接开销。
在开发PHP应用程序时,尤其是采用面向对象(OOP)范式时,数据库连接是不可或缺的一部分。然而,初学者常犯的一个错误是在每个需要与数据库交互的方法内部都重新实例化一个PDO对象,例如:
protected function insertUser(){
$connectionvar = new PDO('mysql:host='. $this->host .';dbname='.$this->db, $this->user, $this->password);
// 后续的SQL执行代码
}这种做法存在显著问题:
解决上述问题的关键在于,只创建一次数据库连接,并将其存储在类的属性中,以便在整个对象生命周期中复用。 最常见且推荐的做法是在类的构造函数中初始化PDO连接,并将其赋值给一个受保护的(protected)或私有的(private)类属性。
以下是一个示例,展示如何构建一个基础的数据库连接类:
<?php
class DB
{
/**
* @var PDO 数据库连接实例
*/
protected PDO $connection;
/**
* 构造函数,在对象创建时建立数据库连接
*
* @param string $host 数据库主机名
* @param string $db 数据库名称
* @param string $user 数据库用户名
* @param string $password 数据库密码
*/
public function __construct(string $host, string $db, string $user, string $password)
{
try {
$dsn = "mysql:host={$host};dbname={$db};charset=utf8mb4";
$options = [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION, // 错误模式:抛出异常
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC, // 默认获取模式:关联数组
PDO::ATTR_EMULATE_PREPARES => false, // 禁用模拟预处理语句
];
$this->connection = new PDO($dsn, $user, $password, $options);
} catch (PDOException $e) {
// 在生产环境中,应记录错误而非直接输出
throw new PDOException("数据库连接失败: " . $e->getMessage(), (int)$e->getCode());
}
}
}在这个DB类中:
一旦PDO连接被存储为类属性,任何继承自DB类或通过依赖注入获得DB实例的类,都可以在其方法中通过$this->connection来访问这个已建立的连接,而无需再次实例化。
例如,如果你有一个用户管理类UserManager,它需要进行CRUD操作:
<?php
class UserManager extends DB
{
/**
* 插入新用户到数据库
*
* @param string $username 用户名
* @param string $email 邮箱
* @param string $password 密码(应加密存储)
* @return bool 插入是否成功
*/
public function insertUser(string $username, string $email, string $password): bool
{
// 直接使用父类中已建立的数据库连接
$stmt = $this->connection->prepare("INSERT INTO users (username, email, password) VALUES (?, ?, ?)");
return $stmt->execute([$username, $email, $password]);
}
/**
* 根据用户ID获取用户信息
*
* @param int $userId 用户ID
* @return array|false 用户信息数组或false
*/
public function getUserById(int $userId): array|false
{
$stmt = $this->connection->prepare("SELECT id, username, email FROM users WHERE id = ?");
$stmt->execute([$userId]);
return $stmt->fetch(); // 默认PDO::FETCH_ASSOC
}
// 其他CRUD方法...
}
// 示例使用
$dbHost = 'localhost';
$dbName = 'test_db';
$dbUser = 'root';
$dbPass = 'password';
try {
$userManager = new UserManager($dbHost, $dbName, $dbUser, $dbPass);
$isInserted = $userManager->insertUser('john_doe', 'john@example.com', 'hashed_password');
if ($isInserted) {
echo "用户插入成功!\n";
}
$user = $userManager->getUserById(1);
if ($user) {
echo "获取用户ID为1的信息:\n";
print_r($user);
} else {
echo "未找到用户ID为1的信息。\n";
}
} catch (PDOException $e) {
echo "操作失败: " . $e->getMessage() . "\n";
}
?>通过这种方式,UserManager类及其所有方法都可以共享同一个数据库连接,避免了重复实例化PDO对象。
神采PromeAI
将涂鸦和照片转化为插画,将线稿转化为完整的上色稿。
111
查看详情
为了进一步解耦和提高代码的复用性,最佳实践是让DB类不仅负责连接管理,还提供通用的数据库查询执行方法。这样,其他业务逻辑类(如UserManager)就不需要直接操作prepare、execute等方法,而是调用DB类提供的更高级别的接口。
修改DB类,添加一个通用的查询方法:
<?php
class DB
{
protected PDO $connection;
public function __construct(string $host, string $db, string $user, string $password)
{
try {
$dsn = "mysql:host={$host};dbname={$db};charset=utf8mb4";
$options = [
PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
PDO::ATTR_EMULATE_PREPARES => false,
];
$this->connection = new PDO($dsn, $user, $password, $options);
} catch (PDOException $e) {
throw new PDOException("数据库连接失败: " . $e->getMessage(), (int)$e->getCode());
}
}
/**
* 执行一个SQL查询并返回所有结果(适用于SELECT)
*
* @param string $sql SQL查询语句
* @param array $parameters 绑定到SQL语句的参数数组
* @return array 查询结果集
*/
public function runQueryAndGetResult(string $sql, array $parameters = []): array
{
$statement = $this->connection->prepare($sql);
$statement->execute($parameters);
return $statement->fetchAll();
}
/**
* 执行一个SQL查询并返回单行结果(适用于SELECT单行)
*
* @param string $sql SQL查询语句
* @param array $parameters 绑定到SQL语句的参数数组
* @return array|false 单行结果数组或false
*/
public function runQueryAndGetSingleResult(string $sql, array $parameters = []): array|false
{
$statement = $this->connection->prepare($sql);
$statement->execute($parameters);
return $statement->fetch();
}
/**
* 执行一个SQL语句并返回受影响的行数(适用于INSERT, UPDATE, DELETE)
*
* @param string $sql SQL语句
* @param array $parameters 绑定到SQL语句的参数数组
* @return int 受影响的行数
*/
public function runStatement(string $sql, array $parameters = []): int
{
$statement = $this->connection->prepare($sql);
$statement->execute($parameters);
return $statement->rowCount();
}
/**
* 获取最后插入的ID
*
* @return string|false
*/
public function getLastInsertId(): string|false
{
return $this->connection->lastInsertId();
}
}现在,UserManager类可以不再继承DB类,而是通过依赖注入的方式接收DB实例。这是一种更灵活、更推荐的实践,因为它降低了类之间的耦合度。
<?php
// 假设 DB 类已定义如上
class UserManager
{
private DB $db; // 持有 DB 类的实例
/**
* 构造函数,通过依赖注入接收 DB 实例
*
* @param DB $db 数据库操作对象
*/
public function __construct(DB $db)
{
$this->db = $db;
}
public function insertUser(string $username, string $email, string $password): bool
{
$sql = "INSERT INTO users (username, email, password) VALUES (?, ?, ?)";
$affectedRows = $this->db->runStatement($sql, [$username, $email, $password]);
return $affectedRows > 0;
}
public function getUserById(int $userId): array|false
{
$sql = "SELECT id, username, email FROM users WHERE id = ?";
return $this->db->runQueryAndGetSingleResult($sql, [$userId]);
}
public function getAllUsers(): array
{
$sql = "SELECT id, username, email FROM users";
return $this->db->runQueryAndGetResult($sql);
}
// 其他CRUD方法...
}
// 示例使用
$dbHost = 'localhost';
$dbName = 'test_db';
$dbUser = 'root';
$dbPass = 'password';
try {
$db = new DB($dbHost, $dbName, $dbUser, $dbPass); // 只创建一次 DB 实例
$userManager = new UserManager($db); // 将 DB 实例注入 UserManager
$isInserted = $userManager->insertUser('jane_doe', 'jane@example.com', 'another_hashed_password');
if ($isInserted) {
echo "用户 Jane Doe 插入成功!\n";
}
$user = $userManager->getUserById(2);
if ($user) {
echo "获取用户ID为2的信息:\n";
print_r($user);
} else {
echo "未找到用户ID为2的信息。\n";
}
$allUsers = $userManager->getAllUsers();
echo "所有用户信息:\n";
print_r($allUsers);
} catch (PDOException $e) {
echo "操作失败: " . $e->getMessage() . "\n";
}
?>通过这种分层设计:
通过在类的构造函数中一次性创建并存储PDO数据库连接为类属性,可以有效避免重复创建连接带来的性能问题和代码冗余。进一步地,将数据库操作封装在一个专门的DB类中,并通过依赖注入的方式将其提供给其他业务逻辑类,是实现高内聚、低耦合、可维护和可测试代码的最佳实践。
注意事项:
以上就是PHP面向对象编程中避免重复创建PDO数据库连接的最佳实践的详细内容,更多请关注php中文网其它相关文章!
# 绑定
# seo服务崇德甜柚网络
# 南京网站seo排名
# 贵州网站网络推广模式
# 口红微信营销推广方案
# 大众网站推广方案
# 阳泉网站推广优势
# 盐都关键词排名优化
# 网站建设会议纪要
# 保定自动seo
# 青海seo查询案例官网
# 复用
# 类中
# 应用程序
# 是在
# mysql
# 加载
# 类属
# 适用于
# 面向对象
# php面向对象编程
# sql语句
# 面向对象编程
# 邮箱
# 配置文件
# 环境变量
# ai
# 编码
# word
# php
相关文章:
QQ网页版官方账号入口 QQ网页版网页版登录指南
大象笔记网页版入口 印象笔记网页版登录入口
C#如何安全地从用户上传的XML文件中读取数据? 验证与清理策略
b站如何看历史记录_b站观看历史找回方法
c++ 获取系统当前时间 c++时间戳获取方法
Shopware订单中获取产品自定义字段的实用指南
excel怎么制作工资条 excel快速生成工资条的方法
提升Kafka消费者健壮性:会话超时处理与消息处理语义
解决macOS上安装pyhdf时‘hdf.h’文件缺失的编译错误
《主播少女的秘密账号迷宫》首支宣传片
我的世界mc.js免费游戏直接能玩 我的世界mc.js小游戏免费秒玩入口
如何使 Jest 模拟函数默认抛出错误以提高测试效率
Golang如何优雅处理error_Golang error处理最佳实践总结
Composer如何在生产环境安全地执行composer update
Excel Power Pivot如何处理XML数据源 构建高级数据模型
C++的std::mdspan是什么_C++23中用于操作多维数组的非拥有视图
想当下一个《2077》?《心之眼》Steam评价升至"多半好评"
微信聊天记录怎么加密_微信聊天记录加密方法
漫蛙漫画登录站点 漫蛙2正版漫画快速访问
css卡片内容溢出如何处理_使用overflow隐藏或scroll显示内容
内存检查:在VS Code中调试C++时的内存视图
抖音极速版最新版本 抖音极速版官方下载地址
PHP表单提交后函数重复执行的解决方案:管理$_POST数据
马斯克:Optimus 人形机器人复数形式为 Optimi
蛙漫画网页版全站入口 蛙漫热门作品免费浏览
Linux如何构建多环境配置管理_Linux多环境配置方案
c++如何使用std::memory_order控制原子操作顺序_c++ C++11内存模型详解
Python实时数据流中的动态最值查找策略
Golang如何通过reflect获取匿名字段方法_Golang reflect匿名字段方法访问技巧
J*aScript中localStorage数据的获取、清洗与格式化教程
Go语言中JSON数据解析与字段访问教程
sublime侧边栏怎么增强功能_SideBarEnhancements for sublime安装与配置
极兔快递快件信息查询系统 极兔快递官网运单号追踪
响应式图片在网页设计中的正确实现方法
格力空气能E5故障代码是什么情况_格力空气能E5代码解析与应对措施
html网页设计源代码怎么运行_运行html网页设计源代码步骤【指南】
谷歌google账号注册详细步骤 谷歌账号注册官方教程
yy漫画网页版官方入口_yy漫画官网登录页面链接
TikTok国际版网页端快速入口 TikTok全球版短视频浏览教程
千牛数据看板网页版_千牛数据看板网页版访问方法
LINUX下如何进行磁盘分区_fdisk与parted工具在LINUX中的使用对比
C++如何检测键盘输入_C++ _kbhit与_getch函数非阻塞输入
抖音网页版快捷访问 抖音网页版网页版入口操作教程
菜鸟取件码是什么怎么查 最全查询渠道汇总
限制HTML日期输入框的日期选择范围
印象笔记怎样用批量导出备知识库_印象笔记用批量导出备知识库【备份方法】
我的世界官方游戏入口 我的世界官网平台直达链接
拼多多视频播放卡顿如何处理 拼多多视频播放优化技巧
Archive of Our Own官网直达 AO3最新可用地址一览
Gmail邮箱申请注册直达_Gmail邮箱免费注册PC版官网入口2025
*请认真填写需求信息,我们会在24小时内与您取得联系。