设为首页 加入收藏

TOP

Linux下通过PHP对MySQL中的数据进行定时统计并入库
2014-11-24 03:32:22 来源: 作者: 【 】 浏览:0
Tags:Linux 通过 PHP MySQL 数据 进行 定时 统计 入库

本文讲解Linux下对数据库的数据进行统计计算并将结果入库到另一个表中。本文分3部分进行讲解:第一部分介绍:linux下执行php的命令;第二部分介绍:通过脚本实现统计前几个月的数据并入库;第三部分介绍:如何实现每日凌晨对昨日的数据进行统计并入库。


linux下执行php文件的命令为:php filename arguments


即:php 文件名 参数


Eg/usr/local/php/bin/php /home/zhaolincheung/insert_talkcountdata.php


例如,将之前60天内的数据统计入库。


首先,写一个shell文件talkcount_insert_db.sh,循环计算日期,并将该日期传给php文件,进行统计并入库。shell如下:


#!/bin/sh
for((i=1;i<=60;i++));
do
echo -e $i":";
day=`date -d "-"$i" day" "+%Y-%m-%d"`;
/usr/local/php/bin/php /home/zhaolincheung/insert_talkcountdata.php $day;
echo "";
done


而insert_talkcountdata.php是对某一天的数据统计并入库,如下:


< php
  include_once('/data/analys/DB/MyDB.class.php');
  
//定义大类的编号
$cidArr = array(0,2,1,11,15,14,7,6,4,12,5,13,16,3,9,1001,1002);


$yesterday = $_SERVER["argv"][1]; //获取php执行文件的参数
echo $yesterday . "\n";


//遍历大类并入库
foreach($cidArr as $cid){
//统计大类
insert_db($cid,$yesterday);
}

//根据指定的大类和日期,计算该天的消息量并入库
function insert_db($category, $date){
$dateArr = explode("-", $date);
if(checkdate($dateArr[1], $dateArr[2], $dateArr[0]) == false){
return false;
}
//将日期转为时间戳
$thisdate = mktime(0, 0, 0, $dateArr[1], $dateArr[2], $dateArr[0]);
$nextdate = $thisdate + 3600 * 24;


$sql = "select talkid,count(*) as msgcount from table1 where postcategoryid=$category ";
$sql .= " and updatetime >= $thisdate and updatetime < $nextdate group by talkid order by msgcount desc";


$db = new MyDB();
$res = $db->query($sql);

//初始化关联数组
$mc["c20"]=$mc["c10"]=$mc["c6"]=$mc["c5"]=$mc["c4"]=$mc["c3"]=$mc["c2"]=$mc["c1"]=0;
//分段统计消息数对应的会话数
while(($result = $db->fetch_assoc($res)))
{
$msgcount = $result["msgcount"];
if($msgcount > 20)
$mc["c20"]++;
else if($msgcount > 10 && $msgcount <= 20)
$mc["c10"]++;
else if($msgcount >= 6 && $msgcount <= 10)
$mc["c6"]++;
else if($msgcount == 5)
$mc["c5"]++;
else if($msgcount == 4)
$mc["c4"]++;
else if($msgcount == 3)
$mc["c3"]++;
else if($msgcount == 2)
$mc["c2"]++;
else if($msgcount == 1)
$mc["c1"]++;
}

//insert table 'talkcount'
$sql_insert = "insert into talkcount(analysisdate,postcategoryid,c20,c10,c6,c5,c4,c3,c2,c1) values('";
$sql_insert .= $date . "',";
$sql_insert .= $category . ",";
$sql_insert .= $mc["c20"] . ",";
$sql_insert .= $mc["c10"] . ",";
$sql_insert .= $mc["c6"] . ",";
$sql_insert .= $mc["c5"] . ",";
$sql_insert .= $mc["c4"] . ",";
$sql_insert .= $mc["c3"] . ",";
$sql_insert .= $mc["c2"] . ",";
$sql_insert .= $mc["c1"] . ")";

echo $sql_insert . "\n";

$db->query($sql_insert);

$db->close();
}
>



】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇Linux后台网络编程中select/poll/.. 下一篇Linux下处理实时日志生成另一个实..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

·工业机器人TCP校准中 (2025-12-25 05:19:17)
·opc 通讯协议与 TCP (2025-12-25 05:19:15)
·labview中tcp/ip通信 (2025-12-25 05:19:13)
·新书介绍《Python数 (2025-12-25 04:49:47)
·怎么利用 Python 进 (2025-12-25 04:49:45)