PHP数据库触发器与事件调度-源码库

PHP数据库触发器与事件调度：实战经验与避坑指南

作为一名长期与PHP和MySQL打交道的开发者，我发现很多同行对数据库的触发器（Triggers）和事件调度（Event Scheduler）了解不深。今天我就结合自己的实战经验，带大家深入理解这两个强大的数据库功能。

什么是数据库触发器？

触发器就像是数据库的”自动应答机” – 当特定事件（INSERT、UPDATE、DELETE）发生时，它会自动执行预设的SQL语句。我在用户积分系统中就经常用到它。

-- 创建用户表
CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    points INT DEFAULT 0
);

-- 创建积分变更日志表
CREATE TABLE points_log (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id INT,
    old_points INT,
    new_points INT,
    change_time TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

实战：创建用户积分变更触发器

下面这个触发器是我在电商项目中实际使用的，它能自动记录用户积分的每次变更：

DELIMITER $$
CREATE TRIGGER track_points_change 
    AFTER UPDATE ON users
    FOR EACH ROW
BEGIN
    IF OLD.points != NEW.points THEN
        INSERT INTO points_log (user_id, old_points, new_points)
        VALUES (NEW.id, OLD.points, NEW.points);
    END IF;
END$$
DELIMITER ;

踩坑提示：记得使用DELIMITER改变语句结束符，否则分号会导致触发器创建失败。这个坑我当初踩了好几次！

在PHP中测试触发器

让我们用PHP代码来测试这个触发器是否正常工作：

prepare("UPDATE users SET points = points + 100 WHERE id = ?");
$stmt->execute([1]);

// 检查日志记录
$logStmt = $pdo->query("SELECT * FROM points_log WHERE user_id = 1");
$logs = $logStmt->fetchAll(PDO::FETCH_ASSOC);

echo "积分变更记录：n";
print_r($logs);
?>

事件调度：数据库的定时任务

事件调度器让数据库能够定期执行任务，就像Linux的cron job。我在清理过期数据时特别依赖它。

-- 启用事件调度器（如果未启用）
SET GLOBAL event_scheduler = ON;

-- 创建每天清理30天前日志的事件
CREATE EVENT clean_old_logs
ON SCHEDULE EVERY 1 DAY
STARTS CURRENT_TIMESTAMP
DO
    DELETE FROM points_log 
    WHERE change_time < DATE_SUB(NOW(), INTERVAL 30 DAY);

PHP中管理事件调度

我们可以通过PHP来动态管理这些事件：

pdo = $pdo;
    }
    
    public function createCleanupEvent($table, $days = 30) {
        $sql = "CREATE EVENT clean_{$table}
                ON SCHEDULE EVERY 1 DAY
                DO
                    DELETE FROM {$table} 
                    WHERE created_at < DATE_SUB(NOW(), INTERVAL {$days} DAY)";
        
        return $this->pdo->exec($sql);
    }
    
    public function showEvents() {
        return $this->pdo->query("SHOW EVENTS")->fetchAll();
    }
}

// 使用示例
$eventManager = new DatabaseEventManager($pdo);
$eventManager->createCleanupEvent('points_log', 30);
$events = $eventManager->showEvents();
?>