数据库(Db) - TP5源代码阅读

public static function connect($config = [], $name = false)
    {
 if (false === $name) {
     $name = md5(serialize($config));
 }
 if (true === $name || !isset(self::$instance[$name])) {
     // 解析连接参数 支持数组和字符串
     $options = self::parseConfig($config);
     if (empty($options['type'])) {
  throw new InvalidArgumentException('Underfined db type');
     }
     $class = false !== strpos($options['type'], '\') ? $options['type'] : '\think\db\connector\' . ucwords($options['type']);
     // 记录初始化信息
     if (App::$debug) {
  Log::record('[ DB ] INIT ' . $options['type'], 'info');
     }
     if (true === $name) {
  return new $class($options);
     } else {
  self::$instance[$name] = new $class($options);
     }
 }
 return self::$instance[$name];
    }

## Db::parseConfig()
>> 数据库数组配置解析
> 获取配置中的数据库配置字段


private static function parseConfig($config)
    {
 if (empty($config)) {
     $config = Config::get('database');
 } elseif (is_string($config) && false === strpos($config, '/')) {
     // 支持读取配置参数
     $config = Config::get($config);
 }
 if (is_string($config)) {
     return self::parseDsn($config);
 } else {
     return $config;
 }
    }


## Db::parseDsn()
>> 数据库字符串配置解析

>解析DSN格式数据库配置


private static function parseDsn($dsnStr)
    {
 $info = parse_url($dsnStr);
 if (!$info) {
     return [];
 }
 $dsn = [
     'type'     => $info['scheme'],
     'username' => isset($info['user']) ? $info['user'] : '',
     'password' => isset($info['pass']) ? $info['pass'] : '',
     'hostname' => isset($info['host']) ? $info['host'] : '',
     'hostport' => isset($info['port']) ? $info['port'] : '',
     'database' => !empty($info['path']) ? ltrim($info['path'], '/') : '',
     'charset'  => isset($info['fragment']) ? $info['fragment'] : 'utf8',
 ];

 if (isset($info['query'])) {
     parse_str($info['query'], $dsn['params']);
 } else {
     $dsn['params'] = [];
 }
 return $dsn;
    }


# 2 数据库接口

## Db::__callStatic()
>>对于不存在Db类的静态方法的调用则调用连接对象的方法
>连接对象的相关操作见 [数据库连接](http://www.kancloud.cn/zmwtp/tp/212778) 章节

public static function __callStatic($method, $params)
    {
 // 自动初始化数据库
 return call_user_func_array([self::connect(), $method], $params);
    }