如何在MySQL中进行数据的分布式存储和查询？

CREATE TABLE `user` (
  `user_id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`user_id`)
) ENGINE=InnoDB;

-- 创建划分规则
CREATE FUNCTION shard_hash(user_id INT) RETURNS INT
BEGIN
    RETURN user_id % 4; -- 按照 user_id 的哈希值进行划分为4个片段
END;

-- 创建辅助表存储分片信息
CREATE TABLE `shard_mapping` (
  `user_id` int(11) NOT NULL,
  `shard_id` int(11) NOT NULL,
  PRIMARY KEY (`user_id`)
) ENGINE=InnoDB;

-- 将数据按照划分规则插入对应的片段
INSERT INTO `user` (name)
SELECT name FROM origin_user WHERE shard_hash(user_id) = 0; -- 插入到片段 0

INSERT INTO `user` (name)
SELECT name FROM origin_user WHERE shard_hash(user_id) = 1; -- 插入到片段 1

-- ...

-- 插入分片信息
INSERT INTO `shard_mapping` (user_id, shard_id)
SELECT user_id, shard_hash(user_id) FROM origin_user;

-- 查询时需要根据分片信息路由到对应的片段
SELECT u.name
FROM user u
JOIN shard_mapping m ON u.user_id = m.user_id
WHERE m.shard_id = shard_hash(123); -- 根据分片信息查询对应的片段

-- 在每个MySQL实例上创建相同的表结构
CREATE TABLE `user` (
  `user_id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`user_id`)
) ENGINE=InnoDB;

-- 使用分片映射表查询对应的片段
SELECT u.name
FROM user u
JOIN shard_mapping m ON u.user_id = m.user_id
WHERE m.shard_id = shard_hash(123); -- 根据分片信息查询对应的片段