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