本文实例讲述了php实现的pdo公共类定义与用法。分享给大家供大家参考,具体如下:

db.class.php :
<?php
class db extends \PDO {
private static $_instance = null;
protected $dbName = '';
protected $dsn;
protected $dbh;
public function __construct($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset='utf8') {
try {
$this->dsn = 'mysql:host=' . $dbHost . ';dbname=' . $dbName;
$this->dbh = new \PDO($this->dsn, $dbUser, $dbPasswd);
$this->dbh->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false);
$this->dbh->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
$this->dbh->exec('SET character_set_connection='.$dbCharset.';SET character_set_client='.$dbCharset.';SET character_set_results='.$dbCharset);
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public static function getInstance($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset='utf8') {
if (self::$_instance === null) {
self::$_instance = new self($dbHost, $dbUser, $dbPasswd, $dbName, $dbCharset);
}
return self::$_instance;
}
public function fetchAll($sql, $params = array()) {
try {
$stm = $this->dbh->prepare($sql);
if ($stm && $stm->execute($params)) {
return $stm->fetchAll(\PDO::FETCH_ASSOC);
}
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function fetchOne($sql, $params = array()) {
try {
$result = false;
$stm = $this->dbh->prepare($sql);
if ($stm && $stm->execute($params)) {
$result = $stm->fetch(\PDO::FETCH_ASSOC);
}
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function fetchColumn($sql, $params = array()) {
$result = '';
try {
$stm = $this->dbh->prepare($sql);
if ($stm && $stm->execute($params)) {
$result = $stm->fetchColumn();
}
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function insert($table, $params = array(), $returnLastId = true) {
$_implode_field = '';
$fields = array_keys($params);
$_implode_field = implode(',', $fields);
$_implode_value = '';
foreach ($fields as $value) {
$_implode_value .= ':'. $value.',';
}
$_implode_value = trim($_implode_value, ',');
$sql = 'INSERT INTO ' . $table . '(' . $_implode_field . ') VALUES ('.$_implode_value.')';
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
if ( $returnLastId ) {
$result = $this->dbh->lastInsertId();
}
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function update($table, $params = array(), $where = null) {
$_implode_field = '';
$_implode_field_arr = array();
if ( empty($where) ) {
return false;
}
$fields = array_keys($params);
foreach ($fields as $key) {
$_implode_field_arr[] = $key . '=' . ':'.$key;
}
$_implode_field = implode(',', $_implode_field_arr);
$sql = 'UPDATE ' . $table . ' SET ' . $_implode_field . ' WHERE ' . $where;
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function delete($sql, $params = array()) {
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
public function exec($sql, $params = array()) {
try {
$stm = $this->dbh->prepare($sql);
$result = $stm->execute($params);
return $result;
} catch (Exception $e) {
$this->outputError($e->getMessage());
}
}
private function outputError($strErrMsg) {
throw new Exception("MySQL Error: " . $strErrMsg);
}
public function __destruct() {
$this->dbh = null;
}
}
实例:
<?php
require_once './db.class.php';
$pdo = db::getInstance('127.0.0.1', 'root', '111111', 'php_cms');
$sql = "select id, title1 from cms_wz where id = :id limit 1";
$parame = array('id' => 12,);
$res = $pdo->fetchOne($sql, $parame);
var_dump($res);
$sql = 'SELECT * FROM cms_link';
$result = $db->fetchAll($sql);
print_r($result);
//查询记录数量
$sql = 'SELECT COUNT(*) FROM cms_link';
$count = $db->fetchColumn($sql);
echo $count;
$data = array(
'siteid' => 1,
'linktype' => 1,
'name' => 'google',
'url' => 'http://www.google.com',
'listorder' => 0,
'elite' => 0,
'passed' => 1,
'addtime' => time()
);
$lastInsertId = $db->insert('cms_link', $data);
echo $lastInsertId;
//用 try
try {
$result = $pdo->insert('news', $essay);
} catch (Exception $e) {
error_log($e->getMessage());
error_log($e->getMessage() . ' in ' . __FILE__ . ' on line ' . __LINE__);
saveLog('url文章 : ' . $essay['link'] . ' 数据插入失败<br>');
continue;
}
$data = array(
'siteid' => 1,
'linktype' => 1,
'name' => 'google',
'url' => 'http://www.google.com',
'listorder' => 0,
'elite' => 0,
'passed' => 1,
'addtime' => time()
);
$db->insert('cms_link', $data);
$sql = 'DELETE FROM cms_link WHERE linkid=4';
$result = $db->delete($sql);
var_dump($result);
更多关于PHP相关内容感兴趣的读者可查看本站专题:《PHP基于pdo操作数据库技巧总结》、《php+Oracle数据库程序设计技巧总结》、《PHP+MongoDB数据库操作技巧大全》、《php面向对象程序设计入门教程》、《php字符串(string)用法总结》、《php+mysql数据库操作入门教程》及《php常见数据库操作技巧汇总》
希望本文所述对大家PHP程序设计有所帮助。
# php
# pdo公共类
# PHP基于PDO实现的SQLite操作类【包含增删改查及事务等操作】
# php PDO实现的事务回滚示例
# php使用PDO事务配合表格读取大量数据插入操作实现方法
# php的PDO事务处理机制实例分析
# PHP中PDO的事务处理分析
# php下pdo的mysql事务处理用法实例
# php中在PDO中使用事务(Transaction)
# ThinkPHP实现事务回滚示例代码
# PHP操作MySQL事务实例
# php+mysql事务rollback&commit示例
# php实现基于pdo的事务处理方法示例
# 程序设计
# 操作技巧
# 相关内容
# 感兴趣
# 给大家
# 更多关于
# 所述
# 面向对象
# 讲述了
# Exception
# outputError
# character_set_results
# catch
# return
# fetchAll
# getMessage
# getInstance
# ATTR_ERRMODE
# ERRMODE_EXCEPTION
# ATTR_EMULATE_PREPARES
相关文章:
如何获取PHP WAP自助建站系统源码?
c# Task.ConfigureAwait(true) 在什么场景下是必须的
建站主机选择指南:服务器配置与SEO优化实战技巧
实例解析angularjs的filter过滤器
C++用Dijkstra(迪杰斯特拉)算法求最短路径
如何在IIS中新建站点并解决端口绑定冲突?
已有域名和空间如何搭建网站?
网站app免费制作软件,能免费看各大网站视频的手机app?
小捣蛋自助建站系统:数据分析与安全设置双核驱动网站优化
香港服务器网站卡顿?如何解决网络延迟与负载问题?
济南企业网站制作公司,济南社保单位网上缴费步骤?
电商网站制作公司有哪些,1688网是什么意思?
如何零成本快速生成个人自助网站?
简历在线制作网站免费,免费下载个人简历的网站是哪些?
手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站?
制作门户网站的参考文献在哪,小说网站怎么建立?
如何在阿里云完成域名注册与建站?
建站之星导航配置指南:自助建站与SEO优化全解析
c++怎么使用类型萃取type_traits_c++ 模板元编程类型判断【方法】
建站主机是什么?如何选择适合的建站主机?
已有域名能否直接搭建网站?
建站主机与虚拟主机有何区别?如何选择最优方案?
油猴 教程,油猴搜脚本为什么会网页无法显示?
linux top下的 minerd 木马清除方法
北京网站制作公司哪家好一点,北京租房网站有哪些?
北京网站制作的公司有哪些,北京白云观官方网站?
如何挑选优质建站一级代理提升网站排名?
公司网站制作需要多少钱,找人做公司网站需要多少钱?
太原网站制作公司有哪些,网约车营运证查询官网?
再谈Python中的字符串与字符编码(推荐)
如何高效搭建专业期货交易平台网站?
如何在阿里云通过域名搭建网站?
如何快速搭建高效可靠的建站解决方案?
如何在Windows 2008云服务器安全搭建网站?
c# F# 的 MailboxProcessor 和 C# 的 Actor 模型
宿州网站制作公司兴策,安徽省低保查询网站?
深圳网站制作培训,深圳哪些招聘网站比较好?
如何在企业微信快速生成手机电脑官网?
如何快速搭建高效简练网站?
上海制作企业网站有哪些,上海有哪些网站可以让企业免费发布招聘信息?
如何在自有机房高效搭建专业网站?
新网站制作渠道有哪些,跪求一个无线渠道比较强的小说网站,我要发表小说?
微课制作网站有哪些,微课网怎么进?
公司网站制作价格怎么算,公司办个官网需要多少钱?
武汉外贸网站制作公司,现在武汉外贸前景怎么样啊?
如何用好域名打造高点击率的自主建站?
家庭服务器如何搭建个人网站?
股票网站制作软件,网上股票怎么开户?
建站之星五站合一营销型网站搭建攻略,流量入口全覆盖优化指南
专业的网站制作设计是什么,如何制作一个企业网站,建设网站的基本步骤有哪些?
*请认真填写需求信息,我们会在24小时内与您取得联系。