本篇文章分享的内容是PHP数据库基于PDO操作类（mysql），现在分享给大家，有需要的朋友可以参考一下本篇文章的内容
PHP数据库基于PDO操作类（mysql）
这是网上找的关于Mysql的操作类，非常适合初学者使用
<?phpclass Mysql { protected static $_dbh = null; //静态属性,所有数据库实例共用,避免重复连接数据库
protected $_dbType = 'mysql'; protected $_pconnect = true; //是否使用长连接
protected $_host = 'localhost'; protected $_port = 3306; protected $_user = 'root'; protected $_pass = ''; protected $_dbName = null; //数据库名
protected $_sql = false; //最后一条sql语句
protected $_where = ''; protected $_order = ''; protected $_limit = ''; protected $_field = '*'; protected $_clear = 0; //状态，0表示查询条件干净，1表示查询条件污染
protected $_trans = 0; //事务指令数
/**
* 初始化类
* @param array $conf 数据库配置 */
public function __construct(array $conf) { class_exists('PDO') or die("PDO: class not exists."); $this->_host = $conf['host']; $this->_port = $conf['port']; $this->_user = $conf['user']; $this->_pass = $conf['password']; $this->_dbName = $conf['dbname']; //连接数据库
if ( is_null(self::$_dbh) ) { $this->_connect();
}
} /**
* 连接数据库的方法 */
protected function _connect() { $dsn = $this->_dbType.':host='.$this->_host.';port='.$this->_port.';dbname='.$this->_dbName; //持久化连接
$options = $this->_pconnect ? array(PDO::ATTR_PERSISTENT=>true) : array(); try {
$dbh = new PDO($dsn, $this->_user, $this->_pass, $options); $dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); //设置如果sql语句执行错误则抛出异常，事务会自动回滚
$dbh->setAttribute(PDO::ATTR_EMULATE_PREPARES, false); //禁用prepared statements的仿真效果(防SQL注入)
} catch (PDOException $e) {
die('Connection failed: ' . $e->getMessage());
} $dbh->exec('SET NAMES utf8');
self::$_dbh = $dbh;
} /**
* 字段和表名添加 `符号
* 保证指令中使用关键字不出错 针对mysql
* @param string $value
* @return string
*/
protected function _addChar($value) {
if ('*'==$value || false!==strpos($value,'(') || false!==strpos($value,'.') || false!==strpos($value,'`')) {
//如果包含* 或者 使用了sql方法 则不作处理
} elseif (false === strpos($value,'`') ) {
$value = '`'.trim($value).'`';
}
return $value;
} /**
* 取得数据表的字段信息
* @param string $tbName 表名
* @return array
*/
protected function _tbFields($tbName) { $sql = 'SELECT COLUMN_NAME FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_NAME="'.$tbName.'" AND TABLE_SCHEMA="'.$this->_dbName.'"'; $stmt = self::$_dbh->prepare($sql); $stmt->execute(); $result = $stmt->fetchAll(PDO::FETCH_ASSOC); $ret = array(); foreach ($result as $key=>$value) { $ret[$value['COLUMN_NAME']] = 1;
} return $ret;
} /**
* 过滤并格式化数据表字段
* @param string $tbName 数据表名
* @param array $data POST提交数据
* @return array $newdata
*/
protected function _dataFormat($tbName,$data) { if (!is_array($data)) return array(); $table_column = $this->_tbFields($tbName); $ret=array(); foreach ($data as $key=>$val) { if (!is_scalar($val)) continue; //值不是标量则跳过
if (array_key_exists($key,$table_column)) { $key = $this->_addChar($key); if (is_int($val)) {
$val = intval($val);
} elseif (is_float($val)) {
$val = floatval($val);
} elseif (preg_match('/^\(\w*(\+|\-|\*|\/)?\w*\)$/i', $val)) { // 支持在字段的值里面直接使用其它字段 ,例如 (score+1) (name) 必须包含括号
$val = $val;
} elseif (is_string($val)) {
//将字符串中的单引号（'）、双引号（"）、反斜线（\）与 NUL（NULL 字符转义
$val = '"'.addslashes($val).'"';
} $ret[$key] = $val;
}
} return $ret;
} /**
* 执行查询 主要针对 SELECT, SHOW 等指令
* @param string $sql sql指令
* @return mixed
*/
protected function _doQuery($sql='') { $this->_sql = $sql; $pdostmt = self::$_dbh->prepare($this->_sql); //prepare或者query 返回一个PDOStatement
$pdostmt->execute(); $result = $pdostmt->fetchAll(PDO::FETCH_ASSOC); return $result;
} /**
* 执行语句 针对 INSERT, UPDATE 以及DELETE,exec结果返回受影响的行数
* @param string $sql sql指令
* @return integer
*/
protected function _doExec($sql='') { $this->_sql = $sql; return self::$_dbh->exec($this->_sql);
} /**
* 执行sql语句，自动判断进行查询或者执行操作
* @param string $sql SQL指令
* @return mixed
*/
public function doSql($sql='') { $queryIps = 'INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|LOAD DATA|SELECT .* INTO|COPY|ALTER|GRANT|REVOKE|LOCK|UNLOCK';
if (preg_match('/^\s*"?(' . $queryIps . ')\s+/i', $sql)) {
return $this->_doExec($sql);
} else { //查询操作
return $this->_doQuery($sql);
}
} /**
* 获取最近一次查询的sql语句
* @return String 执行的SQL
*/
public function getLastSql() {
return $this->_sql;
} /**
* 插入方法
* @param string $tbName 操作的数据表名
* @param array $data 字段-值的一维数组
* @return int 受影响的行数 */
public function insert($tbName,array $data){ $data = $this->_dataFormat($tbName,$data); if (!$data) return; $sql = "insert into ".$tbName."(".implode(',',array_keys($data)).") values(".implode(',',array_values($data)).")"; return $this->_doExec($sql);
} /**
* 删除方法
* @param string $tbName 操作的数据表名
* @return int 受影响的行数 */
public function delete($tbName) { //安全考虑,阻止全表删除
if (!trim($this->_where)) return false; $sql = "delete from ".$tbName." ".$this->_where; $this->_clear = 1; $this->_clear(); return $this->_doExec($sql);
} /**
* 更新函数
* @param string $tbName 操作的数据表名
* @param array $data 参数数组
* @return int 受影响的行数 */
public function update($tbName,array $data) { //安全考虑,阻止全表更新
if (!trim($this->_where)) return false; $data = $this->_dataFormat($tbName,$data); if (!$data) return; $valArr = ''; foreach($data as $k=>$v){ $valArr[] = $k.'='.$v;
} $valStr = implode(',', $valArr); $sql = "update ".trim($tbName)." set ".trim($valStr)." ".trim($this->_where); return $this->_doExec($sql);
} /**
* 查询函数
* @param string $tbName 操作的数据表名
* @return array 结果集 */
public function select($tbName='') { $sql = "select ".trim($this->_field)." from ".$tbName." ".trim($this->_where)." ".trim($this->_order)." ".trim($this->_limit); //echo $sql;
$this->_clear = 1; $this->_clear(); return $this->_doQuery(trim($sql));
} /**
* @param mixed $option 组合条件的二维数组，例：$option['field1'] = array(1,'=>','or')
* @return $this */
public function where($option) { if ($this->_clear>0) $this->_clear(); $this->_where = ' where '; $logic = 'and'; if (is_string($option)) { $this->_where .= $option;
} elseif (is_array($option)) { foreach($option as $k=>$v) { if (is_array($v)) { $relative = isset($v[1]) ? $v[1] : '='; $logic = isset($v[2]) ? $v[2] : 'and'; $condition = ' ('.$this->_addChar($k).' '.$relative.' '.$v[0].') ';
} else { $logic = 'and'; $condition = ' ('.$this->_addChar($k).'='.$v.') ';
} $this->_where .= isset($mark) ? $logic.$condition : $condition; $mark = 1;
}
} return $this;
} /**
* 设置排序
* @param mixed $option 排序条件数组 例:array('sort'=>'desc')
* @return $this */
public function order($option) { if ($this->_clear>0) $this->_clear(); $this->_order = ' order by '; if (is_string($option)) { $this->_order .= $option;
} elseif (is_array($option)) { foreach($option as $k=>$v){ $order = $this->_addChar($k).' '.$v; $this->_order .= isset($mark) ? ','.$order : $order; $mark = 1;
}
} return $this;
} /**
* 设置查询行数及页数
* @param int $page pageSize不为空时为页数，否则为行数
* @param int $pageSize 为空则函数设定取出行数，不为空则设定取出行数及页数
* @return $this */
public function limit($page,$pageSize=null) { if ($this->_clear>0) $this->_clear(); if ($pageSize===null) { $this->_limit = "limit ".$page;
} else { $pageval = intval( ($page - 1) * $pageSize); $this->_limit = "limit ".$pageval.",".$pageSize;
} return $this;
} /**
* 设置查询字段
* @param mixed $field 字段数组
* @return $this */
public function field($field){ if ($this->_clear>0) $this->_clear(); if (is_string($field)) { $field = explode(',', $field);
} $nField = array_map(array($this,'_addChar'), $field); $this->_field = implode(',', $nField); return $this;
} /**
* 清理标记函数 */
protected function _clear() { $this->_where = ''; $this->_order = ''; $this->_limit = ''; $this->_field = '*'; $this->_clear = 0;
} /**
* 手动清理标记
* @return $this */
public function clearKey() { $this->_clear(); return $this;
} /**
* 启动事务
* @return void
*/
public function startTrans() {
//数据rollback 支持
if ($this->_trans==0) self::$_dbh->beginTransaction(); $this->_trans++;
return;
} /**
* 用于非自动提交状态下面的查询提交
* @return boolen
*/
public function commit() { $result = true; if ($this->_trans>0) {
$result = self::$_dbh->commit();
$this->_trans = 0;
}
return $result;
} /**
* 事务回滚
* @return boolen
*/
public function rollback() { $result = true; if ($this->_trans>0) { $result = self::$_dbh->rollback(); $this->_trans = 0;
} return $result;
} /**
* 关闭连接
* PHP 在脚本结束时会自动关闭连接。 */
public function close() { if (!is_null(self::$_dbh)) self::$_dbh = null;
}
}
相关推荐：
以上是PHP数据库基于PDO操作类（mysql）的详细内容。更多信息请关注PHP中文网其他相关文章！
声明
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
如何使PHP应用程序更快May 12, 2025 am 12:12 AMtomakephpapplicationsfaster，关注台词：1）useopcodeCachingLikeLikeLikeLikeLikePachetoStorePreciledScompiledScriptbyTecode.2）MinimimiedAtabaseSqueriSegrieSqueriSegeriSybysequeryCachingandeffeftExting.3）Leveragephp7 leveragephp7 leveragephp7 leveragephpphp7功能forbettercodeefficy.4）
PHP性能优化清单：立即提高速度May 12, 2025 am 12:07 AM到ImprovephPapplicationspeed，关注台词：1）启用opcodeCachingwithapCutoredUcescriptexecutiontime.2）实现databasequerycachingusingpdotominiminimizedatabasehits.3）usehttp/2tomultiplexrequlexrequestsandredececonnection.4 limitsclection.4.4
PHP依赖注入：提高代码可检验性May 12, 2025 am 12:03 AM依赖注入（DI）通过显式传递依赖关系，显着提升了PHP代码的可测试性。 1）DI解耦类与具体实现，使测试和维护更灵活。 2）三种类型中，构造函数注入明确表达依赖，保持状态一致。 3）使用DI容器管理复杂依赖，提升代码质量和开发效率。
PHP性能优化：数据库查询优化May 12, 2025 am 12:02 AMdatabasequeryOptimizationinphpinvolVolVOLVESEVERSEVERSTRATEMIESOENHANCEPERANCE.1）SELECTONLYNLYNESSERSAYCOLUMNSTORMONTOUMTOUNSOUDSATATATATATATATATATATRANSFER.3）
简单指南：带有PHP脚本的电子邮件发送May 12, 2025 am 12:02 AMphpisusedforsenderemailsduetoitsbuilt-inmail（）函数andsupportiveLibrariesLikePhpMailerandSwiftMailer.1）usethemail（）functionforbasicemails，butithasimails.2）butithasimimitations.2）
PHP性能：识别和修复瓶颈May 11, 2025 am 12:13 AMPHP性能瓶颈可以通过以下步骤解决：1)使用Xdebug或Blackfire进行性能分析，找出问题所在；2)优化数据库查询并使用缓存，如APCu；3)使用array_filter等高效函数优化数组操作；4)配置OPcache进行字节码缓存；5)优化前端，如减少HTTP请求和优化图片；6)持续监控和优化性能。通过这些方法，可以显着提升PHP应用的性能。
PHP的依赖注入：快速摘要May 11, 2025 am 12:09 AM依赖性注射（DI）InphpisadesignPatternthatManages和ReducesClassDeptions，增强量产生性，可验证性和Maintainability.itallowspasspassingDepentenciesLikEdenceSeconnectionSeconnectionStoclasseconnectionStoclasseSasasasasareTers，interitationApertatingAeseritatingEaseTestingEasingEaseTeStingEasingAndScalability。
提高PHP性能：缓存策略和技术May 11, 2025 am 12:08 AMcachingimprovesphpermenceByStorcyResultSofComputationsorqucrouctationsorquctationsorquickretrieval，reducingServerLoadAndenHancingResponsetimes.feftectivestrategiesinclude：1）opcodecaching，whereStoresCompiledSinmememorytssinmemorytoskipcompliation; 2）datacaching datacachingsingMemccachingmcachingmcachings
热AI工具
Undresser.AI Undress
人工智能驱动的应用程序，用于创建逼真的裸体照片
AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。
Undress AI Tool
免费脱衣服图片
Clothoff.io
AI脱衣机
Video Face Swap
使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸！
热门文章
<🎜>：种植花园 - 完整的突变指南
3 周前ByDDD
<🎜>：泡泡胶模拟器无穷大 - 如何获取和使用皇家钥匙
3 周前By尊渡假赌尊渡假赌尊渡假赌
如何修复KB5055612无法在Windows 10中安装？
3 周前ByDDD
北端：融合系统，解释
3 周前By尊渡假赌尊渡假赌尊渡假赌
Mandragora：巫婆树的耳语 - 如何解锁抓钩
3 周前By尊渡假赌尊渡假赌尊渡假赌
热工具
WebStorm Mac版
好用的JavaScript开发工具
SublimeText3汉化版
中文版，非常好用
mPDF
mPDF是一个PHP库，可以从UTF-8编码的HTML生成PDF文件。原作者Ian Back编写mPDF以从他的网站上“即时”输出PDF文件，并处理不同的语言。与原始脚本如HTML2FPDF相比，它的速度较慢，并且在使用Unicode字体时生成的文件较大，但支持CSS样式等，并进行了大量增强。支持几乎所有语言，包括RTL（阿拉伯语和希伯来语）和CJK（中日韩）。支持嵌套的块级元素（如P、DIV），
SublimeText3 Mac版
神级代码编辑软件(SublimeText3)
PhpStorm Mac 版本
最新（2018.2.1 ）专业的PHP集成开发工具
