带线程池的Spring JPA事务

Question

我试图理解为什么下面的代码片段不能像预期的那样工作。

我已经有id=1234和name=A1的客户，我正在创建2个可调用的任务，并要求他们执行跨国更新方法。

这两个事务一起运行（在从数据库中读取客户副本（如代码所示）后，我引入了1秒的延迟），并使用id=1234和name=A1读取原始客户

一个尝试从A1-更新名称-

我期望至少有一个事务抛出提交冲突/陈旧的数据异常，但在下面的情况下，两个都成功了。

你能帮我理解一下吗？我在概念上遗漏了什么吗？

主要的JAVA

    @Autowired
    CustomerService service;

    // Update address from A1 to A2
    Callable<String> t1 = new Callable<String>() {

        @Override
        public String call() throws Exception {
            service.updateCustomer("1234", "A2");
            return "T1 Done";
        }
    };

    // Update address from A1 to A3
    Callable<String> t2 = new Callable<String>() {

        @Override
        public String call() throws Exception {
            service.updateCustomer("1234", "A3");
            return "T2 Done";
        }
    };

    ExecutorService executorService = Executors.newFixedThreadPool(2);
    executorService.invokeAll((Collection) Arrays.asList(t1, t2));

客户ervice.java

@Transactional
public void updateCustomer(String customerId, String customerName) {
    try {
        Optional<Customer> currentCopyHandle = repo.findById(customerId);
        Customer currentCopy = currentCopyHandle.get();

        Thread.sleep(1000);

        ObjectMapper mapper = new ObjectMapper();

        String customerDetails = currentCopy.getDetails();

        ObjectNode writableDetails = (ObjectNode) mapper.readTree(customerDetails);
        writableDetails.put("name", customerName);

        currentCopy.setDetails(mapper.writeValueAsString(writableDetails));

        repo.save(currentCopy);

    } catch (Exception e) {
        throw new RuntimeException(e);
    }
}

编辑-1客户。JAVA

这是一个与Oracle 12c兼容的POJO，其中名为details的字段标记为@Lob，oracle12c表具有json约束

@Entity
public class Customer {

@Id
@javax.persistence.Id
private String cid;

@Lob
private String details;

public Customer() {
}

@PersistenceConstructor
public Customer(String cid, String details) {
    super();
    this.cid = cid;
    this.details = details;
}

public String getCid() {
    return cid;
}

public void setCid(String cid) {
    this.cid = cid;
}

public String getDetails() {
    return details;
}

public void setDetails(String details) {
    this.details = details;
}
}

在我开始这个练习之前，我做了以下活动。

String json = "{ \"cid\" : \"1234\", \"name\" : \"A1\", \"address\" : \"India\"}";

service.saveCustomer1(new Customer("1234", json));




Answer 1

谢谢你JBNizet！

通过在我的模型中添加@Version属性来使用乐观锁定解决了我的问题。