Synchronisation et réplication des données en temps réel à l'aide de PHP et SQLite

Titre : Synchronisation et réplication des données en temps réel à l'aide de PHP et SQLite

Introduction :
À l'ère de l'information d'aujourd'hui, la synchronisation et la réplication des données en temps réel deviennent de plus en plus importantes. Qu’il s’agisse de synchronisation de données au sein d’une entreprise ou de réplication de données entre plusieurs systèmes, une méthode efficace et fiable est nécessaire pour y parvenir. Cet article explique comment utiliser PHP et SQLite pour réaliser la synchronisation et la réplication des données en temps réel, et fournit des exemples de code correspondants.

1. Introduire les extensions SQLite et PHP
Tout d'abord, nous devons nous assurer que la base de données SQLite a été installée dans le système et l'associer à l'extension PHP. Les extensions SQLite et PHP peuvent être installées via les commandes suivantes :

sudo apt-get install sqlite3
sudo apt-get install php-sqlite3

2. Créer la base de données maître et la base de données esclave
Avant de commencer, nous devons créer une base de données maître et une base de données esclave. Les fichiers de base de données peuvent être créés à l'aide des outils de ligne de commande ou des outils visuels de SQLite. Supposons que nous créions une base de données maître nommée « main.db » et une base de données esclave nommée « replica.db ».

3. Écrivez un script de synchronisation de données
Ensuite, nous écrirons un script PHP pour réaliser une synchronisation en temps réel entre la base de données maître et la base de données esclave. Le code spécifique est le suivant :

<?php
// 连接主数据库
$mainDb = new SQLite3('main.db');

// 连接从数据库
$replicaDb = new SQLite3('replica.db');

// 获取主数据库中最后更新的时间戳
$lastTimestamp = $replicaDb->querySingle("SELECT max(timestamp) FROM data");

// 查询主数据库中大于该时间戳的数据
$query = "SELECT * FROM data WHERE timestamp > '{$lastTimestamp}'";
$result = $mainDb->query($query);

// 将查询结果插入从数据库中
while ($row = $result->fetchArray()) {
    $query = "INSERT INTO data VALUES ('{$row['data']}', '{$row['timestamp']}')";
    $replicaDb->exec($query);
}

Le code ci-dessus comprend principalement les opérations suivantes :

1. Connectez la base de données maître et la base de données esclave, implémentées via la classe SQLite3.
2. Obtenez le dernier horodatage mis à jour de la base de données esclave et utilisez-le pour interroger les dernières données de la base de données principale.
3. Interrogez les données de la base de données principale qui sont supérieures à l'horodatage.
4. Insérez les résultats de la requête dans la base de données.

4. Réaliser la réplication automatique des données
Afin d'obtenir la synchronisation et la réplication des données en temps réel, nous pouvons utiliser des tâches planifiées pour exécuter automatiquement le script PHP ci-dessus. Les tâches planifiées peuvent être configurées via la commande crontab. L'exemple de code est le suivant :

*/5 * * * * /usr/bin/php /path/to/sync_script.php >> /path/to/log.txt

Le code ci-dessus signifie exécuter le script sync_script.php toutes les 5 minutes et enregistrer les résultats de sortie dans le fichier journal log.txt. Vous pouvez l'ajuster selon vos besoins.

Résumé :
Cet article explique comment utiliser PHP et SQLite pour réaliser la synchronisation et la réplication des données en temps réel, et fournit des exemples de code correspondants. En exécutant régulièrement des scripts PHP, nous pouvons réaliser une synchronisation des données entre la base de données maître et la base de données esclave pour garantir la cohérence des données en temps réel. Cette méthode convient aux petites applications et systèmes et est simple, efficace et fiable. Bien entendu, pour les systèmes à grande échelle, d’autres outils de synchronisation et de réplication de bases de données plus puissants peuvent être envisagés pour la mise en œuvre.

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!