Microsoft Technologies Transaction Management এবং Concurrency Control গাইড ও নোট

Transaction Management এবং Concurrency Control হল ডেটাবেস পরিচালনার দুটি গুরুত্বপূর্ণ অংশ, যা অ্যাপ্লিকেশন এর ডেটা এক্সেস এবং সংশ্লিষ্ট অপারেশনগুলির সঠিকতা ও নির্ভরযোগ্যতা নিশ্চিত করে। NHibernate এ এই দুটি ধারণা খুবই গুরুত্বপূর্ণ, কারণ তারা ডেটাবেসের সাথে সংঘর্ষ প্রতিরোধ এবং একাধিক ব্যবহারকারীর অ্যাক্সেস নিয়ন্ত্রণে সহায়তা করে।

1. Transaction Management

Transaction Management একটি সিস্টেমের মধ্যে একাধিক অপারেশন (যেমন ডেটা ইনসার্ট, আপডেট বা ডিলিট) একত্রিত করে একটি একক আণবিক অপারেশন হিসেবে সম্পাদন করার প্রক্রিয়া। একটি ট্রানজেকশন বা লেনদেন সব অপারেশনগুলো সফলভাবে শেষ না হওয়া পর্যন্ত সঠিকভাবে কার্যকর হতে পারে না। যদি ট্রানজেকশনের মধ্যে কোনো একটি অপারেশন ব্যর্থ হয়, তবে সমস্ত পরিবর্তন বাতিল করা হয় (roll back), যাতে ডেটাবেসের অখণ্ডতা বজায় থাকে।

NHibernate এ Transaction Management

NHibernate এ ট্রানজেকশন ব্যবস্থাপনা সাধারণত Session এর সাথে কাজ করে। একটি Session তৈরি হলে, আপনি একটি Transaction শুরু করতে পারেন, এবং এই ট্রানজেকশনের মধ্যে সমস্ত ডেটাবেস অপারেশন করা হয়।

using (var session = sessionFactory.OpenSession())
{
    var transaction = session.BeginTransaction();

    try
    {
        var employee = new Employee { Name = "John Doe", Age = 30 };
        session.Save(employee);

        // অন্যান্য ডেটাবেস অপারেশন

        transaction.Commit();  // ট্রানজেকশন সফলভাবে শেষ হলে কমিট করা হবে
    }
    catch (Exception ex)
    {
        transaction.Rollback();  // কোনো সমস্যা হলে ট্রানজেকশন রোলব্যাক
        Console.WriteLine("Error: " + ex.Message);
    }
}

এখানে:

• BeginTransaction() দ্বারা ট্রানজেকশন শুরু করা হচ্ছে।
• Commit() মেথড ব্যবহার করে ট্রানজেকশন সফলভাবে সম্পন্ন হলে সমস্ত পরিবর্তন ডেটাবেসে সংরক্ষিত হয়।
• Rollback() মেথড ব্যবহার করে, যদি কোনো সমস্যা হয়, তবে সমস্ত পরিবর্তন বাতিল হয়ে যায় এবং ডেটাবেস আগের অবস্থায় ফিরে যায়।

2. Concurrency Control

Concurrency Control হল এমন একটি প্রক্রিয়া, যার মাধ্যমে একাধিক ব্যবহারকারী বা থ্রেড একসাথে একই ডেটা বা রেকর্ড আপডেট করার সময় ডেটাবেসের অখণ্ডতা রক্ষা করা হয়। যখন একাধিক ব্যবহারকারী একে অপরের সাথে সংঘর্ষের মধ্যে কাজ করেন, তখন ডেটাবেসের Consistency এবং Isolation সঠিকভাবে বজায় রাখা উচিত।

Concurrency Control এর ধরন

1. Optimistic Concurrency Control (OCC):
   • এই পদ্ধতিতে, ডেটা আপডেট করার আগে কোনও "lock" তৈরি করা হয় না।
   • যদি একজন ব্যবহারকারী ডেটা পরিবর্তন করতে গেলে অন্য ব্যবহারকারী একই রেকর্ডে পরিবর্তন করার চেষ্টা করেন, তখন versioning বা timestamp ব্যবহার করে চেক করা হয় যে ডেটার মধ্যে কোন পরিবর্তন হয়েছে কিনা।
   • যদি পরিবর্তন হয়ে থাকে, তবে Exception ছোঁড়া হয় বা কনফ্লিক্টের বার্তা দেখানো হয়।
2. Pessimistic Concurrency Control (PCC):
   • এই পদ্ধতিতে, যখন কোনো ব্যবহারকারী ডেটা দেখবে বা পরিবর্তন করবে, তখন ওই রেকর্ডে একটি "lock" বসিয়ে দেওয়া হয়।
   • এটি অন্য ব্যবহারকারীকে সেই রেকর্ডের উপর কাজ করতে বাধা দেয় যতক্ষণ না প্রথম ব্যবহারকারী কাজ শেষ করে এবং "unlock" করে দেয়।
   • এই পদ্ধতিতে locking ব্যবহার করা হয়, যা কিছু ক্ষেত্রে কার্যকরী হলেও, অনেক সময় কর্মক্ষমতা সমস্যার সৃষ্টি করতে পারে।

3. NHibernate এ Concurrency Control

NHibernate এ Concurrency Control দুটি প্রধান পদ্ধতি ব্যবহার করে কার্যকরী করা হয়: Optimistic Locking এবং Pessimistic Locking।

Optimistic Locking

Optimistic Locking এ, প্রতিটি রেকর্ডের জন্য একটি version ফিল্ড রাখা হয়। যখন কোনো রেকর্ডে পরিবর্তন করা হয়, তখন version ফিল্ডের মান আপডেট করা হয়। যদি অন্য ব্যবহারকারী সেই একই রেকর্ডে পরিবর্তন করার চেষ্টা করেন এবং রেকর্ডের version ম্যাচ না করে, তবে StaleObjectStateException ছোঁড়া হয় এবং কনফ্লিক্টের বার্তা প্রদর্শন করা হয়।

এখানে একটি উদাহরণ:

public class Employee
{
    public virtual int Id { get; set; }
    public virtual string Name { get; set; }
    public virtual int Version { get; set; }  // version ফিল্ড
}

// HBM ফাইল বা Fluent API ব্যবহার করে version ম্যানেজমেন্ট
<property name="Version" column="version" type="Int32" />

Pessimistic Locking

Pessimistic Locking এর জন্য, NHibernate LockMode ব্যবহার করে রেকর্ডে লক বসাতে পারে। উদাহরণস্বরূপ, আপনি LockMode.PessimisticWrite ব্যবহার করতে পারেন:

using (var session = sessionFactory.OpenSession())
{
    var employee = session.Get<Employee>(1, LockMode.PessimisticWrite);
    employee.Name = "Jane Doe";
    session.Update(employee);
}

এখানে, LockMode.PessimisticWrite ব্যবহার করা হয়েছে, যা রেকর্ডে একটি লিখিত লক বসায় এবং অন্য কোনো ব্যবহারকারী সেই রেকর্ডে পরিবর্তন করতে পারে না যতক্ষণ না প্রথম ব্যবহারকারী কাজ শেষ করে।

4. Isolation Levels

Isolation Level ডেটাবেস ট্রানজেকশনের নির্ভরতা এবং এক্সিকিউশনের পর্যায় নির্ধারণ করে। এটি Concurrency Control এর সাথে সম্পর্কিত, কারণ প্রতিটি ট্রানজেকশন নির্দিষ্ট "isolation" স্তরের মধ্যে এক্সিকিউট করা হয়।

NHibernate এ Isolation Level কনফিগার করার উদাহরণ:

using (var session = sessionFactory.OpenSession())
{
    var transaction = session.BeginTransaction(IsolationLevel.Serializable);

    try
    {
        // ট্রানজেকশন কোড
        transaction.Commit();
    }
    catch (Exception)
    {
        transaction.Rollback();
    }
}

এখানে, Serializable isolation level ব্যবহার করা হয়েছে, যা সর্বোচ্চ কনকারেন্সি রোধ করে এবং ট্রানজেকশনের মধ্যে সঠিক ডেটার অখণ্ডতা নিশ্চিত করে।

সারাংশ

• Transaction Management হল ডেটাবেসের মধ্যে একাধিক অপারেশনকে একত্রিত করে একটি একক ইউনিট হিসেবে সম্পাদন করার প্রক্রিয়া। NHibernate এ ট্রানজেকশন ব্যবস্থাপনা সহজ এবং কার্যকর, যেখানে আপনি Commit() এবং Rollback() ব্যবহার করে ডেটাবেস ট্রানজেকশন পরিচালনা করতে পারেন।
• Concurrency Control হল একাধিক ব্যবহারকারী বা থ্রেডের মধ্যে ডেটা অ্যাক্সেসের সামঞ্জস্য বজায় রাখা। NHibernate এ এটি Optimistic Locking এবং Pessimistic Locking পদ্ধতির মাধ্যমে করা হয়।
• Isolation Levels নির্ধারণ করে ট্রানজেকশনের মধ্যে ডেটা অ্যাক্সেস কেমন হবে এবং কিভাবে একাধিক ট্রানজেকশন একে অপরের সাথে ইন্টারঅ্যাক্ট করবে।

এভাবে, Transaction Management এবং Concurrency Control নিশ্চিত করে যে, আপনার অ্যাপ্লিকেশন ডেটাবেসে সঠিকভাবে ডেটা পরিচালনা করছে এবং একাধিক ব্যবহারকারীর মধ্যে কোনো সংঘর্ষ হচ্ছে না।

Transaction একটি ডেটাবেস অপারেশন যা একাধিক SQL কমান্ডকে একত্রিত করে একটি একক একক ইউনিটে সম্পাদন করা হয়। একটি ট্রানজেকশন শুরু, সম্পন্ন, অথবা বাতিল হতে পারে, এবং এটি ডেটাবেসের একীভূততা এবং সঠিকতা বজায় রাখে। ট্রানজেকশন ব্যবস্থাপনা ডেটাবেসের একটি গুরুত্বপূর্ণ অংশ, যা ACID (Atomicity, Consistency, Isolation, Durability) প্রপার্টিজের মাধ্যমে কার্যকর হয়।

এখানে BEGIN, COMMIT, এবং ROLLBACK এর মৌলিক ধারণা এবং কিভাবে এগুলি ট্রানজেকশনে ব্যবহৃত হয়, তা আলোচনা করা হবে।

BEGIN

BEGIN ট্রানজেকশন শুরু করার জন্য ব্যবহৃত হয়। একটি ট্রানজেকশন শুরু করার পর, আপনি একাধিক ডেটাবেস অপারেশন (যেমন, Insert, Update, Delete) সম্পাদন করতে পারেন। যতক্ষণ না আপনি COMMIT অথবা ROLLBACK করেন, ততক্ষণ পর্যন্ত এই অপারেশনগুলো স্থায়ী হবে না।

NHibernate তে ট্রানজেকশন শুরু করতে session.BeginTransaction() মেথড ব্যবহার করা হয়।

using (var session = NHibernateHelper.SessionFactory.OpenSession())
{
    using (var transaction = session.BeginTransaction())
    {
        // Your database operations here
    }
}

এখানে:

• session.BeginTransaction(): এটি একটি নতুন ট্রানজেকশন শুরু করে।

COMMIT

COMMIT অপারেশনটি একটি ট্রানজেকশন সম্পন্ন করে এবং সেই ট্রানজেকশনের সমস্ত পরিবর্তন ডেটাবেসে স্থায়ী করে তোলে। একবার COMMIT করা হলে, ট্রানজেকশনের সমস্ত পরিবর্তন রোলব্যাক করা সম্ভব নয়।

এটি নিশ্চিত করে যে, সমস্ত অপারেশন সফলভাবে সম্পাদিত হয়েছে এবং ডেটাবেসের অবস্থা পরিবর্তন হয়েছে।

using (var session = NHibernateHelper.SessionFactory.OpenSession())
{
    using (var transaction = session.BeginTransaction())
    {
        var employee = new Employee
        {
            Name = "John Doe",
            Age = 30
        };

        session.Save(employee);  // Insert operation
        transaction.Commit();  // Commit the transaction
    }
}

এখানে:

• transaction.Commit(): এটি ট্রানজেকশন সফলভাবে শেষ করে এবং সমস্ত পরিবর্তন ডেটাবেসে সেভ করে।

ROLLBACK

ROLLBACK অপারেশনটি একটি ট্রানজেকশন বাতিল করে এবং সমস্ত পরিবর্তন পূর্বের অবস্থায় ফিরে নিয়ে যায়। যদি কোনো কারণে ট্রানজেকশনের মধ্যে ত্রুটি ঘটে, তাহলে ROLLBACK ব্যবহার করা হয়। এটি ডেটাবেসের একীকৃততা বজায় রাখে এবং অবৈধ বা আংশিক অপারেশনগুলো বাতিল করে।

using (var session = NHibernateHelper.SessionFactory.OpenSession())
{
    using (var transaction = session.BeginTransaction())
    {
        try
        {
            var employee = new Employee
            {
                Name = "Jane Doe",
                Age = 28
            };

            session.Save(employee);  // Insert operation

            // Simulate an error (for example, violating a database constraint)
            throw new Exception("Something went wrong!");

            transaction.Commit();  // Commit the transaction
        }
        catch (Exception ex)
        {
            transaction.Rollback();  // Rollback if there is an error
            Console.WriteLine($"Error: {ex.Message}");
        }
    }
}

এখানে:

• transaction.Rollback(): এটি টপকে ডেটাবেসে কোনো পরিবর্তন না নিয়ে ট্রানজেকশনটি পূর্বের অবস্থায় ফিরিয়ে আনে।
• try-catch block: এটি নিশ্চিত করে যে, কোনো ত্রুটি ঘটলে, সেই ত্রুটির পরে পরিবর্তনগুলি রোলব্যাক করা হবে।

ACID প্রপার্টিজ

Transaction ব্যবহারের সময় ACID প্রপার্টিজের (Atomicity, Consistency, Isolation, Durability) অধীনে কাজ করে। প্রতিটি প্রপার্টি একটি ট্রানজেকশনের শুদ্ধতা এবং নির্ভরযোগ্যতা নিশ্চিত করে।

1. Atomicity: একাধিক অপারেশন একসাথে একটি ইউনিট হিসেবে কাজ করে। যদি কোন একটি অপারেশন ব্যর্থ হয়, তাহলে সম্পূর্ণ ট্রানজেকশনই ব্যর্থ হয়ে যাবে এবং সমস্ত পরিবর্তন রোলব্যাক হবে।
2. Consistency: ট্রানজেকশন সম্পন্ন হওয়ার পর, ডেটাবেস একটি সঠিক অবস্থায় থাকবে। অর্থাৎ, কোনো ত্রুটি ছাড়াই ডেটাবেসের স্টেট পরিবর্তন হবে।
3. Isolation: একাধিক ট্রানজেকশন একসাথে চলতে পারে, তবে প্রতিটি ট্রানজেকশন একে অপর থেকে আলাদা থাকবে। একটিতে ঘটে যাওয়া পরিবর্তন অন্যটিতে প্রভাব ফেলবে না যতক্ষণ না প্রথমটি COMMIT হয়।
4. Durability: একবার একটি ট্রানজেকশন COMMIT হয়ে গেলে, তার পরিবর্তনগুলি স্থায়ী এবং পermanently ডেটাবেসে সংরক্ষিত হয়। এমনকি সিস্টেম ক্র্যাশ হলেও তা রক্ষা পাবে।

Best Practices for Transactions

• Transaction Boundary: ট্রানজেকশন যখন শুরু হয়, তখন তার সীমা নির্ধারণ করা গুরুত্বপূর্ণ। আপনি কোথায় BEGIN করবেন এবং কোথায় COMMIT বা ROLLBACK করবেন তা পরিষ্কারভাবে বুঝে রাখতে হবে।
• Exception Handling: ট্রানজেকশন ব্যবস্থাপনায় সঠিক exception handling গুরুত্বপূর্ণ, কারণ একটি ত্রুটি ঘটলে ROLLBACK করতে হবে যাতে ডেটাবেসের ডেটা সঠিক থাকে।
• Avoid Long Transactions: দীর্ঘ সময় ধরে চলা ট্রানজেকশন সিস্টেমের পারফরম্যান্স কমিয়ে দেয় এবং ডেটাবেসে লক সৃষ্টি করতে পারে। যতটা সম্ভব ছোট, দ্রুত এবং কার্যকরী ট্রানজেকশন তৈরি করা উচিত।

Conclusion

ট্রানজেকশন ব্যবস্থাপনা (BEGIN, COMMIT, ROLLBACK) ডেটাবেসের একীকৃততা এবং সঠিকতা বজায় রাখতে সহায়ক। ট্রানজেকশন ব্যবহারে ACID প্রপার্টিজ নিশ্চিত করে যে, সমস্ত ডেটাবেস অপারেশন সফলভাবে এবং নিরাপদে সম্পন্ন হবে।

NHibernate এর Transaction API ডেটাবেসের সাথে ইনটিগ্রেটেড ট্রানজেকশন পরিচালনা করার জন্য ব্যবহৃত হয়। এটি আপনাকে একাধিক ডেটাবেস অপারেশনকে একত্রে একটি transaction ব্লকে রাখার সুবিধা দেয়। একটি ট্রানজেকশন ব্লকের মধ্যে সমস্ত অপারেশন সফলভাবে সম্পন্ন না হলে, সেই অপারেশনগুলো রোলব্যাক (rollback) করা হয়।

NHibernate ট্রানজেকশন পরিচালনা করার মূল ধারণা

• Transaction Start: ট্রানজেকশন শুরু করা হয় BeginTransaction() মেথড দিয়ে।
• Commit: সমস্ত অপারেশন সফল হলে, পরিবর্তনগুলো ডেটাবেসে সেভ করা হয় Commit() মেথড দিয়ে।
• Rollback: কোনো কারণে অপারেশনটি ব্যর্থ হলে, সমস্ত পরিবর্তন রিভার্স করতে Rollback() ব্যবহার করা হয়।

NHibernate এ Transaction API ব্যবহার করার ধাপ

1. Session তৈরি করা: NHibernate এর ISession অবজেক্ট ব্যবহার করে ডেটাবেসের সাথে যোগাযোগ স্থাপন করা হয়।
2. Transaction শুরু করা: BeginTransaction() মেথড ব্যবহার করে ট্রানজেকশন শুরু করা হয়।
3. CRUD অপারেশন করা: ডেটাবেসে ডেটা সেভ, আপডেট বা ডিলিট করা হয়।
4. Commit করা: সব অপারেশন সফল হলে Commit() মেথডের মাধ্যমে ট্রানজেকশন নিশ্চিত করা হয়।
5. Rollback করা: কোনো সমস্যা হলে Rollback() মেথড দিয়ে সমস্ত অপারেশন পূর্বাবস্থায় ফিরিয়ে আনা হয়।

উদাহরণ: NHibernate এর Transaction API ব্যবহার

ধরা যাক, আমাদের Employee এবং Department দুটি টেবিল আছে, এবং আমরা একটি ট্রানজেকশন ব্লকে একাধিক অপারেশন করতে চাই। নিচে একটি উদাহরণ দেয়া হল:

1. Transaction শুরু করা এবং কমিট করা

using NHibernate;

public class EmployeeService
{
    private readonly ISessionFactory _sessionFactory;

    public EmployeeService(ISessionFactory sessionFactory)
    {
        _sessionFactory = sessionFactory;
    }

    public void AddEmployeeWithTransaction(Employee employee)
    {
        using (var session = _sessionFactory.OpenSession())
        {
            // Transaction শুরু করা
            using (var transaction = session.BeginTransaction())
            {
                try
                {
                    // Employee সেভ করা
                    session.Save(employee);

                    // Department সেভ করা (যদি প্রয়োজন হয়)
                    var department = new Department { Name = "HR" };
                    session.Save(department);

                    // Transaction কমিট করা
                    transaction.Commit();
                }
                catch (Exception ex)
                {
                    // কোনো সমস্যা হলে Transaction রোলব্যাক করা
                    transaction.Rollback();
                    Console.WriteLine("Error: " + ex.Message);
                }
            }
        }
    }
}

এখানে:

• BeginTransaction() মেথড দিয়ে ট্রানজেকশন শুরু হয়েছে।
• session.Save() ব্যবহার করে Employee এবং Department টেবিলে ডেটা সেভ করা হচ্ছে।
• transaction.Commit() এর মাধ্যমে ট্রানজেকশনটি সফলভাবে কমিট করা হয়েছে।
• যদি কোনো সমস্যা ঘটে, তবে transaction.Rollback() দিয়ে সমস্ত অপারেশন রোলব্যাক করা হয়।

2. Rollback এর উদাহরণ

ধরা যাক, আমরা একটি ট্রানজেকশনে একাধিক অপারেশন করব, এবং যদি কোনো এক জায়গায় ব্যর্থতা ঘটে, তবে সমস্ত পরিবর্তন রোলব্যাক করতে হবে।

public void UpdateEmployeeWithTransaction(Employee employee)
{
    using (var session = _sessionFactory.OpenSession())
    {
        using (var transaction = session.BeginTransaction())
        {
            try
            {
                // Employee আপডেট করা
                var existingEmployee = session.Get<Employee>(employee.Id);
                if (existingEmployee != null)
                {
                    existingEmployee.Name = employee.Name;
                    existingEmployee.Department = employee.Department;
                    session.Update(existingEmployee);
                }

                // যদি এখানে কোনো সমস্যা হয়, Transaction রোলব্যাক হবে
                transaction.Commit();
            }
            catch (Exception)
            {
                // কোনো সমস্যা হলে সকল পরিবর্তন রোলব্যাক করা হবে
                transaction.Rollback();
            }
        }
    }
}

এখানে:

• Get() মেথড দিয়ে পূর্ববর্তী Employee রেকর্ডটি পাওয়ার পর সেটি আপডেট করা হচ্ছে।
• যদি কোনো সমস্যা ঘটে, transaction.Rollback() এর মাধ্যমে পূর্বাবস্থায় ফিরে আসা হয়।

NHibernate Transaction API এর কিছু গুরুত্বপূর্ণ পয়েন্ট

1. ট্রানজেকশন ব্লকের মধ্যে সকল অপারেশন: একাধিক অপারেশন একে অপরের উপর নির্ভরশীল হলে, তা একটি ট্রানজেকশনের মধ্যে রাখা উচিত। একাধিক ট্রানজেকশন তৈরি না করে একটি একক ট্রানজেকশনের মধ্যে সমস্ত ডেটাবেস অপারেশন সম্পন্ন করা উচিত।
2. Rollback এর প্রয়োজনীয়তা: যখন কোনো একক অপারেশন ব্যর্থ হয়, তখন Rollback() এর মাধ্যমে সমস্ত ডেটাবেস পরিবর্তন রিভার্স করা হয়। এটি ডেটাবেসের ডেটা Integrity বজায় রাখতে সহায়তা করে।
3. Transaction Commit এর পরে পরিবর্তন দৃশ্যমান হয়: ট্রানজেকশন কমিট না হওয়া পর্যন্ত কোনো ডেটাবেস পরিবর্তন দৃশ্যমান হয় না। অন্যথায়, সব পরিবর্তন উল্টে গিয়ে পূর্বাবস্থায় ফিরে যায়।

Summary

NHibernate এর Transaction API ডেটাবেস অপারেশনের জন্য একটি একক ইউনিট পরিচালনা করতে সহায়তা করে। এটি নিশ্চিত করে যে সমস্ত অপারেশন একত্রে সফলভাবে শেষ হলে ডেটাবেসে সেভ হবে, আর যদি কোনো সমস্যা হয়, তবে সমস্ত পরিবর্তন রোলব্যাক হয়ে যাবে। এটি ডেটাবেস Integrity এবং অ্যাপ্লিকেশনের সঠিক কার্যকারিতা নিশ্চিত করতে গুরুত্বপূর্ণ একটি হাতিয়ার।

Locking Techniques হল ডেটাবেসে একাধিক ট্রানজেকশনের মধ্যে ডেটার নিরাপত্তা এবং এক্সক্লুসিভ অ্যাক্সেস নিশ্চিত করার প্রক্রিয়া। এই দুইটি প্রধান লকিং টেকনিক হল Optimistic Locking এবং Pessimistic Locking। এই দুটি টেকনিক ডেটার প্রতিযোগী অ্যাক্সেস বা "race conditions" নিয়ন্ত্রণ করতে ব্যবহৃত হয়, তবে এগুলির মধ্যে কিছু মৌলিক পার্থক্য রয়েছে।

Pessimistic Locking

Pessimistic Locking হল এমন একটি পদ্ধতি যেখানে একটি রেকর্ড যখন একটি ট্রানজেকশন দ্বারা এক্সেস করা হয়, তখন তা অন্য কোন ট্রানজেকশনের জন্য লক হয়ে থাকে। অর্থাৎ, ডেটা পরিবর্তন বা পড়ার আগে ট্রানজেকশনটি অন্য কোন ট্রানজেকশন দ্বারা প্রবেশ করতে পারে না, যতক্ষণ না প্রথম ট্রানজেকশন সম্পূর্ণ হয়।

বৈশিষ্ট্য:

• Immediate Locking: ডেটা এক্সেস করার সাথে সাথেই লক হয়ে যায়।
• High Safety: ডেটার সাথে একাধিক ট্রানজেকশনের সংঘর্ষের সম্ভাবনা কমে যায়।
• Performance Hit: লকিংয়ের কারণে পারফরমেন্স কিছুটা কমে যেতে পারে, কারণ একাধিক ট্রানজেকশন একে অপরকে অপেক্ষা করতে হয়।

উদাহরণ:

যদি দুটি ইউজার একই সময়ে একটি Employee রেকর্ড আপডেট করতে চায়, তবে Pessimistic Locking নিশ্চিত করবে যে এক ইউজার যখন রেকর্ডটি আপডেট করছে, তখন অন্য ইউজার সেই রেকর্ডে অ্যাক্সেস করতে পারবে না।

NHibernate-এ Pessimistic Locking কনফিগারেশন:

using NHibernate;
using NHibernate.Criterion;

ISession session = sessionFactory.OpenSession();
using (ITransaction transaction = session.BeginTransaction())
{
    var employee = session.CreateCriteria<Employee>()
                          .Add(Restrictions.IdEq(1))
                          .SetLockMode(LockMode.PessimisticWrite)  // Locking the record for write
                          .UniqueResult<Employee>();

    employee.Name = "New Name";  // Update operation
    session.Update(employee);
    transaction.Commit();
}

এখানে:

• LockMode.PessimisticWrite: এই লকিং মোডটি ডেটার ওপর এক্সক্লুসিভ লক প্রয়োগ করে, যাতে অন্য ট্রানজেকশন ঐ রেকর্ডটিতে পরিবর্তন করতে না পারে।

Optimistic Locking

Optimistic Locking এমন একটি পদ্ধতি যেখানে একটি রেকর্ড পরিবর্তনের আগে তার কোনো লকিং করা হয় না। পরিবর্তে, ডেটা পরিবর্তন করার সময় যদি ডেটার অবস্থা (যেমন টাইমস্ট্যাম্প বা ভার্সন নম্বর) পরিবর্তিত হয়ে থাকে, তবে তা বুঝতে পারলে ডেটা আপডেট করা হবে না। অর্থাৎ, এটি ধরে নেয় যে একাধিক ট্রানজেকশন একই রেকর্ডে প্রবেশ করার পরও কোনো সংঘর্ষ হবে না, তবে যদি সংঘর্ষ হয়, তখন তা ডিটেক্ট করা হয় এবং প্রয়োজনীয় পদক্ষেপ গ্রহণ করা হয়।

বৈশিষ্ট্য:

• No Immediate Locking: রেকর্ডে কোন লক করা হয় না যখন এটি পড়া হয়।
• Higher Concurrency: একাধিক ট্রানজেকশন একই রেকর্ডে অ্যাক্সেস করতে পারে, তবে কেবল একটিই সফল হবে।
• Lower Safety: সংঘর্ষ হলে আপডেট ব্যর্থ হতে পারে, তবে পারফরমেন্স ভালো থাকে কারণ কম লকিং হয়।

উদাহরণ:

ধরা যাক, একটি Employee রেকর্ডের সাথে একটি ভার্সন নম্বর যুক্ত রয়েছে। যদি একজন ইউজার রেকর্ডটি আপডেট করতে চায়, তবে সে বর্তমান ভার্সন নম্বরটি ব্যবহার করবে। যখন অন্য ইউজারও একই রেকর্ড আপডেট করার চেষ্টা করবে, তখন তাদের মধ্যে সংঘর্ষ হবে এবং দ্বিতীয় ইউজারের আপডেট ব্যর্থ হবে।

NHibernate-এ Optimistic Locking কনফিগারেশন:

public class Employee
{
    public virtual int Id { get; set; }
    public virtual string Name { get; set; }
    public virtual int Version { get; set; } // Version for Optimistic Locking
}

public class EmployeeMap : ClassMap<Employee>
{
    public EmployeeMap()
    {
        Id(x => x.Id).GeneratedBy.Identity();
        Map(x => x.Name);
        Version(x => x.Version);  // Mapping version column for Optimistic Locking
    }
}

ISession session = sessionFactory.OpenSession();
using (ITransaction transaction = session.BeginTransaction())
{
    var employee = session.Get<Employee>(1); // Fetch the employee record
    employee.Name = "Updated Name"; // Modify the name
    
    try
    {
        session.Update(employee); // Attempt to update the record
        transaction.Commit();
    }
    catch (StaleObjectStateException ex) // Handle Optimistic Locking failure
    {
        Console.WriteLine("Concurrency conflict detected: " + ex.Message);
    }
}

এখানে:

• Version(x => x.Version): Version প্রপার্টি দ্বারা রেকর্ডের বর্তমান অবস্থার ভার্সন নির্ধারণ করা হয়। যখন কোনো ইউজার রেকর্ড আপডেট করতে যাবে, তখন তাদের ভার্সন নম্বর চেক করা হয়। যদি অন্য কোনো ট্রানজেকশন এর মধ্যে রেকর্ডটি আপডেট করে, তবে StaleObjectStateException ছুঁড়ে দেয়া হয়।

তুলনা: Optimistic এবং Pessimistic Locking

এই দুটি পদ্ধতির মধ্যে সঠিকটি বেছে নেয়া আপনার অ্যাপ্লিকেশন এবং ডেটাবেসের পারফরমেন্স, সেফটি এবং স্কেলেবিলিটির উপর নির্ভর করে। Pessimistic Locking যেখানে একাধিক ট্রানজেকশনের মধ্যে সংঘর্ষ এড়াতে হবে, সেখানে বেশি উপকারী। অপরদিকে, Optimistic Locking সাধারণত উচ্চ পারফরমেন্সের জন্য ব্যবহৃত হয়, যেখানে ট্রানজেকশন সংখ্যা বেশি হলেও একাধিক ইউজারের জন্য তথ্যের সংঘর্ষ কম হয়।

NHibernate-এ Versioning এবং Timestamp দুটি গুরুত্বপূর্ণ কৌশল যা Optimistic Concurrency Control (OCC) এর আওতায় ডেটাবেসে একাধিক ইউজার বা থ্রেডের মধ্যে ডেটার সংঘর্ষ বা কনকারেন্সি সমস্যা এড়াতে ব্যবহৃত হয়। এটি বিশেষ করে সেই পরিস্থিতিতে গুরুত্বপূর্ণ যেখানে একাধিক ইউজার একই ডেটা আপডেট করার চেষ্টা করে।

Versioning

Versioning হল একটি কৌশল যেখানে একটি version বা timestamp ফিল্ড ব্যবহৃত হয় যেটি একটি নির্দিষ্ট রেকর্ডের সংস্করণ বা সময়কে ট্র্যাক করে। এই ফিল্ডের সাহায্যে NHibernate নিশ্চিত করে যে একটি রেকর্ড শুধুমাত্র তখনই আপডেট করা যাবে যদি তার সংস্করণটি সঠিক থাকে।

উদাহরণ:

ধরা যাক, আমাদের একটি Product টেবিল রয়েছে, যেখানে একটি Version ফিল্ড সংযুক্ত করা হয়েছে:

public class Product
{
    public virtual int Id { get; set; }
    public virtual string Name { get; set; }
    public virtual decimal Price { get; set; }
    
    // Versioning field
    public virtual int Version { get; set; }
}

এখানে:

• Version প্রপার্টি হল সেই ফিল্ড যা রেকর্ডের সংস্করণ বা ভার্সন নম্বর ট্র্যাক করে।

Mapping with Fluent NHibernate:

public class ProductMap : ClassMap<Product>
{
    public ProductMap()
    {
        Table("Products");
        Id(x => x.Id).GeneratedBy.Identity();
        Map(x => x.Name).Not.Nullable();
        Map(x => x.Price).Not.Nullable();
        
        // Versioning field
        Version(x => x.Version);
    }
}

এখানে:

• Version(x => x.Version): এটি NHibernate কে বলে যে, Version ফিল্ডটি একটি optimistic concurrency control ফিল্ড, যা NHibernate দ্বারা ডেটাবেসে রেকর্ড আপডেটের সময় চেক করা হবে।

Versioning-এর কাজ কিভাবে হয়?

যখন আপনি একটি রেকর্ড আপডেট করেন, NHibernate এটি যাচাই করে যে আপডেট করার পূর্ববর্তী রেকর্ডের সংস্করণ এবং বর্তমান সংস্করণ মিলছে কিনা। যদি সংস্করণটি পরিবর্তিত হয়ে থাকে (অর্থাৎ অন্য কোনো ইউজার বা থ্রেড রেকর্ডটি আগে আপডেট করেছে), তবে NHibernate একটি OptimisticLockException ছুঁড়ে দিবে।

Timestamp

Timestamp হল একটি ডেটাবেস কলাম যা রেকর্ডের সর্বশেষ আপডেট সময় ট্র্যাক করে। এটি মূলত একই রকমভাবে কাজ করে যেমন Versioning, তবে এটি একটি টাইমস্ট্যাম্প ব্যবহার করে যা সাধারণত DateTime টাইপের হয়।

উদাহরণ:

একটি Product ক্লাসে টাইমস্ট্যাম্প ব্যবহার করার জন্য:

public class Product
{
    public virtual int Id { get; set; }
    public virtual string Name { get; set; }
    public virtual decimal Price { get; set; }
    
    // Timestamp field
    public virtual DateTime LastUpdated { get; set; }
}

এখানে:

• LastUpdated হল সেই ফিল্ড যা রেকর্ডের সর্বশেষ পরিবর্তনের সময় ট্র্যাক করবে।

Mapping with Fluent NHibernate:

public class ProductMap : ClassMap<Product>
{
    public ProductMap()
    {
        Table("Products");
        Id(x => x.Id).GeneratedBy.Identity();
        Map(x => x.Name).Not.Nullable();
        Map(x => x.Price).Not.Nullable();
        
        // Timestamp field
        Map(x => x.LastUpdated).CustomType("timestamp");
    }
}

এখানে:

• CustomType("timestamp"): এই কাস্টম টাইপ নির্দেশ করে যে, LastUpdated ফিল্ডটি একটি টাইমস্ট্যাম্প ফিল্ড এবং NHibernate এই কলামটি রেকর্ড আপডেট করার সময় ব্যবহার করবে।

Timestamp-এর কাজ কিভাবে হয়?

টাইমস্ট্যাম্প ফিল্ডে সাধারণত ডেটাবেস দ্বারা স্বয়ংক্রিয়ভাবে সময় যোগ করা হয় যখন একটি রেকর্ড তৈরি বা আপডেট হয়। যখন আপনি একটি রেকর্ড আপডেট করার চেষ্টা করবেন, NHibernate সিস্টেমে যাচাই করবে যে LastUpdated টাইমস্ট্যাম্পটি গত আপডেটের পর পরিবর্তিত হয়েছে কিনা। যদি টাইমস্ট্যাম্প পরিবর্তিত হয়ে থাকে, তবে অর্থাৎ অন্য কেউ রেকর্ডটি পরিবর্তন করেছে, তখন NHibernate একটি OptimisticLockException তৈরি করবে।

Versioning vs Timestamp

• Versioning ফিল্ডটি সাধারণত একটি সংখ্যা হিসেবে কাজ করে (যেমন int বা long), যা রেকর্ডের প্রতি পরিবর্তনের জন্য বৃদ্ধি পায়।
• Timestamp ফিল্ডটি সাধারণত একটি DateTime স্টাইলের ফিল্ড যা রেকর্ডের সর্বশেষ পরিবর্তন সময় ট্র্যাক করে।

কখন কোনটি ব্যবহার করবেন?

• Versioning: যখন আপনাকে একটি নির্দিষ্ট সংখ্যক পরিবর্তনের ট্র্যাক রাখতে হবে এবং আপডেটের জন্য একটি সংখ্যা ব্যবহার করতে চান।
• Timestamp: যখন আপনাকে সময়ের উপর ভিত্তি করে কনকারেন্সি নিয়ন্ত্রণ করতে হবে এবং ডেটাবেসের সর্বশেষ আপডেট সময় প্রয়োজন।

উপসংহার

NHibernate-এ Versioning এবং Timestamp দুটি কৌশল Optimistic Concurrency Control নিশ্চিত করার জন্য ব্যবহৃত হয়। Versioning এবং Timestamp ফিল্ড ব্যবহারের মাধ্যমে, আপনি ডেটাবেসে ডেটার একাধিক ইউজারের মধ্যে সংঘর্ষ বা কনকারেন্সি সমস্যা কমাতে পারেন। Versioning সংখ্যা ব্যবহার করে সংস্করণ ট্র্যাক করে, আর Timestamp সময় ব্যবহার করে সর্বশেষ পরিবর্তন চিহ্নিত করে।