المعاملات (Transactions)

-- بدء معاملة جديدة
START TRANSACTION;

-- أو
BEGIN;

-- حفظ جميع التغييرات في المعاملة
COMMIT;

-- إلغاء جميع التغييرات والعودة لحالة ما قبل المعاملة
ROLLBACK;

-- بدء المعاملة
START TRANSACTION;

-- إدراج موظف جديد
INSERT INTO employees (first_name, last_name, salary)
VALUES ('أحمد', 'محمد', 5000);

-- تحديث ميزانية القسم
UPDATE departments 
SET budget = budget + 5000 
WHERE department_name = 'IT';

-- تأكيد المعاملة (حفظ التغييرات)
COMMIT;

-- الآن التغييرات محفوظة نهائياً

-- بدء المعاملة
START TRANSACTION;

-- حذف جميع الموظفين (خطأ!)
DELETE FROM employees;

-- التحقق من عدد الصفوف المحذوفة
SELECT COUNT(*) FROM employees; -- النتيجة: 0

-- إلغاء المعاملة (استرجاع البيانات)
ROLLBACK;

-- التحقق مرة أخرى
SELECT COUNT(*) FROM employees; -- الموظفون عادوا!

-- جدول الحسابات البنكية
CREATE TABLE accounts (
    account_id INT PRIMARY KEY AUTO_INCREMENT,
    account_holder VARCHAR(100) NOT NULL,
    balance DECIMAL(15, 2) NOT NULL DEFAULT 0,
    CHECK (balance >= 0)
);

-- إدراج حسابين للاختبار
INSERT INTO accounts (account_holder, balance)
VALUES 
    ('أحمد محمد', 10000.00),
    ('فاطمة علي', 5000.00);

-- بدء المعاملة
START TRANSACTION;

-- خصم 1000 من حساب أحمد (ID = 1)
UPDATE accounts 
SET balance = balance - 1000 
WHERE account_id = 1;

-- إضافة 1000 لحساب فاطمة (ID = 2)
UPDATE accounts 
SET balance = balance + 1000 
WHERE account_id = 2;

-- التحقق من الأرصدة
SELECT * FROM accounts;

-- تأكيد المعاملة
COMMIT;

-- الآن التحويل مكتمل ومحفوظ نهائياً

-- بدء المعاملة
START TRANSACTION;

-- محاولة خصم 15000 من حساب أحمد (رصيده 9000 فقط)
UPDATE accounts 
SET balance = balance - 15000 
WHERE account_id = 1;
-- هذا سيفشل بسبب قيد CHECK (balance >= 0)

-- بما أن العملية فشلت، نلغي المعاملة
ROLLBACK;

-- الرصيد لم يتغير

-- بدء المعاملة
START TRANSACTION;

-- عملية 1: إدراج موظف
INSERT INTO employees (first_name, last_name, salary)
VALUES ('سارة', 'أحمد', 4000);

-- إنشاء نقطة حفظ
SAVEPOINT after_insert;

-- عملية 2: تحديث الراتب
UPDATE employees SET salary = salary * 1.1 WHERE last_name = 'أحمد';

-- إنشاء نقطة حفظ أخرى
SAVEPOINT after_update;

-- عملية 3: حذف (خطأ!)
DELETE FROM employees WHERE department = 'IT';

-- العودة لنقطة الحفظ الثانية (إلغاء الحذف فقط)
ROLLBACK TO SAVEPOINT after_update;

-- تأكيد المعاملة (الإدراج والتحديث محفوظان، الحذف ملغى)
COMMIT;

START TRANSACTION;

-- 1. إنشاء الطلب
INSERT INTO orders (customer_id, order_date, total_amount)
VALUES (1, NOW(), 0);

SET @order_id = LAST_INSERT_ID();
SAVEPOINT order_created;

-- 2. إضافة منتجات للطلب
INSERT INTO order_items (order_id, product_id, quantity, price)
VALUES (@order_id, 101, 2, 50.00);

SAVEPOINT items_added;

-- 3. تحديث المخزون
UPDATE products SET stock = stock - 2 WHERE product_id = 101;

SAVEPOINT stock_updated;

-- 4. حساب الإجمالي
UPDATE orders SET total_amount = (
    SELECT SUM(quantity * price) FROM order_items WHERE order_id = @order_id
) WHERE order_id = @order_id;

-- إذا حدث خطأ في أي مرحلة، يمكن الرجوع لنقطة حفظ معينة
-- مثلاً: ROLLBACK TO SAVEPOINT items_added;

-- تأكيد المعاملة
COMMIT;

-- تعيين مستوى العزل للمعاملة التالية
SET TRANSACTION ISOLATION LEVEL READ COMMITTED;
START TRANSACTION;
-- عمليات المعاملة
COMMIT;

-- أو تعيين مستوى العزل للجلسة بالكامل
SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;

-- عرض مستوى العزل الحالي
SELECT @@transaction_isolation;

DELIMITER //

CREATE PROCEDURE transfer_money(
    IN from_account INT,
    IN to_account INT,
    IN amount DECIMAL(15, 2),
    OUT success BOOLEAN,
    OUT message VARCHAR(255)
)
BEGIN
    DECLARE from_balance DECIMAL(15, 2);
    DECLARE EXIT HANDLER FOR SQLEXCEPTION
    BEGIN
        ROLLBACK;
        SET success = FALSE;
        SET message = 'فشلت عملية التحويل';
    END;
    
    -- بدء المعاملة
    START TRANSACTION;
    
    -- التحقق من الرصيد
    SELECT balance INTO from_balance
    FROM accounts
    WHERE account_id = from_account;
    
    IF from_balance < amount THEN
        ROLLBACK;
        SET success = FALSE;
        SET message = 'الرصيد غير كافٍ';
    ELSE
        -- خصم المبلغ
        UPDATE accounts 
        SET balance = balance - amount 
        WHERE account_id = from_account;
        
        -- إضافة المبلغ
        UPDATE accounts 
        SET balance = balance + amount 
        WHERE account_id = to_account;
        
        -- تأكيد المعاملة
        COMMIT;
        SET success = TRUE;
        SET message = 'تمت عملية التحويل بنجاح';
    END IF;
END //

DELIMITER ;

-- استخدام الإجراء
CALL transfer_money(1, 2, 500, @success, @message);
SELECT @success, @message;

CREATE TABLE flights (
    flight_id INT PRIMARY KEY,
    flight_number VARCHAR(10),
    available_seats INT,
    price DECIMAL(10, 2)
);

CREATE TABLE bookings (
    booking_id INT PRIMARY KEY AUTO_INCREMENT,
    flight_id INT,
    passenger_name VARCHAR(100),
    seat_number VARCHAR(5),
    booking_date DATETIME DEFAULT CURRENT_TIMESTAMP,
    FOREIGN KEY (flight_id) REFERENCES flights(flight_id)
);

CREATE TABLE payments (
    payment_id INT PRIMARY KEY AUTO_INCREMENT,
    booking_id INT,
    amount DECIMAL(10, 2),
    payment_status VARCHAR(20),
    FOREIGN KEY (booking_id) REFERENCES bookings(booking_id)
);

DELIMITER //

CREATE PROCEDURE book_flight(
    IN p_flight_id INT,
    IN p_passenger_name VARCHAR(100),
    IN p_seat_number VARCHAR(5),
    OUT p_booking_id INT,
    OUT p_success BOOLEAN,
    OUT p_message VARCHAR(255)
)
BEGIN
    DECLARE v_available_seats INT;
    DECLARE v_price DECIMAL(10, 2);
    
    DECLARE EXIT HANDLER FOR SQLEXCEPTION
    BEGIN
        ROLLBACK;
        SET p_success = FALSE;
        SET p_message = 'فشل الحجز بسبب خطأ في النظام';
        SET p_booking_id = 0;
    END;
    
    START TRANSACTION;
    
    -- التحقق من توفر المقاعد
    SELECT available_seats, price
    INTO v_available_seats, v_price
    FROM flights
    WHERE flight_id = p_flight_id
    FOR UPDATE; -- قفل الصف لمنع الحجوزات المتزامنة
    
    IF v_available_seats <= 0 THEN
        ROLLBACK;
        SET p_success = FALSE;
        SET p_message = 'لا توجد مقاعد متاحة';
        SET p_booking_id = 0;
    ELSE
        -- إنشاء الحجز
        INSERT INTO bookings (flight_id, passenger_name, seat_number)
        VALUES (p_flight_id, p_passenger_name, p_seat_number);
        
        SET p_booking_id = LAST_INSERT_ID();
        
        -- تسجيل الدفع
        INSERT INTO payments (booking_id, amount, payment_status)
        VALUES (p_booking_id, v_price, 'pending');
        
        -- تحديث المقاعد المتاحة
        UPDATE flights
        SET available_seats = available_seats - 1
        WHERE flight_id = p_flight_id;
        
        COMMIT;
        SET p_success = TRUE;
        SET p_message = 'تم الحجز بنجاح';
    END IF;
END //

DELIMITER ;

-- اختبار الإجراء
INSERT INTO flights VALUES (1, 'SA123', 50, 500.00);

CALL book_flight(1, 'أحمد محمد', '12A', @booking_id, @success, @msg);
SELECT @booking_id, @success, @msg;

-- هذا الأمر يُنفذ في معاملة ضمنية
INSERT INTO employees (first_name, last_name) VALUES ('أحمد', 'محمد');
-- يُلتزم به تلقائياً بعد التنفيذ

-- تعطيل Auto-commit
SET autocommit = 0;

-- الآن جميع الأوامر تحتاج COMMIT يدوي
INSERT INTO employees (first_name, last_name) VALUES ('سارة', 'أحمد');
UPDATE employees SET salary = 5000 WHERE employee_id = 1;

-- يجب تأكيد التغييرات يدوياً
COMMIT;

-- إعادة تفعيل Auto-commit
SET autocommit = 1;