[PDO]②④--更新記錄

    /**
     * array(
     * 'username'=>'imoocccc,
     * 'password'=>'imooc222',
     * 'email'=>'imooc111@imooc.com'
     * )
     * update user set username='imoocccc'......where id<=38
     *    order by username limit 3
     */
    /** 更新記錄
     * @param $data
     * @param $table
     * @param null $where
     * @param null $order
     * @param null $limit
     * @return bool|int
     */
    public static function update($data, $table, $where = null, $order = null, $limit = null)
    {
        $sets = '';
        foreach ($data as $key => $val) {
            $sets .= $key . "='" . $val . "',";
        }
        //echo $sets;//username='imooc111',password='imooc212',email='imooc222@imooc22.com',
        $sets = rtrim($sets, ',');
        $sql = "UPDATE {$table} SET {$sets} " . self::parseWhere($where) . self::parseOrder($order) . self::parseLimit($limit);
        return self::execute($sql);
    }

PdoMYSQL.class.func

<?php

class PdoMYSQL
{
    public static $config = array();//設(shè)置配置參數(shù)蚁署,配置信息
    public static $link = null;//保存連接標識符
    public static $pconnect = false;//是否開啟長連接
    public static $dbVersion = null;//保存數(shù)據(jù)庫版本
    public static $connected = false;//判斷是否連接成功
    public static $PDOStatement = null;//保存PDOStatement對象
    public static $queryStr = null;//保存最后執(zhí)行的操作
    public static $error = null;//保存錯誤信息
    public static $lastInsertId = null;//保存上一步插入操作產(chǎn)生AUTO_INCREMENT
    public static $numRows = 0;//上一步操作產(chǎn)生受影響的記錄的條數(shù)

    public function __construct($dbConfig = '')
    {
        if (!class_exists("PDO")) {
            self::throw_exception('不支持PDO,請先開啟');
        }
        if (!is_array($dbConfig)) {
            $dbConfig = array(
                'hostname' => DB_HOST,
                'username' => DB_USER,
                'password' => DB_PWD,
                'database' => DB_NAME,
                'hostport' => DB_PORT,
                'dsn' => DB_TYPE . ":host=" . DB_HOST . ";dbname=" . DB_NAME);
        }
        if (empty($dbConfig['hostname']))
            self::throw_exception('沒有定義數(shù)據(jù)庫配置蒋譬,請先定義');
        self::$config = $dbConfig;
        if (empty(self::$config['params']))
            self::$config['params'] = array();
        if (!isset(self::$link)) {
            $configs = self::$config;
            if (self::$pconnect) {
                //開啟長連接呈队,添加到配置數(shù)組中
                $configs['params'][constant("PDO::ATTR_PERSISTENT")] = true;
            }
            try {
                self::$link = new PDO($configs['dsn'], $configs['username'], $configs['password'], $configs['params']);
            } catch (PDOException $e) {
                self::throw_exception($e->getMessage());
            }
            if (!self::$link) {
                self::throw_exception('PDO連接錯誤');
                return false;
            }
            self::$link->exec('SET NAMES ' . DB_CHARSET);
            self::$dbVersion = self::$link->getAttribute(constant("PDO::ATTR_SERVER_VERSION"));
            self::$connected = true;
            unset($configs);
        }
    }

    /**得到所有記錄
     * @param null $sql
     * @return mixed
     */
    public static function getAll($sql = null)
    {
        if ($sql != null) {
            self::query($sql);
        }
        $result = self::$PDOStatement->fetchAll(constant("PDO::FETCH_ASSOC"));
        return $result;
    }

    /**
     * 得到結(jié)果集的一條記錄
     * @param null $sql
     * @return mixed
     */
    public static function getRow($sql = null)
    {
        if ($sql != null) {
            self::query($sql);
        }
        $result = self::$PDOStatement->fetch(constant("PDO::FETCH_ASSOC"));
        return $result;
    }


    /** 根據(jù)主鍵查找記錄
     * @param $tabName
     * @param $priId
     * @param string $fields
     * @return mixed
     */
    public static function findById($tabName, $priId, $fields = '*')
    {
        $sql = 'SELECT %s FROM %s WHERE id=%d;';
        return self::getRow(sprintf($sql, self::parseFields($fields), $tabName, $priId));
    }

    /**
     * 執(zhí)行普通查詢
     * @param $tables
     * @param null $where
     * @param string $fields
     * @param null $group
     * @param null $having
     * @param null $order
     * @param null $limit
     * @return mixed
     */
    public static function find($tables, $where = null, $fields = '*', $group = null, $having = null, $order = null, $limit = null)
    {
        $sql = 'SELECT ' . self::parseFields($fields) . ' FROM ' . $tables . ' '
            . self::parseWhere($where)
            . self::parseGroup($group)
            . self::parseHaving($having)
            . self::parseOrder($order)
            . self::parseLimit($limit);
        $dataAll = self::getAll($sql);
        return count($dataAll) == 1 ? $dataAll[0] : $dataAll;
    }

    /**
     * array(
     * 'username'=>'imoocccc,
     * 'password'=>'imooc222',
     * 'email'=>'imooc111@imooc.com'
     * )
     * update user set username='imoocccc'......where id<=38
     *    order by username limit 3
     */
    /** 更新記錄
     * @param $data
     * @param $table
     * @param null $where
     * @param null $order
     * @param null $limit
     * @return bool|int
     */
    public static function update($data, $table, $where = null, $order = null, $limit = null)
    {
        $sets = '';
        foreach ($data as $key => $val) {
            $sets .= $key . "='" . $val . "',";
        }
        //echo $sets;//username='imooc111',password='imooc212',email='imooc222@imooc22.com',
        $sets = rtrim($sets, ',');
        $sql = "UPDATE {$table} SET {$sets} " . self::parseWhere($where) . self::parseOrder($order) . self::parseLimit($limit);
        return self::execute($sql);
    }

    /**
     * 解析where條件
     * @param $where
     * @return string
     */
    public static function parseWhere($where)
    {
        $whereStr = '';
        if (is_string($where) && !empty($where)) {
            $whereStr = $where;
        }
        return empty($whereStr) ? '' : ' WHERE ' . $whereStr;
    }

    /**
     * 添加記錄的操作
     * array(
     *  'username'=>'imooc',
     *  'password'=>'imooc',
     *  'email'=>'email'
     * )
     *
     * INSERT user(username,password,email) VALUES('aa','aa','aa@aa.com');
     */
    public static function add($data, $table)
    {
        $keys = array_keys($data);
        array_walk($keys, array('PdoMySQL', 'addSpecilChar'));
        $fieldsStr = join(',', $keys);
        $values = "'" . join("','", array_values($data)) . "'";
        $sql = "INSERT {$table}({$fieldsStr}) VALUES({$values});";
        //echo $sql;
        return self::execute($sql);
    }

    /**
     * 解析group by
     * @param $group
     * @return string
     */
    public static function parseGroup($group)
    {
        $groupStr = '';
        if (is_array($group)) {
            $groupStr .= ' GROUP BY' . implode(',', $group);
        } else if (is_string($group) && !empty($group)) {
            $groupStr .= ' GROUP BY ' . $group;
        }
        return empty($groupStr) ? '' : $groupStr;
    }

    /**
     * 對分組結(jié)果通過Having子句進行二次刪選
     * @param $having
     * @return string
     */
    public static function parseHaving($having)
    {
        $havingStr = '';
        if (is_string($having) && !empty($having)) {
            $havingStr .= ' HAVING ' . $having;
        }
        return $havingStr;
    }

    /**
     * 解析order by
     * @param $order
     * @return mixed
     */
    public static function parseOrder($order)
    {
        $orderStr = '';
        if (is_array($order)) {
            $orderStr = ' ORDER BY ' . join(',', $order);
        } elseif (is_string($order) && !empty($order)) {
            $orderStr .= ' ORDER BY ' . $order;
        }
        return $orderStr;
    }

    /**
     * 解析顯示顯示條件
     * limit 3
     * limit 0,3
     * @param $limit
     * @return string
     */
    public static function parseLimit($limit)
    {
        $limitStr = '';
        if (is_array($limit)) {
            if (count($limit) > 1) {
                $limitStr .= ' LIMIT ' . $limit[0] . ',' . $limit[1];
            } else {
                $limitStr .= ' LIMIT ' . $limit[0];
            }
        } elseif (is_string($limit) && !empty($limit)) {
            $limitStr .= ' LIMIT ' . $limit;
        }
        return $limitStr;
    }


    /**
     * 解析字段
     * @param $fields
     * @return string
     */
    public static function parseFields($fields)
    {
        if (is_array($fields)) {
            array_walk($fields, array('PdoMySQL', 'addSpecilChar'));
            $fieldsStr = implode(',', $fields);
        } else if (is_string($fields) && !empty($fields)) {
            if (strpos($fields, '^') === false) {
                //0==false 0:position
                $fields = explode(',', $fields);
                array_walk($fields, array('PdoMySQL', 'addSpecilChar'));
                $fieldsStr = implode(',', $fields);
            } else {
                $fieldsStr = $fields;
            }
        } else {
            $fieldsStr = '*';
        }
        return $fieldsStr;

    }

    /**
     * 通過反引號引用字段
     * @param $value
     */
    public static function addSpecilChar(&$value)
    {
        if ($value == '*' || strpos($value, '.') !== false || strpos($value, '^') !== false) {
            //不用做處理

        } elseif (strpos($value, '^') === false) {
            //$value = '^' . trim($value) . '^';
            $value = '' . trim($value) . '';
        }

    }


    /**執(zhí)行增刪改操作剂习,返回受影響的記錄的條數(shù)
     * @param null $sql
     * @return bool|int
     */
    public static function execute($sql = null)
    {
        $link = self::$link;
        if (!$link) return false;
        self::$queryStr = $sql;
        if (!empty(self::$PDOStatement)) self::free();
        $result = $link->exec(self::$queryStr);
        self::haveErrorThrowException();
        if ($result) {
            self::$lastInsertId = $link->lastInsertId();
            self::$numRows = $result;
            return self::$numRows;
        } else {
            return false;
        }
    }


    /**
     * 釋放結(jié)果集
     */
    public static function free()
    {
        self::$PDOStatement = null;
    }

    public static function query($sql = '')
    {
        $link = self::$link;
        if (!$link) return false;
        //判斷之前是否有結(jié)果集,如果有沪编,釋放結(jié)果集
        if (!empty(self::$PDOStatement)) self::free();
        self::$queryStr = $sql;
        self::$PDOStatement = $link->prepare(self::$queryStr);
        $res = self::$PDOStatement->execute();
        self::haveErrorThrowException();
        return $res;
    }

    public static function haveErrorThrowException()
    {
        $obj = empty(self::$PDOStatement) ? self::$link : self::$PDOStatement;
        $arrError = $obj->errorInfo();
        /**
         * Array
         * (
         * [0] => 42S02
         * [1] => 1146
         * [2] => Table 'test.user1' doesn't exist
         * )
         */
//        print_r($arrError);
        if ($arrError[0] != '00000') {
            self::$error = 'SQLSTATE ' . $arrError[0] . 'SQL Error: ' . $arrError[2] . '<br/>Error SQL: ' . self::$queryStr;
            self::throw_exception(self::$error);
            return false;
        }
        if (self::$queryStr == '') {
            self::throw_exception('沒有執(zhí)行SQL語句');
            return false;
        }
    }

    /**
     * 自定義錯誤處理
     * @param $errMsg
     */
    public
    static function throw_exception($errMsg)
    {
        echo '<div style="width:80%;background-color:#ABCDEF;color: black;font-size: 20px;padding: 20px 0px">
        ' . $errMsg . '</div>';
    }

}

require_once 'config.php';
$PdoMySQL = new PdoMYSQL();
$tables = 'user';

$data = array(
    'username' => 'imooc181',
    'password' => 'imooc212',
    'email' => 'imooc222@imooc22.com'
);
var_dump($PdoMySQL::update($data, $tables, 'id=15', 'id DESC'));

Paste_Image.png
最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末帖池,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子慌申,更是在濱河造成了極大的恐慌陌选,老刑警劉巖,帶你破解...
    沈念sama閱讀 217,509評論 6 504
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件蹄溉,死亡現(xiàn)場離奇詭異咨油,居然都是意外死亡,警方通過查閱死者的電腦和手機柒爵,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,806評論 3 394
  • 文/潘曉璐 我一進店門臼勉,熙熙樓的掌柜王于貴愁眉苦臉地迎上來,“玉大人餐弱,你說我怎么就攤上這事〈亚纾” “怎么了膏蚓?”我有些...
    開封第一講書人閱讀 163,875評論 0 354
  • 文/不壞的土叔 我叫張陵,是天一觀的道長畸写。 經(jīng)常有香客問我驮瞧,道長,這世上最難降的妖魔是什么枯芬? 我笑而不...
    開封第一講書人閱讀 58,441評論 1 293
  • 正文 為了忘掉前任论笔,我火速辦了婚禮,結(jié)果婚禮上千所,老公的妹妹穿的比我還像新娘狂魔。我一直安慰自己,他們只是感情好淫痰,可當我...
    茶點故事閱讀 67,488評論 6 392
  • 文/花漫 我一把揭開白布最楷。 她就那樣靜靜地躺著,像睡著了一般待错。 火紅的嫁衣襯著肌膚如雪籽孙。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,365評論 1 302
  • 那天火俄,我揣著相機與錄音犯建,去河邊找鬼。 笑死瓜客,一個胖子當著我的面吹牛卵皂,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播减江,決...
    沈念sama閱讀 40,190評論 3 418
  • 文/蒼蘭香墨 我猛地睜開眼裹唆,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了知染?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 39,062評論 0 276
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎胳搞,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體称杨,經(jīng)...
    沈念sama閱讀 45,500評論 1 314
  • 正文 獨居荒郊野嶺守林人離奇死亡肌毅,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,706評論 3 335
  • 正文 我和宋清朗相戀三年,在試婚紗的時候發(fā)現(xiàn)自己被綠了姑原。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片悬而。...
    茶點故事閱讀 39,834評論 1 347
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖锭汛,靈堂內(nèi)的尸體忽然破棺而出笨奠,到底是詐尸還是另有隱情,我是刑警寧澤唤殴,帶...
    沈念sama閱讀 35,559評論 5 345
  • 正文 年R本政府宣布般婆,位于F島的核電站,受9級特大地震影響朵逝,放射性物質(zhì)發(fā)生泄漏蔚袍。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 41,167評論 3 328
  • 文/蒙蒙 一配名、第九天 我趴在偏房一處隱蔽的房頂上張望啤咽。 院中可真熱鬧,春花似錦渠脉、人聲如沸宇整。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,779評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽没陡。三九已至,卻和暖如春索赏,著一層夾襖步出監(jiān)牢的瞬間盼玄,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 32,912評論 1 269
  • 我被黑心中介騙來泰國打工潜腻, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留埃儿,地道東北人。 一個月前我還...
    沈念sama閱讀 47,958評論 2 370
  • 正文 我出身青樓融涣,卻偏偏與公主長得像童番,于是被迫代替她去往敵國和親精钮。 傳聞我的和親對象是個殘疾皇子,可洞房花燭夜當晚...
    茶點故事閱讀 44,779評論 2 354

推薦閱讀更多精彩內(nèi)容