PESSIMESTIC LOCK不适用于访问MySQL的Spring Data

Question

我正在使用Spring Boot构建一个调度作业数据处理应用程序。主要的逻辑是在一个预定的作业中，该作业接收一批记录并处理它们。我应该运行应用程序的2个实例，不应该选择相同的记录两次。我试图利用无等待悲观锁来解决任何记录选择冲突。事情不像预期的那样运转。两个实例都选择了相同的记录，尽管我期望只有一个实例锁定并处理一些记录，而另一个实例跳过第一个实例锁定的记录。Spring Boot版本:2.2.4 .发布

数据库：MySQl

首先，我尝试使用@Lock和@QueryHint注释：

@Lock(value = LockModeType.PESSIMISTIC_WRITE) // adds 'FOR UPDATE' statement
@QueryHints(value={@QueryHint(name = "javax.persistence.lock.timeout", value = LockOptions.SKIP_LOCKED+"")})
Page<Transaction> findByStatus(String status, Pageable pageable);

即使有WAIT_FOREVER，行为也没有改变，好像@QueryHints被完全忽略了一样。我尝试的另一个选项是使用NativeQuery：

@Query(value ="select * from transaction t where t.status = ?1 limit ?2 for update SKIP LOCKED",
            countQuery="select count(*) from transaction t where t.status = ?1",
            nativeQuery = true)
List<Transaction> findByStatusNQ(String status, Integer pageSize);

同样的行为。没有锁定，两个应用程序实例都在选择相同的数据集这是定义的实体：

@Entity
public class Transaction {
    @Id
    private Long id;

    private String description;

    private String status;

    private String managedBy;

    @Temporal(TemporalType.TIMESTAMP)
    private Date manageDate;
...
}

调用方服务组件带有@Transactional注释，以强制为每个执行创建新事务：

    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public List<Transaction> updateTrxStatus(String oldStatus,String newStatus){

        List<Transaction> trxs = this.executeUsingNQ(oldStatus);

        if(trxs.size()>0) {
            logger.info( "Start updating Data");
            trxs.forEach(transaction -> {
                transaction.setStatus(newStatus);
                transaction.setManagedBy(instanceName);
                transaction.setManageDate(new Date(System.currentTimeMillis()));
            });
        }else{
            logger.info(" Nothing to process");
        }
        return trxs;
    }

    @Transactional(propagation = Propagation.REQUIRED)
    public List<Transaction> executeUsingNQ(String oldStatus){
        List<Transaction> trxs = trxRepo.findByStatusNQ(oldStatus,2);
        return trxs;
    }
    @Transactional(propagation = Propagation.REQUIRED)
    public List<Transaction> executeWithPage(String oldStatus){
        Pageable firstPageWithTwoElements = PageRequest.of(0, 2);
        Page<Transaction> trxs = trxRepo.findByStatus(oldStatus, firstPageWithTwoElements);
        return trxs.getContent();
    }

希望有人可以帮助确定是否存在一些编码问题或缺少配置!!!!

Answer 1

据运行，该问题是由于在MySql中使用了不正确的方言引起的。该版本的Dialect“MySQLDialect”在创建表时假定“MyISAMStorageEngine”为默认存储引擎。该引擎不支持任何类型的事务。唯一支持事务的存储引擎是“InnoDB”，当使用其他方言（如“MySQL55Dialect”、“MySQL57Dialect“或“MySQL8Dialect）时，它被选为默认选项