一个 MySQL 分库分表php类

当一个表数据记录过大时就会出现性能瓶颈，而一般对应的解决办法是要么做分区表，要么分表，分区表就不说了，分表又分为垂直分割和水平分割，具体区 别请自行搜索。一般而言，分库分表属于水平分割，按照一定的规则将数据插入到不同的表中去。而分库则可以很方便的转移数据库的压力，比如将一个很大库的分 别放在不同的服务器上。

下面是我写的一个分库分表的实现:

    <?php  
    /** 
     * User: guoyu 
     * Date: 14-8-12 
     * Time: 下午3:16 
     */  
       
    namespace App\Model\Database;  
       
    class Config  
    {  
        public $dsn;  
        public $user;  
        public $password;  
        /** 
         * @var string 分库分表后得到的数据库名 
         */  
        public $dbname;  
        /** 
         * @var string 分库分表后得到的表名 
         */  
        public $table;  
       
        /** 
         * @var array MySQL 配置数组 
         */  
        private static $config;  
       
        /** 
         * @var string 配置文件路径 
         */  
        private static $configFile = 'mysql.php';  
       
        public function __construct($dbname, $table, $id = 0)  
        {  
            if (is_null(static::$config)) {  
                $config = include(static::$configFile);  
                static::$config = $config;  
            }  
       
            $config = static::$config;  
            if (isset($config['shared']) && isset($config['shared'][$dbname])) {  
                $dbconfig = $config['shared'][$dbname];  
                $id = is_numeric($id) ? (int)$id : crc32($id);  
                $database_id = ($id / $dbconfig['database_split'][0]) % $dbconfig['database_split'][1];  
                $table_id = ($id / $dbconfig['table_split'][0]) % $dbconfig['table_split'][1];  
       
                foreach ($dbconfig['host'] as $key => $conf) {  
                    list($from, $to) = explode('-', $key);  
                    if ($from <= $database_id && $database_id <= $to) {  
                        $the_config = $conf;  
                    }  
                }  
       
                $this->dbname = $dbname . '_' . $database_id;  
                $this->table = $table . '_' . $table_id;  
            } else {  
                $this->dbname = $dbname;  
                $this->table = $table;  
                $the_config = $config['db'][$dbname];  
            }  
            $c = $the_config;  
            if (isset($c['unix_socket']) && $c['unix_socket']) {  
                $this->dsn = sprintf('mysql:dbname=%s;unix_socket=%s', $this->dbname, $c['unix_socket']);  
            } else {  
                $this->dsn = sprintf('mysql:dbname=%s;host=%s;port=%s', $this->dbname, $c['host'], $c['port']);  
            }  
            $this->user = $c['user'];  
            $this->password = $c['password'];  
        }  
       
    }  


Config 类就做一个事情，根据配置文件，去拿到对应的库和表的链接配置，然后客户可以根据 dsn 去链接对应的数据库。对应的配置文件如下：

[php] view plaincopyprint?在CODE上查看代码片派生到我的代码片

    <?php  
    /** 
     * User: guoyu 
     * Date: 14-8-6 
     * Time: 上午11:19 
     */  
       
    $default = array(  
        'unix_socket' => null,  
        'host' => 'localhost',  
        'port' => '3306',  
        'user' => 'root',  
        'password' => '',  
    );  
       
    $config = array(  
        // 不进行分库分表的数据库  
        'db' => array(  
            'my_site' => $default,  
        ),  
        // 分库分表  
        'shared' => array(  
            'user' => array(  
                'host' => array(  
                    /** 
                     * 编号为 0 到 10 的库使用的链接配置 
                     */  
                    '0-10' => $default,  
                    /** 
                     * 编号为 11 到 28 的库使用的链接配置 
                     */  
                    '11-28' => $default,  
                    /** 
                     * 编号为 29 到 99 的库使用的链接配置 
                     */  
                    '29-99' => $default,  
       
                ),  
       
                // 分库分表规则  
                /** 
                 * 下面的配置对应百库百表 
                 * 如果根据 uid 进行分表，假设 uid 为 543234678，对应的库表为： 
                 *  (543234678 / 1) % 100 = 78 为编号为 78 的库 
                 *  (543234678 / 100) % 100 = 46 为编号为 46 的表 
                 */  
                'database_split' => array(1, 100),  
                'table_split' => array(100, 100),  
            ),  
        ),  
    );  
       
       
    return $config;  


给出一个使用这个分库分表的例子：

[php] view plaincopyprint?在CODE上查看代码片派生到我的代码片

    <?php  
    /** 
     * User: guoyu 
     * Date: 14-8-6 
     * Time: 上午10:23 
     */  
       
    namespace App\Model;  
       
    use App\Model\Database\Config;  
    use \PDO;  
       
    abstract class Model  
    {  
        /** 
         * @var Config 
         */  
        public $config;  
       
        /** 
         * @var PDO 
         */  
        public $connection;  
       
        protected $dbnamePrefix;  
        protected $tablePrefix;  
       
        /** 
         * @var string 分库分表后对应的表 
         */  
        protected $table;  
       
        public function __construct($id)  
        {  
            $this->config = new Config($this->dbnamePrefix, $this->tablePrefix, $id);  
            $this->connection = new Pdo($this->config->dsn, $this->config->user, $this->config->password);  
            $this->table = $this->config->table;  
        }  
       
        public function update(array $data, array $where = array())  
        {  
       
        }  
       
        public function select(array $where)  
        {  
       
        }  
       
        public function insert(array $data)  
        {  
       
        }  
       
        public function query($sql)  
        {  
            return $this->connection->query($sql);  
        }  
    }  

下面这个例子展示了如何使用上述的 Model 类：

    <?php  
    /** 
     * User: guoyu 
     * Date: 14-8-12 
     * Time: 下午4:06 
     */  
       
    require 'Config.php';  
    require 'Model.php';  
       
    use App\Model\Model;  
       
    class User extends Model  
    {  
        protected $dbnamePrefix = 'user';  
        protected $tablePrefix = 'userinfo';  
    }  
       
    $user = new User(4455345345);  
       
    print_r($user);  

来自：http://blog.csdn.net/phpfenghuo/article/details/45342311