Comment effectuer un stockage distribué et une requête de données dans MySQL ?

Comment effectuer un stockage distribué et une requête de données dans MySQL ?

À mesure que la quantité de données continue de croître, les performances de stockage et de requêtes d'une seule base de données MySQL peuvent ne pas être en mesure de répondre à la demande. À l'heure actuelle, vous devez envisager d'utiliser le stockage et les requêtes distribués pour améliorer l'évolutivité et les performances de. le système. Cet article explique comment effectuer un stockage distribué et une requête de données dans MySQL et fournit un exemple de code.

1. Partage de données
   Le partage de données consiste à diviser les données de la base de données en plusieurs fragments, et chaque fragment est stocké dans une instance MySQL différente. Le principe du partitionnement peut être de diviser en fonction de la plage de valeurs d'un certain champ, comme la division en fonction de la valeur de hachage de l'ID utilisateur, ou de personnaliser les règles de division en fonction des besoins de l'entreprise.

Ce qui suit est un exemple de méthode de partage de données, en supposant que nous ayons une table utilisateuruser，其中有user_id和namedeux champs.

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

Nous pouvons stocker des données dans des fragments via les méthodes suivantes :

-- 创建划分规则
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); -- 根据分片信息查询对应的片段

2. Requête de données
   Après avoir utilisé le stockage distribué, l'interrogation de données impliquera des opérations sur plusieurs instances MySQL. L'interrogation peut être effectuée via :

-- 在每个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); -- 根据分片信息查询对应的片段

Il convient de noter que la cohérence des données est un problème important lors de l'utilisation du stockage distribué et des requêtes. Les performances de lecture peuvent être améliorées grâce à une expansion horizontale, mais les opérations d'écriture doivent garantir la cohérence des données. Des verrous ou coordinateurs distribués peuvent être utilisés pour résoudre des problèmes de cohérence des données.

Résumé :
Cet article explique comment effectuer un stockage distribué et une requête de données dans MySQL. Grâce au partage de données et au mappage de partitions, les données peuvent être stockées dans différentes instances MySQL et les données peuvent être acheminées vers les fragments correspondants via la table de mappage de partitions. Dans le même temps, il faut veiller à garantir la cohérence des données. Des verrous ou des coordinateurs distribués peuvent être utilisés pour résoudre ce problème. L'utilisation de cette méthode peut améliorer l'évolutivité et les performances du système et répondre aux besoins de stockage et de requête de données à grande échelle.

Remarque : les règles de partitionnement et le mappage de partitionnement dans l'exemple de code devront peut-être être ajustés en fonction des besoins réels de l'entreprise.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!