全部產品
Search
文件中心

PolarDB:掃描全部/部分分庫分表

更新時間:Jul 06, 2024

本文介紹了掃描全部/部分分庫分表的HINT文法和樣本。

本文適用於PolarDB-X 1.0 5.3及以上版本。

除了可以將SQL單獨下發到一個或多個分庫執行,PolarDB-X 1.0還提供了掃描全部/部分分庫與分表的SCAN HINT。使用SCAN HINT,您可以一次將SQL下發到每一個分庫執行, 比如查看某個分庫上的所有分表,或者查看某個邏輯表的每張物理表中的資料量等。

通過SCAN HINT,可以指定四種執行SQL的方式:
  1. 在所有分庫的所有分表上執行;
  2. 在指定分庫的所有分表上執行;
  3. 在指定分庫分表上執行,根據條件計算物理表名稱;
  4. 在指定分庫分表上執行,顯式指定物理表名;

SCAN HINT支援 DML、DDL和部分DAL語句。

文法

# SCAN HINT

# 將SQL語句下發到所有分庫的所有分表上執行
SCAN()                               

# 將SQL語句下發到指定分庫的所有分表上執行
SCAN(NODE="node_list")               # 指定分庫

# 將SQL語句下發到指定分庫分表上執行,根據條件計算物理表名稱
SCAN(
  [TABLE=]"table_name_list"          # 邏輯表名
  , CONDITION="condition_string"     # 使用TABLE和CONDITION中的內容計算物理表名稱
  [, NODE="node_list"] )             # 過濾通過CONDITION計算出的結果,僅保留指定物理庫

# 將SQL語句下發到指定分庫分表上執行,顯式指定物理表名
SCAN(
  [TABLE=]"table_name_list"          # 邏輯表名
  , REAL_TABLE=("table_name_list")   # 物理表名,對所有物理庫使用相同的物理表名
  [, NODE="node_list"] )             # 過濾通過CONDITION計算出的結果,僅保留指定物理庫


# 物理/邏輯表名列表
table_name_list: 
    table_name [, table_name]...

# 物理庫列表,支援GROUP_KEY和GROUP的序號, 可以通過`SHOW NODE`語句獲得 
node_list: 
    {group_key | group_index} [, {group_key | group_index}]...
    
# 支援SQL WHERE的文法,需要為每一張表設定條件,如:t1.id = 2 and t2.id = 2
condition_string: 
    where_condition

            

注意事項

  • PolarDB-X 1.0自訂HINT支援/*+TDDL:hint_command*//!+TDDL:hint_command*/兩種格式。
  • 如果使用/*+TDDL:hint_command*/格式,在使用MySQL官方命令列用戶端執行帶有PolarDB-X 1.0自訂HINT的SQL時,請在登入命令中加上-c 參數。否則,由於PolarDB-X 1.0自訂HINT是以 MySQL 注釋形式使用的,該用戶端會將備註陳述式刪除後再發送到服務端執行,導致PolarDB-X 1.0自訂HINT失效。具體請查看MySQL 官方用戶端命令

樣本

  • 在所有分庫的所有分表上執行:
    SELECT /*+TDDL:scan()*/ COUNT(1) FROM t1      

    執行後會下發SQL語句到t1的所有物理表上執行,並將結果集合并後返回。

  • 在指定分庫的所有分表上執行:
    SELECT /*+TDDL:scan(node='0,1,2')*/ COUNT(1) FROM t1          

    執行後會首先計算出t1在0000, 0001, 0002分庫上的所有物理表,然後下發SQL語句並將結果集合并後返回。

  • 按條件在指定分表上執行:
    SELECT /*+TDDL:scan('t1', condition='t1.id = 2')*/ COUNT(1) FROM t1           

    執行後會首先計算出邏輯表t1滿足condition條件的所有物理表,然後下發SQL語句並將結果集合并後返回。

  • 按條件在指定分表上執行,有JOIN的情況:
    SELECT /*+TDDL:scan('t1, t2', condition='t1.id = 2 and t2.id = 2')*/ * FROM t1 a JOIN t2 b ON a.id = b.id WHERE b.name = "test"
                

    執行後會首先計算出邏輯表t1t2滿足 condition 條件的所有物理表,然後下發 SQL 陳述式並將結果集合并後返回。 注意:使用該自訂注釋需要保證兩張表的分庫和分表數量一致,否則PolarDB-X 1.0計算出的兩個索引值對應的分庫不一致,就會報錯。

  • 在指定分庫分表上執行,顯式指定物理表名:
    SELECT /*+TDDL:scan('t1', real_table=("t1_00", "t1_01"))*/ COUNT(1) FROM t1
                

    執行後會下發SQL語句到所有分庫的t1_00``t1_01分表上,合并結果集後返回。

  • 在指定分庫分表上執行,顯式指定物理表名, 有JOIN的情況:
    SELECT /*+TDDL:scan('t1, t2', real_table=("t1_00,t2_00", "t1_01,t2_01"))*/ * FROM t1 a JOIN t2 b ON a.id = b.id WHERE b.name = "test";
                

    執行後會下發SQL語句到所有分庫的t1_00t2_00t1_01t2_01分表上,合并結果集後返回。