频道导航

• ▸ PHP
• ▸ Java
• ▸ Java SE
• ▸ Python
• ▸ C#
• ▸ C&C++
• ▸ Ruby
• ▸ VB
• ▸ asp.Net
• ▸ Go
• ▸ Perl
• ▸ netty
• ▸ Django
• ▸ Delphi
• ▸ Jsp
• ▸ .NET Core
• ▸ Spring
• ▸ Flask
• ▸ Springboot
• ▸ SpringMVC
• ▸ Lua
• ▸ Laravel
• ▸ Mybatis
• ▸ Asp
• ▸ Groovy
• ▸ ThinkPHP
• ▸ Yii
• ▸ swoole
• ▸ HTML
• ▸ HTML5
• ▸ JavaScript
• ▸ CSS
• ▸ jQuery
• ▸ Bootstrap
• ▸ Angularjs
• ▸ TypeScript
• ▸ Vue
• ▸ Dojo
• ▸ Json
• ▸ Electron
• ▸ Node.js
• ▸ extjs
• ▸ Express
• ▸ XML
• ▸ ES6
• ▸ Ajax
• ▸ Flash
• ▸ Unity
• ▸ React
• ▸ Flex
• ▸ Ant Design
• ▸ Web前端
• ▸ 微信小程序
• ▸ 微信公众号
• ▸ iOS
• ▸ Android
• ▸ Swift
• ▸ Hybrid
• ▸ Cocos2d-x
• ▸ Flutter
• ▸ Xcode
• ▸ Silverlight
• ▸ cocoa
• ▸ Cordova

• 前端之家
• PHP
• 通过PHP CLI实现简单的数据库实时监控调度

<div class="codebody" id="code60551">
!#/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秒后进入下次循环
}