PHP数据库审计日志实现-源码库

PHP数据库审计日志实现：记录每一次数据变更

大家好，我是33blog的技术作者。今天想和大家分享一个在实际项目中非常重要的功能实现——数据库审计日志。记得在我之前参与的一个电商项目中，因为缺乏完善的审计日志，当出现数据异常时，排查问题简直是一场噩梦。从那以后，我就特别重视审计日志的实现。

为什么需要数据库审计日志？

审计日志不仅仅是记录谁在什么时候做了什么操作，更重要的是它能够：

追踪数据变更历史
满足合规性要求
快速定位问题根源
防止数据误操作

实现方案选择

经过多个项目的实践，我总结出几种常见的实现方式：

数据库触发器：性能好但维护困难
代码层面拦截：灵活可控，推荐使用
中间件方案：适合微服务架构

今天重点分享代码层面拦截的实现方式，这也是我在实际项目中最常用的方案。

数据库表设计

首先我们需要设计审计日志表，这里是我常用的表结构：

CREATE TABLE audit_logs (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    table_name VARCHAR(100) NOT NULL,
    record_id BIGINT NOT NULL,
    operation ENUM('INSERT', 'UPDATE', 'DELETE') NOT NULL,
    old_data JSON,
    new_data JSON,
    user_id INT,
    ip_address VARCHAR(45),
    user_agent TEXT,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
    INDEX idx_table_record (table_name, record_id),
    INDEX idx_created_at (created_at)
);

核心实现代码

接下来是PHP实现的核心部分。我习惯使用面向对象的方式封装：

pdo = $pdo;
        $this->currentUser = $currentUser;
    }
    
    public function log($tableName, $recordId, $operation, $oldData = null, $newData = null)
    {
        $sql = "INSERT INTO audit_logs 
                (table_name, record_id, operation, old_data, new_data, user_id, ip_address, user_agent) 
                VALUES (?, ?, ?, ?, ?, ?, ?, ?)";
        
        $stmt = $this->pdo->prepare($sql);
        
        return $stmt->execute([
            $tableName,
            $recordId,
            $operation,
            $oldData ? json_encode($oldData) : null,
            $newData ? json_encode($newData) : null,
            $this->currentUser,
            $_SERVER['REMOTE_ADDR'] ?? '127.0.0.1',
            $_SERVER['HTTP_USER_AGENT'] ?? ''
        ]);
    }
    
    // 封装常用的操作日志方法
    public function logInsert($tableName, $recordId, $newData)
    {
        return $this->log($tableName, $recordId, 'INSERT', null, $newData);
    }
    
    public function logUpdate($tableName, $recordId, $oldData, $newData)
    {
        return $this->log($tableName, $recordId, 'UPDATE', $oldData, $newData);
    }
    
    public function logDelete($tableName, $recordId, $oldData)
    {
        return $this->log($tableName, $recordId, 'DELETE', $oldData, null);
    }
}
?>

在实际业务中的使用

让我们看看如何在用户管理功能中使用审计日志：

pdo = $pdo;
        $this->auditLogger = $auditLogger;
    }
    
    public function updateUser($userId, $updateData)
    {
        // 获取更新前的数据
        $stmt = $this->pdo->prepare("SELECT * FROM users WHERE id = ?");
        $stmt->execute([$userId]);
        $oldData = $stmt->fetch(PDO::FETCH_ASSOC);
        
        // 执行更新操作
        $setParts = [];
        $params = [];
        foreach ($updateData as $field => $value) {
            $setParts[] = "{$field} = ?";
            $params[] = $value;
        }
        $params[] = $userId;
        
        $sql = "UPDATE users SET " . implode(', ', $setParts) . " WHERE id = ?";
        $stmt = $this->pdo->prepare($sql);
        $result = $stmt->execute($params);
        
        if ($result) {
            // 记录审计日志
            $this->auditLogger->logUpdate('users', $userId, $oldData, $updateData);
        }
        
        return $result;
    }
    
    public function deleteUser($userId)
    {
        // 获取删除前的数据
        $stmt = $this->pdo->prepare("SELECT * FROM users WHERE id = ?");
        $stmt->execute([$userId]);
        $oldData = $stmt->fetch(PDO::FETCH_ASSOC);
        
        // 执行删除
        $stmt = $this->pdo->prepare("DELETE FROM users WHERE id = ?");
        $result = $stmt->execute([$userId]);
        
        if ($result) {
            // 记录审计日志
            $this->auditLogger->logDelete('users', $userId, $oldData);
        }
        
        return $result;
    }
}
?>

踩坑经验与优化建议

在实际项目中，我踩过不少坑，这里分享几个重要的经验：

性能考虑：审计日志表会快速增长，记得定期归档和建立合适的索引
数据脱敏：敏感信息（如密码、身份证号）在记录前需要进行脱敏处理
异常处理：审计日志记录失败不应该影响主业务流程
异步处理：对于高并发场景，建议使用消息队列异步记录日志

异步处理实现示例

对于性能要求高的场景，可以使用Redis队列实现异步记录：

 $tableName,
            'record_id' => $recordId,
            'operation' => $operation,
            'old_data' => $oldData,
            'new_data' => $newData,
            'user_id' => $this->currentUser,
            'ip_address' => $_SERVER['REMOTE_ADDR'] ?? '127.0.0.1',
            'user_agent' => $_SERVER['HTTP_USER_AGENT'] ?? '',
            'created_at' => date('Y-m-d H:i:s')
        ];
        
        // 推送到Redis队列
        return $this->redis->lpush('audit_log_queue', json_encode($logData));
    }
}
?>