我正在尝试构建一个应用程序来查询数据库，并在数据进入数据库时​​将数据发送到某处。

我可以使用这段代码从数据库中获取我想要的数据:

$sql="SELECT * FROM `signals` order by `time` DESC LIMIT 100";
$result = mysqli_query($DatabasePointer,$sql) 
    or die(mysqli_error($DatabasePointer));
$row_cnt = mysqli_num_rows($result);

if($row_cnt>0)
{
    $array = array();
    $i=0;

    while($row = mysqli_fetch_array($result))
    {
        $i++;
        //$a = array();
        $epoch = $row['time'];
        // convert UNIX timestamp to PHP DateTime
        $dt = new DateTime("@$epoch");

        if(
            ($row['symbol'] === 'USDJPYecn') 
            || ($row['symbol'] === 'USDCADecn') 
            || ($row['symbol'] === 'EURUSDecn')
            ) 
        {
            if(
                ($row['timeframe'] === 'M5') 
                || ($row['timeframe'] === 'M15')
                )  
            {
                $a = array(
                    "time" => $dt->format('Y-m-d H:i:s'),
                    "signal" => $row['signal'],
                    "symbol" => $row['symbol'],
                    "price" => $row['price'],
                    "timeframe" => $row['timeframe'],
                    "epoch" => $row['time'],
                    "candel" => $row['candel'] 
                    );
                $array[] = $a;
             }
        }

    } // while

    echo json_encode($array, JSON_UNESCAPED_SLASHES);           
}

但是，我不确定如何修改代码来检查数据是否是新的，或者是否已经发送到另一个来源。我也不确定如何修改代码以仅在新数据到达数据库时发送新数据，而不是像我现在调用的那样发送整个数据数组。

有人能给我指出正确的方向吗？

编辑:

$sql="SELECT * FROM `tdisignals` order by `time` DESC LIMIT 100";
$result = mysqli_query($DatabasePointer,$sql) 
    or die(mysqli_error($DatabasePointer));
$row_cnt = mysqli_num_rows($result);

if($row_cnt>0)
{
    $array = array();
    $i=0;
    while($row = mysqli_fetch_array($result))
    {
        $i++;
        //$a = array();
        $epoch = $row['time']; 
        // convert UNIX timestamp to PHP DateTime
        $dt = new DateTime("@$epoch");

        if( 
            $row['symbol'] === 'USDJPYecn' 
            || ($row['symbol'] === 'USDCADecn') 
            || ($row['symbol'] === 'GBPUSDecn'))
        {
            if(
                $row['timeframe'] === 'M5')
                || ($row['timeframe'] === 'M15'))
            {

                $a = array(
                    "time" => $dt->format('Y-m-d H:i:s'),
                    "signal" => $row['signal'],
                    "symbol" => $row['symbol'],
                    "price" => $row['price'],
                    "timeframe" => $row['timeframe'],
                    "epoch" => $row['time'],
                    "candel" => $row['candel'],
                    );

                $array[] = $a;
            }

        }

    }

    // echo json_encode($array, JSON_UNESCAPED_SLASHES);
    $fuegostore = json_encode($array, JSON_UNESCAPED_SLASHES);
    // $sql2 = "INSERT INTO fuegosync (time, lastsync) ".
    //          "VALUES ('$date', '$fuegostore')";
    // $result2 = mysqli_query($DatabasePointer,$sql2) 
       // or die(mysqli_error($DatabasePointer));
    $sql3="SELECT lastsync, MAX(CAST(time AS CHAR)) FROM `fuegosync`";
    $result3 = mysqli_query($DatabasePointer,$sql3) 
        or die(mysqli_error($DatabasePointer));

    $row2 = mysqli_fetch_row($result3);

    if($row2[0] === $fuegostore)
        echo 'No New Signals';
    else
        echo 'New Signals';
                    ///OPTION 1:
                    //print_r (json_encode($array[0], JSON_UNESCAPED_SLASHES));
                    //OPTION 2:
                    foreach($array as $x) {
                        if(strtotime($array[0]['time']) >= $row2[1]) {
                        echo '<br /><span>'.$x['signal'].' - '.$x['symbol'].' - '.$x['price'].'<br />';
                        } else {
                            echo 'No New Signals';
                        }
                }

    echo $row2[0];
}

此代码成功检测到一个新数据命中数据库。我现在正在努力的是修改代码以仅显示新检测到的数据片段，而不是您看到的整个数组。

新编辑: 我已经获得了只显示最新数据的代码，但现在我遇到了一个难题。 如果我每分钟轮询一次数据库，并且一条新数据命中数据库，脚本将拾取它——但是，如果在第一条新数据发送到目标后几秒内另一条新数据命中数据库，则第二条新作品将完全被忽略，因为投票将每分钟进行一次。我基本上必须每隔几秒轮询一次数据库……这听起来像是一场性能噩梦……

灰色的选项 1 显示最新数据，但会在基于分钟的轮询之前跳过较新的部分，除非每秒轮询一次数据库。 选项 2 有效，但显示整个数组...所以我不确定如何修改代码以仅显示最新的片段，而不是整个数组。

有什么建议吗？