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

Class ElasticsearchAnySearchDAO

java.lang.Object

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

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

All Implemented Interfaces:

AnySearchDAO

public class ElasticsearchAnySearchDAO
extends AbstractAnySearchDAO

Search engine implementation for users, groups and any objects, based on Elasticsearch.

Field Summary

Fields

Modifier and Type	Field	Description
protected final co.elastic.clients.elasticsearch.ElasticsearchClient	client
protected static final Set<String>	ID_PROPS
protected final int	indexMaxResultWindow

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

ALWAYS_FALSE_CLAUSE, anyObjectDAO, anyUtilsFactory, dynRealmDAO, entityFactory, groupDAO, LOG, plainSchemaDAO, realmSearchDAO, RELATIONSHIP_FIELDS, userDAO, validator

Constructor Summary

Constructors

Constructor	Description
ElasticsearchAnySearchDAO(RealmSearchDAO realmSearchDAO, DynRealmDAO dynRealmDAO, UserDAO userDAO, GroupDAO groupDAO, AnyObjectDAO anyObjectDAO, PlainSchemaDAO schemaDAO, EntityFactory entityFactory, AnyUtilsFactory anyUtilsFactory, PlainAttrValidationManager validator, co.elastic.clients.elasticsearch.ElasticsearchClient client, int indexMaxResultWindow)

Method Summary

Modifier and Type	Method	Description
protected Triple<PlainSchema,PlainAttrValue,AnyCond>	check(AnyCond cond, AnyTypeKind kind)
protected long	doCount(Realm base, boolean recursive, Set<String> adminRealms, SearchCond cond, AnyTypeKind kind)
protected <T extends Any> List<T>	doSearch(Realm base, boolean recursive, Set<String> adminRealms, SearchCond cond, org.springframework.data.domain.Pageable pageable, AnyTypeKind kind)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	fillAttrQuery(PlainSchema schema, PlainAttrValue attrValue, AttrCond cond)
protected Triple<Optional<co.elastic.clients.elasticsearch._types.query_dsl.Query>,Set<String>,Set<String>>	getAdminRealmsFilter(Realm base, boolean recursive, Set<String> adminRealms, AnyTypeKind kind)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(AnyCond cond, AnyTypeKind kind)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(AnyTypeCond 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(DynRealmCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(MemberCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(MembershipCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(RelationshipCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(RelationshipTypeCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(ResourceCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(RoleCond cond)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(SearchCond cond, AnyTypeKind kind)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQuery(Realm base, boolean recursive, Set<String> adminRealms, SearchCond cond, AnyTypeKind kind)
protected co.elastic.clients.elasticsearch._types.query_dsl.Query	getQueryForCustomConds(SearchCond cond, AnyTypeKind kind)
protected List<co.elastic.clients.elasticsearch._types.SortOptions>	sortBuilders(AnyTypeKind kind, Stream<org.springframework.data.domain.Sort.Order> orderBy)

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

buildEffectiveCond, buildResult, check, check, check, check, count, isPatternMatch, key, search, search, search

Methods inherited from class java.lang.Object

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

Field Details

ID_PROPS

protected static final Set<String> ID_PROPS

client

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

indexMaxResultWindow

protected final int indexMaxResultWindow

Constructor Details

ElasticsearchAnySearchDAO

public ElasticsearchAnySearchDAO(RealmSearchDAO realmSearchDAO,
 DynRealmDAO dynRealmDAO,
 UserDAO userDAO,
 GroupDAO groupDAO,
 AnyObjectDAO anyObjectDAO,
 PlainSchemaDAO schemaDAO,
 EntityFactory entityFactory,
 AnyUtilsFactory anyUtilsFactory,
 PlainAttrValidationManager validator,
 co.elastic.clients.elasticsearch.ElasticsearchClient client,
 int indexMaxResultWindow)

Method Details

getAdminRealmsFilter

protected Triple<Optional<co.elastic.clients.elasticsearch._types.query_dsl.Query>,Set<String>,Set<String>> getAdminRealmsFilter(Realm base,
 boolean recursive,
 Set<String> adminRealms,
 AnyTypeKind kind)

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(Realm base,
 boolean recursive,
 Set<String> adminRealms,
 SearchCond cond,
 AnyTypeKind kind)

doCount

protected long doCount(Realm base,
 boolean recursive,
 Set<String> adminRealms,
 SearchCond cond,
 AnyTypeKind kind)

Specified by:

doCount in class AbstractAnySearchDAO

sortBuilders

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

doSearch

protected <T extends Any> List<T> doSearch(Realm base,
 boolean recursive,
 Set<String> adminRealms,
 SearchCond cond,
 org.springframework.data.domain.Pageable pageable,
 AnyTypeKind kind)

Specified by:

doSearch in class AbstractAnySearchDAO

getQuery

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

getQuery

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

getQuery

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

getQuery

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

getQuery

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

getQuery

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

getQuery

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

getQuery

protected co.elastic.clients.elasticsearch._types.query_dsl.Query getQuery(MemberCond 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)

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)

check

protected Triple<PlainSchema,PlainAttrValue,AnyCond> check(AnyCond cond,
 AnyTypeKind kind)

Overrides:

check in class AbstractAnySearchDAO

getQuery

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

getQueryForCustomConds

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