注意，經常出現插入資料庫資料時，中文字元亂碼，這時需要設定一下 pdo 的傳輸編碼。

$pdo->exec("SET CHARACTER SET UTF8");

後來使用了高版本的php和mysql，發現之前那個類過時了，，於是就重寫了使用pdo的操作類。

寫了兩個，一個比較簡單。。一個比較複雜。。。。。。doc寫的挺詳細的，，，我就不解釋了。。。

具體使用方法

好了，，，先上簡單的。。

<?php
/**
 * Created by PhpStorm.
 * User: leif
 * Date: 2016/5/11 0011
 * Time: 10:13
 */
include_once
 
 'config.php';

/**
 * 連線資料庫
 * @param string $dbhost
 * @param string $dbname
 * @param string $username
 * @param string $password
 * @return PDO
 */
function connectMysql($dbhost,$dbname,$username,$password){
    $dsn = "mysql:host={$dbhost};dbname={$dbname}";
    $pdo = new PDO($dsn,$username,$password
 
);
    return $pdo;
}

/**
 * 查詢一條資料
 * @param PDO $pdo
 * @param $sql
 * @return mixed|PDOStatement
 */
function fetchOneMysql(PDO $pdo,$sql){
    $row = $pdo->query($sql);
    $row = $row->fetch();
    return $row;
}

/**
 * 查詢多條資料
 * @param $pdo
 * @param $sql
 * @return mixed
 */
function fetchAllMysql
 
($pdo,$sql){
    $row = $pdo->query($sql);
    $row = $row->fetchAll();
    return $row;
}

/** 刪除一條資料
 * @param PDO $pdo
 * @param $table
 * @param null $where
 * @return int
 */
function deleteMysql(PDO $pdo,$table,$where=null){
    $sql = "delete from {$table} where {$where}";
    $res = $pdo->exec($sql);
    return $res;
}

/**
 * 插入一條資料
 * @param PDO $pdo
 * @param string $table
 * @param array $array
 * @return number
 */
function insertIntoOneMysql(PDO $pdo,$table,$array){
    $keys = join(",", array_keys($array));
    $values = join(",", array_values($array));
    $sql = "insert into `{$table}` ({$keys}) values ({$values})";
    $res = $pdo->exec($sql);
    return $res;
}

/**
 * 修改一條資料
 * @param PDO $pdo
 * @param string $table
 * @param array $array
 * @param string $where
 * @return string
 */
function updateMysql($pdo,$table, $array,$where){
    foreach ($array as $key=>$value){
        if (@$set == null){
            $p = "";
        }else {
            $p = ",";
        }
        @$set .= "{$p}`{$key}`='{$value}'";
    }
    $sql = "update `{$table}` set {$set} ".($where==null?null:"where ({$where})");
    $res = $pdo->exec($sql);
    return $res;
}

然後是複雜的，但是魯棒性更好

<?php

/**
 * 
 * @author [email protected]
 *
 */
class mysqlcon{
    private $_dbhost;
    private $_dbname;
    private $_username;
    private $_password;
    private $_pdo;

    /**
     * 建立物件是初始化資料庫連線資訊
     * @param string $dbhost databases-host
     * @param string $dbname databases-name
     * @param string $username databases-username
     * @param string $password databases-password
     */
    function __construct($dbhost,$dbname,$username,$password){
        $this->_dbhost = $dbhost;
        $this->_dbname = $dbname;
        $this->_username = $username;
        $this->_password = $password;
    }

    /**
     * 連線資料庫
     * @return string  連線失敗會返回異常資訊,成功返回成功資訊
     */
    function connectMysql(){
        try {
            $dsn = "mysql:host={$this->_dbhost};dbname={$this->_dbname}";
            $pdo = new PDO($dsn,$this->_username,$this->_password);
        } catch (PDOException $e) {
            return "mysql 連線失敗".$e->getMessage();
        }
        $this->_pdo = $pdo;
        return "Query OK";
    }

    /**
     * 查詢一行資料
     * @param string $sql 查詢語句
     * @throws Exception  查詢失敗，丟擲異常
     * @return array 查詢成功返回陣列，失敗返回異常資訊
     */
    function fetchOneMysql($sql){
        try {
            $row = $this->_pdo->query($sql);
            if ($row){
                $row = $row->fetch();
            }else {
                throw new Exception("sql語句或pdo物件出錯，查詢結果為空");
            }           
        } catch (Exception $e) {
            return $e->getMessage();
        }
        return $row;
    }

    /**
     * 查詢多行資料
     * @param string $sql 查詢語句
     * @throws Exception  查詢失敗，丟擲異常
     * @return array 查詢成功返回陣列，失敗返回異常資訊
     */
    function fetchAllMysql($sql){
        try {
            $row = $this->_pdo->query($sql);
            if ($row){
                $row = $row->fetchAll();
            }else {
                throw new Exception("sql語句或pdo物件出錯，查詢結果為空");
            }
        } catch (Exception $e) {
            return $e->getMessage();
        }
        return $row;
    }

    /**
     * 刪除資料
     * @param string $table 要操作的表
     * @param string $where 刪除條件 
     * @throws Exception 刪除失敗，丟擲異常
     * @return string 刪除成功，返回query ok資訊，刪除失敗，返回異常資訊
     */
    function deleteMysql($table,$where=null){
        $sql = "delete from {$table} where {$where}";
        try {
            $res = $this->_pdo->exec($sql);
            if ($res){

            }else {
                throw new Exception("刪除失敗，請檢查傳入引數");
            }
        } catch (Exception $e) {
            return $e->getMessage();
        }
        return "Query OK, {$res} row affected";
    }

    /**
     * 插入一條資料
     * @param string $table 要操作的表
     * @param array $array 要插入的資料，以key=>value方式對應儲存在陣列
     * @throws Exception 插入失敗，丟擲異常
     * @return string 插入成功，返回query ok資訊，插入失敗，返回異常資訊
     */
    function insertIntoOneMysql($table,$array){
        $keys = join(",", array_keys($array));
        $values = join(",", array_values($array));
        $sql = "insert into `{$table}` ({$keys}) values ({$values})";
        try {
            $res = $this->_pdo->exec($sql);
            if ($res){

            }else {
                throw new Exception("插入失敗，請檢查引數是否正確");
            }
        } catch (Exception $e) {
            return $e->getMessage();
        }
        return "Query OK, {$res} row affected";
    }

    /**
     * 修改資料
     * @param string $table 要操作的表
     * @param array $array 要修改的資料，以key=>value的方式對應儲存在陣列中
     * @param string $where 修改條件
     * @throws Exception 修改失敗，丟擲異常
     * @return string 修改成功，返回query ok資訊，修改失敗，返回異常資訊
     */
    function updateMysql($table, $array,$where){
        foreach ($array as $key=>$value){
            if (@$set == null){
                $p = "";
            }else {
                $p = ",";
            }
            @$set .= "{$p}`{$key}`='{$value}'";
        }
        $sql = "update `{$table}` set {$set} ".($where==null?null:"where ({$where})");
        try {
            $res = $this->_pdo->exec($sql);
            if ($res){

            }else {
                throw new Exception("修改失敗，請檢查引數");
            }
        } catch (Exception $e) {
            return $e->getMessage();
        }
        return "Query OK, {$res} row affected";
    }
}


?>