PHP と SQLite を使用したリアルタイムのデータ同期とレプリケーション

タイトル: PHP と SQLite を使用したリアルタイム データの同期とレプリケーション

はじめに:
今日の情報化時代では、データのリアルタイム同期とレプリケーションがますます重要になっています。企業内のデータ同期であっても、複数システム間のデータ複製であっても、それを実現するには効率的で信頼性の高い方法が必要です。この記事では、PHP と SQLite を使用してリアルタイムのデータ同期とレプリケーションを実現する方法を紹介し、対応するコード例を示します。

1. SQLite および PHP 拡張機能の紹介
まず、SQLite データベースがシステムにインストールされていることを確認し、それを PHP 拡張機能に関連付ける必要があります。 SQLite および PHP 拡張機能は、次のコマンドを使用してインストールできます。

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

2. マスター データベースとスレーブ データベースを作成します
開始する前に、マスター データベースとスレーブ データベースを作成する必要があります。データベース ファイルは、SQLite のコマンド ライン ツールまたはビジュアル ツールを使用して作成できます。 「main.db」という名前のマスター データベースと「replica.db」という名前のスレーブ データベースを作成するとします。

3. データ同期スクリプトを作成する
次に、マスター データベースとスレーブ データベース間のリアルタイム同期を実現するための PHP スクリプトを作成します。具体的なコードは次のとおりです。

<?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);
}

上記のコードには、主に次の操作が含まれています。

1. マスター データベースとスレーブ データベースの接続は、SQLite3 クラスを通じて実装されます。
2. スレーブ データベースの最終更新タイムスタンプを取得します。これは、マスター データベースの最新データをクエリするために使用されます。
3. メイン データベース内のタイムスタンプより大きいデータをクエリします。
4. クエリ結果をデータベースに挿入します。

4. 自動データ レプリケーションの実装
データのリアルタイム同期とレプリケーションを実現するために、スケジュールされたタスクを使用して上記の PHP スクリプトを自動的に実行できます。スケジュールされたタスクは、crontab コマンドを通じて設定できます。サンプル コードは次のとおりです。

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

上記のコードは、sync_script.php スクリプトを 5 分ごとに実行し、出力結果を log.txt ログ ファイルに保存することを意味します。ニーズに応じて調整できます。

概要:
この記事では、PHP と SQLite を使用してリアルタイムのデータ同期とレプリケーションを実現する方法を紹介し、対応するコード例を示します。 PHP スクリプトを定期的に実行することで、マスター データベースとスレーブ データベース間のデータ同期を実現し、データのリアルタイムの一貫性を確保できます。この方法は小規模なアプリケーションやシステムに適しており、シンプルで効率的で信頼性が高くなります。もちろん、大規模システムの場合は、他のより強力なデータベース同期およびレプリケーション ツールの実装を検討できます。

以上がPHP と SQLite を使用したリアルタイムのデータ同期とレプリケーションの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。