المشغلات (Triggers)

DELIMITER //

CREATE TRIGGER trigger_name
{BEFORE | AFTER} {INSERT | UPDATE | DELETE}
ON table_name
FOR EACH ROW
BEGIN
    -- أوامر SQL هنا
END //

DELIMITER ;

-- جدول الموظفين
CREATE TABLE employees (
    employee_id INT PRIMARY KEY AUTO_INCREMENT,
    first_name VARCHAR(50),
    last_name VARCHAR(50),
    salary DECIMAL(10, 2),
    created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);

-- جدول سجل التدقيق
CREATE TABLE employee_audit (
    audit_id INT PRIMARY KEY AUTO_INCREMENT,
    employee_id INT,
    action VARCHAR(50),
    action_date DATETIME DEFAULT CURRENT_TIMESTAMP
);

-- مشغل يُنفذ بعد إدراج موظف جديد
DELIMITER //

CREATE TRIGGER after_employee_insert
AFTER INSERT ON employees
FOR EACH ROW
BEGIN
    INSERT INTO employee_audit (employee_id, action)
    VALUES (NEW.employee_id, 'تم إضافة موظف جديد');
END //

DELIMITER ;

-- اختبار المشغل
INSERT INTO employees (first_name, last_name, salary)
VALUES ('أحمد', 'محمد', 5000);

-- التحقق من سجل التدقيق
SELECT * FROM employee_audit;

-- مشغل يحول البريد الإلكتروني إلى أحرف صغيرة قبل الحفظ
DELIMITER //

CREATE TRIGGER before_employee_insert
BEFORE INSERT ON employees
FOR EACH ROW
BEGIN
    -- تحويل البريد الإلكتروني إلى أحرف صغيرة
    SET NEW.email = LOWER(NEW.email);
    
    -- التأكد من أن الراتب لا يقل عن الحد الأدنى
    IF NEW.salary < 3000 THEN
        SET NEW.salary = 3000;
    END IF;
END //

DELIMITER ;

-- اختبار
INSERT INTO employees (first_name, last_name, email, salary)
VALUES ('فاطمة', 'أحمد', 'FATIMA@EXAMPLE.COM', 2500);

-- البريد سيُحفظ بأحرف صغيرة والراتب سيكون 3000

-- جدول لحفظ تاريخ تغييرات الرواتب
CREATE TABLE salary_history (
    history_id INT PRIMARY KEY AUTO_INCREMENT,
    employee_id INT,
    old_salary DECIMAL(10, 2),
    new_salary DECIMAL(10, 2),
    changed_at DATETIME DEFAULT CURRENT_TIMESTAMP,
    changed_by VARCHAR(100)
);

-- مشغل يحفظ تاريخ تغييرات الراتب
DELIMITER //

CREATE TRIGGER after_salary_update
AFTER UPDATE ON employees
FOR EACH ROW
BEGIN
    -- فقط إذا تغير الراتب
    IF OLD.salary != NEW.salary THEN
        INSERT INTO salary_history (employee_id, old_salary, new_salary, changed_by)
        VALUES (NEW.employee_id, OLD.salary, NEW.salary, USER());
    END IF;
END //

DELIMITER ;

-- اختبار
UPDATE employees SET salary = 6000 WHERE employee_id = 1;

-- التحقق من السجل
SELECT * FROM salary_history;

-- مشغل يمنع تخفيض الراتب بأكثر من 10%
DELIMITER //

CREATE TRIGGER before_salary_decrease
BEFORE UPDATE ON employees
FOR EACH ROW
BEGIN
    IF NEW.salary < OLD.salary THEN
        -- حساب نسبة التخفيض
        IF (OLD.salary - NEW.salary) / OLD.salary > 0.10 THEN
            -- إلغاء التحديث برفع خطأ
            SIGNAL SQLSTATE '45000'
            SET MESSAGE_TEXT = 'لا يمكن تخفيض الراتب بأكثر من 10%';
        END IF;
    END IF;
END //

DELIMITER ;

-- هذا سيفشل
UPDATE employees SET salary = 2000 WHERE employee_id = 1 AND salary = 5000;

-- جدول لحفظ الموظفين المحذوفين
CREATE TABLE deleted_employees (
    deleted_id INT PRIMARY KEY AUTO_INCREMENT,
    employee_id INT,
    first_name VARCHAR(50),
    last_name VARCHAR(50),
    email VARCHAR(100),
    salary DECIMAL(10, 2),
    deleted_at DATETIME DEFAULT CURRENT_TIMESTAMP,
    deleted_by VARCHAR(100)
);

-- مشغل يحفظ نسخة من الموظف قبل الحذف
DELIMITER //

CREATE TRIGGER before_employee_delete
BEFORE DELETE ON employees
FOR EACH ROW
BEGIN
    INSERT INTO deleted_employees (
        employee_id, 
        first_name, 
        last_name, 
        email, 
        salary,
        deleted_by
    )
    VALUES (
        OLD.employee_id,
        OLD.first_name,
        OLD.last_name,
        OLD.email,
        OLD.salary,
        USER()
    );
END //

DELIMITER ;

-- اختبار
DELETE FROM employees WHERE employee_id = 1;

-- التحقق من النسخة المحفوظة
SELECT * FROM deleted_employees;

-- مشغل يحذف جميع الطلبات عند حذف عميل
DELIMITER //

CREATE TRIGGER after_customer_delete
AFTER DELETE ON customers
FOR EACH ROW
BEGIN
    -- حذف جميع طلبات العميل
    DELETE FROM orders WHERE customer_id = OLD.customer_id;
    
    -- حفظ سجل في جدول التدقيق
    INSERT INTO audit_log (action, description)
    VALUES ('DELETE_CUSTOMER', CONCAT('تم حذف العميل: ', OLD.customer_name));
END //

DELIMITER ;

-- جدول المنتجات
CREATE TABLE products (
    product_id INT PRIMARY KEY AUTO_INCREMENT,
    product_name VARCHAR(100),
    stock_quantity INT DEFAULT 0,
    price DECIMAL(10, 2)
);

-- جدول المبيعات
CREATE TABLE sales (
    sale_id INT PRIMARY KEY AUTO_INCREMENT,
    product_id INT,
    quantity_sold INT,
    sale_date DATETIME DEFAULT CURRENT_TIMESTAMP,
    total_amount DECIMAL(10, 2),
    FOREIGN KEY (product_id) REFERENCES products(product_id)
);

-- جدول سجل المخزون
CREATE TABLE inventory_log (
    log_id INT PRIMARY KEY AUTO_INCREMENT,
    product_id INT,
    change_type VARCHAR(20),
    quantity_change INT,
    old_quantity INT,
    new_quantity INT,
    log_date DATETIME DEFAULT CURRENT_TIMESTAMP
);

-- 1. مشغل BEFORE INSERT للتحقق من توفر المخزون
DELIMITER //

CREATE TRIGGER before_sale_insert
BEFORE INSERT ON sales
FOR EACH ROW
BEGIN
    DECLARE available_stock INT;
    DECLARE product_price DECIMAL(10, 2);
    
    -- الحصول على الكمية المتاحة والسعر
    SELECT stock_quantity, price 
    INTO available_stock, product_price
    FROM products
    WHERE product_id = NEW.product_id;
    
    -- التحقق من توفر الكمية
    IF available_stock < NEW.quantity_sold THEN
        SIGNAL SQLSTATE '45000'
        SET MESSAGE_TEXT = 'الكمية المطلوبة غير متوفرة في المخزون';
    END IF;
    
    -- حساب المبلغ الإجمالي تلقائياً
    SET NEW.total_amount = NEW.quantity_sold * product_price;
END //

DELIMITER ;

-- 2. مشغل AFTER INSERT لتحديث المخزون
DELIMITER //

CREATE TRIGGER after_sale_insert
AFTER INSERT ON sales
FOR EACH ROW
BEGIN
    DECLARE old_stock INT;
    DECLARE new_stock INT;
    
    -- الحصول على الكمية القديمة
    SELECT stock_quantity INTO old_stock
    FROM products
    WHERE product_id = NEW.product_id;
    
    -- تحديث المخزون
    UPDATE products
    SET stock_quantity = stock_quantity - NEW.quantity_sold
    WHERE product_id = NEW.product_id;
    
    -- حساب الكمية الجديدة
    SET new_stock = old_stock - NEW.quantity_sold;
    
    -- حفظ سجل التغيير
    INSERT INTO inventory_log (
        product_id, 
        change_type, 
        quantity_change,
        old_quantity,
        new_quantity
    )
    VALUES (
        NEW.product_id,
        'SALE',
        -NEW.quantity_sold,
        old_stock,
        new_stock
    );
END //

DELIMITER ;

-- 3. مشغل لإلغاء البيع (عند الحذف)
DELIMITER //

CREATE TRIGGER after_sale_delete
AFTER DELETE ON sales
FOR EACH ROW
BEGIN
    DECLARE old_stock INT;
    
    SELECT stock_quantity INTO old_stock
    FROM products
    WHERE product_id = OLD.product_id;
    
    -- إرجاع الكمية للمخزون
    UPDATE products
    SET stock_quantity = stock_quantity + OLD.quantity_sold
    WHERE product_id = OLD.product_id;
    
    -- حفظ سجل الإرجاع
    INSERT INTO inventory_log (
        product_id,
        change_type,
        quantity_change,
        old_quantity,
        new_quantity
    )
    VALUES (
        OLD.product_id,
        'RETURN',
        OLD.quantity_sold,
        old_stock,
        old_stock + OLD.quantity_sold
    );
END //

DELIMITER ;

-- إضافة منتج
INSERT INTO products (product_name, stock_quantity, price)
VALUES ('لابتوب', 50, 3000);

-- بيع 5 قطع (سيحدث المخزون تلقائياً)
INSERT INTO sales (product_id, quantity_sold)
VALUES (1, 5);

-- التحقق من المخزون (يجب أن يكون 45)
SELECT * FROM products WHERE product_id = 1;

-- التحقق من سجل المخزون
SELECT * FROM inventory_log;

-- محاولة بيع كمية غير متوفرة (سيفشل)
INSERT INTO sales (product_id, quantity_sold)
VALUES (1, 100);

-- جدول التدقيق الشامل
CREATE TABLE audit_trail (
    audit_id INT PRIMARY KEY AUTO_INCREMENT,
    table_name VARCHAR(50),
    operation VARCHAR(10),
    record_id INT,
    old_values TEXT,
    new_values TEXT,
    changed_by VARCHAR(100),
    changed_at DATETIME DEFAULT CURRENT_TIMESTAMP
);

-- مشغل INSERT
DELIMITER //

CREATE TRIGGER audit_employee_insert
AFTER INSERT ON employees
FOR EACH ROW
BEGIN
    INSERT INTO audit_trail (table_name, operation, record_id, new_values, changed_by)
    VALUES (
        'employees',
        'INSERT',
        NEW.employee_id,
        CONCAT('Name: ', NEW.first_name, ' ', NEW.last_name, ', Salary: ', NEW.salary),
        USER()
    );
END //

DELIMITER ;

-- مشغل UPDATE
DELIMITER //

CREATE TRIGGER audit_employee_update
AFTER UPDATE ON employees
FOR EACH ROW
BEGIN
    INSERT INTO audit_trail (
        table_name, 
        operation, 
        record_id, 
        old_values, 
        new_values, 
        changed_by
    )
    VALUES (
        'employees',
        'UPDATE',
        NEW.employee_id,
        CONCAT('Name: ', OLD.first_name, ' ', OLD.last_name, ', Salary: ', OLD.salary),
        CONCAT('Name: ', NEW.first_name, ' ', NEW.last_name, ', Salary: ', NEW.salary),
        USER()
    );
END //

DELIMITER ;

-- مشغل DELETE
DELIMITER //

CREATE TRIGGER audit_employee_delete
BEFORE DELETE ON employees
FOR EACH ROW
BEGIN
    INSERT INTO audit_trail (table_name, operation, record_id, old_values, changed_by)
    VALUES (
        'employees',
        'DELETE',
        OLD.employee_id,
        CONCAT('Name: ', OLD.first_name, ' ', OLD.last_name, ', Salary: ', OLD.salary),
        USER()
    );
END //

DELIMITER ;

-- عرض جميع المشغلات في قاعدة البيانات
SHOW TRIGGERS;

-- عرض مشغلات جدول معين
SHOW TRIGGERS WHERE `Table` = 'employees';

-- عرض تعريف مشغل معين
SHOW CREATE TRIGGER after_employee_insert;

-- من جداول النظام
SELECT 
    TRIGGER_NAME,
    EVENT_MANIPULATION,
    EVENT_OBJECT_TABLE,
    ACTION_TIMING
FROM information_schema.TRIGGERS
WHERE TRIGGER_SCHEMA = DATABASE();

-- حذف مشغل
DROP TRIGGER after_employee_insert;

-- حذف آمن
DROP TRIGGER IF EXISTS after_employee_insert;