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

Class ElasticsearchAnySearchDAO

java.lang.Object

org.apache.syncope.core.persistence.jpa.dao.AbstractDAO<Any<?>>

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

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

All Implemented Interfaces:

AnySearchDAO, DAO<Any<?>>

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 co.elastic.clients.elasticsearch.ElasticsearchClient	client
protected int	indexMaxResultWindow

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

anyObjectDAO, anyUtilsFactory, dynRealmDAO, entityFactory, groupDAO, plainSchemaDAO, realmDAO, RELATIONSHIP_FIELDS, userDAO, validator

Fields inherited from class org.apache.syncope.core.persistence.jpa.dao.AbstractDAO

LOG

Constructor Summary

Constructors

Constructor	Description
ElasticsearchAnySearchDAO(RealmDAO realmDAO, 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 int	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, int page, int itemsPerPage, List<OrderByClause> orderBy, 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, AnyTypeKind kind)
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(PrivilegeCond 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, List<OrderByClause> orderBy)

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

buildEffectiveCond, buildResult, check, check, check, check, check, count, search, search, search

Methods inherited from class org.apache.syncope.core.persistence.jpa.dao.AbstractDAO

detach, entityManager, entityManagerFactory, isOracle, refresh

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.DAO

detach, refresh

Field Detail

client

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

indexMaxResultWindow

protected final int indexMaxResultWindow

Constructor Detail

ElasticsearchAnySearchDAO

public ElasticsearchAnySearchDAO(RealmDAO realmDAO,
                                 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 Detail

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 int 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,
                                                                                 List<OrderByClause> orderBy)

doSearch

protected <T extends Any<?>> List<T> doSearch(Realm base,
                                              boolean recursive,
                                              Set<String> adminRealms,
                                              SearchCond cond,
                                              int page,
                                              int itemsPerPage,
                                              List<OrderByClause> orderBy,
                                              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(PrivilegeCond 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,
                                                                           AnyTypeKind kind)

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)