php实时读取数据库内容

<?php
$host = 'localhost';
$dbname = 'your_database';
$user = 'your_username';
$pass = 'your_password';

$conn = new mysqli($host, $user, $pass, $dbname);

if ($conn->connect_error) {
    die("Connection failed: " . $conn->connect_error);
}

$sql = "SELECT * FROM your_table WHERE updated_at > ?";
$stmt = $conn->prepare($sql);
$last_update = time() - 60; // 假设我们检查过去60秒内的更新
$stmt->bind_param("i", $last_update);

while (true) {
    $stmt->execute();
    $result = $stmt->get_result();

    if ($result->num_rows > 0) {
        while ($row = $result->fetch_assoc()) {
            // 处理新数据
            echo json_encode($row);
        }
    }

    // 等待一段时间再检查
    sleep(1);
}

$stmt->close();
$conn->close();
?>