3、分库分表
先了解一下MyCat配置,MyCat配置主要涉及以下三个文件:
3.1、编辑配置文件
温馨提示:只需要配置主服务器的MyCat,此处不对server.xml做任何修改。
实验目的:往数据库表中批量插入数据,可以根据某种规则自动地将数据分配到不同的数据库表上。
编辑schema.xml:
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://org.opencloudb/" >
<schema name="TESTDB" checkSQLschema="false" sqlMaxLimit="100">
<table name="travelrecord" dataNode="dn1,dn2" rule="sharding-by-month" />
</schema>
<dataNode name="dn1" dataHost="testhost" database="db1" />
<dataNode name="dn2" dataHost="testhost" database="db2" />
<dataHost name="testhost" maxCon="1000" minCon="10" balance="1"
writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100">
<heartbeat>select user()</heartbeat>
<writeHost host="M1" url="localhost:3306" user="root" password="123456">
</writeHost>
</dataHost>
</mycat:schema>
编辑rule.xml:
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mycat:rule SYSTEM "rule.dtd">
<mycat:rule xmlns:mycat="http://org.opencloudb/">
<tableRule name="sharding-by-month">
<rule>
<columns>create_date</columns>
<algorithm>partbymonth</algorithm>
</rule>
</tableRule>
<function name="partbymonth"
class="org.opencloudb.route.function.PartitionByMonth">
<property name="dateFormat">yyyy-MM-dd</property>
<property name="sBeginDate">2019-01-01</property>
</function>
</mycat:rule>
解读:两个配置文件中都定义了 “sharding-by-month”的分片规则,rule.xml中的配置说明按照表中的“create_time”字段进行分割:从“2019-01-01”开始,月份不同的数据会插入到不同的数据库表中,不同数据库的表相同。
3.2、创建数据库
在MySQL中创建数据库db1、db2,根据schema.xml中的dataNode标签内容来创建:
create database db1;
create database db2;
3.3、MyCat创建表并插入数据
mysql -utest -ptest -h127.0.0.1 -P8066 -DTESTDB # 连接至mycat
create table travelrecord (id int not null primary key,price double,create_date DATE); # 创建表
insert into travelrecord(id,price,create_date) values(1,2000,'2019-01-03');
insert into travelrecord(id,price,create_date) values(2,3000,'2019-02-03');
实验预期结果:第一条数据和第二条数据会分别插入到db1和db2中的travelrecord表。
4、主从设置
实验目的:主服务器(M1)创建数据库、往表中插入数据都会同步到从服务器(S1)中。
4.1、配置文件修改
(1)、主(M1)
编辑schema.xml(第一个writeHost标签中嵌套一个readHost标签):
<writeHost host="M1" url="localhost:3306" user="root" password="123456">
<readHost host="S1" url="192.168.0.4:3306" user="root" password="123456" />
</writeHost>
编辑my.cnf(路径:/etc/my.cnf):
在“socket=/var/lib/mysql/mysql.sock”后面加入下面两行代码:
server-id=2 # 必须指定一个大于0的数字作为唯一标识接收从的连接请求,本人使用的是ip地址的结尾
log_bin=master
重启数据库
service mysqld restart
在Navicat中输入“show master status”查看M1的状态
(2)、从(S1)
编辑my.cnf:
在“socket=/var/lib/mysql/mysql.sock”后面加入一行代码:
server-id=4
重启数据库
service mysqld restart
配置从(slave)服务器中与主的关联:
参数master_log_file和master_log_pos的内容可通过在主(master)服务器上使用“show master status”查看,分别对应执行结果的File和Position的内容:
mysql -u root -p
stop slave; # 停止slave
change master to master_host='192.168.0.2',master_user='root',
master_password='123456',master_log_file='xxx',master_log_pos=xxx;
start slave; # 启动slave
exit;
4.2、创建新数据库、插入数据
create database db3; # M1的mysql
create database db1; # S1的mysql
create database db2; # S1的mysql
insert into travelrecord(id,price,create_date) values(3,4000,'2019-02-04'); # M1的mysql
实验预期结果:从服务器(S1)中多了一个数据库db3;数据成功插入到S1的数据库表中。