Analysis of database reading and writing separation code under thinkphp-ThinkPHP-php.cn

Analysis of database reading and writing separation code under thinkphp

藏色散人

Release： 2020-08-20 13:28:57

forward

3077 people have browsed it

The following is the thinkphp framework tutorial column to introduce to you the analysis of the database reading and writing separation code under thinkphp. I hope it will be helpful to friends in need!

Analysis of database reading and writing separation code under thinkphp

#When using the original SQL statement for write operations, execute is used, and query is used for read operations.

MySQL data master-slave synchronization still depends on the MySQL mechanism. Therefore, at this time, the delay problem of MySQL master-slave synchronization needs to be optimized, and the delay time is too long. It not only affects the business, but also affects the user experience.

In the thinkphp core class Thinkphp/library/Model.class.php, the query method,

calls Thinkphp/library/Think/Db/Driver/Mysql.class. php

  /**
     * SQL查询
     * @access public
     * @param string $sql  SQL
     * @param mixed $parse  是否需要解析SQL  
     * @return mixed
     */
    public function query($sql,$parse=false) {
        if(!is_bool($parse) && !is_array($parse)) {
            $parse = func_get_args();
            array_shift($parse);
        }
        $sql  =   $this->parseSql($sql,$parse);
        return $this->db->query($sql);
    }

Copy after login

Call Thinkphp/library/Think/Db/Driver/Mysql.class.php

  /**
     * 执行查询 返回数据集
     * @access public
     * @param string $str  sql指令
     * @return mixed
     */
    public function query($str) {
        if(0===stripos($str, &#39;call&#39;)){ // 存储过程查询支持
            $this->close();
            $this->connected    =   false;
        }
        $this->initConnect(false);
        if ( !$this->_linkID ) return false;
        $this->queryStr = $str;
        //释放前次的查询结果
        if ( $this->queryID ) {    $this->free();    }
        N(&#39;db_query&#39;,1);
        // 记录开始执行时间
        G(&#39;queryStartTime&#39;);
        $this->queryID = mysql_query($str, $this->_linkID);
        $this->debug();
        if ( false === $this->queryID ) {
            $this->error();
            return false;
        } else {
            $this->numRows = mysql_num_rows($this->queryID);
            return $this->getAll();
        }
    }

Copy after login

When initializing the database link above, initConnect(false), call Thinkphp/library/Think/Db /Db.class.php, pay attention to the false and true code implementation. true means calling the main library directly, false means calling the reading library with separate reading and writing.

  /**
     * 初始化数据库连接
     * @access protected
     * @param boolean $master 主服务器
     * @return void
     */
    protected function initConnect($master=true) {
        if(1 == C(&#39;DB_DEPLOY_TYPE&#39;))
            // 采用分布式数据库
            $this->_linkID = $this->multiConnect($master);
        else
            // 默认单数据库
            if ( !$this->connected ) $this->_linkID = $this->connect();
    }
    /**
     * 连接分布式服务器
     * @access protected
     * @param boolean $master 主服务器
     * @return void
     */
    protected function multiConnect($master=false) {
        foreach ($this->config as $key=>$val){
            $_config[$key]      =   explode(&#39;,&#39;,$val);
        }        
        // 数据库读写是否分离
        if(C(&#39;DB_RW_SEPARATE&#39;)){
            // 主从式采用读写分离
            if($master)
                // 主服务器写入
                $r  =   floor(mt_rand(0,C(&#39;DB_MASTER_NUM&#39;)-1));
            else{
                if(is_numeric(C(&#39;DB_SLAVE_NO&#39;))) {// 指定服务器读
                    $r = C(&#39;DB_SLAVE_NO&#39;);
                }else{
                    // 读操作连接从服务器
                    $r = floor(mt_rand(C(&#39;DB_MASTER_NUM&#39;),count($_config[&#39;hostname&#39;])-1));   // 每次随机连接的数据库
                }
            }
        }else{
            // 读写操作不区分服务器
            $r = floor(mt_rand(0,count($_config[&#39;hostname&#39;])-1));   // 每次随机连接的数据库
        }
        $db_config = array(
            &#39;username&#39;  =>  isset($_config[&#39;username&#39;][$r])?$_config[&#39;username&#39;][$r]:$_config[&#39;username&#39;][0],
            &#39;password&#39;  =>  isset($_config[&#39;password&#39;][$r])?$_config[&#39;password&#39;][$r]:$_config[&#39;password&#39;][0],
            &#39;hostname&#39;  =>  isset($_config[&#39;hostname&#39;][$r])?$_config[&#39;hostname&#39;][$r]:$_config[&#39;hostname&#39;][0],
            &#39;hostport&#39;  =>  isset($_config[&#39;hostport&#39;][$r])?$_config[&#39;hostport&#39;][$r]:$_config[&#39;hostport&#39;][0],
            &#39;database&#39;  =>  isset($_config[&#39;database&#39;][$r])?$_config[&#39;database&#39;][$r]:$_config[&#39;database&#39;][0],
            &#39;dsn&#39;       =>  isset($_config[&#39;dsn&#39;][$r])?$_config[&#39;dsn&#39;][$r]:$_config[&#39;dsn&#39;][0],
            &#39;params&#39;    =>  isset($_config[&#39;params&#39;][$r])?$_config[&#39;params&#39;][$r]:$_config[&#39;params&#39;][0],
            &#39;charset&#39;   =>  isset($_config[&#39;charset&#39;][$r])?$_config[&#39;charset&#39;][$r]:$_config[&#39;charset&#39;][0],            
        );
        return $this->connect($db_config,$r);
    }

Copy after login

The query method parameter is false, and others delete, update, and add the main reading library. This can be combined with the delete, save, and add operations in Thinkphp/library/Model.class.php, and the parameter is true.

The above is the detailed content of Analysis of database reading and writing separation code under thinkphp. For more information, please follow other related articles on the PHP Chinese website!