php 基于DBmysqli操作工具

作者: hopevow | 来源:发表于2016-11-07 11:38 被阅读48次

    在一个记录中,对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就算封闭完成了。

    相关文章

      网友评论

      本文标题:php 基于DBmysqli操作工具

      本文链接:https://www.haomeiwen.com/subject/lqqwuttx.html