de.hybris.platform.solrfacetsearch.solr.impl

Class AbstractSolrSearchProvider

java.lang.Object

de.hybris.platform.solrfacetsearch.solr.impl.AbstractSolrSearchProvider

All Implemented Interfaces:

SolrSearchProvider

Direct Known Subclasses:

SolrCloudSearchProvider, SolrStandaloneSearchProvider

public abstract class AbstractSolrSearchProvider
extends Object
implements SolrSearchProvider

Abstract implementation of SolrSearchProvider.

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.solrfacetsearch.solr.SolrSearchProvider

SolrSearchProvider.CommitType

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	CHARSET
protected static int	DEFAULT_ALIVE_CHECK_INTERVAL
protected static String	DEFAULT_CONFIGSET_PROPERTY
protected static String	DEFAULT_CONFIGSET_VALUE
protected static int	DEFAULT_CONNECTION_TIMEOUT
protected static int	DEFAULT_MAX_CONNECTIONS
protected static int	DEFAULT_MAX_CONNECTIONS_PER_HOST
protected static int	DEFAULT_SOCKET_TIMEOUT
protected static String	FILTER_IGNORE_CASE_KEY
protected static String	IGNORE_CASE_ATTRIBUTE
protected static String	MANAGED_STOPWORDS_RESOURCE_CLASS
protected static String	MANAGED_SYNONYM_RESOURCE_CLASS
protected static String	SOLR_QUERY_SELECT_ALL
protected static String	STOP_WORDS_RESOURCE_PATH
protected static String	SYNONYM_RESOURCE_PATH
protected static String	SYNONYM_SPLIT_CHAR
protected static String	UTF8_ENCODING

Constructor Summary

Constructors

Constructor and Description
AbstractSolrSearchProvider()

Method Summary

Modifier and Type	Method and Description
protected Map<String,Set<String>>	buildSynonyms(String synonymFromInput)
protected Map<String,Set<String>>	buildSynonyms(String synonymFromInput, String synonymToInput)
void	commit(Index index, SolrSearchProvider.CommitType commitType) Performs a commit on the given index.
protected void	compareSynonyms(Map<String,Set<String>> synonyms, Map<String,Set<String>> serverSynonyms, Map<String,Set<String>> synonymsToAdd, Set<String> synonymsToRemove)
protected Map<String,Set<String>>	createSynonyms(String lang, FacetSearchConfig facetSearchConfig)
protected Map<String,Map<String,Set<String>>>	createSynonymsForLanguages(Collection<String> languages, FacetSearchConfig facetSearchConfig)
void	deleteAllDocuments(Index index) Deletes all documents from an index.
void	deleteDocumentsByPk(Index index, Collection<PK> pks) Deletes documents matching the provided list of pks
void	deleteOldDocuments(Index index, long indexOperationId) Deletes old documents from an index.
protected String	encode(String string)
protected void	executeHttpDelete(HttpClient httpClient, String requestUrl)
protected <T> T	executeHttpGet(HttpClient httpClient, String requestUrl, ObjectMapper objectMapper, Class<T> responseType)
protected void	executeHttpPost(HttpClient httpClient, String requestUrl, ObjectMapper objectMapper, Object body)
protected void	executeHttpPut(HttpClient httpClient, String requestUrl, ObjectMapper objectMapper, Object body)
protected void	exportStopWords(String serverURL, HttpClient httpClient, Collection<String> languages, Map<String,Set<String>> stopWordsForLanguage)
protected void	exportSynonyms(String serverURL, HttpClient httpClient, Collection<String> languages, Map<String,Map<String,Set<String>>> synonymsForLanguagesMap)
ConfigurationService	getConfigurationService()
IndexNameResolver	getIndexNameResolver()
protected int	getIntegerValue(Integer bigInt, int defaultValue)
protected Collection<String>	getLanguages(FacetSearchConfig configuration)
SolrClientPool	getSolrClientPool()
SolrFacetSearchConfigDao	getSolrFacetSearchConfigDao()
protected Map<String,Set<String>>	getStopWordsFromConfig(FacetSearchConfig facetSearchConfig)
protected void	logSynonyms(SolrFacetSearchConfigModel facetSearchConfigModel)
void	optimize(Index index) Optimizes a given index.
protected String	resolveConfigSet(FacetSearchConfig facetSearchConfig, IndexedType indexedType)
Index	resolveIndex(FacetSearchConfig facetSearchConfig, IndexedType indexedType, String qualifier) Resolves an index.
void	setConfigurationService(ConfigurationService configurationService)
void	setIndexNameResolver(IndexNameResolver indexNameResolver)
void	setSolrClientPool(SolrClientPool solrClientPool)
void	setSolrFacetSearchConfigDao(SolrFacetSearchConfigDao solrFacetSearchConfigDao)

Methods inherited from class java.lang.Object

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

Methods inherited from interface de.hybris.platform.solrfacetsearch.solr.SolrSearchProvider

createIndex, deleteIndex, exportConfig, getClient, getClientForIndexing

Field Detail

DEFAULT_ALIVE_CHECK_INTERVAL

protected static final int DEFAULT_ALIVE_CHECK_INTERVAL

See Also:

Constant Field Values

DEFAULT_MAX_CONNECTIONS

protected static final int DEFAULT_MAX_CONNECTIONS

See Also:

Constant Field Values

DEFAULT_MAX_CONNECTIONS_PER_HOST

protected static final int DEFAULT_MAX_CONNECTIONS_PER_HOST

See Also:

Constant Field Values

DEFAULT_SOCKET_TIMEOUT

protected static final int DEFAULT_SOCKET_TIMEOUT

See Also:

Constant Field Values

DEFAULT_CONNECTION_TIMEOUT

protected static final int DEFAULT_CONNECTION_TIMEOUT

See Also:

Constant Field Values

DEFAULT_CONFIGSET_PROPERTY

protected static final String DEFAULT_CONFIGSET_PROPERTY

See Also:

Constant Field Values

DEFAULT_CONFIGSET_VALUE

protected static final String DEFAULT_CONFIGSET_VALUE

See Also:

Constant Field Values

SYNONYM_SPLIT_CHAR

protected static final String SYNONYM_SPLIT_CHAR

See Also:

Constant Field Values

SYNONYM_RESOURCE_PATH

protected static final String SYNONYM_RESOURCE_PATH

See Also:

Constant Field Values

STOP_WORDS_RESOURCE_PATH

protected static final String STOP_WORDS_RESOURCE_PATH

See Also:

Constant Field Values

MANAGED_SYNONYM_RESOURCE_CLASS

protected static final String MANAGED_SYNONYM_RESOURCE_CLASS

See Also:

Constant Field Values

MANAGED_STOPWORDS_RESOURCE_CLASS

protected static final String MANAGED_STOPWORDS_RESOURCE_CLASS

See Also:

Constant Field Values

FILTER_IGNORE_CASE_KEY

protected static final String FILTER_IGNORE_CASE_KEY

See Also:

Constant Field Values

IGNORE_CASE_ATTRIBUTE

protected static final String IGNORE_CASE_ATTRIBUTE

See Also:

Constant Field Values

CHARSET

protected static final String CHARSET

See Also:

Constant Field Values

UTF8_ENCODING

protected static final String UTF8_ENCODING

See Also:

Constant Field Values

SOLR_QUERY_SELECT_ALL

protected static final String SOLR_QUERY_SELECT_ALL

See Also:

Constant Field Values

Constructor Detail

AbstractSolrSearchProvider

public AbstractSolrSearchProvider()

Method Detail

resolveIndex

public Index resolveIndex(FacetSearchConfig facetSearchConfig,
                          IndexedType indexedType,
                          String qualifier)

Description copied from interface: SolrSearchProvider

Resolves an index. Resolving an index only creates a search provider specific instance of Index.

Specified by:

resolveIndex in interface SolrSearchProvider

Parameters:

facetSearchConfig - - the facet search configuration

indexedType - - the indexed type

qualifier - - the qualifier

Returns:

the index

deleteAllDocuments

public void deleteAllDocuments(Index index)
                        throws SolrServiceException

Description copied from interface: SolrSearchProvider

Deletes all documents from an index.

Specified by:

deleteAllDocuments in interface SolrSearchProvider

Parameters:

index - - the index

Throws:

SolrServiceException - if an error occurs

deleteOldDocuments

public void deleteOldDocuments(Index index,
                               long indexOperationId)
                        throws SolrServiceException

Description copied from interface: SolrSearchProvider

Deletes old documents from an index. Old documents are documents that were not created/updated since a given index operation.

Specified by:

deleteOldDocuments in interface SolrSearchProvider

Parameters:

index - - the index

indexOperationId - - the index operation id

Throws:

SolrServiceException - if an error occurs

deleteDocumentsByPk

public void deleteDocumentsByPk(Index index,
                                Collection<PK> pks)
                         throws SolrServiceException

Description copied from interface: SolrSearchProvider

Deletes documents matching the provided list of pks

Specified by:

deleteDocumentsByPk in interface SolrSearchProvider

Parameters:

index - - the index

pks - - the pks list

Throws:

SolrServiceException - if an error occurs

commit

public void commit(Index index,
                   SolrSearchProvider.CommitType commitType)
            throws SolrServiceException

Description copied from interface: SolrSearchProvider

Performs a commit on the given index. An hard commit makes sure that indexed documents are persisted and visible, a soft commit makes sure indexed documents are visible.

Specified by:

commit in interface SolrSearchProvider

Parameters:

index - - the index

commitType - - the commit type

Throws:

SolrServiceException - if an error occurs

optimize

public void optimize(Index index)
              throws SolrServiceException

Description copied from interface: SolrSearchProvider

Optimizes a given index. It does not wait for the operation to complete.

Specified by:

optimize in interface SolrSearchProvider

Parameters:

index - - the index

Throws:

SolrServiceException - if an error occurs

resolveConfigSet

protected String resolveConfigSet(FacetSearchConfig facetSearchConfig,
                                  IndexedType indexedType)

getIntegerValue

protected int getIntegerValue(Integer bigInt,
                              int defaultValue)

encode

protected String encode(String string)
                 throws SolrServiceException

Throws:

SolrServiceException

exportSynonyms

protected void exportSynonyms(String serverURL,
                              HttpClient httpClient,
                              Collection<String> languages,
                              Map<String,Map<String,Set<String>>> synonymsForLanguagesMap)
                       throws IOException,
                              SolrServiceException,
                              SolrRestException

Throws:

IOException

SolrServiceException

SolrRestException

compareSynonyms

protected void compareSynonyms(Map<String,Set<String>> synonyms,
                               Map<String,Set<String>> serverSynonyms,
                               Map<String,Set<String>> synonymsToAdd,
                               Set<String> synonymsToRemove)

getLanguages

protected Collection<String> getLanguages(FacetSearchConfig configuration)
                                   throws SolrServiceException

Throws:

SolrServiceException

createSynonymsForLanguages

protected Map<String,Map<String,Set<String>>> createSynonymsForLanguages(Collection<String> languages,
                                                                         FacetSearchConfig facetSearchConfig)

createSynonyms

protected Map<String,Set<String>> createSynonyms(String lang,
                                                 FacetSearchConfig facetSearchConfig)

buildSynonyms

protected Map<String,Set<String>> buildSynonyms(String synonymFromInput,
                                                String synonymToInput)

buildSynonyms

protected Map<String,Set<String>> buildSynonyms(String synonymFromInput)

logSynonyms

protected void logSynonyms(SolrFacetSearchConfigModel facetSearchConfigModel)

exportStopWords

protected void exportStopWords(String serverURL,
                               HttpClient httpClient,
                               Collection<String> languages,
                               Map<String,Set<String>> stopWordsForLanguage)
                        throws IOException,
                               SolrServiceException,
                               SolrRestException

Throws:

IOException

SolrServiceException

SolrRestException

getStopWordsFromConfig

protected Map<String,Set<String>> getStopWordsFromConfig(FacetSearchConfig facetSearchConfig)

executeHttpGet

protected <T> T executeHttpGet(HttpClient httpClient,
                               String requestUrl,
                               ObjectMapper objectMapper,
                               Class<T> responseType)
                        throws IOException,
                               SolrRestException

Throws:

IOException

SolrRestException

executeHttpPut

protected void executeHttpPut(HttpClient httpClient,
                              String requestUrl,
                              ObjectMapper objectMapper,
                              Object body)
                       throws IOException,
                              SolrRestException

Throws:

IOException

SolrRestException

executeHttpPost

protected void executeHttpPost(HttpClient httpClient,
                               String requestUrl,
                               ObjectMapper objectMapper,
                               Object body)
                        throws IOException,
                               SolrRestException

Throws:

IOException

SolrRestException

executeHttpDelete

protected void executeHttpDelete(HttpClient httpClient,
                                 String requestUrl)
                          throws IOException,
                                 SolrRestException

Throws:

IOException

SolrRestException

getSolrFacetSearchConfigDao

public SolrFacetSearchConfigDao getSolrFacetSearchConfigDao()

setSolrFacetSearchConfigDao

public void setSolrFacetSearchConfigDao(SolrFacetSearchConfigDao solrFacetSearchConfigDao)

getIndexNameResolver

public IndexNameResolver getIndexNameResolver()

setIndexNameResolver

public void setIndexNameResolver(IndexNameResolver indexNameResolver)

getConfigurationService

public ConfigurationService getConfigurationService()

setConfigurationService

public void setConfigurationService(ConfigurationService configurationService)

getSolrClientPool

public SolrClientPool getSolrClientPool()

setSolrClientPool

public void setSolrClientPool(SolrClientPool solrClientPool)