mysql 数据库通知

DELIMITER //

CREATE TRIGGER after_customer_insert
AFTER INSERT ON customers
FOR EACH ROW
BEGIN
    CALL send_notification('customer_inserted', NEW.id);
END //

CREATE PROCEDURE send_notification(IN event_name VARCHAR(255), IN event_data INT)
BEGIN
    -- 这里可以编写发送通知的逻辑，例如插入到通知表或调用外部API
    INSERT INTO notifications (event_name, event_data, created_at) VALUES (event_name, event_data, NOW());
END //

DELIMITER ;

DELIMITER //

CREATE EVENT check_orders
ON SCHEDULE EVERY 1 MINUTE
DO
BEGIN
    CALL process_orders();
END //

CREATE PROCEDURE process_orders()
BEGIN
    -- 这里可以编写处理订单的逻辑
    -- ...

    -- 发送通知
    CALL send_notification('orders_processed', NOW());
END //

DELIMITER ;