如何通過binlog獲取我們想要的MySql語句？

/**
* @return $this
*/
protected function parseSql
{
$fillFileHandler = fopen(__DIR__ . "/data/file.sql", "r");
$sqlArr = ;
if ($this->_type == "ROW") {
$match = NULL;
$sqlStr = "";
while (($sql = fgets($fillFileHandler)) !== false) {
if (($match = preg_match("/UPDATE|INSERT|DELETE/", $sql)) || strrpos($sql, "end_log_pos") !== false) {
# 如果有指定表
if ($match && $this->_table && strpos($sql, $this->_table) === false) continue;
$sqlStr == "" || array_push($sqlArr, $sqlStr);
$sqlStr = $match ? trim(substr($sql, 3, -1)) . " " : "";
} elseif (strpos($sql, "@") !== false || strpos($sql, "SET")) {
$sqlStr .= trim(substr($sql, 3, -1)) . " ";
}
}
$sqlStr == "" || array_push($sqlArr, $sqlStr);
} else {
# statement 和 mixed格式一樣
while (($sql = fgets($fillFileHandler)) !== false) {
$sql = trim($sql);
if (preg_match("/(UPDATE|INSERT|DELETE)s+/", $sql)) {
array_push($sqlArr, $sql);
}
}
}
$sqlArr = array_map(function ($value) {
return preg_replace_callback("/(@(d+))/", function ($matches) use ($value) {
$parts = explode(".", $value);
return $this->getTableColumns(explode("`", array_pop($parts))[1])[$matches[2] - 1];
}, $value);
}, $sqlArr);

$mysqlFile = Util::getFile(__DIR__ . "/data/mysql.sql");

array_map(function ($value) use ($mysqlFile) {
file_put_contents($mysqlFile, $value . PHP_EOL, FILE_APPEND);
}, $sqlArr);
fclose($fillFileHandler);

return $this;
}