Mức độ cô lập giao dịch (Transaction Isolation Level) là gì?

Các vấn đề có thể phát sinh

• Dirty Read: Đọc dữ liệu từ một giao dịch khác chưa được Commit.
• Non-Repeatable Read: Trong cùng một giao dịch, đọc cùng một dữ liệu nhiều lần nhưng kết quả trả về khác nhau (do giao dịch khác đã Update).
• Phantom Read: Trong cùng một giao dịch, thực hiện cùng một câu lệnh truy vấn điều kiện nhiều lần nhưng số lượng dòng trả về khác nhau (do giao dịch khác đã Insert/Delete).

So sánh 4 mức độ cô lập giao dịch

MVCC là gì?

FOR UPDATE là gì?

Ví dụ sử dụng:

BEGIN;
-- Khóa dòng dữ liệu sản phẩm có id = 1
SELECT stock FROM product WHERE id = 1 FOR UPDATE;
-- Cập nhật kho hàng an toàn
UPDATE product SET stock = stock - 1 WHERE id = 1;
COMMIT;

Ví dụ thực tế với R2DBC + MySQL

1. Kiểm tra mức độ cô lập trong MySQL

-- Kiểm tra mức độ cô lập của session hiện tại
SELECT @@tx_isolation;
-- Thiết lập mức độ REPEATABLE READ
SET SESSION TRANSACTION ISOLATION LEVEL REPEATABLE READ;

2. Định nghĩa bảng dữ liệu

CREATE TABLE product (
    id BIGINT PRIMARY KEY,
    name VARCHAR(255),
    stock INT,
    updated_at DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP
) ENGINE=InnoDB;

3. Kotlin Repository (Sử dụng FOR UPDATE)

@Repository
class ProductRepositoryImpl(private val client: DatabaseClient) : ProductRepository {
    override fun findWithLock(productId: Long): Mono<Product> {
        return client.sql("SELECT * FROM product WHERE id = :id FOR UPDATE")
            .bind("id", productId)
            .map { row ->
                Product(
                    id = row.get("id", Long::class.java)!!,
                    name = row.get("name", String::class.java)!!,
                    stock = row.get("stock", Int::class.java)!!
                )
            }.one()
    }

    override fun updateStock(productId: Long, newStock: Int): Mono<Void> {
        return client.sql("UPDATE product SET stock = :stock WHERE id = :id")
            .bind("stock", newStock)
            .bind("id", productId)
            .then()
    }
}

4. Xử lý giao dịch với TransactionalOperator

@Service
class ProductService(
    private val productRepository: ProductRepository,
    private val tx: TransactionalOperator,
) {
    fun purchase(productId: Long): Mono<Void> {
        return tx.execute {
            productRepository.findWithLock(productId)
                .flatMap { product ->
                    if (product.stock <= 0) {
                        return@flatMap Mono.error(IllegalStateException("Hết hàng"))
                    }
                    productRepository.updateStock(product.id, product.stock - 1)
                }
        }.then()
    }
}

Tổng kết

• Mức độ cô lập: REPEATABLE READ (Mặc định của MySQL)
• Xử lý nhất quán: Đọc snapshot dựa trên MVCC
• Ngăn chặn xung đột: Sử dụng FOR UPDATE để chiếm khóa độc quyền
• Tổ hợp công nghệ: MySQL + Spring WebFlux + R2DBC