【正文】 分庫 11 分庫 12 分庫 13 分庫 14 分庫 15 分庫 16 product值 Hash取模 user值 Hash取模 0 1 2 3 0 1 2 3 visit表 USER PRODUCT ? 一張表的多個(gè)字段 同時(shí) 作為拆分字段 Hash(“A”)%4 = 分庫 1 分庫 2 分庫 3 分庫 4 分庫 5 分庫 6 分庫 7 分庫 8 分庫 9 分庫 10 分庫 11 分庫 12 分庫 13 分庫 14 分庫 15 分庫 16 product值 Hash取模 user值 Hash取模 0 1 2 3 0 1 2 3 CocaCola A SELECT * FROM visit WHERE product=?ColaCola? AND user=?A? 分庫 1 分庫 2 分庫 3 分庫 4 分庫 5 分庫 6 分庫 7 分庫 8 分庫 9 分庫 10 分庫 11 分庫 12 分庫 13 分庫 14 分庫 15 分庫 16 product值 Hash取模 user值 Hash取模 0 1 2 3 0 1 2 3 CocaCola SELECT * FROM visit WHERE product=?ColaCola? Hash(“A”)%4 = A 分庫 1 分庫 2 分庫 3 分庫 4 分庫 5 分庫 6 分庫 7 分庫 8 分庫 9 分庫 10 分庫 11 分庫 12 分庫 13 分庫 14 分庫 15 分庫 16 product值 Hash取模 user值 Hash取模 0 1 2 3 0 1 2 3 SELECT * FROM visit WHERE product=?ColaCola? AND user=?A? Cobar的策略 ? MySQL集群替代 Oracle單點(diǎn) ? 基亍表的水平拆分和分布 – 根據(jù)字段值的一致性 Hash分布 – 多維拆分 ? 數(shù)據(jù)查詢方式 – 根據(jù) where中的拆分字段分發(fā) ? SQL語句其他元素的處理 – 將 Cobar收到的 SQL語句做變換 分發(fā)到各個(gè)分庫執(zhí)行 – 對執(zhí)行結(jié)果合并、處理 保證返回前端的內(nèi)容滿足語義 JOIN有限的處理 ? 跨庫 JOIN問題 SELECT * FROM tb1 INNER JOIN tb2 ON = ID MEMBE_ID 2 zzzz 4 xyzxyz ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID 1 efghijk 3 xxxxxx 5 abcd ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 ID MEMBER_ID ID NAME 1 efghijk 4 efghijk 5 abcd 6 abcd 2 zzzz 2 zzzz 4 xyzxyz 3 xyzxyz 迭代查詢 SELECT * FROM tb1 INNER JOIN tb2 ON = ID MEMBE_ID 2 zzzz 4 xyzxyz ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID 1 efghijk 3 xxxxxx 5 abcd ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 FOR row1 IN select * FROM tb1{ ADD( SELECT * FROM tb2 WHERE = )TO RESULT } 跨庫索引 ID MEMBE_ID 2 zzzz 4 xyzxyz ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID 1 efghijk 3 xxxxxx 5 abcd ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 ID1 ID2 JOIN_COL 2 2 zzzz 4 3 xyzxyz idx ID1 ID2 JOIN_COL 1 4 efghijk 5 6 abcd idx 掃描 idx，再根據(jù)每一行的 id1,id2查到最終結(jié)果 跨庫索引 ID MEMBE_ID 2 zzzz 4 xyzxyz ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID 1 efghijk 3 xxxxxx 5 abcd ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 SELECT * FROM tb1 INNER JOIN tb2 ON = WHERE = 5 SELECT * FROM idx WHERE id1 = 5 再根據(jù) id1,id2查到最終結(jié)果 跨庫索引 ID MEMBE_ID 2 zzzz 4 xyzxyz ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID 1 efghijk 3 xxxxxx 5 abcd ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 ID1 ID2 JOIN_COL 2 2 zzzz 4 3 xyzxyz idx ID1 ID2 JOIN_COL 1 4 efghijk 5 6 abcd idx 一定以 JOIN_COL 為索引的拆分字段嗎？ 跨庫索引 SELECT * FROM tb1 INNER JOIN tb2 ON = WHERE 600 ID MEMBE_ID GMT 2 zzzz 525 4 xyzxyz 1010 ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID GMT 1 efghijk 1205 3 xxxxxx 131 5 abcd 604 ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 跨庫索引 ID MEMBE_ID GMT 2 zzzz 525 4 xyzxyz 1010 ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID GMT 1 efghijk 1205 3 xxxxxx 131 5 abcd 604 ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 ID1 ID2 JOIN_COL 2 2 zzzz 4 3 xyzxyz idx ID1 ID2 JOIN_COL 1 4 efghijk 5 6 abcd idx ID MEMBE_ID 2 zzzz 4 xyzxyz ID NAME 4 efghijk 5 aaaa 6 abcd ID MEMBE_ID 1 efghijk 3 xxxxxx 5 abcd ID NAME 2 zzzz 3 xyzxyz tb1 tb1 tb2 tb2 ID1 ID2 JOIN_COL 2 2 zzzz 4 3 xyzxyz idx ID1 ID2 JOIN_COL 1 4 efghijk 5 6 abcd idx SELECT , tb1.* FROM idx INNER JOIN tb1 ON = WHERE 600 SELECT , tb1.* FROM idx INNER JOIN tb1 ON = WHERE 600 SELECT * FROM tb1 INNER JOIN tb2 ON = WHERE 600 跨庫索引 跨庫索引 ID MEMBE_ID GMT 2 zzzz 525 4 xyzxyz 1010 ID NAME TIME 4 efghijk 123 5 aaaa 922 6 abcd 222 ID MEMBE_ID GMT 1 efghijk 1205 3 xxxxxx 131 5 abcd 604 ID NAME TIME 2 zzzz 1201 3 xyzxyz 1111 tb1 tb1 tb2 tb2 SELECT * FROM tb1 INNER JOIN tb2 ON = WHERE 600 AND 600 ID1 ID2 JOIN_COL TIME 2 2 zzzz 1201 4 3 xyzxyz 1111 idx 跨庫索引 ID1 ID2 JOIN_COL TIME 2 2 zzzz 1201 4 3 xyzxyz 1111 idx ID1 ID2 JOIN_COL TIME 1 4 efghijk 123 5 6 abcd 222 idx ? 索引表的拆分 – WHERE條件中的字段所在表的拆分字段，作為索引拆分字段 ? 索引包含 – 兩張表的主鍵 – JOIN字段 – WHERE中的其他字段 ? 索引的更新 – 分布式事務(wù)的支持 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 select ... order by c1 limit 0, 6 select ... order by c1 limit 0, 6 select ... order by c1 limit 0, 6 分庫 1 分庫 2 分庫 3 cobar Order By/Limit 分庫 1 分庫 2 分庫 3 Order By/Limit 4 5 6 3 2 7 8 10 6 5 1 11 13 14 9 7 3 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 分庫 1 分庫 2 分庫 3 Order By/Limit 4 5 6 3 2 7 8 10 6 5 1 11 13 14 9 7 3 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 0 最終結(jié)果集 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 分庫 1 分庫 2 分庫 3 Order By/Limit 4 5 6 3 2 7 8 10 6 5 11 13 14 9 7 3 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 1 最終結(jié)果集 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 分庫 1 分庫 2 分庫 3 Order By/Limit 4 5 6 3 7 8 10 6 5 11 13 14 9 7 3 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 2 最終結(jié)果集 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 分庫 1 分庫 2 分庫 3 Order By/Limit 4 5 6 7 8 10 6 5 11 13 14 9 7 3 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 3 最終結(jié)果集 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 分庫 1 分庫 2 分庫 3 Order By/Limit 4 5 6 7 8 10 6 5 11 13 14 9 7 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 4 最終結(jié)果集 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 最終結(jié)果集 分庫 1 分庫 2 分庫 3 Order By/Limit 5 6 7 8 10 6 5 11 13 14 9 7 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 4 4 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 最終結(jié)果集 分庫 1 分庫 2 分庫 3 Order By/Limit 4 6 7 8 10 6 5 11 13 14 9 7 返回結(jié)果 返回結(jié)果 返回結(jié)果 8 4 5 SELECT c1 FROM tb1 ORDER BY c1 LIMIT 4, 2 Order By/Limit 方案總結(jié) select