MyCat02--MyCat入門無ZK實踐
阿新 • • 發佈：2020-10-28
本文為初次使用mycat的過程，屬於無知狀態，現記錄在此，各種錯誤與問題，請各位幫忙提出幫忙改進，謝謝。
1.需求分析
假定場景：
一個學校，有很多班級，每個班級有很多學生，根據班級的年級，每年制定不同的教學計劃，每個班級的不同課程有不同的老師教學，現在需要一個系統來管理教學計劃和學生考核成績。
分析需求：
整理表：
可以整理出以下幾個表（括號中為主要欄位）：
班次（id、年度、班次），實體如2011級1班
班級（id、班次id、級別），實體如2011級1班1年級
年級課程（id、年度、年級、課程），如2011級1年級課程1
老師（id、名稱）
學生（id、名稱）
學生資訊（id、家庭等資訊欄位等等）
成績（id、學生id、年級課程id、分數）
老師課程關係表（id、老師id、班級id、年級課程id）
分析資料量：
成績>>學生=學生資訊>>老師課程關係>班級、課程、老師、班次
分析表關係：
學生資訊和學生可以認為一個表的拆分，可以配置ER表
班次與班級、學生有直接關係，與老師課程關係、成績有間接關係，與年級課程、老師無關係，而後兩者又是小量的表。
故：
可以將年級課程、老師設定為全域性表，其他的設定為普通表並統計新增冗餘欄位班次id（若沒有此欄位），其他表按照班次id進行水平切分。
整理後sql如下：
-- 全域性表 -- 年級課程（id、年度、年級、課程），如2011級1年級課程1 DROP TABLE IF EXISTS `caurse`; CREATE TABLE `caurse` ( `id` varchar(255) NOT NULL, `full_name` varchar(255) DEFAULT NULL COMMENT '全名，如2011級1年級英語', `year` int(255) DEFAULT NULL COMMENT '年度，如2011年1年級英語中2011', `grade` int(255) DEFAULT NULL COMMENT '年級，如2011年1年級英語中1年級', `name` varchar(255) DEFAULT NULL COMMENT '課程名，如2011年1年級英語中英語', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; -- 老師（id、名稱） DROP TABLE IF EXISTS `teacher`; CREATE TABLE `teacher` ( `id` varchar(255) NOT NULL, `name` varchar(255) DEFAULT NULL, `age` int(11) DEFAULT NULL, `home` varchar(255) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; -- 普通表 -- 班次（id、年度、班次），實體如2011級1班 DROP TABLE IF EXISTS `period_class`; CREATE TABLE `period_class` ( `id` varchar(255) NOT NULL, `year` int(11) DEFAULT NULL COMMENT '年度，如2011級1班中2011', `classes` int(255) DEFAULT NULL COMMENT '班次，如2011級1班中2班', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `grade_class`; -- 班級（id、班次id、級別），實體如2011級1班1年級 CREATE TABLE `grade_class` ( `id` varchar(255) NOT NULL, `period_class_id` varchar(255) DEFAULT NULL, `full_name` varchar(255) DEFAULT NULL COMMENT '完整班級名，如2011級1年級2班', `grade` int(255) DEFAULT NULL COMMENT '班次，如2011級1年級2班中1年級', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `score`; --成績（id、學生id、年級課程id、分數） CREATE TABLE `score` ( `id` varchar(255) NOT NULL, `period_class_id` varchar(255) NOT NULL, `student_id` varchar(255) NOT NULL, `course_id` varchar(255) NOT NULL DEFAULT '', `score` int(11) DEFAULT '0', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `teacher_course_rel`; -- 老師課程關係表（id、老師id、班級id、年級課程id） CREATE TABLE `teacher_course_rel` ( `id` varchar(255) NOT NULL, `period_class_id` varchar(255) NOT NULL, `grade_class_id` varchar(255) NOT NULL, `course_id` varchar(255) NOT NULL, `teacher_id` varchar(255) NOT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; --er表+水平分片 -- 學生（id、名稱） DROP TABLE IF EXISTS `student`; CREATE TABLE `student` ( `id` varchar(255) NOT NULL, `period_class_id` varchar(255) DEFAULT NULL, `name` varchar(255) DEFAULT NULL, `age` int(11) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8; DROP TABLE IF EXISTS `student_msg`; -- 學生資訊（id、家庭等資訊欄位等等） CREATE TABLE `student_msg` ( `id` varchar(255) NOT NULL, `student_id` varchar(255) NOT NULL, `age` int(11) DEFAULT NULL, `phone` varchar(255) DEFAULT NULL, `mother` varchar(255) DEFAULT NULL, `mother_phone` varchar(255) DEFAULT NULL, `father` varchar(255) DEFAULT NULL, `father_phone` varchar(255) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
2.安裝Mycat
擬定3.27上按照Mycat，3.27和3.207為兩個資料伺服器。
2.1安裝軟體
1）下載安裝包
當前下載的版本是1.6.7.5
下載連結：https://github.com/MyCATApache/Mycat-Server/releases
2）下載後上傳解壓
3）在解壓目錄建立logs資料夾
2.2配置
1）配置server.xml
這個檔案主要是修改了下user配置資訊
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
<system>
<!-- 0為需要密碼登陸、1為不需要密碼登陸 ,預設為0，設定為1則需要指定預設賬戶-->
<property name="nonePasswordLogin">0</property>
<!-- MyCat對外提供服務的埠,預設8066-->
<property name="serverPort">8066</property>
<!-- 對MyCat進行管理的埠，預設9066-->
<property name="managerPort">9066</property>
<!-- 外部應用於mycat最大無操作連線時間，，單位毫秒，如果外部app和mycat連線後超過idleTimeout毫秒沒有進行操作，連線將斷開-->
<property name="idleTimeout">300000</property>
<!-- 在哪些ip上監聽，0.0.0.0表示所有ip -->
<property name="bindIp">0.0.0.0</property>
<!-- 心跳檢查頻率，單位毫秒-->
<property name="dataNodeIdleCheckPeriod">10000</property>
<!-- mycat連線mysql，兩邊的charset一定要一致，否則會出現亂碼 -->
<property name="charset">utf-8</property>
<!-- 前端寫佇列大小， -->
<property name="frontWriteQueueSize">4096</property>
<!-- Mycat程序數量，通常為伺服器核心數目-->
<property name="processors">4</property>
<!-- mycat連線到mysql的預設隔離級別（1.讀未提交，2.讀已提交，3.可重複度，4.序列化讀），預設是可重複度-->
<property name="txIsolation">3</property>
<!-- SQL 執行超時,超時則斷開連線 單位:秒-->
<property name="sqlExecuteTimeout">300</property>
<!-- 0遇上沒有實現的報文(Unknown command:),就會報錯、1為忽略該報文，返回ok報文。 在某些mysql客戶端存在客戶端已經登入的時候還會繼續傳送登入報文,mycat會報錯,該設定可以繞過這個錯誤-->
<property name="ignoreUnknownCommand">0</property>
<!-- -->
<property name="useHandshakeV10">1</property>
<!-- -->
<property name="removeGraveAccent">1</property>
<!-- 1為開啟實時統計、0為關閉 -->
<property name="useSqlStat">0</property>
<!-- 1為開啟全加班一致性檢測、0為關閉 -->
<property name="useGlobleTableCheck">0</property>
<property name="sequenceHandlerType">1</property>
<!--<property name="sequnceHandlerPattern">(?:(\s*next\s+value\s+for\s*MYCATSEQ_(\w+))(,|\)|\s)*)+</property>
INSERT INTO `travelrecord` (`id`,user_id) VALUES ('next value for MYCATSEQ_GLOBAL',"xxx");
-->
<!--必須帶有MYCATSEQ_或者 mycatseq_進入序列匹配流程 注意MYCATSEQ_有空格的情況-->
<property name="sequnceHandlerPattern">(?:(\s*next\s+value\s+for\s*MYCATSEQ_(\w+))(,|\)|\s)*)+</property>
<property name="subqueryRelationshipCheck">false</property> <!-- 子查詢中存在關聯查詢的情況下,檢查關聯欄位中是否有分片欄位 .預設 false -->
<property name="sequenceHanlderClass">io.mycat.route.sequence.handler.HttpIncrSequenceHandler</property>
<!-- <property name="useCompression">1</property>--> <!--1為開啟mysql壓縮協議-->
<!-- <property name="fakeMySQLVersion">5.6.20</property>--> <!--設定模擬的MySQL版本號-->
<!-- <property name="processorBufferChunk">40960</property> -->
<!--預設為type 0: DirectByteBufferPool | type 1 ByteBufferArena | type 2 NettyBufferPool -->
<property name="processorBufferPoolType">0</property>
<!--預設是65535 64K 用於sql解析時最大文字長度 -->
<!--<property name="maxStringLiteralLength">65535</property>-->
<!--<property name="sequenceHandlerType">0</property>-->
<!--<property name="backSocketNoDelay">1</property>-->
<!--<property name="frontSocketNoDelay">1</property>-->
<!--<property name="processorExecutor">16</property>-->
<!--分散式事務開關，0為不過濾分散式事務，1為過濾分散式事務（如果分散式事務內只涉及全域性表，則不過濾），2為不過濾分散式事務,但是記錄分散式事務日誌-->
<property name="handleDistributedTransactions">0</property>
<!-- off heap for merge/order/group/limit 1開啟 0關閉 -->
<property name="useOffHeapForMerge">0</property>
<!-- 單位為m -->
<property name="memoryPageSize">64k</property>
<!-- 單位為k -->
<property name="spillsFileBufferSize">1k</property>
<property name="useStreamOutput">0</property>
<!-- 單位為m -->
<property name="systemReserveMemorySize">384m</property>
<!--是否採用zookeeper協調切換 -->
<property name="useZKSwitch">false</property>
<!-- XA Recovery Log日誌路徑 -->
<!--<property name="XARecoveryLogBaseDir">./</property>-->
<!-- XA Recovery Log日誌名稱 -->
<!--<property name="XARecoveryLogBaseName">tmlog</property>-->
<!--如果為 true的話 嚴格遵守隔離級別,不會在僅僅只有select語句的時候在事務中切換連線-->
<property name="strictTxIsolation">false</property>
<!--如果為0的話,涉及多個DataNode的catlet任務不會跨執行緒執行-->
<property name="parallExecute">0</property>
</system>
<user name="root" defaultAccount="true">
<property name="password">root</property>
<property name="schemas">mycat_t1</property>
<property name="defaultSchema">mycat_t1</property>
</user>
<user name="user1">
<property name="password">user1</property>
<property name="schemas">mycat_t1</property>
<!--設定了readOnly屬性，該使用者只可以讀取，不可以寫-->
<property name="readOnly">false</property>
<!--No MyCAT Database selected 錯誤前會嘗試使用該schema作為schema，不設定則為null,報錯 -->
<property name="defaultSchema">mycat_t1</property>
<!-- 表級 DML 許可權設定 -->
<!--
<privileges check="false">
<schema name="TESTDB" dml="0110" >
<table name="tb01" dml="0000"></table>
<table name="tb02" dml="1111"></table>
</schema>
</privileges>
-->
</user>
</mycat:server>
2）配置schema.xml
<?xml version="1.0"?> <!DOCTYPE mycat:schema SYSTEM "schema.dtd"> <mycat:schema xmlns:mycat="http://io.mycat/"> <!-- schema 標籤用於定義 MyCat 例項中的邏輯庫 name屬性 配置邏輯庫的名字（即資料庫例項名） dataNode屬性 用於配置該邏輯庫預設的分片。沒有通過table標籤配置的表，就會走到預設的分片上。這裡注意沒有配置在table標籤的表，用工具檢視是無法顯示的，但是可以正常使用。 如果沒有配置dataNode屬性，則沒有配置在table標籤的表，是無法使用的。注意，dual表在mycat中，也被視為一個表。 另外，通過mycat建表，而該表並沒有提前配置table標籤，則mycat會找到預設的dataNode，並把表建在預設的dataNode上。如果沒有配置預設dataNode，則mycat會報錯。 checkSQLschema屬性 boolean型別。 當前端執行【select *from USERDB.tf_user;】時（表名前指定了mycat邏輯庫名），兩種取值： true：mycat會把語句轉換為【select * from tf_user;】 false：會報錯:錯誤程式碼： 1064 find no Route:SELECT * FROM USERDB.tf_user LIMIT 0, 1000 sqlMaxLimit屬性 相當於sql的結果集中，加上【limit N】。如果sql本身已經指定limit，則以sql指定的為準。 注意，如果table標籤的表，needAddLimit屬性配置為false，則該表的sql禁止自動加上limit --> <schema name="mycat_t1" checkSQLschema="true" sqlMaxLimit="100" randomDataNode="dn1"> <!-- auto sharding by id (long) --> <!--splitTableNames 啟用<table name 屬性使用逗號分割配置多個表,即多個表使用這個配置--> <!--fetchStoreNodeByJdbc 啟用ER表使用JDBC方式獲取DataNode--> <!-- table標籤用於定義Mycat的邏輯表，以及邏輯表的分片規則 name屬性 邏輯表的表名，同一個schema表名必須唯一 dataNode屬性 定義這個邏輯表所屬的 dataNode，用英文逗號間隔，如：dataNode="dn1,dn2" 如果dataNode過多，可以使用如下的方法減少配置： <table name="travelrecord" dataNode="multipleDn$0-99,multipleDn2$100-199" rule="auto-shardinglong" ></table> <dataNode name="multipleDn" dataHost="localhost1" database="db$0-99" ></dataNode> <dataNode name="multipleDn2" dataHost="localhost1" database=" db$0-99" ></dataNode> db$0-99為mysql的資料庫，即從db0至db99的資料庫（100個） rule屬性 該屬性用於指定邏輯表要使用的規則名字，規則名字在 rule.xml 中定義，必須與 tableRule 標籤中 name 屬性屬性值一一對應 ruleRequired屬性 該屬性用於指定表是否繫結分片規則，如果配置為 true，但沒有配置具體 rule 的話 ，程式會報錯 primaryKey屬性 指定該邏輯表對應真實表的主鍵。 MyCat會快取主鍵（通過primaryKey屬性配置）與具體 dataNode的資訊。當分片規則使用非主鍵進行分片時，那麼在使用主鍵進行查詢時，MyCat就會通過快取先確定記錄在哪個dataNode上，然後再在該dataNode上執行查詢。如果快取並沒有命中的話，還是會發送語句給所有的dataNode。 關於Mycat的主鍵快取，其機制是：當根據主鍵查詢的SQL語句第一次執行時，Mycat會對其結果進行分析，確定該主鍵在哪個分片上，並進行該主鍵到分片ID的快取。通過連線MyCAT的9066管理埠，執行show@@cache，可以顯示當前快取的使用情況。可在sql執行前後的2個時間點執行show @@cache，通過結果資訊中的LAST_PUT和LAST_ACCESS列，判斷相應表的快取是否有被更新過。 type屬性 該屬性定義了邏輯表的型別，目前邏輯表只有“全域性表”和”普通表”兩種型別。對應的配置：全域性表：global。普通表：不指定該值為 global 的所有表。 needAddLimit屬性 與schema標籤的sqlMaxLimit配合使用，如果needAddLimit值為false，則語句不會加上limit autoIncrement屬性 --> <!--兩個全域性吧表--> <table name="teacher" primaryKey="id" dataNode="dn1,dn2"/> <table name="caurse" primaryKey="id" dataNode="dn1,dn2"/> <!--若干普通水平分片表--> <table name="period_class" primaryKey="id" dataNode="dn1,dn2" rule="mycat-test1-period-rule0"/> <table name="grade_class" primaryKey="id" dataNode="dn1,dn2" rule="mycat-test1-period-rule1"/> <table name="score" primaryKey="id" dataNode="dn1,dn2" rule="mycat-test1-period-rule1"/> <table name="teacher_course_rel" primaryKey="id" dataNode="dn1,dn2" rule="mycat-test1-period-rule1"/> <table name="student" primaryKey="id" dataNode="dn1,dn2" rule="mycat-test1-period-rule1" fetchStoreNodeByJdbc="true"> <!-- childTable 標籤用於定義 E-R 分片的子表。通過標籤上的屬性與父表進行關聯。 name屬性 定義子表的表名 joinKey屬性 插入子表的時候會使用這個列的值查詢父表儲存的資料節點。 parentKey屬性 該屬性指定的值一般為與父表建立關聯關係的列名。Mycat首先獲取 joinkey 的值，再通過 parentKey 屬性指定的列名產生查詢語句，通過執行該語句得到父表儲存在哪個分片上。從而確定子表儲存的位置。 --> <childTable name="student_msg" primaryKey="id" joinKey="id" parentKey="student_id"> </childTable> </table> </schema> <!-- 分片節點 --> <dataNode name="dn1" dataHost="localhost1" database="mycat_t1" /> <dataNode name="dn2" dataHost="localhost2" database="mycat_t1" /> <!-- dataHost標籤用於定義後端的資料庫主機 name 屬性 指定dataHost的名字 maxCon 指定每個讀寫例項連線池的最大連線。也就是說，標籤內巢狀的writeHost、 readHost 標籤都會使用這個屬 性的值來例項化出連線池的最大連線數。 minCon 屬性 指定每個讀寫例項連線池的最小連線，初始化連線池的大小。 balance 屬性 負載均衡型別： （1）balance="0", 不開啟讀寫分離機制，所有讀操作都發送到當前可用的writeHost 上。 （2）balance="1"，全部的 readHost 與 stand by writeHost 參與 select 語句的負載均衡，簡單的說，當雙主雙從模式(M1->S1，M2->S2，並且 M1 與 M2 互為主備)，正常情況下，M2,S1,S2 都參與 select 語句的負載均衡。 （3）balance="2"，所有讀操作都隨機的在 writeHost、 readhost 上分發。 （4）balance="3"，所有讀請求隨機的分發到 wiriterHost 對應的 readhost 執行，writerHost 不負擔讀壓力，注意 balance=3 只在 1.4 及其以後版本有，1.3 沒有。 writeType 屬性 （1）writeType="0", 所有寫操作傳送到配置的第一個 writeHost，第一個掛了切到還生存的第二個riteHost，重新啟動後已切換後的為準，切換記錄在配置檔案中:dnindex.properties. （2）writeType="1"，所有寫操作都隨機的傳送到配置的 writeHost，1.5 以後廢棄不推薦。 dbType 屬性 指定後端連線的資料庫型別，目前支援二進位制的 mysql 協議，還有其他使用 JDBC 連線的資料庫。例如：mongodb、 oracle、 spark 等。 dbDriver 屬性 指定連線後端資料庫使用的 Driver，目前可選的值有 native 和 JDBC。使用native 的話，因為這個值執行的是二進位制的 mysql 協議，所以可以使用 mysql 和 maridb。其他型別的資料庫則需要使用 JDBC 驅動來支援。 switchType 屬性： -1 表示不自動切換 1 預設值，自動切換 2 基於 MySQL 主從同步的狀態決定是否切換 心跳語句為 show slave status 3 基於 MySQL galary cluster 的切換機制（適合叢集）（1.4.1） 心跳語句為 show status like ‘wsrep%’. tempReadHostAvailable 屬性 如果配置了這個屬性 writeHost 下面的 readHost 仍舊可用，預設 0 可配置（0、 1） --> <dataHost name="localhost1" maxCon="30" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1" slaveThreshold="100"> <heartbeat>select user()</heartbeat> <!-- writeHost 標籤、 readHost 標籤 host 屬性 用於標識不同例項，一般 writeHost 我們使用*M1，readHost 我們用*S1。 url 屬性 後端例項連線地址，如果是使用 native 的 dbDriver，則一般為 address:port 這種形式。用 JDBC 或其他的dbDriver，則需要特殊指定。當使用 JDBC 時則可以這麼寫：jdbc:mysql://localhost:3306/。 user 屬性 後端儲存例項需要的使用者名稱字 password 屬性 端儲存例項需要的密碼 weight 屬性 重 配置在 readhost 中作為讀節點的權重（1.4 以後） usingDecrypt 屬性 否對密碼加密預設 0 否 如需要開啟配置 1，同時使用加密程式對密碼加密 --> <!-- can have multi write hosts --> <writeHost host="hostM1" url="jdbc:mysql://192.168.3.207:3306" user="admin" password="adminpswd"> </writeHost> </dataHost> <dataHost name="localhost2" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1" slaveThreshold="100"> <heartbeat>select user()</heartbeat> <writeHost host="hostM1" url="jdbc:mysql://localhost:3306" user="admin" password="adminpswd"> </writeHost> </dataHost> </mycat:schema>
3）配置rule.xml
這裡使用的是一致性雜湊分片規則
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mycat:rule SYSTEM "rule.dtd"> <mycat:rule xmlns:mycat="http://io.mycat/"> <!-- name 屬性： 指定唯一的名字，用於標識不同的表規則。 rule標籤： 指定對物理表中的哪一列進行拆分和使用什麼路由演算法。columns 指定要拆分的列名字。algorithm 使用function標籤中的name屬性，連線表規則和具體路由演算法。 --> <tableRule name="mycat-test1-period-rule0"> <rule> <columns>id</columns> <algorithm>func1</algorithm> </rule> </tableRule> <tableRule name="mycat-test1-period-rule1"> <rule> <columns>period_class_id</columns> <algorithm>func1</algorithm> </rule> </tableRule> <!-- name屬性：指定演算法的名字。 class屬性：指定路由演算法具體的類名字。 property屬性：為具體演算法需要用到的一些屬性。 --> <function name="func1" class="io.mycat.route.function.PartitionByMurmurHash"> <property name="seed">0</property><!-- 預設是0--> <property name="count">2</property><!-- 要分片的資料庫節點數量，必須指定，否則沒法分片 --> <property name="virtualBucketTimes">10</property><!-- 一個實際的資料庫節點被對映為這麼多虛擬節點，預設是160倍，也就是虛擬節點數是物理節點數的160倍--> <!-- <property name="weightMapFile">weightMapFile</property> 節點的權重，沒有指定權重的節點預設是1。以properties檔案的格式填寫，以從0開始到count-1的整數值也就是節點索引為key，以節點權重值為值。所有權重值必須是正整數，否則以1代替 --> <!-- <property name="bucketMapPath">/etc/mycat/bucketMapPath</property> 用於測試時觀察各物理節點與虛擬節點的分佈情況，如果指定了這個屬性，會把虛擬節點的murmur hash值與物理節點的對映按行輸出到這個檔案，沒有預設值，如果不指定，就不會輸出任何東西 --> </function> </mycat:rule>
4）使用Navicat進行連線測試，連線方式如mysql一樣，只不過要將埠修改為8066
3.mybatis連線mycat
mybatis連線mycat如果mysql一樣，只不過埠不同，下面是測試用的幾個關鍵檔案的程式碼，
pom.xml:
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.0</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.0</version>
</dependency>
<dependency>
<groupId>org.mybatis.generator</groupId>
<artifactId>mybatis-generator-core</artifactId>
<version>1.3.7</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.42</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
application.properties:
server.port=9999 spring.datasource.name=test # 連結url與mysql並無區別 spring.datasource.url=jdbc:mysql://192.168.3.27:8066/mycat_t1 spring.datasource.username=user1 spring.datasource.password=user1 # 使用durid連線池 spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.filters=stat spring.datasource.maxActive=20 spring.datasource.initialSize=1 spring.datasource.maxWait=60000 spring.datasource.minIdle=1 spring.datasource.timeBetweenEvictionRunsMillis=60000 spring.datasource.minEvictableIdleTimeMillis=300000 spring.datasource.validationQuery=select 'x' spring.datasource.testWhileIdle=true spring.datasource.testOnBorrow=false spring.datasource.testOnReturn=false spring.datasource.poolPreparedStatements=true spring.datasource.maxOpenPreparedStatements=20
mapper java 類：
package com.example.demo.mycatt1.mapper; import com.example.demo.mycatt1.pojo.PeriodClass; import com.example.demo.mycatt1.pojo.PeriodClassExample; import java.util.List; import org.apache.ibatis.annotations.Param; public interface PeriodClassMapper { long countByExample(PeriodClassExample example); int deleteByPrimaryKey(String id); int insert(PeriodClass record); int insertSelective(PeriodClass record); List<PeriodClass> selectByExample(PeriodClassExample example); PeriodClass selectByPrimaryKey(String id); int updateByPrimaryKeySelective(PeriodClass record); int updateByPrimaryKey(PeriodClass record); }
mapper.xml:
mapper的配置與使用mysql一樣
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.example.demo.mycatt1.mapper.PeriodClassMapper"> <resultMap id="BaseResultMap" type="com.example.demo.mycatt1.pojo.PeriodClass"> <id column="id" jdbcType="VARCHAR" property="id" /> <result column="year" jdbcType="INTEGER" property="year" /> <result column="classes" jdbcType="INTEGER" property="classes" /> </resultMap> <sql id="Example_Where_Clause"> <where> <foreach collection="oredCriteria" item="criteria" separator="or"> <if test="criteria.valid"> <trim prefix="(" prefixOverrides="and" suffix=")"> <foreach collection="criteria.criteria" item="criterion"> <choose> <when test="criterion.noValue"> and ${criterion.condition} </when> <when test="criterion.singleValue"> and ${criterion.condition} #{criterion.value} </when> <when test="criterion.betweenValue"> and ${criterion.condition} #{criterion.value} and #{criterion.secondValue} </when> <when test="criterion.listValue"> and ${criterion.condition} <foreach close=")" collection="criterion.value" item="listItem" open="(" separator=","> #{listItem} </foreach> </when> </choose> </foreach> </trim> </if> </foreach> </where> </sql> <sql id="Base_Column_List"> id, year, classes </sql> <select id="selectByExample" parameterType="com.example.demo.mycatt1.pojo.PeriodClassExample" resultMap="BaseResultMap"> select <if test="distinct"> distinct </if> 'false' as QUERYID, <include refid="Base_Column_List" /> from period_class <if test="_parameter != null"> <include refid="Example_Where_Clause" /> </if> <if test="orderByClause != null"> order by ${orderByClause} </if> </select> <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap"> select <include refid="Base_Column_List" /> from period_class where id = #{id,jdbcType=VARCHAR} </select> <delete id="deleteByPrimaryKey" parameterType="java.lang.String"> delete from period_class where id = #{id,jdbcType=VARCHAR} </delete> <insert id="insert" parameterType="com.example.demo.mycatt1.pojo.PeriodClass"> insert into period_class (id, year, classes ) values (#{id,jdbcType=VARCHAR}, #{year,jdbcType=INTEGER}, #{classes,jdbcType=INTEGER} ) </insert> <insert id="insertSelective" parameterType="com.example.demo.mycatt1.pojo.PeriodClass"> insert into period_class <trim prefix="(" suffix=")" suffixOverrides=","> <if test="id != null"> id, </if> <if test="year != null"> year, </if> <if test="classes != null"> classes, </if> </trim> <trim prefix="values (" suffix=")" suffixOverrides=","> <if test="id != null"> #{id,jdbcType=VARCHAR}, </if> <if test="year != null"> #{year,jdbcType=INTEGER}, </if> <if test="classes != null"> #{classes,jdbcType=INTEGER}, </if> </trim> </insert> <select id="countByExample" parameterType="com.example.demo.mycatt1.pojo.PeriodClassExample" resultType="java.lang.Long"> select count(*) from period_class <if test="_parameter != null"> <include refid="Example_Where_Clause" /> </if> </select> <update id="updateByPrimaryKeySelective" parameterType="com.example.demo.mycatt1.pojo.PeriodClass"> update period_class <set> <if test="year != null"> year = #{year,jdbcType=INTEGER}, </if> <if test="classes != null"> classes = #{classes,jdbcType=INTEGER}, </if> </set> where id = #{id,jdbcType=VARCHAR} </update> <update id="updateByPrimaryKey" parameterType="com.example.demo.mycatt1.pojo.PeriodClass"> update period_class set year = #{year,jdbcType=INTEGER}, classes = #{classes,jdbcType=INTEGER} where id = #{id,jdbcType=VARCHAR} </update> </mapper>
controller類
package com.example.demo.mycatt1;
import java.util.UUID;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import com.example.demo.mycatt1.mapper.CaurseMapper;
import com.example.demo.mycatt1.mapper.PeriodClassMapper;
import com.example.demo.mycatt1.pojo.Caurse;
import com.example.demo.mycatt1.pojo.PeriodClass;
@Controller
@RequestMapping("period")
public class PeriodClassController {
@Autowired
PeriodClassMapper periodClassMapper;
@RequestMapping("add")
@ResponseBody
public String add(){
System.out.println("PeriodClassController-add");
for(int i = 1;i<=1000;i++){
PeriodClass periodClass = new PeriodClass();
periodClass.setClasses(i);
periodClass.setId(UUID.randomUUID().toString().replace("-", ""));
periodClass.setYear(2011);
periodClassMapper.insert(periodClass);
}
return "PeriodClassController-add";
}
}
執行程式，訪問介面，可以發現數據被比較平均的分散到兩臺機器上了。