全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

php实现的pdo公共类定义与用法示例

本文实例讲述了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 


相关文章: 网站制作大概要多少钱一个,做一个平台网站大概多少钱?  如何在Windows虚拟主机上快速搭建网站?  如何在阿里云虚拟服务器快速搭建网站?  相册网站制作软件,图片上的网址怎么复制?  如何在IIS中新建站点并解决端口绑定冲突?  如何快速重置建站主机并恢复默认配置?  如何快速查询网址的建站时间与历史轨迹?  制作网站的软件免费下载,免费制作app哪个平台好?  公司网站制作价格怎么算,公司办个官网需要多少钱?  如何通过FTP空间快速搭建安全高效网站?  微信小程序 input输入框控件详解及实例(多种示例)  安云自助建站系统如何快速提升SEO排名?  如何在云虚拟主机上快速搭建个人网站?  外汇网站制作流程,如何在工商银行网站上做外汇买卖?  如何快速搭建高效可靠的建站解决方案?  如何选购建站域名与空间?自助平台全解析  网站制作怎么样才能赚钱,用自己的电脑做服务器架设网站有什么利弊,能赚钱吗?  实惠建站价格推荐:2025年高性价比自助建站套餐解析  如何选择长沙网站建站模板?H5响应式与品牌定制哪个更优?  建站之星后台搭建步骤解析:模板选择与产品管理实操指南  北京网站制作公司哪家好一点,北京租房网站有哪些?  如何在IIS服务器上快速部署高效网站?  南阳网站制作公司推荐,小学电子版试卷去哪里找资源好?  网站制作中优化长尾关键字挖掘的技巧,建一个视频网站需要多少钱?  如何通过智能用户系统一键生成高效建站方案?  南京做网站制作公司,南京哈发网络有限公司,公司怎么样,做网页美工DIV+CSS待遇怎么样?  建站之星导航如何优化提升用户体验?  如何制作一个表白网站视频,关于勇敢表白的小标题?  如何通过宝塔面板实现本地网站访问?  儿童网站界面设计图片,中国少年儿童教育网站-怎么去注册?  微信小程序制作网站有哪些,微信小程序需要做网站吗?  如何选择靠谱的建站公司加盟品牌?  建站一年半SEO优化实战指南:核心词挖掘与长尾流量提升策略  ,怎么在广州志愿者网站注册?  如何用wdcp快速搭建高效网站?  如何通过商城免费建站系统源码自定义网站主题?  如何高效完成独享虚拟主机建站?  如何通过wdcp面板快速创建网站?  建站之星安装失败:服务器环境不兼容?  孙琪峥织梦建站教程如何优化数据库安全?  如何通过西部建站助手安装IIS服务器?  大连 网站制作,大连天途有线官网?  公司网站设计制作厂家,怎么创建自己的一个网站?  如何生成腾讯云建站专用兑换码?  简单实现Android文件上传  网站制作服务平台,有什么网站可以发布本地服务信息?  购物网站制作费用多少,开办网上购物网站,需要办理哪些手续?  ,制作一个手机app网站要多少钱?  如何快速选择适合个人网站的云服务器配置?  高性价比服务器租赁——企业级配置与24小时运维服务 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。