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

Class OpenSearchRealmSearchDAO

java.lang.Object

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

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

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

All Implemented Interfaces:

RealmSearchDAO

public class OpenSearchRealmSearchDAO
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 org.opensearch.client.opensearch.OpenSearchClient	client
protected static final List<org.opensearch.client.opensearch._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
OpenSearchRealmSearchDAO(RealmDAO realmDAO, PlainSchemaDAO plainSchemaDAO, EntityFactory entityFactory, PlainAttrValidationManager validator, org.opensearch.client.opensearch.OpenSearchClient client, int indexMaxResultWindow)

Method Summary

Modifier and Type	Method	Description
protected org.opensearch.client.opensearch._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 org.opensearch.client.opensearch._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 org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(AnyCond 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(ResourceCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQuery(SearchCond cond)
protected org.opensearch.client.opensearch._types.query_dsl.Query	getQueryForCustomConds(SearchCond cond)
protected List<String>	search(org.opensearch.client.opensearch._types.query_dsl.Query query)
protected List<org.opensearch.client.opensearch._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<org.opensearch.client.opensearch._types.SortOptions> FULLPATH_SORT_OPTIONS

realmDAO

protected final RealmDAO realmDAO

realmUtils

protected final RealmUtils realmUtils

client

protected final org.opensearch.client.opensearch.OpenSearchClient client

indexMaxResultWindow

protected final int indexMaxResultWindow

Constructor Details

OpenSearchRealmSearchDAO

public OpenSearchRealmSearchDAO(RealmDAO realmDAO,
 PlainSchemaDAO plainSchemaDAO,
 EntityFactory entityFactory,
 PlainAttrValidationManager validator,
 org.opensearch.client.opensearch.OpenSearchClient 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(org.opensearch.client.opensearch._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 org.opensearch.client.opensearch._types.query_dsl.Query buildDescendantsQuery(Set<String> bases,
 SearchCond searchCond)

getQuery

protected org.opensearch.client.opensearch._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 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)

getQuery

protected org.opensearch.client.opensearch._types.query_dsl.Query getQuery(AnyCond 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)

getQueryForCustomConds

protected org.opensearch.client.opensearch._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<org.opensearch.client.opensearch._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