打造一套属于自己的php开发框架(一)封装Db类

一直使用thinkphp或者laravel框架,越到后面越发现,这些框架占用太大了,最主要的是很多东西完全用不到,我就想为啥不能自己封装一个?想到就搞,这个是一个Db类,主要封装了MySQL的增删改查方法,使用起来类似thinkphp和laravel。

多的不说了,直接上代码:

<?phpclass Db
{protected static \PDO $connection; // 数据库连接protected static string $table; // 数据表名protected static array $wheres = []; // 查询条件protected static ?int $findId = null; // 查找的记录 IDprotected static bool $initialized = false; // 数据库连接是否已初始化// 确保数据库连接已建立protected static function ensureConnection(){if (!self::$initialized) {self::$connection = new \PDO("mysql:host=localhost;dbname=数据库名称", "数据库用户名", "数据库密码");self::$initialized = true;}}// 设置数据表名public static function table(string $table): self{self::ensureConnection();self::$table = $table;return new self();}// 设置查询条件public static function where(string $column, string $operator, $value): self{self::$wheres[] = compact('column', 'operator', 'value');return new self();}// 根据 ID 查询记录public static function find(int $id): array{self::ensureConnection();$query = "SELECT * FROM " . self::$table . " WHERE id = :id";$statement = self::$connection->prepare($query);$statement->execute([':id' => $id]);return $statement->fetch(\PDO::FETCH_ASSOC);}// 查询符合条件的记录public static function get(): array{self::ensureConnection();$query = "SELECT * FROM " . self::$table;if (!empty(self::$wheres)) {$query .= " WHERE ";foreach (self::$wheres as $where) {$query .= "{$where['column']} {$where['operator']} '{$where['value']}' AND ";}$query = rtrim($query, " AND ");}$statement = self::$connection->prepare($query);$statement->execute();return $statement->fetchAll(\PDO::FETCH_ASSOC);}// 分页查询public static function paginate(int $page = 1, int $perPage = 10): array{self::ensureConnection();$offset = ($page - 1) * $perPage;$query = "SELECT COUNT(*) as count FROM " . self::$table;if (!empty(self::$wheres)) {$query .= " WHERE ";foreach (self::$wheres as $where) {$query .= "{$where['column']} {$where['operator']} '{$where['value']}' AND ";}$query = rtrim($query, " AND ");}$statement = self::$connection->prepare($query);$statement->execute();$totalResults = $statement->fetchColumn();$query = "SELECT * FROM " . self::$table;if (!empty(self::$wheres)) {$query .= " WHERE ";foreach (self::$wheres as $where) {$query .= "{$where['column']} {$where['operator']} '{$where['value']}' AND ";}$query = rtrim($query, " AND ");}$query .= " LIMIT $perPage OFFSET $offset";$statement = self::$connection->prepare($query);$statement->execute();$results = $statement->fetchAll(\PDO::FETCH_ASSOC);$totalPages = ceil($totalResults / $perPage);return ['data' => $results,'total' => $totalResults,'perPage' => $perPage,'currentPage' => $page,'totalPages' => $totalPages,];}// 插入数据public static function insert(array $data): bool{self::ensureConnection();$columns = implode(', ', array_keys($data));$placeholders = implode(', ', array_fill(0, count($data), '?'));$values = array_values($data);$query = "INSERT INTO " . self::$table . " ($columns) VALUES ($placeholders)";$statement = self::$connection->prepare($query);return $statement->execute($values);}// 更新数据public static function update(array $data, int $id): bool{self::ensureConnection();$updates = [];foreach ($data as $column => $value) {$updates[] = "$column = ?";}$setClause = implode(', ', $updates);$query = "UPDATE " . self::$table . " SET $setClause WHERE id = ?";$values = array_values($data);$values[] = $id;$statement = self::$connection->prepare($query);return $statement->execute($values);}// 删除数据public static function delete(int $id): bool{self::ensureConnection();$query = "DELETE FROM " . self::$table . " WHERE id = ?";$statement = self::$connection->prepare($query);return $statement->execute([$id]);}
}

使用方法:

假设有一个名为 users 的数据表

1.插入一条数据

Db::table('users')->insert(['name' => 'John', 'age' => 30]);

2.查询 ID 为 1 的记录

$result = Db::table('users')->find(1);
var_dump($result); // 输出查询结果

3.更新 ID 为 1 的记录

Db::table('users')->update(['age' => 35], 1);

4.查询年龄大于 30 的用户,并分页显示

$users = Db::table('users')->where('age', '>', 30)->paginate(1, 10);
var_dump($users); // 输出分页结果

5.删除 ID 为 1 的记录

Db::table('users')->delete(1);

大概就是这样了,实现了简单的增删改查,如果不够的可以自己添加一些代码

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

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

相关文章

Solidity基础面试题

目录 1、私有、内部、公共和外部函数之间的区别&#xff1f; 2、智能合约大小大约可以有多大&#xff1f; 3、create 和 create2 之间有什么区别&#xff1f; 4、Solidity 0.8.0版本对算术运算有什么重大变化&#xff1f; 5、代理需要哪种特殊的 CALL 才能工作&#xff1f;…

【简单讲解下如何用爬虫玩转石墨文档】

&#x1f3a5;博主&#xff1a;程序员不想YY啊 &#x1f4ab;CSDN优质创作者&#xff0c;CSDN实力新星&#xff0c;CSDN博客专家 &#x1f917;点赞&#x1f388;收藏⭐再看&#x1f4ab;养成习惯 ✨希望本文对您有所裨益&#xff0c;如有不足之处&#xff0c;欢迎在评论区提出…

flink1.18.0 流转表 表转流 jdk17 attachAsDataStream

目的 流表互转 而且流sink 表sink同时存在且都可以输出. 依赖类 package flink.luca.flinkTableAndSQL.Convert;import lombok.AllArgsConstructor; import lombok.Data; import lombok.NoArgsConstructor;@Data @AllArgsConstructor @NoArgsConstructor public class Outer…

【设计模式】享元模式

目录 什么是享元模式 代码实现 什么是享元模式 Java中的享元模式&#xff08;Flyweight Pattern&#xff09;是一种结构型设计模式&#xff0c;它用于减少系统中对象的数量&#xff0c;以节省内存和提高性能。享元模式通过共享相似对象之间的公共部分来最小化内存使用。 在享…

小记一篇 vuecli4项目 打包内存溢出问题

目录 背景先解决内存溢出问题 让项目能够打包打包优化公共第三方模块 提取出来 不走webpack 打包 , 改成 cdn 引入项目中使用 图片等 静态资源 全部走cdn使用thread-loader 开启多线程打包 后序 背景 其他项目组有个项目迭代了3年&#xff0c;突然有一天 vuecli-4 webpack打包…

链表OJ - 6(链表分割)

题目描述&#xff08;来源&#xff09; 现有一链表的头指针 ListNode* pHead&#xff0c;给一定值x&#xff0c;编写一段代码将所有小于x的结点排在其余结点之前&#xff0c;且不能改变原来的数据顺序&#xff0c;返回重新排列后的链表的头指针。 思路 创建两个链表&#xff0c…

【C#】防御性编程策略float.TryParse()

float.TryParse(Result[0].ToString(), out realValue1);这行C#代码用于尝试将一个字符串转换成浮点数&#xff08;float&#xff09;。具体来说&#xff0c;它使用了 float.TryParse 方法&#xff0c;这是一个非常常用的方法&#xff0c;用于在转换时提供错误处理&#xff0c;…

ChatGPT:引领未来的语言模型革命?

一、引言 随着人工智能技术的不断发展&#xff0c;Chat GPT作为一种自然语言处理技术&#xff0c;已经逐渐渗透到各个领域&#xff0c;具有广泛的应用前景。本文将从多个角度探讨Chat GPT的应用领域及其未来发展趋势。 ChatGPT的语言处理能力超越了以往任何一款人工智能产品。…

iOS知识点---Runloop

iOS 中的 Runloop 机制是一种事件驱动模型&#xff0c;用于管理和调度线程上的事件&#xff0c;确保线程在有工作要做时保持活跃&#xff0c;无事可做时进入休眠状态以节省系统资源。以下是 Runloop 机制的关键组成部分及其工作原理&#xff1a; 关键组成部分与原理&#xff1…

Docker一键快速私有化部署(Ollama+Openwebui) +AI大模型(gemma,llama2,qwen)20240417更新

几行命令教你私有化部署自己的AI大模型&#xff0c;每个人都可以有自己的GTP 第一步&#xff1a;安装Docker(如果已经有了可以直接跳第二步) ####下载安装Docker wget https://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repo -O/etc/yum.repos.d/docker-ce.repo##…

STM32 USB虚拟串口

电路原理图 usb部分 晶振部分 usb与单片机连接 配置信息 sys配置信息 rcc配置信息 usb配置信息 虚拟串口配置信息 时钟配置信息 项目配置信息 代码 包含文件 主函数代码 实验效果 修改接收波特率依然可以正常接收&#xff0c;也就是说单片机可以自动适应上位机的波特率设置。…

4.17作业

#include "double_link_list.h" node_p create_double_link_list() //创建双向链表 {node_p H(node_p)malloc(sizeof(node));if(HNULL){printf("空间申请失败\n");return NULL;}H->data0;H->priNULL;H->nextNULL;return H; } node_p create_node…

【S32K3 MCAL配置】-6.1-ICU Driver:WKPU外设让MCU芯片从“Low Power Mode低功耗模式”中WakeUp唤醒

"><--返回「Autosar_MCAL高阶配置」专栏主页--> 案例背景:此博文适用于“MCU芯片处在常电”工作(MCU的5V/3.3V供电一直存在)的项目当中。另外S32K3仅有RUN模式和STANDBY模式,MCU进入“Low Power Mode低功耗模式”(STANDBY模式)后,可通过WKPU Pin唤醒MCU芯片…

MapReduce分区机制(Hadoop)

在MapReduce中&#xff0c;分区&#xff08;Partitioning&#xff09;是将Map阶段输出的键值对根据某种规则分发到不同的Reduce任务上的过程。这个过程非常关键&#xff0c;因为它直接影响到了Reduce阶段的负载均衡和性能。 1. 哈希分区&#xff08;Hash Partitioning&#xf…

封装react-antd-table组件参数以及方法如rowSelection、pageNum、pageSize、分页方法等等

一般情况下&#xff0c;我们在页面组件里面都会使用state创建对应的分页参数和分页方法然后传入对应的组件内部&#xff0c;再或者选择行、全选等等&#xff0c;这都会在每一个组件中徒增大量的代码行数&#xff0c;所以简单整理了一下这个只是针对于处理逻辑的组件&#xff1a…

BUUCTF——[GXYCTF2019]BabyUpload

BUUCTF——[GXYCTF2019]BabyUpload 1.上传嘛&#xff0c;直接丢正常的jpg文件进服务器 2.发现可以正常上传&#xff0c;并且回显出来啦文件上传的路径 /var/www/html/upload/7df22610744ec51e9cb7a8a8eb674374/1111.jpg 3.尝试上传一句话木马 <?php eval($POST[123456]…

HDFS详解(Hadoop)

Hadoop 分布式文件系统&#xff08;Hadoop Distributed File System&#xff0c;HDFS&#xff09;是 Apache Hadoop 生态系统的核心组件之一&#xff0c;它是设计用于存储大规模数据集并运行在廉价硬件上的分布式文件系统。 1. 分布式存储&#xff1a; HDFS 将文件分割成若干块…

Python机器学习项目开发实战:深度神经网络

注意&#xff1a;本文提供下载的教程&#xff0c;与以下文章的思路有相同点&#xff0c;也有不同点&#xff0c;最终目标只是让读者从多维度去熟练掌握本知识点。 在Python中开发一个基于深度神经网络的机器学习项目&#xff0c;可以涉及到许多不同的步骤和技术。以下是一个简化…

「 网络安全常用术语解读 」漏洞利用交换VEX详解

漏洞利用交换&#xff08;Vulnerability Exploitability eXchange&#xff0c;简称VEX&#xff09;是一个信息安全领域的标准&#xff0c;旨在提供关于软件漏洞及其潜在利用的实时信息。根据美国政府发布的用例(PDF)&#xff0c;由美国政府开发的漏洞利用交换(VEX)使供应商和用…

[ LeetCode ] 题刷刷(Python)-第26题:删除有序数组中的重复项

题目描述 给你一个 非严格递增排列 的数组 nums &#xff0c;请你 原地 删除重复出现的元素&#xff0c;使每个元素 只出现一次 &#xff0c;返回删除后数组的新长度。元素的 相对顺序 应该保持 一致 。然后返回 nums 中唯一元素的个数。 考虑 nums 的唯一元素的数量为 k &…