数据分片

优质

小牛编辑

186浏览

2023-12-01

使用实战

前置工作

启动MySQL服务
创建MySQL数据库(参考ShardingProxy数据源配置规则)
为ShardingProxy创建一个拥有创建权限的角色或者用户
启动Zookeeper服务 (为了持久化配置)

启动ShardingProxy

添加 mode 和 authentication 配置参数到 server.yaml (请参考相关example案例)
启动 ShardingProxy (相关介绍)

创建分布式数据库和分片表

连接到ShardingProxy
创建分布式数据库

CREATE DATABASE sharding_db;

使用新创建的数据库

USE sharding_db;

配置数据源信息

ADD RESOURCE ds_0 (
HOST=127.0.0.1,
PORT=3306,
DB=ds_1,
USER=root,
PASSWORD=root
);

ADD RESOURCE ds_1 (
HOST=127.0.0.1,
PORT=3306,
DB=ds_2,
USER=root,
PASSWORD=root
);

创建分片规则

CREATE SHARDING TABLE RULE t_order(
RESOURCES(ds_0,ds_1),
SHARDING_COLUMN=order_id,
TYPE(NAME=hash_mod,PROPERTIES("sharding-count"=4)),
GENERATED_KEY(COLUMN=order_id,TYPE(NAME=snowflake,PROPERTIES("worker-id"=123)))
);

创建切分表

CREATE TABLE `t_order` (
  `order_id` int NOT NULL,
  `user_id` int NOT NULL,
  `status` varchar(45) DEFAULT NULL,
  PRIMARY KEY (`order_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4

删除切分表

DROP TABLE t_order;

删除分片规则

DROP SHARDING TABLE RULE t_order;

删除数据源

DROP RESOURCE ds_0, ds_1;

删除分布式数据库

DROP DATABASE sharding_db;

注意事项

当前, DROP DB只会移除逻辑的分布式数据库，不会删除用户真实的数据库 (TODO)。
DROP TABLE会将逻辑分片表和数据库中真实的表全部删除。
CREATE DB只会创建逻辑的分布式数据库，所以需要用户提前创建好真实的数据库（TODO）。
自动分片算法会持续增加，从而覆盖用户各大分片场景 (TODO)。
重构ShardingAlgorithmPropertiesUtil（TODO）。
保证所有客户端完成RDL执行（TODO）。
增加 ALTER DB 和 ALTER TABLE的支持（TODO）。