5.1.3 配置

<schema name="SHOPPING" checkSQLschema="true" sqlMaxLimit="100">
<table name="tb_goods_base" dataNode="dn1" primaryKey="id" />
<table name="tb_goods_brand" dataNode="dn1" primaryKey="id" />
<table name="tb_goods_cat" dataNode="dn1" primaryKey="id" />
<table name="tb_goods_desc" dataNode="dn1" primaryKey="goods_id" />
<table name="tb_goods_item" dataNode="dn1" primaryKey="id" />
<table name="tb_order_item" dataNode="dn2" primaryKey="id" />
<table name="tb_order_master" dataNode="dn2" primaryKey="order_id" />
<table name="tb_order_pay_log" dataNode="dn2" primaryKey="out_trade_no" />
<table name="tb_user" dataNode="dn3" primaryKey="id" />
<table name="tb_user_address" dataNode="dn3" primaryKey="id" />
<table name="tb_areas_provinces" dataNode="dn3" primaryKey="id"/>
<table name="tb_areas_city" dataNode="dn3" primaryKey="id"/>
<table name="tb_areas_region" dataNode="dn3" primaryKey="id"/>
</schema>
<dataNode name="dn1" dataHost="dhost1" database="shopping" />
<dataNode name="dn2" dataHost="dhost2" database="shopping" />
<dataNode name="dn3" dataHost="dhost3" database="shopping" />
<dataHost name="dhost1" maxCon="1000" minCon="10" balance="0"
writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1"
slaveThreshold="100">
<heartbeat>select user()</heartbeat>
<writeHost host="master" url="jdbc:mysql://192.168.200.210:3306?
useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8"
user="root" password="1234" />
</dataHost>
<dataHost name="dhost2" maxCon="1000" minCon="10" balance="0"
writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1"
slaveThreshold="100">
<heartbeat>select user()</heartbeat>
<writeHost host="master" url="jdbc:mysql://192.168.200.213:3306?
useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8"
user="root" password="1234" />
</dataHost>
<dataHost name="dhost3" maxCon="1000" minCon="10" balance="0"
writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1"
slaveThreshold="100">
<heartbeat>select user()</heartbeat>
<writeHost host="master" url="jdbc:mysql://192.168.200.214:3306?
useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8"
user="root" password="1234" />
</dataHost>

2). server.xml

<user name="root" defaultAccount="true">
<property name="password">123456</property>
<property name="schemas">SHOPPING</property>
<!-- 表級(jí) DML 權(quán)限設(shè)置 -->
<!--
<privileges check="true">
<schema name="DB01" dml="0110" >
<table name="TB_ORDER" dml="1110"></table>
</schema>
</privileges>
-->
</user>
<user name="user">
<property name="password">123456</property>
<property name="schemas">SHOPPING</property>
<property name="readOnly">true</property>
</user>

5.1.4 測(cè)試

1). 上傳測(cè)試 SQL 腳本到服務(wù)器的 /root 目錄

2). 執(zhí)行指令導(dǎo)入測(cè)試數(shù)據(jù)

重新啟動(dòng) MyCat 后，在 mycat 的命令行中，通過 source 指令導(dǎo)入表結(jié)構(gòu)，以及對(duì)應(yīng)的數(shù)據(jù)，查看數(shù)據(jù)分布情況。

source /root/shopping-table.sql
source /root/shopping-insert.sql

將表結(jié)構(gòu)及對(duì)應(yīng)的測(cè)試數(shù)據(jù)導(dǎo)入之后，可以檢查一下各個(gè)數(shù)據(jù)庫(kù)服務(wù)器中的表結(jié)構(gòu)分布情況。 檢查是否和我們準(zhǔn)備工作中規(guī)劃的服務(wù)器一致。

?3). 查詢用戶的收件人及收件人地址信息(包含省、市、區(qū))。

在 MyCat 的命令行中，當(dāng)我們執(zhí)行以下多表聯(lián)查的 SQL 語句時(shí)，可以正常查詢出數(shù)據(jù)。

?

select ua.user_id, ua.contact, p.province, c.city, r.area , ua.address from
tb_user_address ua ,tb_areas_city c , tb_areas_provinces p ,tb_areas_region r
where ua.province_id = p.provinceid and ua.city_id = c.cityid and ua.town_id =
r.areaid ;

?4). 查詢每一筆訂單及訂單的收件地址信息(包含省、市、區(qū))。

實(shí)現(xiàn)該需求對(duì)應(yīng)的 SQL 語句如下：

SELECT order_id , payment ,receiver, province , city , area FROM tb_order_master o
, tb_areas_provinces p , tb_areas_city c , tb_areas_region r WHERE
o.receiver_province = p.provinceid AND o.receiver_city = c.cityid AND
o.receiver_region = r.areaid ;

但是現(xiàn)在存在一個(gè)問題，訂單相關(guān)的表結(jié)構(gòu)是在 192.168.200.213 數(shù)據(jù)庫(kù)服務(wù)器中，而省市區(qū)的數(shù)

據(jù)庫(kù)表是在 192.168.200.214 數(shù)據(jù)庫(kù)服務(wù)器中。那么在 MyCat 中執(zhí)行是否可以成功呢？

經(jīng)過測(cè)試，我們看到， SQL 語句執(zhí)行報(bào)錯(cuò)。原因就是因?yàn)?/span> MyCat 在執(zhí)行該 SQL 語句時(shí)，需要往具體的數(shù)據(jù)庫(kù)服務(wù)器中路由，而當(dāng)前沒有一個(gè)數(shù)據(jù)庫(kù)服務(wù)器完全包含了訂單以及省市區(qū)的表結(jié)構(gòu)，造成 SQL 語句失敗，報(bào)錯(cuò)。

對(duì)于上述的這種現(xiàn)象，我們?nèi)绾蝸斫鉀Q呢？ 下面我們介紹的全局表，就可以輕松解決這個(gè)問題。

5.1.5 全局表

對(duì)于省、市、區(qū) / 縣表 tb_areas_provinces , tb_areas_city , tb_areas_region ，是屬于

數(shù)據(jù)字典表，在多個(gè)業(yè)務(wù)模塊中都可能會(huì)遇到，可以將其設(shè)置為全局表，利于業(yè)務(wù)操作。

修改 schema.xml 中的邏輯表的配置，修改 tb_areas_provinces 、 tb_areas_city 、

tb_areas_region 三個(gè)邏輯表，增加 type 屬性，配置為 global ，就代表該表是全局表，就會(huì)在

所涉及到的 dataNode 中創(chuàng)建給表。對(duì)于當(dāng)前配置來說，也就意味著所有的節(jié)點(diǎn)中都有該表了。

<table name="tb_areas_provinces" dataNode="dn1,dn2,dn3" primaryKey="id"
type="global"/>
<table name="tb_areas_city" dataNode="dn1,dn2,dn3" primaryKey="id"
type="global"/>
<table name="tb_areas_region" dataNode="dn1,dn2,dn3" primaryKey="id"
type="global"/> 

配置完畢后，重新啟動(dòng)MyCat。

1). 刪除原來每一個(gè)數(shù)據(jù)庫(kù)服務(wù)器中的所有表結(jié)構(gòu)

2). 通過 source 指令，導(dǎo)入表及數(shù)據(jù)

source /root/shopping-table.sql
source /root/shopping-insert.sql

3). 檢查每一個(gè)數(shù)據(jù)庫(kù)服務(wù)器中的表及數(shù)據(jù)分布，看到三個(gè)節(jié)點(diǎn)中都有這三張全局表

4). 然后再次執(zhí)行上面的多表聯(lián)查的 SQL 語句

?

SELECT order_id , payment ,receiver, province , city , area FROM tb_order_master o
, tb_areas_provinces p , tb_areas_city c , tb_areas_region r WHERE
o.receiver_province = p.provinceid AND o.receiver_city = c.cityid AND
o.receiver_region = r.areaid ;

??是可以正常執(zhí)行成功的。 ?????????

5). 當(dāng)在 MyCat 中更新全局表的時(shí)候，我們可以看到，所有分片節(jié)點(diǎn)中的數(shù)據(jù)都發(fā)生了變化，每個(gè)節(jié)點(diǎn)的全局表數(shù)據(jù)時(shí)刻保持一致。

??關(guān)注，就是我創(chuàng)作的動(dòng)力

??點(diǎn)贊，就是對(duì)我最大的認(rèn)可

??這里是小劉，勵(lì)志用心做好每一篇文章，謝謝大家文章來源地址http://www.zghlxwxcb.cn/news/detail-526840.html