Cwikius-Spring/spring-data-elasticsearch
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-data-elasticsearch.git synced 2025-07-04 09:42:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add environment variable to skip repository initialization.

Browse Source 
Original Pull Request #2878
Closes #2876
This commit is contained in:
Peter-Josef Meisch 2024-03-24 17:37:11 +01:00 committed by GitHub
parent aa27bbec27
commit 7f178238db
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleElasticsearchRepository.java
View File

@ -82,10 +82,12 @@ public class SimpleElasticsearchRepository<T, ID> implements ElasticsearchReposi
this.entityClass = this.entityInformation.getJavaType(); this.entityClass = this.entityInformation.getJavaType();
this.indexOperations = operations.indexOps(this.entityClass); this.indexOperations = operations.indexOps(this.entityClass);
if (shouldCreateIndexAndMapping() && !indexOperations.exists()) { if (!"true".equals(System.getenv("SPRING_DATA_ELASTICSEARCH_SKIP_REPOSITORY_INIT"))) {
indexOperations.createWithMapping(); if (shouldCreateIndexAndMapping() && !indexOperations.exists()) {
} else if (shouldAlwaysWriteMapping()) { indexOperations.createWithMapping();
indexOperations.putMapping(); } else if (shouldAlwaysWriteMapping()) {
indexOperations.putMapping();
}
} }
} }

4
src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java
View File

@ -61,7 +61,9 @@ public class SimpleReactiveElasticsearchRepository<T, ID> implements ReactiveEla
this.operations = operations; this.operations = operations;
this.indexOperations = operations.indexOps(entityInformation.getJavaType()); this.indexOperations = operations.indexOps(entityInformation.getJavaType());
createIndexAndMappingIfNeeded(); if (!"true".equals(System.getenv("SPRING_DATA_ELASTICSEARCH_SKIP_REPOSITORY_INIT"))) {
createIndexAndMappingIfNeeded();
}
} }
private void createIndexAndMappingIfNeeded() { private void createIndexAndMappingIfNeeded() {