首页 > 代码库 > pdo封装类
pdo封装类
<?php//数据库连接类,不建议直接使用DB,而是对DB封装一层//这个类不会被污染,不会被直接调用class DB { //pdo对象 private $_pdo = null; //用于存放实例化的对象 static private $_instance = null; //公共静态方法获取实例化的对象 static protected function getInstance() { if (!(self::$_instance instanceof self)) { self::$_instance = new self(); } return self::$_instance; } //私有克隆 private function __clone() {} //私有构造 private function __construct() { try { $this->_pdo = new PDO(DB_DNS, DB_USER, DB_PASS, array(PDO::MYSQL_ATTR_INIT_COMMAND=>‘SET NAMES ‘.DB_CHARSET)); $this->_pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { exit($e->getMessage()); } } //新增 protected function add($_tables, Array $_addData) { $_addFields = array(); $_addValues = array(); foreach ($_addData as $_key=>$_value) { $_addFields[] = $_key; $_addValues[] = $_value; } $_addFields = implode(‘,‘, $_addFields); $_addValues = implode("‘,‘", $_addValues); $_sql = "INSERT INTO $_tables[0] ($_addFields) VALUES (‘$_addValues‘)"; return $this->execute($_sql)->rowCount(); } //修改 protected function update($_tables, Array $_param, Array $_updateData) { $_where = $_setData = ‘‘; foreach ($_param as $_key=>$_value) { $_where .= $_value.‘ AND ‘; } $_where = ‘WHERE ‘.substr($_where, 0, -4); foreach ($_updateData as $_key=>$_value) { if (Validate::isArray($_value)) { $_setData .= "$_key=$_value[0],"; } else { $_setData .= "$_key=‘$_value‘,"; } } $_setData = substr($_setData, 0, -1); $_sql = "UPDATE $_tables[0] SET $_setData $_where"; return $this->execute($_sql)->rowCount(); } //验证一条数据 protected function isOne($_tables, Array $_param) { $_where = ‘‘; foreach ($_param as $_key=>$_value) { $_where .=$_value.‘ AND ‘; } $_where = ‘WHERE ‘.substr($_where, 0, -4); $_sql = "SELECT id FROM $_tables[0] $_where LIMIT 1"; return $this->execute($_sql)->rowCount(); } //删除 protected function delete($_tables, Array $_param) { $_where = ‘‘; foreach ($_param as $_key=>$_value) { $_where .= $_value.‘ AND ‘; } $_where = ‘WHERE ‘.substr($_where, 0, -4); $_sql = "DELETE FROM $_tables[0] $_where LIMIT 1"; return $this->execute($_sql)->rowCount(); } //查询 protected function select($_tables, Array $_fileld, Array $_param = array()) { $_limit = $_order = $_where = $_like = ‘‘; if (Validate::isArray($_param) && !Validate::isNullArray($_param)) { $_limit = isset($_param[‘limit‘]) ? ‘LIMIT ‘.$_param[‘limit‘] : ‘‘; $_order = isset($_param[‘order‘]) ? ‘ORDER BY ‘.$_param[‘order‘] : ‘‘; if (isset($_param[‘where‘])) { foreach ($_param[‘where‘] as $_key=>$_value) { $_where .= $_value.‘ AND ‘; } $_where = ‘WHERE ‘.substr($_where, 0, -4); } if (isset($_param[‘like‘])) { foreach ($_param[‘like‘] as $_key=>$_value) { $_like = "WHERE $_key LIKE ‘%$_value%‘"; } } } $_selectFields = implode(‘,‘, $_fileld); $_table = isset($_tables[1]) ? $_tables[0].‘,‘.$_tables[1] : $_tables[0]; $_sql = "SELECT $_selectFields FROM $_table $_where $_like $_order $_limit"; $_stmt = $this->execute($_sql); $_result = array(); while (!!$_objs = $_stmt->fetchObject()) { $_result[] = $_objs; } return Tool::setHtmlString($_result); } //总记录 protected function total($_tables, Array $_param = array()) { $_where = ‘‘; if (isset($_param[‘where‘])) { foreach ($_param[‘where‘] as $_key=>$_value) { $_where .= $_value.‘ AND ‘; } $_where = ‘WHERE ‘.substr($_where, 0, -4); } $_sql = "SELECT COUNT(*) as count FROM $_tables[0] $_where"; $_stmt = $this->execute($_sql); return $_stmt->fetchObject()->count; } //得到下一个ID protected function nextId($_tables) { $_sql = "SHOW TABLE STATUS LIKE ‘$_tables[0]‘"; $_stmt = $this->execute($_sql); return $_stmt->fetchObject()->Auto_increment; } //执行SQL private function execute($_sql) { try { $_stmt = $this->_pdo->prepare($_sql); $_stmt->execute(); } catch (PDOException $e) { exit(‘SQL语句:‘.$_sql.‘<br />错误信息:‘.$e->getMessage()); } return $_stmt; }}?>
pdo封装类
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。