Có một cách mà anh thấy một số người hay dùng đó là ở tầng service sẽ bắt đầu transaction và sau đó gọi các repository sau đó commit tại đây, ví dụ (anh tạm dùng java để minh hoạ nhé):
class Service {
@Transactional
public void addUserProduct(long userId, long productId) {
userRepo.increaseProductCount(userId);
productRepo.updateProductOwner(productId, userId);
userProductRepo.addUserProduct(userId, productId);
}
}
Tuy nhiên không nên làm như vậy vì tầng service là tầng chuyên xử lý nghiệp vụ, ví dụ như tính toán, tổng hợp dữ liệu, và nó không bao giờ nên phụ thuộc vào transaction, giả sử em bổ sung thêm 1 nghiệp vụ không liên quan gì đến transaction thế này:
class Service {
@Transactional
public void addUserProduct(long userId, long productId) {
Thread.sleep(2000);
sendNewUserProductToKafka(userId, productId);
userRepo.increaseProductCount(userId);
productRepo.updateProductOwner(productId, userId);
userProductRepo.addUserProduct(userId, productId);
}
}
Thì có phải là transaction đang bị kéo dài thêm 2000 và có thể gây ra những lỗi bất ngờ thì sao.
Nên cách tốt nhất là em nên tạo ra 1 repo và gọi tổng hợp như thế này em ạ. Từ entityManager tương đương với context.Context trong go em sẽ có thể chạy các query tuỳ ý và sau đó commit 1 thể.
