原题目：Spring认证中国教育管理中心-Spring Data Elasticsearch教程六（Spring中国教育管理中心）
Spring Data Elasticsearch教程六
- 路由值
当 Elasticsearch 将文档存储在具备多个分片的索引中时，它会依据文档的id确定要应用的分片。有时须要事后定义多个文档应该在同一个分片上建设索引（连贯类型，更快地搜寻相干数据）。为此，Elasticsearch 提供了定义路由的可能性，这是应该用于计算分片而不是id的值。
Spring Data Elasticsearch 反对通过以下形式存储和检索数据的路由定义：
12.1.连贯类型的路由
当应用 join-types（见Join-Type implementation）时，Spring Data Elasticsearch 将主动应用parent实体属性的JoinField属性作为路由的值。
这对于父子关系只有一个级别的所有用例都是正确的。如果它更深一些，比方孩子-父母-祖父母的关系——就像下面的例子中的投票→答复→问题——那么须要应用下一节中形容的技术来明确指定路由（投票须要question.id作为路由值）。
12.2.自定义路由值
为了为实体定义自定义路由，Spring Data Elasticsearch 提供了一个@Routing注解（重用Statement下面的类）：
@Document(indexName = "statements")
@Routing("routing")
public class Statement {
@Idprivate String id;@Field(type = FieldType.Text)private String text;@JoinTypeRelations( relations = { @JoinTypeRelation(parent = "question", children = {"answer", "comment"}), @JoinTypeRelation(parent = "answer", children = "vote") })private JoinField<String> relation;@Nullable@Field(type = FieldType.Keyword)private String routing; // getter/setter...}
这将“路由”定义为路由标准
一个名为routing的属性
Spring Data Elasticsearch教程六
如果routing注解的标准是纯字符串而不是 SpEL 表达式，则将其解释为实体的属性名称，在示例中为路由属性。而后，此属性的值将用作应用该实体的所有申请的路由值。
咱们也能够在@Document正文中应用 SpEL 表达式，如下所示：
@Document(indexName = "statements")
@Routing("@myBean.getRouting(#entity)")
public class Statement{
// all the needed stuff}
在这种状况下，用户须要提供一个名称为myBean 且具备办法的 bean String getRouting(Object)。援用实体“#entity”必须在SpEL表达式中应用，并且返回值必须是null或路由值作为String。
如果一般属性的名称和 SpEL 表达式不足以自定义路由定义，则能够定义提供RoutingResolver接口的实现。而后能够在ElasticOperations实例上设置：
RoutingResolver resolver = ...;
ElasticsearchOperations customOperations= operations.withRouting(resolver);
这些函数返回带有自定义路由集withRouting()的原始实例的正本。ElasticsearchOperations
当实体存储在 Elasticsearch 中时，如果在实体上定义了路由，则在执行获取或删除操作时必须提供雷同的值。对于不应用实体的办法 - 比方get(ID)或delete(ID)
-ElasticsearchOperations.withRouting(RoutingResolver)能够像这样应用该办法：
String id = "someId";
String routing = "theRoutingValue";
// get an entity
Statement s = operations
.withRouting(RoutingResolver.just(routing)) .get(id, Statement.class);// delete an entity
operations.withRouting(RoutingResolver.just(routing)).delete(id);
RoutingResolver.just(s) 返回一个解析器，它只返回给定的字符串。
- 其余 Elasticsearch 操作反对
本章介绍了对无奈通过存储库接口间接拜访的 Elasticsearch 操作的额定反对。倡议将这些操作增加为自定义实现，如Spring Data Repositories的自定义实现中所述。
13.1.索引设置
应用 Spring Data Elasticsearch 创立 Elasticsearch 索引时，能够应用@Setting正文定义不同的索引设置。能够应用以下参数：
useServerConfiguration 不发送任何设置参数，因而 Elasticsearch 服务器配置确定它们。
settingPath 指的是一个 JSON 文件，它定义了必须在类门路中解析的设置
shards要应用的分片数，默认为1
replicas正本数，默认为1
refreshIntervall, 默认为"1s"
indexStoreType, 默认为"fs"
也能够定义索引排序（查看链接的 Elasticsearch 文档以理解可能的字段类型和值）：
@Document(indexName = "entities")
@Setting(
sortFields = { "secondField", "firstField" },
sortModes = { Setting.SortMode.max, Setting.SortMode.min },
sortOrders = { Setting.SortOrder.desc, Setting.SortOrder.asc },
sortMissingValues = { Setting.SortMissing._last, Setting.SortMissing._first })
class Entity {
@Nullable@Id private String id;@Nullable@Field(name = "first_field", type = FieldType.Keyword)private String firstField;@Nullable @Field(name = "second_field", type = FieldType.Keyword)private String secondField;// getter and setter...}
定义排序字段时，应用 Java 属性的名称 ( firstField )，而不是可能为 Elasticsearch 定义的名称 ( first_field )
sortModes,sortOrders并且sortMissingValues是可选的，但如果设置了它们，则条目数必须与sortFields元素数匹配
Spring Data Elasticsearch教程六
13.2.索引映射
当 Spring Data Elasticsearch 应用
IndexOperations.createMapping()办法创立索引映射时，它应用Mapping Annotation Overview中形容的注解，尤其是@Field注解。除此之外，还能够将@Mapping正文增加到类中。此注解具备以下属性：
mappingPathJSON 格局的类门路资源；如果它不为空，则用作映射，则不进行其余映射解决。
enabled 当设置为 false 时，此标记将写入映射并且不进行进一步解决。
dateDetection并numericDetection在未设置为时设置映射中的相应属性DEFAULT。
dynamicDateFormats 当这个 String 数组不为空时，它定义了用于主动日期检测的日期格局。
runtimeFieldsPath JSON 格局的类门路资源，蕴含写入索引映射的运行时字段的定义，例如：
{
"day_of_week": {
"type": "keyword","script": { "source": "emit(doc['@timestamp'].value.dayOfWeekEnum.getDisplayName(TextStyle.FULL, Locale.ROOT))"}}
}
13.3.过滤器生成器
Filter Builder 进步了查问速度。
private ElasticsearchOperations operations;
IndexCoordinates index = IndexCoordinates.of("sample-index");
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(matchAllQuery())
.withFilter(boolFilter().must(termFilter("id", documentId)))
.build();
Page<SampleEntity> sampleEntities = operations.searchForPage(searchQuery, SampleEntity.class, index);
13.4.应用滚动获取大后果集
Elasticsearch 有一个滚动 API，用于获取大块的后果集。Spring Data Elasticsearch 在外部应用它来提供该<T> SearchHitsIterator<T>
SearchOperations.searchForStream(Query query, Class<T> clazz, IndexCoordinates index)办法的实现。
IndexCoordinates index = IndexCoordinates.of("sample-index");
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(matchAllQuery())
.withFields("message")
.withPageable(PageRequest.of(0, 10))
.build();
SearchHitsIterator<SampleEntity> stream = elasticsearchTemplate.searchForStream(searchQuery, SampleEntity.class, index);
List<SampleEntity> sampleEntities = new ArrayList<>();
while (stream.hasNext()) {
sampleEntities.add(stream.next());
}
stream.close();
API中没有SearchOperations拜访滚动 id 的办法，如果须要拜访它，ElasticsearchRestTemplate能够应用以下办法：
@Autowired ElasticsearchRestTemplate template;
IndexCoordinates index = IndexCoordinates.of("sample-index");
SearchQuery searchQuery = new NativeSearchQueryBuilder()
.withQuery(matchAllQuery())
.withFields("message")
.withPageable(PageRequest.of(0, 10))
.build();
SearchScrollHits<SampleEntity> scroll = template.searchScrollStart(1000, searchQuery, SampleEntity.class, index);
String scrollId = scroll.getScrollId();
List<SampleEntity> sampleEntities = new ArrayList<>();
while (scroll.hasSearchHits()) {
sampleEntities.addAll(scroll.getSearchHits());
scrollId = scroll.getScrollId();
scroll = template.searchScrollContinue(scrollId, 1000, SampleEntity.class);
}
template.searchScrollClear(scrollId);
要将 Scroll API 与存储库办法一起应用，返回类型必须Stream在 Elasticsearch 存储库中定义。而后，该办法的实现将应用 ElasticsearchTemplate 中的滚动办法。
interface SampleEntityRepository extends Repository<SampleEntity, String> {
Stream<SampleEntity> findBy();}
13.5排序选项
除了分页和排序中形容的默认排序选项之外，Spring Data Elasticsearch 还提供了
org.springframework.data.elasticsearch.core.query.Order派生自org.springframework.data.domain.Sort.Order. 它提供了在指定后果排序时能够发送到 Elasticsearch 的其余参数（请参阅https://www.elastic.co/guide/...）。
还有一个
org.springframework.data.elasticsearch.core.query.GeoDistanceOrder类可用于按天文间隔排序搜寻操作的后果。
如果要检索的类具备GeoPoint名为location的属性，则以下Sort将按到给定点的间隔对后果进行排序：
Sort.by(new GeoDistanceOrder("location", new GeoPoint(48.137154, 11.5761247)))
13.6运行时字段
从 Elasticsearch 的 7.12 版本开始，增加了运行时字段的性能（
https://www.elastic.co/guide/...）。Spring Data Elasticsearch 通过两种形式反对这一点：
13.6.1.索引映射中的运行时字段定义
定义运行时字段的第一种办法是将定义增加到索引映射中（请参阅
https://www.elastic.co/guide/...）。要在 Spring Data Elasticsearch 中应用这种办法，用户必须提供一个蕴含相应定义的 JSON 文件，例如：
示例 93.runtime-fields.json
{
"day_of_week": {
"type": "keyword","script": { "source": "emit(doc['@timestamp'].value.dayOfWeekEnum.getDisplayName(TextStyle.FULL, Locale.ROOT))"}}
}
此 JSON 文件的门路必须存在于类门路中，而后必须在@Mapping实体的正文中设置：
@Document(indexName = "runtime-fields")
@Mapping(runtimeFieldsPath = "/runtime-fields.json")
public class RuntimeFieldEntity {
// properties, getter, setter,...}
13.6.2.在查问上设置的运行时字段定义
定义运行时字段的第二种办法是将定义增加到搜寻查问（请参阅
https://www.elastic.co/guide/...）。以下代码示例显示了如何应用 Spring Data Elasticsearch 执行此操作：
应用的实体是一个具备price属性的简略对象：
@Document(indexName = "some_index_name")
public class SomethingToBuy {
private @Id @Nullable String id;@Nullable @Field(type = FieldType.Text) private String description;@Nullable @Field(type = FieldType.Double) private Double price;// getter and setter}
以下查问应用一个运行时字段，该字段priceWithTax通过将 19% 加到价格来计算一个值，并在搜寻查问中应用此值来查找priceWithTax高于或等于给定值的所有实体：
RuntimeField runtimeField = new RuntimeField("priceWithTax", "double", "emit(doc['price'].value * 1.19)");
Query query = new CriteriaQuery(new Criteria("priceWithTax").greaterThanEqual(16.5));
query.addRuntimeField(runtimeField);
SearchHits<SomethingToBuy> searchHits = operations.search(query, SomethingToBuy.class);
这实用于Query接口的每个实现。:leveloffset: -1