php 基于DBmysqli操作工具

在一个记录中，对mysqli进行了一定程度上的封装，接下来，我们基于它来搞个工具类 传送门

• 我们将前小节中的类写入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;
}

这里有一个技巧，只有当我们执行了语句的查询时才需要去和数据库通讯，而我们的数据库查询都给了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不存在的静态方法统一给了__callStatic()处理，在这里面初始化数据库的任务给了DB::init();然后数据库请求统一丢给了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就算封闭完成了。