Skip to content

Commit 33973ec

Browse files
committed
Polishing.
1 parent 7f17823 commit 33973ec

File tree

2 files changed

+11
-6
lines changed

2 files changed

+11
-6
lines changed

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

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -83,11 +83,16 @@ public SimpleElasticsearchRepository(ElasticsearchEntityInformation<T, ID> metad
8383
this.indexOperations = operations.indexOps(this.entityClass);
8484

8585
if (!"true".equals(System.getenv("SPRING_DATA_ELASTICSEARCH_SKIP_REPOSITORY_INIT"))) {
86-
if (shouldCreateIndexAndMapping() && !indexOperations.exists()) {
87-
indexOperations.createWithMapping();
88-
} else if (shouldAlwaysWriteMapping()) {
89-
indexOperations.putMapping();
90-
}
86+
createIndexAndMappingIfNeeded();
87+
}
88+
}
89+
90+
public void createIndexAndMappingIfNeeded() {
91+
92+
if (shouldCreateIndexAndMapping() && !indexOperations.exists()) {
93+
indexOperations.createWithMapping();
94+
} else if (shouldAlwaysWriteMapping()) {
95+
indexOperations.putMapping();
9196
}
9297
}
9398

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ public SimpleReactiveElasticsearchRepository(ElasticsearchEntityInformation<T, I
6666
}
6767
}
6868

69-
private void createIndexAndMappingIfNeeded() {
69+
public void createIndexAndMappingIfNeeded() {
7070

7171
var blockingIndexOperations = blocking(indexOperations);
7272

0 commit comments

Comments
 (0)