使用Chatgpt编写的PHP数据库pdo操作类(增删改查)

摘要

将PDO封装成PHP类进行调用有很多好处,包括:

1、封装性和抽象性: 通过将PDO封装到一个类中,您可以将数据库操作逻辑与应用程序的其他部分分离开来,提高了代码的组织性和可维护性。这样,您只需在一个地方维护数据库连接和查询逻辑,而不必在整个应用程序中散布数据库代码。

2、重用性: 将数据库操作封装成类使得这些操作可以在应用程序的不同部分重复使用,而无需重复编写相同的代码。这有助于减少代码冗余,提高效率。

3、安全性: 通过类的方法来执行数据库操作,可以轻松地实施预处理语句,从而减少了SQL注入攻击的风险。类还可以提供错误处理机制,使您能够更容易地处理数据库错误。

4、可扩展性: 使用类封装数据库操作,可以轻松地扩展和维护应用程序。如果需要添加新的数据库操作或更改现有的操作,只需修改类中的相应方法而不必更改应用程序的其他部分。

5、清晰的接口: 类提供了一个清晰的接口,使其他开发人员能够更容易地理解和使用数据库操作。这有助于团队协作和代码维护。

将PDO封装成PHP类可以提高代码的可维护性、可重用性和安全性,同时降低了代码的耦合度,使数据库操作更容易管理和扩展。这是一个良好的软件工程实践,特别适用于中大型和复杂的应用程序。

类文件

Database.php

以下是使用Chatgpt生成的操作类,但是我做了30%的修改和优化。

<?php/*** Title:PDO数据库操作类* Author:TANKING* Blog:https://segmentfault.com/u/tanking* Date:2023-09-18*/class Database{private $host;private $username;private $password;private $database;private $pdo;private $error = null;public function __construct($host, $username, $password, $database){$this->host = $host;$this->username = $username;$this->password = $password;$this->database = $database;$this->connect();}// 获取错误信息public function getError(){return $this->error;}// 连接数据库private function connect(){$dsn = "mysql:host={$this->host};dbname={$this->database}";try {$this->pdo = new PDO($dsn, $this->username, $this->password);$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);} catch (PDOException $e) {die("Connection failed: " . $e->getMessage());}}// 插入数据public function insert($table, $data){try {$columns = implode(", ", array_keys($data));$values = ":" . implode(", :", array_keys($data));$sql = "INSERT INTO $table ($columns) VALUES ($values)";$stmt = $this->pdo->prepare($sql);$result = $stmt->execute($data);if (!$result) {$this->error = $stmt->errorInfo();}return $result;} catch (PDOException $e) {// 处理数据库异常$this->error = $e->getMessage();return FALSE;}}// 更新数据public function update($table, $data, $where){try {$set = "";foreach ($data as $key => $value) {$set .= "$key = :$key, ";}$set = rtrim($set, ', ');$sql = "UPDATE $table SET $set WHERE $where";$stmt = $this->pdo->prepare($sql);$result = $stmt->execute($data);if (!$result) {$this->error = $stmt->errorInfo();}return $result;} catch (PDOException $e) {// 处理数据库异常$this->error = $e->getMessage();return FALSE;}}// 删除数据public function delete($table, $where){try {$sql = "DELETE FROM $table WHERE $where";$stmt = $this->pdo->prepare($sql);$result = $stmt->execute();if($stmt->rowCount() === 0) {// 没有受影响的记录$this->error = '没有受影响的记录';return FALSE;}else {return $result;}} catch (PDOException $e) {// 处理数据库异常$this->error = $e->getMessage();return FALSE;}}// 查询一条数据public function queryOne($table, $conditions = []){$whereClause = $this->buildWhereClause($conditions);$sql = "SELECT * FROM $table $whereClause LIMIT 1";try {$stmt = $this->pdo->prepare($sql);$stmt->execute($conditions);return $stmt->fetch(PDO::FETCH_ASSOC);} catch (PDOException $e) {// 处理数据库异常$this->error = $e->getMessage();return FALSE;}}// 查询所有数据public function queryAll($table, $conditions = []){$whereClause = $this->buildWhereClause($conditions);$sql = "SELECT * FROM $table $whereClause";try {$stmt = $this->pdo->prepare($sql);$stmt->execute($conditions);return $stmt->fetchAll(PDO::FETCH_ASSOC);} catch (PDOException $e) {// 处理数据库异常$this->error = $e->getMessage();return FALSE;}}// 执行原生SQL语句public function executeSQL($sql, $params = []){try {$stmt = $this->pdo->prepare($sql);$result = $stmt->execute($params);if (!$result) {// 执行失败$this->error = $stmt->errorInfo();return FALSE;}return $stmt;} catch (PDOException $e) {// 处理数据库异常$this->error = $stmt->errorInfo();return FALSE;}}// 数据绑定private function buildWhereClause($conditions){if (empty($conditions)) {return '';}$where = 'WHERE';foreach ($conditions as $key => $value) {$where .= " $key = :$key AND";}$where = rtrim($where, ' AND');return $where;}}

实例

配置文件 Db.php

<?php/*** Title:数据库配置* Author:TANKING* Blog:https://segmentfault.com/u/tanking* Date:2023-09-18*/$DbConfig = array('db_host' => 'xxx', // 数据库服务器'db_name' => 'xxx', // 数据库名'db_user' => 'xxx', // 数据库账号'db_pwd' => 'xxx', // 数据库密码);include 'Database.php';
?>

以下实例使用一个名为artcles的数据库表进行操作演示。

在这里插入图片描述

插入数据 insert.php

<?php// 编码header("Content-type:application/json");// 数据库配置include 'Db.php';// 连接数据库$db = new Database($DbConfig['db_host'], $DbConfig['db_user'], $DbConfig['db_pwd'], $DbConfig['db_name']);// 插入数据$data = ['aid' => rand(100000,999999), 'title' => 'sdfgsadg','tag' => 'ceshi','content' => '这是内容','author' => 'TANKING'];$insertArtcle = $db->insert('artcles', $data);if($insertArtcle){echo '插入成功';}else{echo '失败!' . $db->getError();}?>

更新数据 update.php

<?php// 编码header("Content-type:application/json");// 数据库配置include 'Db.php';// 连接数据库$db = new Database($DbConfig['db_host'], $DbConfig['db_user'], $DbConfig['db_pwd'], $DbConfig['db_name']);// 更新$updateData = ['tag' => '测试'];$where = 'id = 19';$updateArtcle = $db->update('artcles', $updateData, $where);if($updateArtcle){echo '更新成功!';}else{echo '更新失败!' . $db->getError();}?>

删除数据 delete.php

<?php// 编码header("Content-type:application/json");// 数据库配置include 'Db.php';// 连接数据库$db = new Database($DbConfig['db_host'], $DbConfig['db_user'], $DbConfig['db_pwd'], $DbConfig['db_name']);// 删除$where = 'id = 11';$deleteArtcle = $db->delete('artcles', $where);if($deleteArtcle){echo '删除成功!';}else{echo '删除失败!' . $db->getError();}?>

查询一条数据 queryOne.php

<?php// 编码header("Content-type:application/json");// 数据库配置include 'Db.php';// 连接数据库$db = new Database($DbConfig['db_host'], $DbConfig['db_user'], $DbConfig['db_pwd'], $DbConfig['db_name']);// 查询一条数据$conditions = ['id' => 18];$getArtcle = $db->queryOne('artcles', $conditions);if($getArtcle){echo json_encode($getArtcle);}else{echo '查询失败!' . $db->getError();}?>

查询所有数据 queryAll.php

<?php// 编码header("Content-type:application/json");// 数据库配置include 'Db.php';// 连接数据库$db = new Database($DbConfig['db_host'], $DbConfig['db_user'], $DbConfig['db_pwd'], $DbConfig['db_name']);// 查询所有数据$conditions = [];$getArtcles = $db->queryAll('artcles', $conditions);if($getArtcles){echo json_encode($getArtcles);}else{echo '查询失败!' . $db->getError();}?>

执行原生SQL语句

// 插入
$sql = "INSERT INTO artcles (aid, title, tag, content, author) VALUES (:aid, :title, :tag, :content, :author)";
$params = [':aid' => rand(100000,999999), ':title' => '这是标题' . uniqid(),':tag' => 'tag' . rand(0,9),':content' => '这是内容' . uniqid(),':author' => 'TANKING'
];// 更新
$sql = "UPDATE artcles SET title = :title WHERE id = :id";
$params = [':id' => 22,':title' => '这是标题_已更新',
];// 删除
$sql = "DELETE FROM artcles WHERE id = :id";
$params = [':id' => 20
];// 查询
$sql = "SELECT * FROM artcles";
try {$stmt = $db->executeSQL($sql);if ($stmt) {$result = $stmt->fetchAll(PDO::FETCH_ASSOC);if (empty($result)) {// 没有匹配的结果echo "没有匹配的结果";} else {echo json_encode($result);}} else {echo "查询失败,错误信息:" . json_encode($db->getError());}
} catch (DatabaseException $e) {// 查询失败echo $e->getMessage();
}

作者

TANKING

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/85571.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

soildwork2022怎么恢复软件界面的默认设置?

1.点击菜单中的” 视图” 2.在弹出的子菜单中选择”工作区” 3.选择工作区中的”默认” 4.点击默认后软件界面就恢复了默认设置。

FPGA 图像缩放 千兆网 UDP 网络视频传输,基于B50610 PHY实现,提供工程和QT上位机源码加技术支持

目录 1、前言版本更新说明免责声明 2、相关方案推荐UDP视频传输--无缩放FPGA图像缩放方案我这里已有的以太网方案 3、设计思路框架视频源选择IT6802解码芯片配置及采集动态彩条跨时钟FIFO图像缩放模块详解设计框图代码框图2种插值算法的整合与选择 UDP协议栈UDP视频数据组包UDP…

二叉树层序遍历及判断完全二叉树

个人主页:Lei宝啊 愿所有美好如期而遇 目录 二叉树层序遍历&#xff1a; 判断完全二叉树&#xff1a; 二叉树层序遍历&#xff1a; 层序遍历就是一层一层&#xff0c;从上到下遍历&#xff0c;上图遍历结果为&#xff1a;4 2 7 1 3 6 9 思路&#xff1a; 通过队列来实现层序…

发送实时音频数据到udp服务

由于浏览器不能直接连接udp服务&#xff0c;所以需要搭建一个websocket服务做中转&#xff0c;让websocket服务连接udp服务 1、vue开发获取实时音频数据并按4096分包后添加rtp协议头发送到websocket服务&#xff08;连接websocket自行编写连接到127.0.0.1:8889&#xff09; da…

购物H5商城架构运维之路

一、引言 公司属于旅游行业&#xff0c;需要将旅游&#xff0c;酒店&#xff0c;购物&#xff0c;聚合到线上商城。通过对会员数据进行聚合&#xff0c;形成大会员系统&#xff0c;从而提供统一的对客窗口。 二、业务场景 围绕更加有效地获取用户&#xff0c;提升用户的LTV&a…

Python线程和进程

1、深度解析Python线程和进程 一篇文章带你深度解析Python线程和进程 - 知乎使用Python中的线程模块&#xff0c;能够同时运行程序的不同部分&#xff0c;并简化设计。如果你已经入门Python&#xff0c;并且想用线程来提升程序运行速度的话&#xff0c;希望这篇教程会对你有所帮…

stm32之看门狗

STM32 有两个看门狗&#xff0c;独立看门狗和窗口看门狗&#xff0c;独立看门狗又称宠物狗&#xff0c;窗 口看门狗又称警犬。可用来检测和解决由软件错误引起的故障。两个看门狗的原理都是当计数器达到给定的超时值时&#xff0c;产生系统复位&#xff0c;对于窗口型看门狗同…

FL Studio21.2中文版数字音乐制作软件

现在的FL也可以像splice一样啦&#xff0c;需要什么样的声音只需在fl里搜索&#xff0c;就会自动展示给你! FL Studio 简称FL&#xff0c;全称&#xff1a;Fruity Loops Studio&#xff0c;国人习惯叫它"水果"。软件现有版本是 FL Studio 21&#xff0c;已全面升级支…

如何利用播放器节省20%点播成本

点播成本节省的点其实涉及诸多部分&#xff0c;例如&#xff1a;CDN、转码、存储等&#xff0c;而利用播放器降本却是很多客户比较陌生的部分。火山引擎基于内部支撑抖音集团相关业务的实践&#xff0c;播放器恰恰是成本优化中最重要和最为依赖的部分。 火山引擎的视频团队做了…

“智慧”北京,人工智能引领“新风尚”

原创 | 文 BFT机器人 北京时间&#xff0c;9月15日&#xff0c;北京人工智能产业峰会暨中关村科学城科创大赛颁奖典礼在北京中关村举行&#xff0c;同时惠阳还举行了“中关村人工智能大模型产业集聚区”启动建设的揭牌仪式。 此次大会围绕北京AI产业的建设与发展&#xff0c;各…

大模型时代,探人工智能发展的新动向

导语 | 今年以来大模型的热度居高不下&#xff0c;人工智能成为国内外各大厂商争相布局的新赛道。那么近期 AI 领域有哪些值得关注的新趋势&#xff0c;它又将为软件开发带来哪些影响呢&#xff1f;今天&#xff0c;我们特邀了微智云科技 CEO、腾讯云 TVP 张虎老师&#xff0c;…

不用addEventListener(‘resize‘, this.resize),用新的Web API ResizeObserver监听DIV元素尺寸的变化

响应式设计指的是根据屏幕视口尺寸的不同&#xff0c;对 Web 页面的布局、外观进行调整&#xff0c;以便更加有效地进行信息的展示。我们日常生活中接触的很多应用都遵循响应式的设计。 响应式设计如今也成为 web 应用的基本需求&#xff0c;而现在很多 web 应用都已经组件化&a…

分布式运用之Filebeat+Kafka+ELK 的服务部署

一、Kafka 架构深入了解 1.1 Kafka 工作流程及文件存储机制 Kafka 中消息是以 topic 进行分类的&#xff0c;生产者生产消息&#xff0c;消费者消费消息&#xff0c;都是面向 topic 的。 topic 是逻辑上的概念&#xff0c;而 partition 是物理上的概念&#xff0c;每个 par…

LinkedList相较于Arravlist的特点/优化

Arravlist底层是内存空间连续的数组&#xff0c;可以根据下标进行随机访问&#xff0c;效率比较高&#xff0c;因为在根据下标访问某一个元素时&#xff0c;并不是一个一个去查&#xff0c;而是算出来这个下标的地址&#xff0c;直接根据这个地址的指向去获取的&#xff0c;因为…

Linux 创建 终止线程(thread)

进程线程区别 创建线程 #include <pthread.h> int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg); -功能&#xff1a;创建一个子线程&#xff0c;一般情况下main函数所在的线程称为主线程&#xff0c;…

Unity的AB包相关

1、打包 在这个界面左边右键&#xff0c;CreateNewBundle 将要打包的模型制作成预设体 在下面勾选 选好平台路径&#xff0c;点击Build 2、加载AB包 public class ABTest : MonoBehaviour {// Start is called before the first frame updatevoid Start(){//加载AB包AssetB…

mysql集群使用nginx配置负载均衡

参考链接&#xff1a;https://mu-sl.com//archives/mysql%E9%9B%86%E7%BE%A4%E4%BD%BF%E7%94%A8nginx%E9%85%8D%E7%BD%AE%E8%B4%9F%E8%BD%BD%E5%9D%87%E8%A1%A1 配置文件nginx_tcp.conf 示例 load_module modules/ngx_stream_module.so;stream{upstream tcpssh{hash $remote_…

【c#-Nuget 包“在此源中不可用”】 Nuget package “Not available in this source“

标题c#-Nuget 包“在此源中不可用”…但 VS 仍然知道它吗&#xff1f; (c# - Nuget package “Not available in this source”… but VS still knows about it?) 背景&#xff1a; 今日从公司svn 上拉取很久很久以前的代码&#xff0c;拉取下来200报错&#xff0c;进一步发…

如何设置代理ip服务器地址

在今天的互联网环境中&#xff0c;代理服务器在保护个人隐私和规避网络限制方面扮演着重要的角色。设置代理服务器地址的方式主要取决于你使用的具体软件或编程语言。在本文中&#xff0c;我们将分别介绍如何在Python和Java中使用HTTP代理服务器、SOCKS代理服务器以及代理池。 …

C/C++开发,opencv阀值操作

目录 一、OpenCV-阀值操作 1.1阀值操作函数threshold 1.2threshold的操作类型 1.3Otsu算法 二、样例开发 2.1 Makefile 2.2 main.cpp 2.3 运行效果 三、OpenCV-自适应阀值操作 3.1 自适应阀值操作函数-adaptiveThreshold 3.2 样例开发 一、OpenCV-阀值操作 1.1阀值操…