Package org.apache.syncope.core.persistence.elasticsearch.dao

Class ElasticsearchRealmSearchDAO

java.lang.Object

org.apache.syncope.core.persistence.common.dao.AbstractSearchDAO

org.apache.syncope.core.persistence.common.dao.AbstractRealmSearchDAO

org.apache.syncope.core.persistence.elasticsearch.dao.ElasticsearchRealmSearchDAO

All Implemented Interfaces:

RealmSearchDAO

public class ElasticsearchRealmSearchDAO
extends AbstractRealmSearchDAO
implements RealmSearchDAO

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.syncope.core.persistence.common.dao.AbstractSearchDAO

AbstractSearchDAO.CheckResult<C extends AttrCond>

Field Summary

Fields

Modifier and Type	Field	Description
protected final co.elastic.clients.elasticsearch.ElasticsearchClient	client
protected static final List<co.elastic.clients.elasticsearch._types.SortOptions>	FULLPATH_SORT_OPTIONS
protected static final Set<String>	ID_PROPS
protected final int	indexMaxResultWindow
protected final RealmDAO	realmDAO
protected final RealmUtils	realmUtils

Fields inherited from class org.apache.syncope.core.persistence.common.dao.AbstractRealmSearchDAO

RELATIONSHIP_FIELDS

Fields inherited from class org.apache.syncope.core.persistence.common.dao.AbstractSearchDAO

ALWAYS_FALSE_CLAUSE, entityFactory, LITERAL_COMPARATOR, LOG, plainSchemaDAO, validator

Constructor Summary

Constructors

Constructor	Description
ElasticsearchRealmSearchDAO(RealmDAO realmDAO, PlainSchemaDAO plainSchemaDAO, EntityFactory entityFactory, PlainAttrValidationManager validator, co.elastic.clients.elasticsearch.ElasticsearchClient client, int indexMaxResultWindow)

Method Summary

Modifier and Type	Method	Description
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	buildDescendantsQuery(Set<String> bases, SearchCond searchCond)
protected AbstractSearchDAO.CheckResult<AnyCond>	check(AnyCond cond, Field field, Set<String> relationshipsFields)
protected long	doCount(Set<String> bases, SearchCond searchCond)
protected List<Realm>	doSearch(Set<String> bases, SearchCond searchCond, org.springframework.data.domain.Pageable pageable)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	fillAttrQuery(PlainSchema schema, PlainAttrValue attrValue, AttrCond cond)
Optional<Realm>	findByFullPath(String fullPath)
List<Realm>	findByName(String name)
List<Realm>	findChildren(Realm realm)
List<Realm>	findDescendants(String base, String prefix)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(AnyCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(AttrCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(AuxClassCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(ResourceCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(SearchCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQueryForCustomConds(SearchCond cond)
protected List<String>	search(co.elastic.clients.elasticsearch._types.query_dsl.Query query)
protected List<co.elastic.clients.elasticsearch._types.SortOptions>	sortBuilders(Stream<org.springframework.data.domain.Sort.Order> orderBy)

Methods inherited from class org.apache.syncope.core.persistence.common.dao.AbstractRealmSearchDAO

count, findByDerAttrValue, search

Methods inherited from class org.apache.syncope.core.persistence.common.dao.AbstractSearchDAO

buildDerAttrValueConditions, check, key, split, syncopeClientException

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.syncope.core.persistence.api.dao.RealmSearchDAO

count, findAncestors, findAncestors, findByDerAttrValue, getAllMatchingCond, search

Field Details

ID_PROPS

protected static final Set<String> ID_PROPS

FULLPATH_SORT_OPTIONS

protected static final List<co.elastic.clients.elasticsearch._types.SortOptions> FULLPATH_SORT_OPTIONS

realmDAO

protected final RealmDAO realmDAO

realmUtils

protected final RealmUtils realmUtils

client

protected final co.elastic.clients.elasticsearch.ElasticsearchClient client

indexMaxResultWindow

protected final int indexMaxResultWindow

Constructor Details

ElasticsearchRealmSearchDAO

public ElasticsearchRealmSearchDAO(RealmDAO realmDAO,
 PlainSchemaDAO plainSchemaDAO,
 EntityFactory entityFactory,
 PlainAttrValidationManager validator,
 co.elastic.clients.elasticsearch.ElasticsearchClient client,
 int indexMaxResultWindow)

Method Details

findByFullPath

@Transactional(readOnly=true)
public Optional<Realm> findByFullPath(String fullPath)

Specified by:

findByFullPath in interface RealmSearchDAO

search

protected List<String> search(co.elastic.clients.elasticsearch._types.query_dsl.Query query)

findByName

public List<Realm> findByName(String name)

Specified by:

findByName in interface RealmSearchDAO

findChildren

public List<Realm> findChildren(Realm realm)

Specified by:

findChildren in interface RealmSearchDAO

buildDescendantsQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query buildDescendantsQuery(Set<String> bases,
 SearchCond searchCond)

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(SearchCond cond)

check

protected AbstractSearchDAO.CheckResult<AnyCond> check(AnyCond cond,
 Field field,
 Set<String> relationshipsFields)

Overrides:

check in class AbstractSearchDAO

fillAttrQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query fillAttrQuery(PlainSchema schema,
 PlainAttrValue attrValue,
 AttrCond cond)

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(AttrCond cond)

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(AnyCond cond)

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(AuxClassCond cond)

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(ResourceCond cond)

getQueryForCustomConds

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQueryForCustomConds(SearchCond cond)

doCount

protected long doCount(Set<String> bases,
 SearchCond searchCond)

Specified by:

doCount in class AbstractRealmSearchDAO

sortBuilders

protected List<co.elastic.clients.elasticsearch._types.SortOptions> sortBuilders(Stream<org.springframework.data.domain.Sort.Order> orderBy)

doSearch

protected List<Realm> doSearch(Set<String> bases,
 SearchCond searchCond,
 org.springframework.data.domain.Pageable pageable)

Specified by:

doSearch in class AbstractRealmSearchDAO

findDescendants

public List<Realm> findDescendants(String base,
 String prefix)

Specified by:

findDescendants in interface RealmSearchDAO