首页 专区 Skill 文章 专题 AI工具 学习 编程手册

PHP MySQL jquery HTML CSS
首页 > php教程 > PHP源码

使用php中的PDO方式做到数据库的增删改查及类的单例花

老墨君_9366

老墨君_9366

2016-05-23

1522人浏览

原创

跳至

class DPDO{
	private $DSN;
	private $DBUser;
	private $DBPwd;
	private $longLink;
	private $pdo;
	//私有构造函数 防止被直接实例化
	private function __construct($dsn, $DBUser, $DBPwd, $longLink = false) {
		$this->DSN = $dsn;
		$this->DBUser = $DBUser;
		$this->DBPwd = $DBPwd;
		$this->longLink = $longLink;
		$this->connect();
	}
	//私有 空克隆函数 防止被克隆
	private function __clone(){}
	//静态 实例化函数 返回一个pdo对象
	static public function instance($dsn, $DBUser, $DBPwd, $longLink = false){
		static $singleton = array();//静态函数 用于存储实例化对象
		$singIndex = md5($dsn . $DBUser . $DBPwd . $longLink);
		if (empty($singleton[$singIndex])) {
			$singleton[$singIndex] = new self($dsn, $DBUser, $DBPwd, $longLink = false);
		}
		return $singleton[$singIndex]->pdo;
	}
	
	private function connect(){
		try{
			if($this->longLink){
				$this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd, array(PDO::ATTR_PERSISTENT => true));
			}else{
				$this->pdo = new PDO($this->DSN, $this->DBUser, $this->DBPwd);
			}
			$this->pdo->query('SET NAMES UTF-8');
		} catch(PDOException $e) {
			die('Error:' . $e->getMessage() . '
');
		}
	}
}

                       

           

2. [代码]用于处理字段映射，使用pdo的字段映射，可以有效避免sql注入   

//字段关联数组处理， 主要用于写入和更新数据、同and 或 or 的查询条件，产生sql语句和映射字段的数组
	public function FDFields($data, $link = ',', $judge = array(), $aliasTable = ''){
		$sql = '';
		$mapData = array();
		foreach($data as $key => $value) {
			$mapIndex = ':' . ($link != ',' ? 'c' : '') . $aliasTable . $key;
			$sql .= ' ' . ($aliasTable ? $aliasTable . '.' : '') . '`' . $key . '` ' . ($judge[$key] ? $judge[$key] : '=') . ' ' . $mapIndex . ' ' . $link;
			$mapData[$mapIndex] = $value;
		}
		$sql = trim($sql, $link);
		return array($sql, $mapData);
	}
	//用于处理单个字段处理
	public function FDField($field, $value, $judge = '=', $preMap = 'cn', $aliasTable = '') {
		$mapIndex = ':' . $preMap . $aliasTable . $field;
		$sql = ' ' . ($aliasTable ? $aliasTable . '.' : '') . '`' . $field . '`' . $judge . $mapIndex;
		$mapData[$mapIndex] = $value;
		return array($sql, $mapData);
	}
	//使用刚方法可以便捷产生查询条件及对应数据数组
	public function FDCondition($condition, $mapData) {
		if(is_string($condition)) {
				$where = $condition;
		} else if (is_array($condition)) {
			if($condition['str']) {
				if (is_string($condition['str'])) {
					$where = $condition['str'];
				} else {
					return false;
				}
			}
			if(is_array($condition['data'])) {
				$link = $condition['link'] ? $condition['link'] : 'and';
				list($conSql, $mapConData) = $this->FDFields($condition['data'], $link, $condition['judge']);
				if ($conSql) {
					$where .= ($where ? ' ' . $link : '') . $conSql;
					$mapData = array_merge($mapData, $mapConData);
				}
			}
		}
		return array($where, $mapData);
	}

           

           

           

3. [代码]增删改查的具体实现     

public function fetch($sql, $searchData = array(), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
		if ($sql) {
			$sql .= ' limit 1';
			$pdoStatement = $this->pdo->prepare($sql, $preType);
			$pdoStatement->execute($searchData);
			return $data = $pdoStatement->fetch($dataMode);
		} else {
			return false;
		}
	}
	
	public function fetchAll($sql, $searchData = array(), $limit = array(0, 10), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
		if ($sql) {
			$sql .= ' limit ' . (int) $limit[0] . ',' . (intval($limit[1]) > 0 ? intval($limit[1]) : 10);
			$pdoStatement = $this->pdo->prepare($sql, $preType);
			$pdoStatement->execute($searchData);
			return $data = $pdoStatement->fetchAll($dataMode);
		} else {
			return false;
		}
	}
	
	public function insert($tableName, $data, $returnInsertId = false, $replace = false) {
		if(!empty($tableName) && count($data) > 0){
			$sql = $replace ? 'REPLACE INTO ' : 'INSERT INTO ';
			list($setSql, $mapData) = $this->FDFields($data);
			$sql .= $tableName . ' set ' . $setSql;
			$pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
			$execRet = $pdoStatement->execute($mapData);
			return $execRet ? ($returnInsertId ? $this->pdo->lastInsertId() : $execRet) : false;
		} else {
			return false;
		}
	}
	
	public function update($tableName, $data, $condition, $mapData = array(), $returnRowCount = true) {
		if(!empty($tableName) && count($data) > 0) {
			$sql = 'UPDATE ' . $tableName . ' SET ';
			list($setSql, $mapSetData) = $this->FDFields($data);
			$sql .= $setSql;
			$mapData = array_merge($mapData, $mapSetData);
			list($where, $mapData) = $this->FDCondition($condition, $mapData);
			$sql .= $where ? ' WHERE ' . $where : '';
			$pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
			$execRet = $pdoStatement->execute($mapData);
			return $execRet ? ($returnRowCount ? $pdoStatement->rowCount() : $execRet) : false;
		} else {
			return false;
		}
	}
	
	public function delete($tableName, $condition, $mapData = array()) {
		if(!empty($tableName) && $condition){
			$sql = 'DELETE FROM ' . $tableName;
			list($where, $mapData) = $this->FDCondition($condition, $mapData);
			$sql .= $where ? ' WHERE ' . $where : '';
			$pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
			$execRet = $pdoStatement->execute($mapData);
			return $execRet;
		}
	}

           

           

           

4. [代码]测试文件     

header("Content-type: text/html; charset=utf-8");
define('APP_DIR', dirname(__FILE__));

if (function_exists('spl_autoload_register')) {
	spl_autoload_register('autoClass');
} else {
	function __auto_load($className){
		autoClass($className);
	}
}

function autoClass($className){
	try{
		require_once APP_DIR.'/class/'.$className.'.php';
	} catch (Exception $e) {
		die('Error:' . $e->getMessage() . '
');
	}
}
$DB = new DB();
//插入
$inData['a'] = rand(1, 100);
$inData['b'] = rand(1, 1000);
$inData['c'] = rand(1,200) . '.' . rand(1,100);
$ret = $DB->insert('a', $inData);
echo '插入' . ($ret ? '成功' : '失败') . '
';
//更新
$upConData['a'] = 100;
$upConJudge['a'] = '

           

           

                   

5. [文件] test.php ~ 2KB        

                



				   				            	            	




	           	


	   				                	



6. [文件]					DB.php ~ 4KB        	



		               	


debugDumpParams() 可以查看sql语句错误
 */
class DB {
	protected $pdo;
	
	public function __construct($dbType = 'mysql'){
		if($dbType == 'mysql') {
			$dsn = "mysql:host=localhost;port=3306;dbname=test";
		}
		$this->pdo = DPDO::instance($dsn, 'root', '');
	}
	
	public function fetch($sql, $searchData = array(), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
		if ($sql) {
			$sql .= ' limit 1';
			$pdoStatement = $this->pdo->prepare($sql, $preType);
			$pdoStatement->execute($searchData);
			return $data = $pdoStatement->fetch($dataMode);
		} else {
			return false;
		}
	}
	
	public function fetchAll($sql, $searchData = array(), $limit = array(0, 10), $dataMode = PDO::FETCH_ASSOC, $preType = array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY)) {
		if ($sql) {
			$sql .= ' limit ' . (int) $limit[0] . ',' . (intval($limit[1]) > 0 ? intval($limit[1]) : 10);
			$pdoStatement = $this->pdo->prepare($sql, $preType);
			$pdoStatement->execute($searchData);
			return $data = $pdoStatement->fetchAll($dataMode);
		} else {
			return false;
		}
	}
	
	public function insert($tableName, $data, $returnInsertId = false, $replace = false) {
		if(!empty($tableName) && count($data) > 0){
			$sql = $replace ? 'REPLACE INTO ' : 'INSERT INTO ';
			list($setSql, $mapData) = $this->FDFields($data);
			$sql .= $tableName . ' set ' . $setSql;
			$pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
			$execRet = $pdoStatement->execute($mapData);
			return $execRet ? ($returnInsertId ? $this->pdo->lastInsertId() : $execRet) : false;
		} else {
			return false;
		}
	}
	
	public function update($tableName, $data, $condition, $mapData = array(), $returnRowCount = true) {
		if(!empty($tableName) && count($data) > 0) {
			$sql = 'UPDATE ' . $tableName . ' SET ';
			list($setSql, $mapSetData) = $this->FDFields($data);
			$sql .= $setSql;
			$mapData = array_merge($mapData, $mapSetData);
			list($where, $mapData) = $this->FDCondition($condition, $mapData);
			$sql .= $where ? ' WHERE ' . $where : '';
			$pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
			$execRet = $pdoStatement->execute($mapData);
			return $execRet ? ($returnRowCount ? $pdoStatement->rowCount() : $execRet) : false;
		} else {
			return false;
		}
	}
	
	public function delete($tableName, $condition, $mapData = array()) {
		if(!empty($tableName) && $condition){
			$sql = 'DELETE FROM ' . $tableName;
			list($where, $mapData) = $this->FDCondition($condition, $mapData);
			$sql .= $where ? ' WHERE ' . $where : '';
			$pdoStatement = $this->pdo->prepare($sql, array(PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY));
			$execRet = $pdoStatement->execute($mapData);
			return $execRet;
		}
	}
	
	
	//字段关联数组处理
	public function FDFields($data, $link = ',', $judge = array(), $aliasTable = ''){
		$sql = '';
		$mapData = array();
		foreach($data as $key => $value) {
			$mapIndex = ':' . ($link != ',' ? 'c' : '') . $aliasTable . $key;
			$sql .= ' ' . ($aliasTable ? $aliasTable . '.' : '') . '`' . $key . '` ' . ($judge[$key] ? $judge[$key] : '=') . ' ' . $mapIndex . ' ' . $link;
			$mapData[$mapIndex] = $value;
		}
		$sql = trim($sql, $link);
		return array($sql, $mapData);
	}
	
	public function FDField($field, $value, $judge = '=', $preMap = 'cn', $aliasTable = '') {
		$mapIndex = ':' . $preMap . $aliasTable . $field;
		$sql = ' ' . ($aliasTable ? $aliasTable . '.' : '') . '`' . $field . '`' . $judge . $mapIndex;
		$mapData[$mapIndex] = $value;
		return array($sql, $mapData);
	}
	
	public function FDCondition($condition, $mapData) {
		if(is_string($condition)) {
				$where = $condition;
		} else if (is_array($condition)) {
			if($condition['str']) {
				if (is_string($condition['str'])) {
					$where = $condition['str'];
				} else {
					return false;
				}
			}
			if(is_array($condition['data'])) {
				$link = $condition['link'] ? $condition['link'] : 'and';
				list($conSql, $mapConData) = $this->FDFields($condition['data'], $link, $condition['judge']);
				if ($conSql) {
					$where .= ($where ? ' ' . $link : '') . $conSql;
					$mapData = array_merge($mapData, $mapConData);
				}
			}
		}
		return array($where, $mapData);
	}
}
?>


				   				            	            	




	           	


	   				                	



7. [文件]					DPDO.php ~ 1KB    




				   				            	            	




	       	





			


php免费学习视频：立即使用
			
踏上前端学习之旅，开启通往精通之路！从前端基础到项目实战，循序渐进，一步一个脚印，迈向巅峰！

							


							

						

						

																		

											

												PHP速学教程(入门到精通)
												

													PHP速学教程(入门到精通)
													
PHP怎么学习？PHP怎么入门？PHP在哪学？PHP怎么学才快？不用担心，这里为大家提供了PHP速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

												

												下载
												
											

										
								

								

									
相关标签:

									
								


								

									

										

											
											

											
										

										

											本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

									

								


																	

										
											
 上一篇：PHP中巧用curl 并发减少获取第三方网页内容时间

										
										
											
下一篇：任意文本数据导入SQL SERVER

										
									

															

					


					

													

								

									
 
										
作者最新文章

									

									
								

								

																	

										
											
阿里云oss对象存储，配置问题详解

										
									

																	

										
											
php验证身份证号码正确性的函数

										
									

																	

										
											
淘宝开放API根据卖家昵称获取卖家店铺ID

										
									

																	

										
											
关于php验证码类的实例分享

										
									

																	

										
											
PHP ASCII码与字符串的相互转换的例子

										
									

																	

										
											
php实现字符串首字母转换成大写的方法_php技巧

										
									

																	

										
											
php获取mysql数据库版本号 mysql_get_server_info

										
									

																	

										
											
面对对象单态

										
									

																	

										
											
PHP读取文本文件并逐行输出该行使用最多的字符串及对应次数

										
									

																	

										
											
php随机生成国内ip地址

										
									

																

							

						
						

							

								
 
									
热门AI工具

								

								更多
							


							

								

																	
										PixTV
										

											
PixTV

										

																					Hot
																			
																	
										花生AI
										

											
花生AI

										

																					Hot
																			
																	
										咔片AIPPT
										

											
咔片AIPPT

										

																					Hot
																			
																	
										豆包大模型
										

											
豆包大模型

										

																			
																	
										UpDream
										

											
UpDream

										

																					Hot
																			
																	
										Laper
										

											
Laper

										

																					Hot
																			
																	
										DeepSeek
										

											
DeepSeek

										

																			
																	
										立刻MV
										

											
立刻MV

										

																					Hot
																			
																

							

						


						


							

								
 
									
相关专题

								

								更多
							

							

								

																	

																			

											Tailwind CSS 响应式布局怎么写
											

												Tailwind CSS 响应式布局怎么写
												
Tailwind CSS 响应式布局通常从移动端样式写起，再用 sm、md、lg 等前缀调整不同屏幕宽度下的网格、间距和导航。本专题整理断点配置、Grid 与 Flex 自适应布局及常见溢出问题，帮助你逐步完成多设备适配。

												

													

														
 
															
2026.11.03

														

														
 
															
0

														

														
 
															
19

														

													

												

											

										

																			

											Tailwind CSS 常用类名怎么记
											

												Tailwind CSS 常用类名怎么记
												
Tailwind CSS 类名很多，先按布局、间距、文字、颜色和状态分组记忆，再通过官方文档检索具体写法。本专题结合类名排序、动态拼接失效、自定义实用类等问题，帮助你建立常用类名的速查方法。

												

													

														
 
															
2026.11.03

														

														
 
															
0

														

														
 
															
12

														

													

												

											

										

																			

											码上飞入口地址合集
											

												码上飞入口地址合集
												
本专题汇总了码上飞（CodeFlying）的官方入口地址合集，涵盖官网主站及网页版在线使用入口，支持注册登录后直接在线体验零代码AI应用生成。同时整理了APP端下载渠道与小程序入口，助你快速访问平台，通过自然语言描述需求即可生成应用、小程序或网站。

												

													

														
 
															
2026.11.03

														

														
 
															
0

														

														
 
															
10

														

													

												

											

										

																		

																	

																			

											Uvicorn 报错与问题解决教程
											

												Uvicorn 报错与问题解决教程
												
本专题汇总了Uvicorn服务器常见问题与报错解决的教程合集，涵盖启动失败、端口占用、模块导入错误、事件循环冲突及热重载失效等典型故障的排查思路。同时整理了多进程与Worker配置、SSL/HTTPS证书报错、跨域与代理配置等实战解决方案，助你快速定位并解决Uvicorn运行中的各类问题。

												

													

														
 
															
2026.11.02

														

														
 
															
20

														

														
 
															
14

														

													

												

											

										

																			

											Uvicorn使用教程
											

												Uvicorn使用教程
												
本专题汇总了Uvicorn使用教程与启动运行指南，涵盖其作为Python ASGI服务器的定位与特点，以及命令行启动（uvicorn main:app --reload）、参数配置（host/port/workers）、程序内嵌运行与Gunicorn结合部署等核心用法。同时整理了热重载调试、日志配置与生产环境部署优化等技巧，助你快速掌握Uvicorn的运行与配置。

												

													

														
 
															
2026.11.02

														

														
 
															
20

														

														
 
															
17

														

													

												

											

										

																			

											Uvicorn安装配置教程
											

												Uvicorn安装配置教程
												
本专题汇总了Uvicorn的安装配置教程与部署指南，涵盖通过pip安装Uvicorn、启动FastAPI/Starlette应用、开发模式热重载（--reload）及多进程工作模式配置等核心操作。同时整理了结合Gunicorn的生产部署方案、HTTPS与反向代理配置及性能调优技巧，助你快速完成Uvicorn服务的安装与上线部署。

												

													

														
 
															
2026.11.02

														

														
 
															
20

														

														
 
															
17

														

													

												

											

										

																		

																	

																			

											Vite 项目如何打包和部署
											

												Vite 项目如何打包和部署
												
Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章，帮助读者完成上线流程。

												

													

														
 
															
2026.10.28

														

														
 
															
120

														

														
 
															
16

														

													

												

											

										

																			

											Vite 如何搭配 Vue.js
											

												Vite 如何搭配 Vue.js
												
Vite搭配Vue.js专题汇集创建Vue 3项目、配置开发环境、路径别名、Vue插件、代理、多环境构建与调试的已审核文章，帮助读者完成从初始化到日常开发的配置。

												

													

														
 
															
2026.10.28

														

														
 
															
100

														

														
 
															
15

														

													

												

											

										

																			

											Vite 项目目录怎么看
											

												Vite 项目目录怎么看
												
Vite项目目录专题汇集入口文件、src源码、public静态资源、路径别名、项目根目录和构建输出目录相关的已审核文章，帮助读者理解各文件夹的用途与引用方式。

												

													

														
 
															
2026.10.28

														

														
 
															
300

														

														
 
															
10

														

													

												

											

										

																		

																

							

							

							


						



						

							

								
 
									
热门下载

								

								更多
							

							

								

									
网站特效  
 /
									
网站源码 
 /
									
网站素材 
 /
									
前端模板 

								

								
								
								
								
							

							

						


						

							

								
 
									
相关下载

								

								更多
							

							

															
MDPHP(麦迪php框架系统)1.1

															
PHP 多国语言框架2.0

															
ujframe简单快速PHP开发框架1.0

															
php轻量型框架1.0

															
MyQEE开源PHP多项目及模块化开发框架3.0 RC2

															
php开源学习型框架CMVC1.2.0

															
PHP框架Kohana3.3.1

														


						


						

							

								
 
									
精品课程

								

								更多
							

							

								

																		
热门推荐 
 /
									
最新课程 

								

																

																			

											
												phpStudy极速入门视频教程
											
											

												phpStudy极速入门视频教程

												

													
共6课时 | 54.7万人学习

												

											

										

																			

											
												独孤九贱(4)_PHP视频教程
											
											

												独孤九贱(4)_PHP视频教程

												

													
共89课时 | 134.1万人学习

												

											

										

																			

											
												PHP实战天龙八部之仿爱奇艺电影网站
											
											

												PHP实战天龙八部之仿爱奇艺电影网站

												

													
共49课时 | 82.6万人学习

												

											

										

																	


								
								

							

						


						

							

								
 
									
最新文章

								

								更多
							

							

															
phpmystudy2016版程序包下载-让天下没有难配的php环境

															
多城市选择器实现代码

															
微信接口php版本sdk的WxApi.class.php

															
php图片加水印类，支持文字水印、透明度设置、自定义水印类

															
php命名空间和动态语言特征

															
PHP弱类型安全问题总结

															
如何读懂并写出装逼的函数式代码

															
用 PHP 爬虫做旅游数据分析

															
C++从文件中按照单词读取内容

															
你所不知道的 PHP - 自动加载