org.springframework.data.elasticsearch.repository.support

Class AbstractElasticsearchRepository<T,ID extends Serializable>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

NumberKeyedRepository, SimpleElasticsearchRepository

public abstract class AbstractElasticsearchRepository<T,ID extends Serializable>
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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
AbstractElasticsearchRepository()
AbstractElasticsearchRepository(ElasticsearchEntityInformation<T,ID> metadata, ElasticsearchOperations elasticsearchOperations)
AbstractElasticsearchRepository(ElasticsearchOperations elasticsearchOperations)

Method Summary

Modifier and Type	Method and Description
long	count()
void	delete(ID id)
void	delete(Iterable<? extends T> entities)
void	delete(T entity)
void	deleteAll()
boolean	exists(ID id)
protected ID	extractIdFromBean(T entity)
Iterable<T>	findAll()
Iterable<T>	findAll(Iterable<ID> ids)
Page<T>	findAll(Pageable pageable)
Iterable<T>	findAll(Sort sort)
T	findOne(ID id)
Class<T>	getEntityClass()
<S extends T> S	index(S entity)
<S extends T> Iterable<S>	save(Iterable<S> entities)
<S extends T> List<S>	save(List<S> entities)
<S extends T> S	save(S entity)
Iterable<T>	search(org.elasticsearch.index.query.QueryBuilder query)
FacetedPage<T>	search(org.elasticsearch.index.query.QueryBuilder query, Pageable pageable)
FacetedPage<T>	search(SearchQuery query)
Page<T>	searchSimilar(T entity, String[] fields, Pageable pageable)
void	setElasticsearchOperations(ElasticsearchOperations elasticsearchOperations)
void	setEntityClass(Class<T> entityClass)
protected abstract String	stringIdRepresentation(ID id)

Methods inherited from class java.lang.Object

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

Field Detail

elasticsearchOperations

protected ElasticsearchOperations elasticsearchOperations

entityClass

protected Class<T> entityClass

entityInformation

protected ElasticsearchEntityInformation<T,ID extends Serializable> entityInformation

Constructor Detail

AbstractElasticsearchRepository

public AbstractElasticsearchRepository()

AbstractElasticsearchRepository

public AbstractElasticsearchRepository(ElasticsearchOperations elasticsearchOperations)

AbstractElasticsearchRepository

public AbstractElasticsearchRepository(ElasticsearchEntityInformation<T,ID> metadata,
                                       ElasticsearchOperations elasticsearchOperations)

Method Detail

findOne

public T findOne(ID id)

Specified by:

findOne in interface CrudRepository<T,ID extends Serializable>

findAll

public Iterable<T> findAll()

Specified by:

findAll in interface CrudRepository<T,ID extends Serializable>

findAll

public Page<T> findAll(Pageable pageable)

Specified by:

findAll in interface PagingAndSortingRepository<T,ID extends Serializable>

findAll

public Iterable<T> findAll(Sort sort)

Specified by:

findAll in interface PagingAndSortingRepository<T,ID extends Serializable>

findAll

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

Specified by:

findAll in interface CrudRepository<T,ID extends Serializable>

count

public long count()

Specified by:

count in interface CrudRepository<T,ID extends Serializable>

save

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

Specified by:

save in interface CrudRepository<T,ID extends Serializable>

save

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

index

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

Specified by:

index in interface ElasticsearchRepository<T,ID extends Serializable>

save

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

Specified by:

save in interface CrudRepository<T,ID extends Serializable>

exists

public boolean exists(ID id)

Specified by:

exists in interface CrudRepository<T,ID extends Serializable>

search

public Iterable<T> search(org.elasticsearch.index.query.QueryBuilder query)

Specified by:

search in interface ElasticsearchRepository<T,ID extends Serializable>

search

public FacetedPage<T> search(org.elasticsearch.index.query.QueryBuilder query,
                             Pageable pageable)

Specified by:

search in interface ElasticsearchRepository<T,ID extends Serializable>

search

public FacetedPage<T> search(SearchQuery query)

Specified by:

search in interface ElasticsearchRepository<T,ID extends Serializable>

searchSimilar

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

Specified by:

searchSimilar in interface ElasticsearchRepository<T,ID extends Serializable>

delete

public void delete(ID id)

Specified by:

delete in interface CrudRepository<T,ID extends Serializable>

delete

public void delete(T entity)

Specified by:

delete in interface CrudRepository<T,ID extends Serializable>

delete

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

Specified by:

delete in interface CrudRepository<T,ID extends Serializable>

deleteAll

public void deleteAll()

Specified by:

deleteAll in interface CrudRepository<T,ID extends Serializable>

getEntityClass

public Class<T> getEntityClass()

setEntityClass

public final void setEntityClass(Class<T> entityClass)

setElasticsearchOperations

public final void setElasticsearchOperations(ElasticsearchOperations elasticsearchOperations)

extractIdFromBean

protected ID extractIdFromBean(T entity)

stringIdRepresentation

protected abstract String stringIdRepresentation(ID id)