国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

PHP使用PDO封裝一個簡單易用的DB類

littlelightss / 1028人閱讀

摘要:使用創建測試庫和表代碼測試運行結果工具類安裝框架中使用建議在框架中使用類用單例模式或者用依賴容器來管理較好。

使用 創建測試庫和表
create database db_test;
CREATE TABLE `user` (
    `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
    `name` char(11) NOT NULL,
    `created_at` int(10) unsigned NOT NULL,
    PRIMARY KEY (`uid`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
INSERT INTO `user` VALUES ("1", "wang", "1501109027");
INSERT INTO `user` VALUES ("2", "meng", "1501109026");
INSERT INTO `user` VALUES ("3", "liu", "1501009027");
INSERT INTO `user` VALUES ("4", "yuan", "1500109027");
代碼測試
require __DIR__ . "/DB.php";
$db = new DB();
$db->__setup([
    "dsn"=>"mysql:dbname=db_test;host=localhost",
    "username"=>"root",
    "password"=>"******",
    "charset"=>"utf8"
]);


$user = $db->fetch("SELECT * FROM user where id = :id", ["id" => 1]);
echo $user["name"];
echo "
";

$insertId = $db->insert("user", ["name" => "salamander", "created_at" => time()]);
echo "insert user {$insertId}
";
$users = $db->fetchAll("SELECT * FROM user");
foreach ($users as $item) {
    echo "user {$item["id"]} is {$item["name"]} 
";
}   

運行結果

DB工具類
dsn = $config["dsn"];
        $this->user = $config["username"];
        $this->password = $config["password"];
        $this->charset = $config["charset"];
        $this->connect();
    }

    private function connect()
    {
        if(!$this->dbh){
            $options = array(
                PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES " . $this->charset,
            );
            $this->dbh = new PDO($this->dsn, $this->user,
                $this->password, $options);
        }
    }

    public function beginTransaction()
    {
        return $this->dbh->beginTransaction();
    }

    public function inTransaction()
    {
        return $this->dbh->inTransaction();
    }

    public function rollBack()
    {
        return $this->dbh->rollBack();
    }

    public function commit()
    {
        return $this->dbh->commit();
    }

    function watchException($execute_state)
    {
        if(!$execute_state){
            throw new MySQLException("SQL: {$this->lastSQL}
".$this->sth->errorInfo()[2], intval($this->sth->errorCode()));
        }
    }

    public function fetchAll($sql, $parameters=[])
    {
        $result = [];
        $this->lastSQL = $sql;
        $this->sth = $this->dbh->prepare($sql);
        $this->watchException($this->sth->execute($parameters));
        while($result[] = $this->sth->fetch(PDO::FETCH_ASSOC)){ }
        array_pop($result);
        return $result;
    }

    public function fetchColumnAll($sql, $parameters=[], $position=0)
    {
        $result = [];
        $this->lastSQL = $sql;
        $this->sth = $this->dbh->prepare($sql);
        $this->watchException($this->sth->execute($parameters));
        while($result[] = $this->sth->fetch(PDO::FETCH_COLUMN, $position)){ }
        array_pop($result);
        return $result;
    }

    public function exists($sql, $parameters=[])
    {
        $this->lastSQL = $sql;
        $data = $this->fetch($sql, $parameters);
        return !empty($data);
    }

    public function query($sql, $parameters=[])
    {
        $this->lastSQL = $sql;
        $this->sth = $this->dbh->prepare($sql);
        $this->watchException($this->sth->execute($parameters));
        return $this->sth->rowCount();
    }

    public function fetch($sql, $parameters=[], $type=PDO::FETCH_ASSOC)
    {
        $this->lastSQL = $sql;
        $this->sth = $this->dbh->prepare($sql);
        $this->watchException($this->sth->execute($parameters));
        return $this->sth->fetch($type);
    }

    public function fetchColumn($sql, $parameters=[], $position=0)
    {
        $this->lastSQL = $sql;
        $this->sth = $this->dbh->prepare($sql);
        $this->watchException($this->sth->execute($parameters));
        return $this->sth->fetch(PDO::FETCH_COLUMN, $position);
    }

    public function update($table, $parameters=[], $condition=[])
    {
        $table = $this->format_table_name($table);
        $sql = "UPDATE $table SET ";
        $fields = [];
        $pdo_parameters = [];
        foreach ( $parameters as $field=>$value){
            $fields[] = "`".$field."`=:field_".$field;
            $pdo_parameters["field_".$field] = $value;
        }
        $sql .= implode(",", $fields);
        $fields = [];
        $where = "";
        if(is_string($condition)) {
            $where = $condition;
        } else if(is_array($condition)) {
            foreach($condition as $field=>$value){
                $parameters[$field] = $value;
                $fields[] = "`".$field."`=:condition_".$field;
                $pdo_parameters["condition_".$field] = $value;
            }
            $where = implode(" AND ", $fields);
        }
        if(!empty($where)) {
            $sql .= " WHERE ".$where;
        }
        return $this->query($sql, $pdo_parameters);
    }

    public function insert($table, $parameters=[])
    {
        $table = $this->format_table_name($table);
        $sql = "INSERT INTO $table";
        $fields = [];
        $placeholder = [];
        foreach ( $parameters as $field=>$value){
            $placeholder[] = ":".$field;
            $fields[] = "`".$field."`";
        }
        $sql .= "(".implode(",", $fields).") VALUES (".implode(",", $placeholder).")";

        $this->lastSQL = $sql;
        $this->sth = $this->dbh->prepare($sql);
        $this->watchException($this->sth->execute($parameters));
        $id = $this->dbh->lastInsertId();
        if(empty($id)) {
            return $this->sth->rowCount();
        } else {
            return $id;
        }
    }

    public function errorInfo()
    {
        return $this->sth->errorInfo();
    }

    protected function format_table_name($table)
    {
        $parts = explode(".", $table, 2);

        if(count($parts) > 1) {
            $table = $parts[0].".`{$parts[1]}`";
        } else {
            $table = "`$table`";
        }
        return $table;
    }

    function errorCode()
    {
        return $this->sth->errorCode();
    }
}

class MySQLException extends Exception { }

Composer安裝

SimpleDB

框架中使用建議

在框架中使用DB類,用單例模式或者用依賴容器來管理較好。

文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。

轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/23322.html

相關文章

  • php封裝db 連接sqlite3

    摘要:最新插入的支持數據庫移植如果你的部署將來有多種數據庫那就用它了同時是設計的執行效率較高他已經封裝為的擴展庫組件了運行快效率高這是修改為版本的原生類導入的配置文件我這里只是方便前端修改,也可以搞成文件 PDO支持數據庫移植,如果你的部署將來有多種數據庫,那就用它了.同時,PDO是C設計的,執行效率較高.他已經封裝為PHP的擴展庫組件了.運行快,效率高 class dbManager{ ...

    alin 評論0 收藏0
  • Laravel 學習筆記之 Query Builder 源碼解析(中)

    說明:本篇主要學習數據庫連接階段和編譯SQL語句部分相關源碼。實際上,上篇已經聊到Query Builder通過連接工廠類ConnectionFactory構造出了MySqlConnection實例(假設驅動driver是mysql),在該MySqlConnection中主要有三件利器:IlluminateDatabaseMysqlConnector;IlluminateDatabaseQuery...

    zhou_you 評論0 收藏0
  • Laravel學習筆記之Query Builder源碼解析(上)

    摘要:說明本文主要學習模塊的源碼。這里,就已經得到了鏈接器實例了,該中還裝著一個,下文在其使用時再聊下其具體連接邏輯。 說明:本文主要學習Laravel Database模塊的Query Builder源碼。實際上,Laravel通過Schema Builder來設計數據庫,通過Query Builder來CURD數據庫。Query Builder并不復雜或神秘,只是在PDO擴展的基礎上又開...

    Steve_Wang_ 評論0 收藏0

發表評論

0條評論

littlelightss

|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<