在一個記錄中凳寺，對mysqli進行了一定程度上的封裝，接下來彤侍，我們基于它來搞個工具類 傳送門

• 我們將前小節(jié)中的類寫入mysql.class.php肠缨，今天的就命名為DB.class.php好了，在文件開頭引入

include "mysql.class.php";

class DB {
    //數據庫配置
    private static $config = false;
    //當前數據庫名
    private static $currentDB = false;
    //連接著的數據庫
    private static $db = false;
    //讀寫標志
    private static $rw = false;
    //數據庫池
    private static $dbPool = array();
    //編碼配置
    private static $charset = 'UTF-8';
    //模型文件文件夾
    private static $mDir;
}

到這里盏阶，基本的屬性定義好了晒奕，剩下的就是功能的一步步實現 。

首先當然是要有一個配置文件名斟，來定義我們的數據庫信息脑慧，配置如下 ，用$ini表示砰盐。,對應DB::$config;

$ini['default'] = 'modou';
$ini['modou']['master'][0] = array(
    'host' => "127.0.0.1",
    'username' => 'root',
    'passwd' => '',
    'dbname' => 'modou',
    'port' => '3306',
    'dbcharset' =>'utf-8',
);

所以要定義一個方法來接收和配置入類

public static function ini($config, $mDir = "../model") {
        self::$mDir = $mDir;
        self::$config = $config;
        self::selectDB($config['default']);
}

其中的DB::selectDB(),就是用來把默認的數庫庫名稱傳遞給DB::currentDB;

public static function selectDB($name) {
        self::$currentDB = $name;
}

這里有一個技巧闷袒，只有當我們執(zhí)行了語句的查詢時才需要去和數據庫通訊，而我們的數據庫查詢都給了DBmysqli岩梳，而現在的DB既然是要用到DBmysqli的囊骤，所以我們可以用一種方式把DBmysqli的方法都據為已有，至少看起來是這樣冀值，這里我們用到了__callStatic();如果有疑問可以參考 這里

public static function __callStatic($func, $arguments) {
        if (self::$rw AND stripos(trim($sql), 'SELECT') === 0) {
            self::init(self::$config[self::$currentDb]['slave'], 'slave_' . self::$currentDB);
        } else {
            self::init(self::$config[self::$currentDB]['master'], 'master_' . self::$currentDB);
        }

        return call_user_func_array(array(self::$db, $func), $arguments);
    }

可以看到也物，在這里所有DB不存在的靜態(tài)方法統(tǒng)一給了__callStatic()處理，在這里面初始化數據庫的任務給了DB::init();然后數據庫請求統(tǒng)一丟給了DBmysqli處理列疗。

所以數據庫初始化就該上場了

public static function init($ini, $k) {
        if (!isset(self::$dbPool[$k])){

            $size = count($ini);
            if ($size > 1) {
                $c = $ini[array_rand($ini)];
            } else {
                $c = $ini[0];
            }

            self::$db = new DBmysqli($c['host'], $c['username'], $c['passwd'], $c['dbname'], $c['port'], $c['dbcharset']);
            self::$dbPool[$k] = self::$db;
            //var_dump(self::$dbPool['modou']->fetchAll('select * from user'));

            self::$db->cmd("SET @@character_set_connection=" . $c['dbcharset'] . ",@@character_set_results=" . self::$charset . ",@@character_set_client=" . self::$charset);

        } else {
                
            self::$db = self::$dbPool[$k];
            if (!self::$db->ping()) {
                unset(self::$dbPool[$k]);
                self::init($ini, $k);
            }

        }
    }

可以看到使用單例來維護數據庫連接滑蚯。

有開有合，定義關連接方法

public static function clear () {
        foreach (self::$dbPool as $mysql) {
            $mysql->close();
        }
    }

利用DBmysqli的sqlHistory屬性構造一個日志信息

public static function sqlLog() {
        echo "<!--";
        foreach (self::$dbPool as $mysql) {
            foreach ($mysql->sqlHistory as $k => $v) {
                echo "\n query time : " , $v[1], ": " , $v[0], "\t mysql:" , $v[2], "\n======\n";
            }
        }
        echo '-->';
    }

利用數據庫信息構造一個簡單模型抵栈。

public static function var_export($tabname) {
        if (!is_dir(self::$mDir)) {
            mkdir(self::mDir, '777');
        }
        $res = self::fetchAll('show full fields from '. $tabname);
        $tabs = array("setting" => [], 'pri' => "", "fields" => []);
        foreach ($res as $t ) {
            if ($t->Key == 'PRI') {
                $tabs['pri'] = $t->Field;
            }
            $t->ini = array();
            if (!empty($t->Comment) && stripos($t->Comment, ':') !== false) {
                $tmp = array_map(function ($v) {
                    return explode(':', trim($v));
                }, explode(",", trim($this->Comment, ',')));
                foreach ($tmp as list($k , $v)) {
                    $t->ini[$k] = $v;
                }
            }
            $t->lang = $t->Field;

            if (stripos($t->Type, '(') !== false) {
                list( $t1, $len) = explode('(', trim($t->Type, ')'));
                $t->type = trim($t1);
                $t->max = intval($len);
            }

            if ($t->Null == 'YES' || !empty($t->Default || $t->Extra == 'auto_increment')) {
                $t->min = 0;
            } else {
                $t->min = 1;
            }

            unset($t->Collation, $t->Privileges, $t->Comment);
            $tabs['setting'][$t->Field] = (array)$t;
            $tabs['fields'] = array_keys($tabs['setting']);
        }
        file_put_contents(self::$mDir . "{$tabname}.php", "<?php return " . var_export($tabs, 1) . ";");
    }

構造一個模型生成工具

public static function createModel($tab = "*") {
        if ($tab == "*") {
            foreach (self::fetchAll('SHOW TABLES', FALSE, 0, MYSQL_NUM) as $n => $tab) {
                self::var_export($tab[0]);
            }
        } else {
            self::var_export($tab);
        }
    }

配置與使用

$ini['default'] = 'modou';
$ini['modou']['master'][0] = array(
    'host' => "127.0.0.1",
    'username' => 'root',
    'passwd' => '',
    'dbname' => 'modou',
    'port' => '3306',
    'dbcharset' =>'utf-8',
);

DB::ini($ini, './');
DB::createModel("*");

運行后可以看到在配置的模型文件夾中生成了許多文件告材，與數據庫的表一一對應。

到此竭讳，這個DB就算封閉完成了创葡。