From 7f178238db2647d82e87a6d4a94885c22a15d570 Mon Sep 17 00:00:00 2001 From: Peter-Josef Meisch Date: Sun, 24 Mar 2024 17:37:11 +0100 Subject: [PATCH] Add environment variable to skip repository initialization. Original Pull Request #2878 Closes #2876 --- .../support/SimpleElasticsearchRepository.java | 10 ++++++---- .../support/SimpleReactiveElasticsearchRepository.java | 4 +++- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java b/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java index 2ed128d2b..64325d33d 100644 --- a/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java +++ b/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java @@ -82,10 +82,12 @@ public class SimpleElasticsearchRepository implements ElasticsearchReposi this.entityClass = this.entityInformation.getJavaType(); this.indexOperations = operations.indexOps(this.entityClass); - if (shouldCreateIndexAndMapping() && !indexOperations.exists()) { - indexOperations.createWithMapping(); - } else if (shouldAlwaysWriteMapping()) { - indexOperations.putMapping(); + if (!"true".equals(System.getenv("SPRING_DATA_ELASTICSEARCH_SKIP_REPOSITORY_INIT"))) { + if (shouldCreateIndexAndMapping() && !indexOperations.exists()) { + indexOperations.createWithMapping(); + } else if (shouldAlwaysWriteMapping()) { + indexOperations.putMapping(); + } } } diff --git a/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java b/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java index 4f3d61ec0..e780c2d27 100644 --- a/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java +++ b/src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java @@ -61,7 +61,9 @@ public class SimpleReactiveElasticsearchRepository implements ReactiveEla this.operations = operations; this.indexOperations = operations.indexOps(entityInformation.getJavaType()); - createIndexAndMappingIfNeeded(); + if (!"true".equals(System.getenv("SPRING_DATA_ELASTICSEARCH_SKIP_REPOSITORY_INIT"))) { + createIndexAndMappingIfNeeded(); + } } private void createIndexAndMappingIfNeeded() {