毕竟入门不久，之前写PHP+MySQL操作都是直接用原生PHP连接数据库进行操作，后来才知道还有PDO这种东西。
PDO扩展为PHP访问数据库定义了一个轻量级的、一致性的接口，它提供了一个数据访问抽象层，这样，无论使用什么数据库，都可以通过一致的函数执行查询和获取数据。
下面是刚开始学PDO写的一个类，目前还不了解PDO跟原生比，有什么明显的优点，先把基本操作搞清楚，然后慢慢来。增删查改已满足：
/*** @abstract PDO study: PDO操作MySQL增删查改类* @date 2014/06/30* @author Silov[bluebird237@gmail.com]*/class mysqlPdoClass{ private $db; private $db_name = 'study';// private $db_serv; private $db_user = 'root'; private $db_pass = 'root'; private $db_host = 'localhost'; //构造函数以及连接数据库 public function __construct( $username = 'root' , $password = 'root' , $connect = 'false'){ $this->db_serv = "mysql:dbname=".$this->db_name.";host=".$this->db_host.";charset=utf-8"; $this->db_user = $username; $this->db_pass = $password; } //管理数据库，析构函数 public function __destruct(){ $this->db->close(); $this->db = null; } //执行SQL语句，返回值为sql执行结果 public function run_query($sql){ $this->db = new PDO($this->db_serv, $this->db_user, $this->db_pass); $row = $this->db->query($sql); $row->setFetchMode(PDO::FETCH_ASSOC); //设置查询结果显示为键值对数组模式 return $row; } //执行SQL语句，返回值为sql影响行数 public function run_exec($sql){ $this->db = new PDO($this->db_serv, $this->db_user, $this->db_pass); return $this->db->exec($sql); } /** * @abstract 插入操作 * @param $table:表名; $data:插入数据键值对数组; * @return 返回值:插入结果，boolean */ public function data_insert($table, $data, $return = true,$debug=false){ if(!$table) { return false; } $fields = array(); $values = array(); foreach ($data as $field => $value){ $fields[] = '`'.$field.'`'; $values[] = "'".addslashes($value)."'"; } if(empty($fields) || empty($values)) { return false; } $sql = 'INSERT INTO `'.$table.'` ('.join(',',$fields).') VALUES ('.join(',',$values).')'; if($debug){ return $sql; } $query = $this->run_exec($sql); return $return ? $this->db->lastInsertId() : $query; } /** * @abstract 更新操作 * @param $table:表名; $condition:更新查询条件; $data:更新数据键值对数组; $limit:更新数据条数上限 * $debug:测试时给true，则不执行update，直接返回完整的sql语句 * @return 返回值:插入结果，boolean */ public function data_update($table, $condition, $data, $limit = 1,$debug=false) { if(!$table) { return false; } $set = array(); foreach ($data as $field => $value) { $set[] = '`'.$field.'`='."'".addslashes($value)."'"; } if(empty($set)) { return false; } $sql = 'UPDATE `'.$table.'` SET '.join(',',$set).' WHERE '.$condition.' '. ($limit ? 'LIMIT '.$limit : ''); if($debug){ return $sql; } return $this->run_exec($sql); } /** * @abstract 查询单个字段值 * @param $sql:sql语句 * @return 返回值:string */ public function getOne($sql){ $row = $this->run_query($sql); $data = $row->fetch(); $data = array_shift($data); return $data; } /** * @abstract 查询单条记录，多个字段 * @param $sql:sql语句 * @return 返回值:键值对数组 */ public function getRow($sql){ $row = $this->run_query($sql); $data = $row->fetch(); return $data; } /** * @abstract 查询多条记录 * @param $sql:sql语句 * @return 返回值:以键值对数组为元素的数组 */ public function getRows($sql){ $row = $this->run_query($sql); $data = $row->fetchAll(); return $data; }}
