PHP中MySQL的二进制日志解析

在 PHP 中，你可以使用 mysqli 或 PDO 扩展来处理 MySQL 二进制日志（Binary Log）。二进制日志记录了所有更改数据库结构的操作，例如创建和删除表、插入、更新和删除数据等。这对于复制和数据恢复非常有用。

以下是使用 mysqli 和 PDO 扩展解析 MySQL 二进制日志的示例：

1. 使用 mysqli 扩展解析二进制日志：

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";

// 创建连接
$conn = new mysqli($servername, $username, $password, $dbname);

// 检查连接
if ($conn->connect_error) {
    die("连接失败: " . $conn->connect_error);
}

// 设置为从二进制日志读取模式
$conn->query("SET SQL_LOG_BIN=0");

// 查询二进制日志
$result = $conn->query("SHOW BINARY LOGS");

if ($result->num_rows > 0) {
    while($row = $result->fetch_assoc()) {
        $binlog_file = $row["File"];
        $binlog_position = $row["Position"];
        echo "Binary Log File: " . $binlog_file . ", Position: " . $binlog_position . "\n";

        // 读取并解析二进制日志事件
        $content = "";
        $handle = fopen($binlog_file, "rb");
        while (!feof($handle)) {
            $event = fread($handle, 4096);
            if (strlen($event) < 4) {
                break;
            }
            $event_type = ord($event[0]);
            if ($event_type == 2) { // 行复制事件
                $events = [];
                while (strlen($event) >= 8) {
                    $length = unpack('N', substr($event, 4, 4))[1];
                    $timestamp = unpack('N', substr($event, 8, 4))[1];
                    $log_data = substr($event, 12, $length);
                    $events[] = [$timestamp, $log_data];
                    $event = substr($event, 16 + $length);
                }
                foreach ($events as $event) {
                    echo "Timestamp: " . $event[0] . ", Data: " . $event[1] . "\n";
                }
            }
        }
        fclose($handle);
    }
} else {
    echo "没有找到二进制日志文件。\n";
}

// 重置为正常模式
$conn->query("SET SQL_LOG_BIN=1");

// 关闭连接
$conn->close();
?>

2. 使用 PDO 扩展解析二进制日志：

<?php
$servername = "localhost";
$username = "username";
$password = "password";
$dbname = "myDB";

try {
    $conn = new PDO("mysql:host=$servername;dbname=$dbname", $username, $password);
    $conn->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

    // 设置为从二进制日志读取模式
    $conn->exec("SET SQL_LOG_BIN=0");

    // 查询二进制日志
    $result = $conn->query("SHOW BINARY LOGS");

    if ($result->rowCount() > 0) {
        while ($row = $result->fetch()) {
            $binlog_file = $row["File"];
            $binlog_position = $row["Position"];
            echo "Binary Log File: " . $binlog_file . ", Position: " . $binlog_position . "\n";

            // 读取并解析二进制日志事件
            $content = "";
            $handle = fopen($binlog_file, "rb");
            while (!feof($handle)) {
                $event = fread($handle, 4096);
                if (strlen($event) < 4) {
                    break;
                }
                $event_type = ord($event[0]);
                if ($event_type == 2) { // 行复制事件
                    $events = [];
                    while (strlen($event) >= 8) {
                        $length = unpack('N', substr($event, 4, 4))[1];
                        $timestamp = unpack('N', substr($event, 8, 4))[1];
                        $log_data = substr($event, 12, $length);
                        $events[] = [$timestamp, $log_data];
                        $event = substr($event, 16 + $length);
                    }
                    foreach ($events as $event) {
                        echo "Timestamp: " . $event[0] . ", Data: " . $event[1] . "\n";
                    }
                }
            }
            fclose($handle);
        }
    } else {
        echo "没有找到二进制日志文件。\n";
    }

    // 重置为正常模式
    $conn->exec("SET SQL_LOG_BIN=1");
} catch (PDOException $e) {
    echo "连接失败: " . $e->getMessage();
}

// 关闭连接
$conn = null;
?>

请注意，这些示例仅适用于行复制事件。如果你需要处理其他类型的事件，你需要根据事件类型进行相应的解析。同时，这些示例可能需要根据你的实际需求进行调整。