如何利用PHP开发一个简单的数据同步功能

$mysqli = new mysqli('localhost', 'username', 'password', 'database_name');

// 检查连接是否成功
if ($mysqli->connect_errno) {
    die('数据库连接失败: ' . $mysqli->connect_error);
}

$sourceData = []; // 存储源数据的数组

$query = "SELECT * FROM source_table";
$result = $mysqli->query($query);

// 将查询结果存储到数组中
while ($row = $result->fetch_assoc()) {
    $sourceData[] = $row;
}

// 释放结果集和关闭数据库连接
$result->free();
$mysqli->close();

$mysqli = new mysqli('localhost', 'username', 'password', 'database_name');

// 检查连接是否成功
if ($mysqli->connect_errno) {
    die('数据库连接失败: ' . $mysqli->connect_error);
}

// 遍历源数据，更新目标数据源
foreach ($sourceData as $row) {
    $id = $row['id'];
    $name = $row['name'];
    $email = $row['email'];

    // 执行更新语句
    $query = "UPDATE target_table SET name='$name', email='$email' WHERE id='$id'";
    $mysqli->query($query);
}

// 关闭数据库连接
$mysqli->close();

try {
    // 建立数据库连接、获取源数据、更新目标数据等操作
} catch (Exception $e) {
    // 处理异常
    die('数据同步失败: ' . $e->getMessage());
}

0 1 * * * php /path/to/sync.php