通过PHP CLI实现简单的数据库实时监控调度

　　!#/usr/local/php/bin/php

　　<?php

　　mysql_connect('localhost', 'username', 'password');

　　mysql_select_db("test");

　　echo 'PID: '.posix_getpid().' '; //当前进程PID（linux下）

　　$old_id = 0;

　　while (1)

　　{

　　$sql = "SELECT `id` FROM `user` ORDER BY `id` DESC LIMIT 1";

　　$result = mysql_query($sql);

　　$item = mysql_fetch_assoc($result);

　　$new_id = $item['id'];

　　$values_arr = array();

　　for ($i=$new_id; $i>$old_id && $old_id!=0; $i--)

　　{

　　$sql = "SELECT `name`,`age` FROM `user` WHERE `id`='{$i}' LIMIT 1";

　　$result = mysql_query($sql);

　　$item = mysql_fetch_assoc($result);

　　$name = $item['name'];

　　$age = $item['age'];

　　$values_arr[] = "('{$name}', '{$age}')";

　　}

　　if (!emptyempty($values_arr))

　　{

　　$values_str = implode(',', $values_arr);

　　$sql = "INSERT INTO `user2`(`name`, `age`) VALUES {$values_str}";

　　mysql_query($sql);

　　}

　　$old_id = max($old_id, $new_id);

　　sleep(3); //3秒后进入下次循环

　　}