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

Class OpenSearchAnySearchDAO

java.lang.Object

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

org.apache.syncope.core.persistence.opensearch.dao.OpenSearchAnySearchDAO

All Implemented Interfaces:

AnySearchDAO

public class OpenSearchAnySearchDAO
extends AbstractAnySearchDAO

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	OpenSearchAnySearchDAO.AdminRealmsFilter

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

AbstractAnySearchDAO.CheckResult<C extends AttrCond>

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.opensearch.client.opensearch.OpenSearchClient	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, entityFactory, groupDAO, LOG, plainSchemaDAO, realmSearchDAO, RELATIONSHIP_FIELDS, userDAO, validator

Constructor Summary

Constructors

Constructor	Description
OpenSearchAnySearchDAO(RealmSearchDAO realmSearchDAO, UserDAO userDAO, GroupDAO groupDAO, AnyObjectDAO anyObjectDAO, PlainSchemaDAO schemaDAO, EntityFactory entityFactory, AnyUtilsFactory anyUtilsFactory, PlainAttrValidationManager validator, org.opensearch.client.opensearch.OpenSearchClient client, int indexMaxResultWindow)

Method Summary

Modifier and Type	Method	Description
protected AbstractAnySearchDAO.CheckResult<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 org.opensearch.client.opensearch._types.query_dsl.Query	fillAttrQuery(PlainSchema schema, PlainAttrValue attrValue, AttrCond cond)
protected OpenSearchAnySearchDAO.AdminRealmsFilter	getAdminRealmsFilter(Realm base, boolean recursive, Set<String> adminRealms)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(AnyCond cond, AnyTypeKind kind)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(AnyTypeCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(AttrCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(AuxClassCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(MemberCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(MembershipCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(RelationshipCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(RelationshipTypeCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(ResourceCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(RoleCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(SearchCond cond, AnyTypeKind kind)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(Realm base, boolean recursive, Set<String> adminRealms, SearchCond cond, AnyTypeKind kind)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQueryForCustomConds(SearchCond cond, AnyTypeKind kind)
protected List<org.opensearch.client.opensearch._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 org.opensearch.client.opensearch.OpenSearchClient client

indexMaxResultWindow

protected final int indexMaxResultWindow

Constructor Details

OpenSearchAnySearchDAO

public OpenSearchAnySearchDAO(RealmSearchDAO realmSearchDAO,
 UserDAO userDAO,
 GroupDAO groupDAO,
 AnyObjectDAO anyObjectDAO,
 PlainSchemaDAO schemaDAO,
 EntityFactory entityFactory,
 AnyUtilsFactory anyUtilsFactory,
 PlainAttrValidationManager validator,
 org.opensearch.client.opensearch.OpenSearchClient client,
 int indexMaxResultWindow)

Method Details

getAdminRealmsFilter

protected OpenSearchAnySearchDAO.AdminRealmsFilter getAdminRealmsFilter(Realm base,
 boolean recursive,
 Set<String> adminRealms)

getQuery

protected org.opensearch.client.opensearch._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<org.opensearch.client.opensearch._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 org.opensearch.client.opensearch._types.query_dsl.Query getQuery(SearchCond cond,
 AnyTypeKind kind)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(AnyTypeCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(RelationshipTypeCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(RelationshipCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(MembershipCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(RoleCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(MemberCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(AuxClassCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(ResourceCond cond)

fillAttrQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query fillAttrQuery(PlainSchema schema,
 PlainAttrValue attrValue,
 AttrCond cond)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(AttrCond cond)

check

protected AbstractAnySearchDAO.CheckResult<AnyCond> check(AnyCond cond,
 AnyTypeKind kind)

Overrides:

check in class AbstractAnySearchDAO

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(AnyCond cond,
 AnyTypeKind kind)

getQueryForCustomConds

protected org.opensearch.client.opensearch._types.query_dsl.Query getQueryForCustomConds(SearchCond cond,
 AnyTypeKind kind)