如何条件数据库插入操作在JavaSpring锁？

Question

我正在尝试对数据库执行条件插入操作（假设为SQLite）。我的目标是确保数据一致性。

假设我们正在做一个预约计划。

所以我们有一个这样的约会表：

>

编号

个人的

appointment_date

但是我们有一个重要的规则，一个人在同一天的约会不能超过3次。

通常，我们从数据库中查询此人当天有多少约会。然后我们决定是否插入。对吧？

但是，假设我们有一个获得大量流量的API。假设两个类似的交易在同一毫秒内开始，并且以某种方式同一个人获得了第4次约会。这是我们不想要的。

我了解到为了防止这种情况，应该在数据库中应用锁操作。但是我无法理解应用哪种锁类型。我们知道悲观锁会发生死锁。当然，我们不希望出现这种情况。

我的问题是，在Java Spring Boot中我应该做什么来防止这种情况？

实体：

@Entity
@AllArgsConstructor
@NoArgsConstructor
@Getter
@Setter
public class Appointment {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    private String person;

    private Date appointment_date;

}

服务：

@Service
public class AppointmentService {
    @Autowired
    private AppointmentRepository appointmentRepository;

    public Appointment saveAppointment(Appointment appointment) {
        return appointmentRepository.save(appointment);
    }
}

存储库：

@Repository
public interface AppointmentRepository extends JpaRepository<Appointment, Long> {
}

控制器：

@RestController
public class AppointmentController {

    @Autowired
    private AppointmentService appointmentService;

    @PostMapping(“/store”)
    public Appointment store(@RequestBody Appointment appointment) {
        return appointmentService.saveAppointment(appointment);
    }
}

非常感谢您的关注：）

Answer 1

假设您可以更改表模式。在这种情况下，约会聚合将包括

• id
• 人ID
• 预约日期
• 版本
• 创建日期

您可以通过在实体中添加@Version注释和表中添加列来使用乐观锁。

伪代码

@Entity
public class Appointment {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;

    @OneToOne
    private String personId;

    @ElementCollection
    private List<Date> appointmentDates = new ArrayList<>();

    @Version private Long version;

    private Instant createdDate;


    public static Appointment create(Appointment appointment) {
        // code that creates a new appointment
    }

    public Appointment addAppointment() {
        // code that updates your appointment
    }

}

@版本注释

在您的服务类中，您可以创建一个新的约会伪代码

var appointment = Appointment.create(newAppointment);
repository.save(appointment);

或者更新伪代码

var appointmentToUpdate = repository.findById(appointmentId);
// validation for appointment count and date
if (createdDate.isToday() && appointmentToUpdate.getAppointmentDates().size() >= 3)
  // exception
var updatedAppointment = appointmentToUpdate.addAppointment();
repository.save(updatedAppointment);

它将抛出 OptimisticLockException，以防另一个线程修改此实体。