A-A+

PHP的PDO常用类库实例分析

2019年10月09日 我爱编程 暂无评论

本文实例讲述了PHP的PDO常用类库。分享给大家供大家参考，具体如下：

1、Db.class.php 连接数据库

  1. <?php
  3. // 连接数据库
  5. class Db {
  7.   static public function getDB() {
  9.     try {
  11.       $pdo = new PDO(DB_DSN, DB_USER, DB_PWD);
  13.       $pdo->setAttribute(PDO::ATTR_PERSISTENT, true); // 设置数据库连接为持久连接
  15.       $pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 设置抛出错误
  17.       $pdo->setAttribute(PDO::ATTR_ORACLE_NULLS, true); // 设置当字符串为空转换为 SQL 的 NULL
  19.       $pdo->query('SET NAMES utf8'); // 设置数据库编码
  21.     } catch (PDOException $e) {
  23.       exit('数据库连接错误，错误信息：'. $e->getMessage());
  25.     }
  27.     return $pdo;
  29.   }
  31. }
  33. ?>

2、Model.class.php 数据库操作类

  1. <?php
  3. /**
  5. * 数据库操作类库
  7. * author Lee.
  9. * Last modify $Date: 2012-1-19 13:59；04 $
  11. */
  13. class M {
  15.   private $_db; //数据库句柄
  17.   public $_sql; //SQL语句
  19.   /**
  21.    * 构造方法
  23.    */
  25.   public function __construct() {
  27.     $this->_db = Db::getDB();
  29.   }
  31.   /**
  33.    * 数据库添加操作
  35.    * @param string $tName 表名
  37.    * @param array $field 字段数组
  39.    * @param array $val 值数组
  41.    * @param bool $is_lastInsertId 是否返回添加ID
  43.    * @return int 默认返回成功与否，$is_lastInsertId 为true，返回添加ID
  45.    */
  47.   public function insert($tName, $fields, $vals, $is_lastInsertId=FALSE) {
  49.     try {
  51.       if (!is_array($fields) || !is_array($vals))
  53.         exit($this->getError(__FUNCTION__, __LINE__));
  55.       $fields = $this->formatArr($fields);
  57.       $vals = $this->formatArr($vals, false);
  59.       $tName = $this->formatTabName($tName);
  61.       $this->_sql = "INSERT INTO {$tName} ({$fields}) VALUES ({$vals})";
  63.       if (!$is_lastInsertId) {
  65.         $row = $this->_db->exec($this->_sql);
  67.         return $row;
  69.       } else {
  71.         $this->_db->exec($this->_sql);
  73.         $lastId = (int)$this->_db->lastInsertId();
  75.         return $lastId;
  77.       }
  79.     } catch (PDOException $e) {
  81.       exit($e->getMessage());
  83.     }
  85.   }
  87.   /**
  89.    * 数据库修改操作
  91.    * @param string $tName 表名
  93.    * @param array $field 字段数组
  95.    * @param array $val 值数组
  97.    * @param string $condition 条件
  99.    * @return int 受影响的行数
  101.    */
  103.   public function update($tName, $fieldVal, $condition) {
  105.     try {
  107.       if (!is_array($fieldVal) || !is_string($tName) || !is_string($condition))
  109.         exit($this->getError(__FUNCTION__, __LINE__));
  111.       $tName = $this->formatTabName($tName);
  113.       $upStr = '';
  115.       foreach ($fieldVal as $k=>$v) {
  117.         $upStr .= '`'.$k . '`=' . '\'' . $v . '\'' . ',';
  119.       }
  121.       $upStr = rtrim($upStr, ',');
  123.       $this->_sql = "UPDATE {$tName} SET {$upStr} WHERE {$condition}";
  125.       $row = $this->_db->exec($this->_sql);
  127.       return $row;
  129.     } catch (PDOException $e) {
  131.       exit($e->getMessage());
  133.     }
  135.   }
  137.   /**
  139.    * 数据库删除操作（注：必须添加 where 条件）
  141.    * @param string $tName 表名
  143.    * @param string $condition 条件
  145.    * @return int 受影响的行数
  147.    */
  149.   public function del($tName, $condition) {
  151.     try {
  153.       if (!is_string($tName) || !is_string($condition))
  155.         exit($this->getError(__FUNCTION__, __LINE__));
  157.       $tName= $this->formatTabName($tName);
  159.       $this->_sql = "DELETE FROM {$tName} WHERE {$condition}";
  161.       $row = $this->_db->exec($this->_sql);
  163.       return $row;
  165.     } catch (PDOException $e) {
  167.       exit($e->getMessage());
  169.     }
  171.   }
  173.   /**
  175.    * 返回表总个数
  177.    * @param string $tName 表名
  179.    * @param string $condition 条件
  181.    * @return int
  183.    */
  185.   public function total($tName, $condition='') {
  187.     try {
  189.       if (!is_string($tName))
  191.         exit($this->getError(__FUNCTION__, __LINE__));
  193.       $tName = $this->formatTabName($tName);
  195.       $this->_sql = "SELECT COUNT(*) AS total FROM {$tName}" .
  197.       ($condition=='' ? '' : ' WHERE ' . $condition);
  199.       $re = $this->_db->query($this->_sql);
  201.       foreach ($re as $v) {
  203.         $total = $v['total'];
  205.       }
  207.       return (int)$total;
  209.     } catch (PDOException $e) {
  211.       exit($e->getMessage());
  213.     }
  215.   }
  217.   /**
  219.    * 数据库删除多条数据
  221.    * @param string $tName 表名
  223.    * @param string $field 依赖字段
  225.    * @param array $ids 删除数组
  227.    * @return int 受影响的行数
  229.    */
  231.   public function delMulti($tName, $field, $ids) {
  233.     try {
  235.       if (!is_string($tName) || !is_array($ids))
  237.         exit($this->getError(__FUNCTION__, __LINE__));
  239.       $delStr = '';
  241.       $tName = $this->formatTabName($tName);
  243.       $field = $this->formatTabName($field);
  245.       foreach ($ids as $v) {
  247.         $delStr .= $v . ',';
  249.       }
  251.       $delStr = rtrim($delStr, ',');
  253.       $this->_sql = "DELETE FROM {$tName} WHERE {$field} IN ({$delStr})";
  255.       $row = $this->_db->exec($this->_sql);
  257.       return $row;
  259.     } catch (PDOException $e) {
  261.       exit($e->getMessage());
  263.     }
  265.   }
  267.   /**
  269.    * 获取表格的最后主键（注：针对 INT 类型）
  271.    * @param string $tName 表名
  273.    * @return int
  275.    */
  277.   public function insertId($tName) {
  279.     try {
  281.       if (!is_string($tName))
  283.         exit($this->getError(__FUNCTION__, __LINE__));
  285.       $this->_sql = "SHOW TABLE STATUS LIKE '{$tName}'";
  287.       $result = $this->_db->query($this->_sql);
  289.       $insert_id = 0;
  291.       foreach ($result as $v) {
  293.         $insert_id = $v['Auto_increment'];
  295.       }
  297.       return (int)$insert_id;
  299.     } catch (PDOException $e) {
  301.       exit($e->getMessage());
  303.     }
  305.   }
  307.   /**
  309.    * 检查数据是否已经存在（依赖条件）
  311.    * @param string $tName 表名
  313.    * @param string $field 依赖的字段
  315.    * @return bool
  317.    */
  319.   public function exists($tName, $condition) {
  321.     try {
  323.       if (!is_string($tName) || !is_string($condition))
  325.         exit($this->getError(__FUNCTION__, __LINE__));
  327.       $tName = $this->formatTabName($tName);
  329.       $this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$condition}";
  331.       $result = $this->_db->query($this->_sql);
  333.       foreach ($result as $v) {
  335.          $b = $v['total'];
  337.       }
  339.       if ($b) {
  341.         return true;
  343.       } else {
  345.         return false;
  347.       }
  349.     } catch (PDOException $e) {
  351.       exit($e->getMessage());
  353.     }
  355.   }
  357.   /**
  359.    * 检查数据是否已经存在（依赖 INT 主键）
  361.    * @param string $tName 表名
  363.    * @param string $primary 主键
  365.    * @param int $id 主键值
  367.    * @return bool
  369.    */
  371.   public function existsByPK($tName, $primary, $id) {
  373.     try {
  375.       if (!is_string($tName) || !is_string($primary)
  377.       || !is_int($id))
  379.         exit($this->getError(__FUNCTION__, __LINE__));
  381.       $tName = $this->formatTabName($tName);
  383.       $this->_sql = "SELECT COUNT(*) AS total FROM {$tName} WHERE {$primary} = ". $id;
  385.       $result = $this->_db->query($this->_sql);
  387.       foreach ($result as $v) {
  389.          $b = $v['total'];
  391.       }
  393.       if ($b) {
  395.         return true;
  397.       } else {
  399.         return false;
  401.       }
  403.     } catch (PDOException $e) {
  405.       exit($e->getMessage());
  407.     }
  409.   }
  411.   /**
  413.    * 预处理删除（注：针对主键为 INT 类型，推荐使用）
  415.    * @param string $tName 表名
  417.    * @param string $primary 主键字段
  419.    * @param int or array or string $ids 如果是删除一条为 INT，多条为 array，删除一个范围为 string
  421.    * @return int 返回受影响的行数
  423.    */
  425.   public function delByPK($tName, $primary, $ids, $mult=FALSE) {
  427.     try {
  429.       if (!is_string($tName) || !is_string($primary)
  431.       || (!is_int($ids) && !is_array($ids) && !is_string($ids))
  433.       || !is_bool($mult)) exit($this->getError(__FUNCTION__, __LINE__));
  435.       $tName = $this->formatTabName($tName);
  437.       $stmt = $this->_db->prepare("DELETE FROM {$tName} WHERE {$primary}=?");
  439.       if (!$mult) {
  441.         $stmt->bindParam(1, $ids);
  443.         $row = $stmt->execute();
  445.       } else {
  447.         if (is_array($ids)) {
  449.           $row = 0;
  451.           foreach ($ids as $v) {
  453.             $stmt->bindParam(1, $v);
  455.             if ($stmt->execute()) {
  457.               $row++;
  459.             }
  461.           }
  463.         } elseif (is_string($ids)) {
  465.           if (!strpos($ids, '-'))
  467.             exit($this->getError(__FUNCTION__, __LINE__));
  469.           $split = explode('-', $ids);
  471.           if (count($split)!=2 || $split[0]>$split[1])
  473.             exit($this->getError(__FUNCTION__, __LINE__));
  475.           $i = null;
  477.           $count = $split[1]-$split[0]+1;
  479.           for ($i=0; $i<$count; $i++) {
  481.             $idArr[$i] = $split[0]++;
  483.           }
  485.           $idStr = '';
  487.           foreach ($idArr as $id) {
  489.             $idStr .= $id . ',';
  491.           }
  493.           $idStr = rtrim($idStr, ',');
  495.           $this->_sql ="DELETE FROM {$tName} WHERE {$primary} in ({$idStr})";
  497.           $row = $this->_db->exec($this->_sql);
  499.         }
  501.       }
  503.       return $row;
  505.     } catch (PDOException $e) {
  507.       exit($e->getMessage());
  509.     }
  511.   }
  513.   /**
  515.    * 返回单个字段数据或单条记录
  517.    * @param string $tName 表名
  519.    * @param string $condition 条件
  521.    * @param string or array $fields 返回的字段，默认是*
  523.    * @return string || array
  525.    */
  527.   public function getRow($tName, $condition='', $fields="*") {
  529.     try {
  531.       if (!is_string($tName) || !is_string($condition)
  533.       || !is_string($fields) || emptyempty($fields))
  535.          exit($this->getError(__FUNCTION__, __LINE__));
  537.       $tName = $this->formatTabName($tName);
  539.       $this->_sql = "SELECT {$fields} FROM {$tName} ";
  541.       $this->_sql .= ($condition=='' ? '' : "WHERE {$condition}") . " LIMIT 1";
  543.       $sth = $this->_db->prepare($this->_sql);
  545.       $sth->execute();
  547.       $result = $sth->fetch(PDO::FETCH_ASSOC);
  549.       if ($fields === '*') {
  551.         return $result;
  553.       } else {
  555.         return $result[$fields];
  557.       }
  559.     } catch (PDOException $e) {
  561.       exit($e->getMessage());
  563.     }
  565.   }
  567.   /**
  569.    * 返回多条数据
  571.    * @param string $tName 表名
  573.    * @param string $fields 返回字段，默认为*
  575.    * @param string $condition 条件
  577.    * @param string $order 排序
  579.    * @param string $limit 显示个数
  581.    * @return PDOStatement
  583.    */
  585.   public function getAll($tName, $fields='*', $condition='', $order='', $limit='') {
  587.     try {
  589.       if (!is_string($tName) || !is_string($fields)
  591.       || !is_string($condition) || !is_string($order)
  593.       || !is_string($limit))
  595.         exit($this->getError(__FUNCTION__, __LINE__));
  597.       $tName = $this->formatTabName($tName);
  599.       $fields = ($fields=='*' || $fields=='') ? '*' : $fields;
  601.       $condition = $condition=='' ? '' : " WHERE ". $condition ;
  603.       $order = $order=='' ? '' : " ORDER BY ". $order;
  605.       $limit = $limit=='' ? '' : " LIMIT ". $limit;
  607.       $this->_sql = "SELECT {$fields} FROM {$tName} {$condition} {$order} {$limit}";
  609.       $sth = $this->_db->prepare($this->_sql);
  611.       $sth->execute();
  613.       $result = $sth->fetchAll(PDO::FETCH_ASSOC);
  615.       return $result;
  617.     } catch (PDOException $e) {
  619.       exit($e->getMessage());
  621.     }
  623.   }
  625.   /**
  627.    * 格式化数组（表结构和值）
  629.    * @param array $field
  631.    * @param bool $isField
  633.    * @return string
  635.    */
  637.   private function formatArr($field, $isField=TRUE) {
  639.     if (!is_array($field)) exit($this->getError(__FUNCTION__, __LINE__));
  641.     $fields = '';
  643.     if ($isField) {
  645.       foreach ($field as $v) {
  647.         $fields .= '`'.$v.'`,';
  649.       }
  651.     } else {
  653.       foreach ($field as $v) {
  655.         $fields .= '\''.$v.'\''.',';
  657.       }
  659.     }
  661.     $fields = rtrim($fields, ',');
  663.     return $fields;
  665.   }
  667.   /**
  669.    * 格式化问号
  671.    * @param int $count 数量
  673.    * @return string 返回格式化后的字符串
  675.    */
  677.   private function formatMark($count) {
  679.     $str = '';
  681.     if (!is_int($count)) exit($this->getError(__FUNCTION__, __LINE__));
  683.     if ($count==1) return '?';
  685.     for ($i=0; $i<$count; $i++) {
  687.       $str .= '?,';
  689.     }
  691.     return rtrim($str, ',');
  693.   }
  695.   /**
  697.    * 错误提示
  699.    * @param string $fun
  701.    * @return string
  703.    */
  705.   private function getError($fun, $line) {
  707.     return __CLASS__ . '->' . $fun . '() line<font color="red">'. $line .'</font> ERROR!';
  709.   }
  711.   /**
  713.    * 处理表名
  715.    * @param string $tName
  717.    * @return string
  719.    */
  721.   private function formatTabName($tName) {
  723.     return '`' . trim($tName, '`') . '`';
  725.   }
  727.   /**
  729.    * 析构方法
  731.    */
  733.   public function __destruct() {
  735.     $this->_db = null;
  737.   }
  739. }
标签：

给我留言

Copyright © 四季博客 保留所有权利.   Theme  Ality

用户登录