spring-retry

build.gradle.kts

@@ -54,6 +54,7 @@ dependencies {
  // spring
  api("org.springframework.boot:spring-boot-starter")
  api("org.springframework.boot:spring-boot-starter-data-jpa")
+ api("org.springframework.retry:spring-retry")
  api("info.picocli:picocli-spring-boot-starter:4.6.1")
 
  // lsp4j core

src/main/java/com/github/_1c_syntax/bsl/languageserver/infrastructure/RetryConfiguration.java

@@ -0,0 +1,30 @@
+/*
+ * This file is a part of BSL Language Server.
+ *
+ * Copyright (c) 2018-2021
+ * Alexey Sosnoviy <labotamy@gmail.com>, Nikita Gryzlov <nixel2007@gmail.com> and contributors
+ *
+ * SPDX-License-Identifier: LGPL-3.0-or-later
+ *
+ * BSL Language Server is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 3.0 of the License, or (at your option) any later version.
+ *
+ * BSL Language Server is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with BSL Language Server.
+ */
+package com.github._1c_syntax.bsl.languageserver.infrastructure;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.retry.annotation.EnableRetry;
+
+@Configuration
+@EnableRetry
+public class RetryConfiguration {
+}

src/main/java/com/github/_1c_syntax/bsl/languageserver/references/ReferenceIndex.java

@@ -39,6 +39,7 @@
 import org.eclipse.lsp4j.Range;
 import org.eclipse.lsp4j.SymbolKind;
 import org.springframework.dao.DataIntegrityViolationException;
+import org.springframework.retry.annotation.Retryable;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -140,6 +141,7 @@ public void clearReferences(URI uri) {
  * @param symbolName Имя символа, к которому происходит обращение.
  * @param range Диапазон, в котором происходит обращение к символу.
  */
+ @Retryable(DataIntegrityViolationException.class)
  public void addMethodCall(URI uri, String mdoRef, ModuleType moduleType, String symbolName, Range range) {
  String symbolNameCanonical = symbolName.toLowerCase(Locale.ENGLISH);
 
@@ -153,15 +155,7 @@ public void addMethodCall(URI uri, String mdoRef, ModuleType moduleType, String
  newSymbol.setSymbolKind(SymbolKind.Method);
  newSymbol.setSymbolName(symbolNameCanonical);
 
- try {
- return symbolRepository.save(newSymbol);
- } catch (DataIntegrityViolationException ignored) {
- return symbolRepository.findByMdoRefAndModuleTypeAndSymbolName(
- mdoRef,
- moduleType,
- symbolNameCanonical
- ).orElseThrow();
- }
+ return symbolRepository.save(newSymbol);
  });
 
  var location = new Location();