Class SimpleElasticsearchRepository<T,ID>

java.lang.Object

org.springframework.data.elasticsearch.repository.support.SimpleElasticsearchRepository<T,ID>

All Implemented Interfaces:

ElasticsearchRepository<T,ID>, CrudRepository<T,ID>, PagingAndSortingRepository<T,ID>, Repository<T,ID>

public class SimpleElasticsearchRepository<T,ID>
extends Object
implements ElasticsearchRepository<T,ID>

Elasticsearch specific repository implementation. Likely to be used as target within ElasticsearchRepositoryFactory

Author:

Rizwan Idrees, Mohsin Husen, Ryan Henszey, Kevin Leturc, Mark Paluch, Christoph Strobl, Michael Wirth, Sascha Woo, Murali Chevuri, Peter-Josef Meisch, Aleksei Arsenev, Jens Schauder

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SimpleElasticsearchRepository.OperationsCallback<R>

Field Summary

Fields

Modifier and Type	Field	Description
protected Class<T>	entityClass
protected ElasticsearchEntityInformation<T,ID>	entityInformation
protected IndexOperations	indexOperations
protected ElasticsearchOperations	operations

Constructor Summary

Constructors

Constructor	Description
SimpleElasticsearchRepository(ElasticsearchEntityInformation<T,ID> metadata, ElasticsearchOperations operations)

Method Summary

Modifier and Type	Method	Description
long	count()
void	createIndexAndMappingIfNeeded()
void	delete(T entity)
void	delete(T entity, @Nullable RefreshPolicy refreshPolicy)
void	deleteAll()
void	deleteAll(Iterable<? extends T> entities)
void	deleteAll(Iterable<? extends T> entities, @Nullable RefreshPolicy refreshPolicy)
void	deleteAll(@Nullable RefreshPolicy refreshPolicy)
void	deleteAllById(Iterable<? extends ID> ids)
void	deleteAllById(Iterable<? extends ID> ids, @Nullable RefreshPolicy refreshPolicy)
void	deleteById(ID id)
void	deleteById(ID id, @Nullable RefreshPolicy refreshPolicy)
<R> @Nullable R	execute(SimpleElasticsearchRepository.OperationsCallback<R> callback)
<R> @Nullable R	executeAndRefresh(SimpleElasticsearchRepository.OperationsCallback<R> callback)
<R> @Nullable R	executeAndRefresh(SimpleElasticsearchRepository.OperationsCallback<R> callback, @Nullable RefreshPolicy refreshPolicy)
boolean	existsById(ID id)
protected @Nullable ID	extractIdFromBean(T entity)
Iterable<T>	findAll()
Page<T>	findAll(Pageable pageable)
Iterable<T>	findAll(Sort sort)
Iterable<T>	findAllById(Iterable<ID> ids)
Optional<T>	findById(ID id)
<S extends T> List<S>	save(List<S> entities)
<S extends T> List<S>	save(List<S> entities, @Nullable RefreshPolicy refreshPolicy)
<S extends T> S	save(S entity)
<S extends T> S	save(S entity, @Nullable RefreshPolicy refreshPolicy)
<S extends T> Iterable<S>	saveAll(Iterable<S> entities)
<S extends T> Iterable<S>	saveAll(Iterable<S> entities, @Nullable RefreshPolicy refreshPolicy)
Page<T>	searchSimilar(T entity, @Nullable String[] fields, Pageable pageable)	Search for similar entities using a morelikethis query
protected @Nullable String	stringIdRepresentation(@Nullable ID id)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

operations

protected ElasticsearchOperations operations

indexOperations

protected IndexOperations indexOperations

entityClass

protected Class<T> entityClass

entityInformation

protected ElasticsearchEntityInformation<T,ID> entityInformation

Constructor Details

SimpleElasticsearchRepository

public SimpleElasticsearchRepository(ElasticsearchEntityInformation<T,ID> metadata,
 ElasticsearchOperations operations)

Method Details

createIndexAndMappingIfNeeded

public void createIndexAndMappingIfNeeded()

findById

public Optional<T> findById(ID id)

Specified by:

findById in interface CrudRepository<T,ID>

findAll

public Iterable<T> findAll()

Specified by:

findAll in interface CrudRepository<T,ID>

findAll

public Page<T> findAll(Pageable pageable)

Specified by:

findAll in interface PagingAndSortingRepository<T,ID>

findAll

public Iterable<T> findAll(Sort sort)

Specified by:

findAll in interface PagingAndSortingRepository<T,ID>

findAllById

public Iterable<T> findAllById(Iterable<ID> ids)

Specified by:

findAllById in interface CrudRepository<T,ID>

count

public long count()

Specified by:

count in interface CrudRepository<T,ID>

save

public <S extends T> S save(S entity)

Specified by:

save in interface CrudRepository<T,ID>

save

public <S extends T> S save(S entity,
 @Nullable RefreshPolicy refreshPolicy)

Specified by:

save in interface ElasticsearchRepository<T,ID>

save

public <S extends T> List<S> save(List<S> entities)

save

public <S extends T> List<S> save(List<S> entities,
 @Nullable RefreshPolicy refreshPolicy)

saveAll

public <S extends T> Iterable<S> saveAll(Iterable<S> entities)

Specified by:

saveAll in interface CrudRepository<T,ID>

saveAll

public <S extends T> Iterable<S> saveAll(Iterable<S> entities,
 @Nullable RefreshPolicy refreshPolicy)

Specified by:

saveAll in interface ElasticsearchRepository<T,ID>

existsById

public boolean existsById(ID id)

Specified by:

existsById in interface CrudRepository<T,ID>

searchSimilar

public Page<T> searchSimilar(T entity,
 @Nullable String[] fields,
 Pageable pageable)

Description copied from interface: ElasticsearchRepository

Search for similar entities using a morelikethis query

Specified by:

searchSimilar in interface ElasticsearchRepository<T,ID>

Parameters:

entity - the entity for which similar documents should be searched, must not be null

fields -

pageable - , must not be null

Returns:

deleteById

public void deleteById(ID id)

Specified by:

deleteById in interface CrudRepository<T,ID>

deleteById

public void deleteById(ID id,
 @Nullable RefreshPolicy refreshPolicy)

Specified by:

deleteById in interface ElasticsearchRepository<T,ID>

delete

public void delete(T entity)

Specified by:

delete in interface CrudRepository<T,ID>

delete

public void delete(T entity,
 @Nullable RefreshPolicy refreshPolicy)

Specified by:

delete in interface ElasticsearchRepository<T,ID>

deleteAllById

public void deleteAllById(Iterable<? extends ID> ids)

Specified by:

deleteAllById in interface CrudRepository<T,ID>

deleteAllById

public void deleteAllById(Iterable<? extends ID> ids,
 @Nullable RefreshPolicy refreshPolicy)

Specified by:

deleteAllById in interface ElasticsearchRepository<T,ID>

deleteAll

public void deleteAll(Iterable<? extends T> entities)

Specified by:

deleteAll in interface CrudRepository<T,ID>

deleteAll

public void deleteAll(Iterable<? extends T> entities,
 @Nullable RefreshPolicy refreshPolicy)

Specified by:

deleteAll in interface ElasticsearchRepository<T,ID>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface CrudRepository<T,ID>

deleteAll

public void deleteAll(@Nullable RefreshPolicy refreshPolicy)

Specified by:

deleteAll in interface ElasticsearchRepository<T,ID>

extractIdFromBean

protected @Nullable ID extractIdFromBean(T entity)

stringIdRepresentation

protected @Nullable String stringIdRepresentation(@Nullable ID id)

execute

public <R> @Nullable R execute(SimpleElasticsearchRepository.OperationsCallback<R> callback)

executeAndRefresh

public <R> @Nullable R executeAndRefresh(SimpleElasticsearchRepository.OperationsCallback<R> callback)

executeAndRefresh

public <R> @Nullable R executeAndRefresh(SimpleElasticsearchRepository.OperationsCallback<R> callback,
 @Nullable RefreshPolicy refreshPolicy)