用PHP提取MYSQL二进制日志的SQL语句

    上一篇说道，在从日志提取出SQL语句的时候，碰到了一句SQL跨了N行无法提取。后来在网上搜了两句shell:

sed -n '/^INSERT /,/;/p' log.sql > log_insert.sql

sed -n '/^UPDATE /,/;/p' log.sql > log_update.sql

    后经实践发现，这两句shell也是有缺陷的。这个问题是必须解决的，今天就趁这机会用php实现了跨行SQL的提取。注释已经很明了了，只需要注意变量$action为提取的SQL语句头，如DELETE、INSERT、UPDATE等，而变量$table为表名。

    过后我还会找时间写个shell版本，尽量用最简洁的方式来实现，本菜自己也很期等啊。

 w1 <?php
//需要用mysqlbinlog将二进制文件转为要阅读明文
//第45行得到的$sql变量为过滤后的干净的sql
//有些二进制日志的sql后会有5个非可见字符，有些日志里却没有，暂时不知道什么原因，请自行开启filter_sql过滤的注释
//只要实现proc_sql函数，即可对最终的sql变量进行处理

$action='INSERT';
$table='table';


$fp=fopen('bin_log.txt','rb+');
if(!$fp) exit('ERR: file error');
$delimiter='/*!*/;'.chr(0x0a);

//
while(!feof($fp))
{
    $sql='';
    $str=fgets($fp,8192);
    if(strstr($str,$action) && strstr($str,$table))
    {
        $sql=$str;
        
        while(!feof($fp))
        {
            if(substr($sql,-7)==$delimiter)
            {
                $sql=substr($sql,0,-7);
                break;
            }
            
            $str=fgets($fp,8192);
            $sql.=$str;
        }
        
        if(feof($fp))
        {
            if(substr($sql,-7)==$delimiter)
            {
                $sql=substr($sql,0,-7);
                break;
            }
        }
        
        $sql=fileter_sql($sql);
        proc_sql($sql);
    }
}



fclose($fp);

function fileter_sql($sql)
{
    return $sql;
    //return substr($sql,0,-5);
}

function proc_sql($sql)
{
    echo $sql,PHP_EOL,PHP_EOL,PHP_EOL;
}