时间:2021-07-01 10:21:17 帮助过:28人阅读
本文实例讲述了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程序设计有所帮助。