<ruby id="bdb3f"></ruby>

    <p id="bdb3f"><cite id="bdb3f"></cite></p>

      <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
        <p id="bdb3f"><cite id="bdb3f"></cite></p>

          <pre id="bdb3f"></pre>
          <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

          <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
          <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

          <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                <ruby id="bdb3f"></ruby>

                ??碼云GVP開源項目 12k star Uniapp+ElementUI 功能強大 支持多語言、二開方便! 廣告
                **當單表達到幾千萬時,查詢一次要很久,如果有聯合查詢,有可能會死在那 分庫分表主要就是解決這個問題,減小數據庫的負擔,縮短查詢時間** ### 分庫: 1、按功能分 用戶類庫、商品類庫、訂單類庫、日志類、統計類庫… 2、按地區分 每個城市或省市一個同樣的庫,加上后綴或前綴如:db_click_bj、db_click_sh… ### 分表: 1、橫向分表 解決表記錄太大問題 1.按某個字段分, 如:discuz的附件表分成10個附件分表pre_forum_attachment_0到pre_forum_attachment_9,還有1個附件索引表pre_forum_attachment存儲tid和附件id關系 根據主題的tid最后一位來決定附件要保存在哪個分表, 2.按日期分表 一些日志、統計類的可以按年、月、日、周分表 如:點擊量統計click_201601、click_201602 3.使用mysql的merge 先把分表創建好,然后創建總表指定engine= MERGE UNION=(table1,table2) INSERT_METHOD = LAST; 2、縱向分表 解決列過多問題 1.經常組合查詢的列放在一個表,常用字段的表可考慮Memory引擎 2.不經常使用的字段單獨成表 3.把text、blob等大字段拆分放在附表 如:phpcms的文章表分成主表v9_news和從表v9_news_data,主表存標題、關鍵字、瀏覽量等,從表存具體內容、模板等 ### 很多主流mvc框架都提供了切換數據庫訪問方法 thinkphp切換數據庫 ``` $this->db(1,"mysql://root:123456@localhost:3306/test")->query("查詢sql");//數據庫連接信息可放在配置文件 $this->db(1)->query("查詢sql");//下次直接使用編號1定位 ``` 分表的話 在查詢前先根據分表規則把表名查出 演示 這里用兩臺機子簡單以同個業務庫分庫,同個表分表,演示插入、查詢如何定位庫和表并最終成功執行 兩臺機子: server1:192.168.1.198 server2:192.168.1.199 兩臺機子都執行下面操作 1、先創建10個數據庫,每個數據庫10個表 當然也可以改成百庫百表,也可手動創建,我為了方便寫了個腳本批量創建 ``` create.php <?php ini_set('memory_limit', '-1'); $con=mysql_connect("192.168.1.198","open","123456"); if($con){ for($i=0;$i<10;$i++){//10個庫 $sql="drop database cloude_{$i};";//刪庫 謹慎 mysql_query($sql); $sql="create database cloude_{$i} default character set utf8 collate utf8_general_ci;"; $do=mysql_query($sql,$con)or die(mysql_error()); if($do){ mysql_select_db("cloude_{$i}",$con); mysql_query("set name gtf8"); for($j=0;$j<10;$j++){ //10個表 $sql="drop table if exists user_{$j};"; mysql_query($sql); $sql="create table user_{$j} ( id char(36) not null primary key, name char(15) not null default '', password char(32) not null default '', sex char(1) not null default '男' )engine=InnoDB;"; $do=mysql_query($sql,$con) or die(mysql_error()); if($do){ //echo "create table user_{$j} successful! <br/>"; }else{ //echo "create error!"; } } } } }else{ echo "connect error!!!!"; } ``` 2、分庫分表路由實現 Config.php ``` <?php class Config{ public $dsn; public $user; public $password; public $dbname; //分庫分表后得到的數據庫名 public $table; //分庫分表后得到的表名 private static $config;//mysql配置數組 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']; } } ``` 3、數據庫配置文件 mysql.php ``` <?php $default = array( 'unix_socket' => null, 'host' => '192.168.1.198', 'port' => '3306', 'user' => 'open', 'password' => '123456', ); $db_199 = array( 'unix_socket' => null, 'host' => '192.168.1.199', 'port' => '3306', 'user' => 'open', 'password' => '123456', ); $config = array( // 不進行分庫分表的數據庫 'db' => array( 'hadoop' => $default, ), // 分庫分表 'shared' => array( 'cloude' => array( 'host' => array( /** * 編號為 0 到 4 的庫使用的鏈接配置 */ '0-4' => $default, /** * 編號為 5 到 9 的庫使用的鏈接配置 */ '5-9' => $db_199, ), // 分庫分表規則 /** * 下面的配置對應10庫10表 * 如果根據 uid 進行分表,假設 uid 為 224,對應的庫表為: * (224 / 1) % 10 = 4 為編號為 4 的庫 * (224 / 10) % 10 = 1 為編號為 2 的表 */ 'database_split' => array(1, 10), 'table_split' => array(10, 10), ), ), ); return $config; ``` 4、模型類操作數據庫 Model.php ``` <?php require_once 'Config.php';//引入配置信息 class Model{ public $config; //數據庫配置 public $connection; //pdo protected $dbnamePrefix; //庫前綴如cloude_50 前綴為cloude protected $tablePrefix; //表前綴 protected $dbname; //分庫分表后對應的庫 protected $table; //分庫分表后對應的庫表 public function __construct($id){ $this->config = new Config($this->dbnamePrefix, $this->tablePrefix, $id); //根據id找到對應庫和表 $this->connection = new Pdo($this->config->dsn, $this->config->user, $this->config->password);//實例化pdo $this->connection->exec("set names utf8"); $this->dbname = $this->config->dbname; $this->table = $this->config->table; } public function update(array $data, array $where = array()){ } public function select(array $condition){ $sqlwhere=''; if(!empty($condition)){ foreach ($condition as $field => $value) { $where[] = '`'.$field.'`='."'".addslashes($value)."'"; } $sqlwhere .= ' '.implode(' and ', $where); } $sql="select * from ".$this->dbname.'.'.$this->table; if($sqlwhere){ $sql.=" where $sqlwhere"; } $res=$this->connection->query($sql); $data['data']=$res->fetchAll(PDO::FETCH_ASSOC); $data['info']=array("dsn"=>$this->config->dsn,"dbname"=>$this->dbname,"table"=>$this->table,"sql"=>$sql); return $data; } public function insert(array $arrData) { $name = $values = ''; $flag = $flagV = 1; $true = is_array( current($arrData) );//判斷是否一次插入多條數據 if($true) { //構建插入多條數據的sql語句 foreach($arrData as $arr) { $values .= $flag ? '(' : ',('; foreach($arr as $key => $value) { if($flagV) { if($flag) $name .= "$key"; $values .= "'$value'"; $flagV = 0; } else { if($flag) $name .= ",$key"; $values .= ",'$value'"; } } $values .= ') '; $flag = 0; $flagV = 1; } } else { //構建插入單條數據的sql語句 foreach($arrData as $key => $value) { if($flagV) { $name = "$key"; $values = "('$value'"; $flagV = 0; } else { $name .= ",$key"; $values .= ",'$value'"; } } $values .= ") "; } $sql = "insert into ".$this->dbname.'.'.$this->table." ($name) values $values"; if( ($rs = $this->connection->exec($sql) ) > 0 ) { return array("dsn"=>$this->config->dsn,"dbname"=>$this->dbname,"table"=>$this->table,"sql"=>$sql); } return false; } public function query($sql){ return $this->connection->query($sql); } } ``` 5、測試 使用主鍵id作為分表字段,那最好就不要使用自增了,可使用uuid User.php ``` <?php require 'Config.php'; require 'Model.php'; class User extends Model { protected $dbnamePrefix = 'cloude'; protected $tablePrefix = 'user'; } //生成唯一uuid function create_uuid($prefix = ""){ //可以指定前綴 $str = md5(uniqid(mt_rand(), true)); $uuid = substr($str,0,8) . '-'; $uuid .= substr($str,8,4) . '-'; $uuid .= substr($str,12,4) . '-'; $uuid .= substr($str,16,4) . '-'; $uuid .= substr($str,20,12); return $prefix . $uuid; } $userId=create_uuid(); $user = new User($userId); $data=array('id'=>$userId,'name'=>'大明'.$userId,'password'=>'14e1b600b1fd579f47433b88e8d85291','sex'=>'男'); if($result=$user->insert($data)){ echo '插入成功:','<pre/>'; print_r($result); } $condition=array("id"=>$userId); $list=$user->select($condition); if($list){ echo '查詢成功:','<pre/>'; print_r($list); } ``` 6、結果 插入成功會返回插入到哪個庫哪個表,查詢成功返回從哪個庫哪個表查的 ** 分庫分表注意事項: ** 1、維度問題 假如用戶購買了商品,需 要將交易記錄保存取來,如果按照用戶的緯度分表,則每個用戶的交易記錄都保存在同一表中,所以很快很方便的查找到某用戶的購買情況,但是某商品被購買的情 況則很有可能分布在多張表中,查找起來比較麻煩。反之,按照商品維度分表,可以很方便的查找到此商品的購買情況,但要查找到買人的交易記錄比較麻煩。 所以常見的解決方式有: 通過掃表的方式解決,此方法基本不可能,效率太低了。 記錄兩份數據,一份按照用戶緯度分表,一份按照商品維度分表。 通過搜索引擎解決,但如果實時性要求很高,又得關系到實時搜索 2、避免分表join操作 因為關聯的表有可能不在同一數據庫中 3、避免跨庫事務 避免在一個事務中修改db0中的表的時候同時修改db1中的表,一個是操作起來更復雜,效率也會有一定影響 4、分表宜多不宜少;這樣做主要是為了盡量避免后期可能遇到的二次拆分 5、盡量把同一組數據放到同一DB服務器上 例如將賣家a的商品和交易信息都放到db0中,當db1掛了的時候,賣家a相關的東西可以正常使用。也就是說避免數據庫中的數據依賴另一數據庫中的數據 ———————————————— 原文鏈接:https://blog.csdn.net/weixin_38642740/java/article/details/81448762
                  <ruby id="bdb3f"></ruby>

                  <p id="bdb3f"><cite id="bdb3f"></cite></p>

                    <p id="bdb3f"><cite id="bdb3f"><th id="bdb3f"></th></cite></p><p id="bdb3f"></p>
                      <p id="bdb3f"><cite id="bdb3f"></cite></p>

                        <pre id="bdb3f"></pre>
                        <pre id="bdb3f"><del id="bdb3f"><thead id="bdb3f"></thead></del></pre>

                        <ruby id="bdb3f"><mark id="bdb3f"></mark></ruby><ruby id="bdb3f"></ruby>
                        <pre id="bdb3f"><pre id="bdb3f"><mark id="bdb3f"></mark></pre></pre><output id="bdb3f"></output><p id="bdb3f"></p><p id="bdb3f"></p>

                        <pre id="bdb3f"><del id="bdb3f"><progress id="bdb3f"></progress></del></pre>

                              <ruby id="bdb3f"></ruby>

                              哎呀哎呀视频在线观看