CodeIgnitor 3.0.x 之 db 类实现机制

宇宙之至尊魔皇

• Codeignitor 的 db 类的说明，锻炼一下文字表达能力
  
• 一般的使用场景：
  

1. class home extends Base_Controller
2. {   
3.     public function test()  
4.     {
5.         $this->load->model('my/User_model');
6.     }
7. }
9. class User_model extend CI_Model  
10. {
11.     public function __construct()  
12.     {
13.        $this->db = $this->load->database('my', TRUE);
14.     }
15. }
17. class CI_Model
18. {
19.     public function __get($key)  
20.     {  
21.         return get_instance()->$key;  
22.     }
23. }

复制代码

• 在 controller 中加载 model 类
  
• 在 model 中加载 db，获得 db 对象，可以用来查询 sql
  
  
  
  • model 中的 load 对象是从 controller 中获取的
    
  • db 对象的类型是 CI_DB_mysqli_driver，这是 load 对象根据默认配置创建的 mysql 数据库查询对象
    
  • 默认配置文件在 /config/database.php，按照框架约定配置好数据库参数
    
  
  
• database.php 内容如下：
  

1. $active_group = 'default';  
2. $query_builder = TRUE;
3. $db['default'] = array(
4.     $db['myche'] = array(  
5.          'dsn' => '',  
6.          'hostname' => $_SERVER['DB_MY_HOST'],  
7.          'username' => $_SERVER['DB_MY_USER'],  
8.          'password' => $_SERVER['DB_MY_PASS'],  
9.          'database' => $_SERVER['DB_MY_NAME'],  
10.          'dbdriver' => 'mysqli',  
11.          'dbprefix' => '',  
12.          'pconnect' => FALSE,  
13.          'db_debug' => (ENVIRONMENT !== 'production'),  
14.          'cache_on' => FALSE,  
15.          'cachedir' => '',  
16.          'char_set' => 'utf8',  
17.          'dbcollat' => 'utf8_general_ci',  
18.          'swap_pre' => '',  
19.          'encrypt' => FALSE,  
20.          'compress' => FALSE,  
21.          'stricton' => FALSE,  
22.          'failover' => array(),  
23.          'save_queries' => (ENVIRONMENT !== 'production')  
24.     );
25. );

复制代码

• CI_DB_mysqli_driver 继承自 CI_DB，CI_DB 类使用了一种奇怪的方式实现的，这个类是在一个叫做DB的函数内声明的，根据 $query_builder=true 的配置来决定声明CI_DB的父类是CI_DB_driver还是CI_DB_query_builder，两者的区别就是后者继承自前者并在前者的基础上实现了常用语句的链式调用方法。按照声明处注释所说，CI_DB类可以理解为 CI_DB_driver 和 CI_DB_query_builder 的别名。
  
• CI_DB_mysqli_driver的创建过程：
  
  
  
  • 在 load 对象的 database 方法中调用 DB 函数
    
  • 在 DB 函数中
    
    
    
    • 声明 CI_DB，根据 $query_builder=true 的配置来决定CI_DB的父类是CI_DB_driver还是CI_DB_query_builder。
      
    • 根据 dbdriver 配置加载数据库驱动类文件，并实例化 CI_DB_mysqli_driver，并返回此对象。
      
    
    
  
  
• DB 函数的实现
  

1. function &DB($params = '', $query_builder_override = NULL)  
2. {
3.     require_once(BASEPATH.'database/DB_driver.php');
4.    
5.     if ( ! isset($query_builder) OR $query_builder === TRUE)
6.         {
7.                 require_once(BASEPATH.'database/DB_query_builder.php');
8.                 if ( ! class_exists('CI_DB', FALSE))
9.                 {
10.                         /**
11.                          * CI_DB
12.                          *
13.                          * Acts as an alias for both CI_DB_driver and CI_DB_query_builder.
14.                          *
15.                          * @see        CI_DB_query_builder
16.                          * @see        CI_DB_driver
17.                          */
18.                         class CI_DB extends CI_DB_query_builder { }
19.                 }
20.         }
21.         elseif ( ! class_exists('CI_DB', FALSE))
22.         {
23.                 class CI_DB extends CI_DB_driver { }
24.         }
25.    
26.     // Load the DB driver  
27.     $driver_file = BASEPATH.'database/drivers/'.$params['dbdriver'].'/'.$params['dbdriver'].'_driver.php';
28.     require_once($driver_file);
29.    
30.     // Instantiate the DB adapter
31.         $driver = 'CI_DB_'.$params['dbdriver'].'_driver';
32.         $DB = new $driver($params);
33.    
34.     return $DB;
35. }

复制代码

• CI_DB_mysqli_driver 最终是继承自 CI_DB_driver 这个抽象类。CI_DB_driver 定义了数据库驱动类需要实现的一些通用方法，具体的驱动类比如 CI_DB_mysqli_driver 则实现了这些方法。
  
• CI_DB_driver 关键方法定义
  

1. abstract class CI_DB_driver {
2.     // db 连接
3.     function db_connect() {}
4.         
5.     // db 长连接
6.     function db_pconnect() {}
7.    
8.     // 设置连接字符集编码
9.     function _db_set_charset() {}
10.    
11.     // 选择数据库
12.     function db_select() {}
13.    
14.     // 开始事务
15.     function _trans_begin() {}
16.    
17.     // 回滚事务
18.     function _trans_rollback() {}
19.    
20.     // 提交事务
21.     function _trans_commit() {}
22.    
23.     // 执行查询
24.     function _execute($sql) {}
25. }

复制代码

上面的描述总结为下图：

• CI_DB_mysqli_driver 的部分实现
  

[code]class CI_DB_mysqli_driver extends CI_DB {    // 连接数据库    public function db_connect($persistent = FALSE)      {        // Do we have a socket path?                if ($this->hostname[0] === '/')                {                        $hostname = NULL;                        $port = NULL;                        $socket = $this->hostname;                }                else                {                        // Persistent connection support was added in PHP 5.3.0                        $hostname = ($persistent === TRUE && is_php('5.3'))                                ? 'p:'.$this->hostname : $this->hostname;                        $port = empty($this->port) ? NULL : $this->port;                        $socket = NULL;                }                $client_flags = ($this->compress === TRUE) ? MYSQLI_CLIENT_COMPRESS : 0;                $this->_mysqli = mysqli_init();                $this->_mysqli->options(MYSQLI_OPT_CONNECT_TIMEOUT, 10);                // ... 此处省略一些设置的代码                if ($this->_mysqli->real_connect($hostname, $this->username, $this->password, $this->database, $port, $socket, $client_flags))                {                        // Prior to version 5.7.3, MySQL silently downgrades to an unencrypted connection if SSL setup fails                        if (                                ($client_flags & MYSQLI_CLIENT_SSL)                                && version_compare($this->_mysqli->client_info, '5.7.3', '