public interface SolrOperations
Modifier and Type | Method and Description |
---|---|
void |
commit(String collection)
Send commit command
SolrClient.commit() |
org.apache.solr.common.SolrInputDocument |
convertBeanToSolrInputDocument(Object bean)
Convert given bean into a solrj InputDocument
|
default long |
count(String collection,
SolrDataQuery query)
return number of elements found by for given query
|
long |
count(String collection,
SolrDataQuery query,
Class<?> domainType)
return number of elements found by for given query
|
long |
count(String collection,
SolrDataQuery query,
Class<?> domainType,
RequestMethod method)
return number of elements found by for given query
|
default long |
count(String collection,
SolrDataQuery query,
RequestMethod method)
return number of elements found by for given query
|
default org.apache.solr.client.solrj.response.UpdateResponse |
delete(String collection,
SolrDataQuery query)
Find and delete all objects matching the provided Query.
|
org.apache.solr.client.solrj.response.UpdateResponse |
delete(String collection,
SolrDataQuery query,
Class<?> domainType)
Find and delete all objects matching the provided Query.
|
org.apache.solr.client.solrj.response.UpdateResponse |
deleteByIds(String collection,
Collection<String> id)
Delete objects with given ids
|
org.apache.solr.client.solrj.response.UpdateResponse |
deleteByIds(String collection,
String id)
Detele the one object with provided id.
|
<T> T |
execute(SolrCallback<T> action)
Execute action within callback
|
<T> Optional<T> |
getById(String collection,
Object id,
Class<T> clazz)
Executes a realtime get using given id.
|
<T> Collection<T> |
getByIds(String collection,
Collection<?> ids,
Class<T> clazz)
Executes a realtime get using given ids.
|
SolrConverter |
getConverter() |
SchemaOperations |
getSchemaOperations(String collection)
Get the
SchemaOperations executable. |
org.apache.solr.client.solrj.SolrClient |
getSolrClient()
Get the underlying SolrClient instance
|
org.apache.solr.client.solrj.response.SolrPingResponse |
ping()
Execute ping against SolrClient and return duration in msec
|
org.apache.solr.client.solrj.response.SolrPingResponse |
ping(String collection)
Execute ping against SolrClient and return duration in msec
|
<T,S extends Page<T>> |
query(String collection,
Query query,
Class<T> clazz)
Execute the query against Solr and return result as page.
|
<T,S extends Page<T>> |
query(String collection,
Query query,
Class<T> clazz,
RequestMethod method)
Execute the query against Solr and return result as page.
|
<T> Cursor<T> |
queryForCursor(String collection,
Query query,
Class<T> clazz)
|
<T> FacetAndHighlightPage<T> |
queryForFacetAndHighlightPage(String collection,
FacetAndHighlightQuery query,
Class<T> clazz)
Execute a query and highlight matches in result
|
<T> FacetAndHighlightPage<T> |
queryForFacetAndHighlightPage(String collection,
FacetAndHighlightQuery query,
Class<T> clazz,
RequestMethod method)
Execute a query and highlight matches in result
|
<T> FacetPage<T> |
queryForFacetPage(String collection,
FacetQuery query,
Class<T> clazz)
Execute a facet query against solr facet result will be returned along with query result within the FacetPage
|
<T> FacetPage<T> |
queryForFacetPage(String collection,
FacetQuery query,
Class<T> clazz,
RequestMethod method)
Execute a facet query against solr facet result will be returned along with query result within the FacetPage
|
<T> GroupPage<T> |
queryForGroupPage(String collection,
Query query,
Class<T> clazz)
Execute the query against solr and return result as
GroupPage |
<T> GroupPage<T> |
queryForGroupPage(String collection,
Query query,
Class<T> clazz,
RequestMethod method)
Execute the query against solr and return result as
GroupPage |
<T> HighlightPage<T> |
queryForHighlightPage(String collection,
HighlightQuery query,
Class<T> clazz)
Execute a query and highlight matches in result
|
<T> HighlightPage<T> |
queryForHighlightPage(String collection,
HighlightQuery query,
Class<T> clazz,
RequestMethod method)
Execute a query and highlight matches in result
|
<T> Optional<T> |
queryForObject(String collection,
Query query,
Class<T> clazz)
Execute the query against solr and return the first returned object
|
<T> Optional<T> |
queryForObject(String collection,
Query query,
Class<T> clazz,
RequestMethod method)
Execute the query against solr and return the first returned object
|
<T> ScoredPage<T> |
queryForPage(String collection,
Query query,
Class<T> clazz)
Execute the query against solr and retrun result as
Page |
<T> ScoredPage<T> |
queryForPage(String collection,
Query query,
Class<T> clazz,
RequestMethod method)
Execute the query against solr and retrun result as
Page |
<T> StatsPage<T> |
queryForStatsPage(String collection,
Query query,
Class<T> clazz)
Execute the query against Solr and return result as
StatsPage . |
<T> StatsPage<T> |
queryForStatsPage(String collection,
Query query,
Class<T> clazz,
RequestMethod method)
Execute the query against Solr and return result as
StatsPage . |
TermsPage |
queryForTermsPage(String collection,
TermsQuery query)
Execute query using terms handler
|
TermsPage |
queryForTermsPage(String collection,
TermsQuery query,
RequestMethod method)
Execute query using terms handler
|
void |
rollback(String collection)
send rollback command
SolrClient.rollback() |
default org.apache.solr.client.solrj.response.UpdateResponse |
saveBean(String collection,
Object obj)
Execute add operation against solr, which will do either insert or update.
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveBean(String collection,
Object obj,
Duration commitWithin)
Execute add operation against solr, which will do either insert or update with support for commitWithin strategy.
|
default org.apache.solr.client.solrj.response.UpdateResponse |
saveBeans(String collection,
Collection<?> beans)
Add a collection of beans to solr, which will do either insert or update.
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveBeans(String collection,
Collection<?> beans,
Duration commitWithin)
Add a collection of beans to solr, which will do either insert or update with support for commitWithin strategy.
|
default org.apache.solr.client.solrj.response.UpdateResponse |
saveDocument(String collection,
org.apache.solr.common.SolrInputDocument document)
Add a solrj input document to solr, which will do either insert or update
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveDocument(String collection,
org.apache.solr.common.SolrInputDocument document,
Duration commitWithin)
Add a solrj input document to solr, which will do either insert or update with support for commitWithin strategy
|
default org.apache.solr.client.solrj.response.UpdateResponse |
saveDocuments(String collection,
Collection<org.apache.solr.common.SolrInputDocument> documents)
Add multiple solrj input documents to solr, which will do either insert or update
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveDocuments(String collection,
Collection<org.apache.solr.common.SolrInputDocument> documents,
Duration commitWithin)
Add multiple solrj input documents to solr, which will do either insert or update with support for commitWithin
strategy.
|
void |
softCommit(String collection)
Send soft commmit command
SolrClient.commit(boolean, boolean, boolean) |
org.apache.solr.client.solrj.SolrClient getSolrClient()
SolrClient
in use. Never null.org.apache.solr.client.solrj.response.SolrPingResponse ping()
SolrPingResponse
containing ping result.DataAccessResourceFailureException
- if ping fails.org.apache.solr.client.solrj.response.SolrPingResponse ping(String collection)
collection
- must not be null.SolrPingResponse
containing ping result.DataAccessResourceFailureException
- if ping fails.default long count(String collection, SolrDataQuery query)
collection
- must not be null.query
- must not be null.long count(String collection, SolrDataQuery query, @Nullable Class<?> domainType)
collection
- must not be null.query
- must not be null.domainType
- can be null.long count(String collection, SolrDataQuery query, @Nullable Class<?> domainType, RequestMethod method)
collection
- must not be null.query
- must not be null.domainType
- can be null.method
- must not be null.default long count(String collection, SolrDataQuery query, RequestMethod method)
collection
- must not be null.query
- must not be null.method
- must not be null.default org.apache.solr.client.solrj.response.UpdateResponse saveBean(String collection, Object obj)
collection
- must not be null.obj
- must not be null.UpdateResponse
containing update result.org.apache.solr.client.solrj.response.UpdateResponse saveBean(String collection, Object obj, Duration commitWithin)
collection
- must not be null.obj
- must not be null.commitWithin
- max time within server performs commit.UpdateResponse
containing update result.default org.apache.solr.client.solrj.response.UpdateResponse saveBeans(String collection, Collection<?> beans)
collection
- must not be null.beans
- must not be null.UpdateResponse
containing update result.org.apache.solr.client.solrj.response.UpdateResponse saveBeans(String collection, Collection<?> beans, Duration commitWithin)
collection
- must not be null.beans
- must not be null.commitWithin
- max time within server performs commit.UpdateResponse
containing update result.default org.apache.solr.client.solrj.response.UpdateResponse saveDocument(String collection, org.apache.solr.common.SolrInputDocument document)
collection
- must not be null.document
- must not be null.UpdateResponse
containing update result.org.apache.solr.client.solrj.response.UpdateResponse saveDocument(String collection, org.apache.solr.common.SolrInputDocument document, Duration commitWithin)
document
- must not be null.commitWithin
- must not be null.UpdateResponse
containing update result.default org.apache.solr.client.solrj.response.UpdateResponse saveDocuments(String collection, Collection<org.apache.solr.common.SolrInputDocument> documents)
collection
- must not be null.documents
- must not be null.UpdateResponse
containing update result.org.apache.solr.client.solrj.response.UpdateResponse saveDocuments(String collection, Collection<org.apache.solr.common.SolrInputDocument> documents, Duration commitWithin)
collection
- must not be null.documents
- must not be null.commitWithin
- max time within server performs commit.UpdateResponse
containing update result.default org.apache.solr.client.solrj.response.UpdateResponse delete(String collection, SolrDataQuery query)
collection
- must not be null.query
- must not be null.UpdateResponse
containing delete result.org.apache.solr.client.solrj.response.UpdateResponse delete(String collection, SolrDataQuery query, @Nullable Class<?> domainType)
collection
- must not be null.query
- must not be null.UpdateResponse
containing delete result.org.apache.solr.client.solrj.response.UpdateResponse deleteByIds(String collection, String id)
collection
- must not be null.id
- must not be null.UpdateResponse
containing delete result.org.apache.solr.client.solrj.response.UpdateResponse deleteByIds(String collection, Collection<String> id)
collection
- must not be null.id
- must not be null.UpdateResponse
containing delete result.<T> Optional<T> queryForObject(String collection, Query query, Class<T> clazz)
collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> Optional<T> queryForObject(String collection, Query query, Class<T> clazz, RequestMethod method)
collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.<T> ScoredPage<T> queryForPage(String collection, Query query, Class<T> clazz)
Page
collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> ScoredPage<T> queryForPage(String collection, Query query, Class<T> clazz, RequestMethod method)
Page
collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.<T> FacetPage<T> queryForFacetPage(String collection, FacetQuery query, Class<T> clazz)
collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> FacetPage<T> queryForFacetPage(String collection, FacetQuery query, Class<T> clazz, RequestMethod method)
collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.<T> HighlightPage<T> queryForHighlightPage(String collection, HighlightQuery query, Class<T> clazz)
collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> HighlightPage<T> queryForHighlightPage(String collection, HighlightQuery query, Class<T> clazz, RequestMethod method)
collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.<T> FacetAndHighlightPage<T> queryForFacetAndHighlightPage(String collection, FacetAndHighlightQuery query, Class<T> clazz)
collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> FacetAndHighlightPage<T> queryForFacetAndHighlightPage(String collection, FacetAndHighlightQuery query, Class<T> clazz, RequestMethod method)
collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.TermsPage queryForTermsPage(String collection, TermsQuery query)
collection
- must not be null.query
- must not be null.TermsPage queryForTermsPage(String collection, TermsQuery query, RequestMethod method)
collection
- must not be null.query
- must not be null.method
- must not be null.<T> Cursor<T> queryForCursor(String collection, Query query, Class<T> clazz)
Query
and returns an open Cursor
allowing to iterate of results, dynamically
fetching additional ones if required.collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> GroupPage<T> queryForGroupPage(String collection, Query query, Class<T> clazz)
GroupPage
collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> GroupPage<T> queryForGroupPage(String collection, Query query, Class<T> clazz, RequestMethod method)
GroupPage
collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.<T> StatsPage<T> queryForStatsPage(String collection, Query query, Class<T> clazz)
StatsPage
.collection
- must not be null.query
- must not be null.clazz
- must not be null.<T> StatsPage<T> queryForStatsPage(String collection, Query query, Class<T> clazz, RequestMethod method)
StatsPage
.collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.<T,S extends Page<T>> S query(String collection, Query query, Class<T> clazz)
collection
- must not be null.query
- must not be null.clazz
- must not be null.<T,S extends Page<T>> S query(String collection, Query query, Class<T> clazz, RequestMethod method)
collection
- must not be null.query
- must not be null.clazz
- must not be null.method
- must not be null.<T> Optional<T> getById(String collection, Object id, Class<T> clazz)
collection
- must not be null.id
- must not be null.clazz
- must not be null.<T> Collection<T> getByIds(String collection, Collection<?> ids, Class<T> clazz)
collection
- must not be null.ids
- must not be null.clazz
- must not be null.void commit(String collection)
SolrClient.commit()
void softCommit(String collection)
SolrClient.commit(boolean, boolean, boolean)
void rollback(String collection)
SolrClient.rollback()
org.apache.solr.common.SolrInputDocument convertBeanToSolrInputDocument(Object bean)
bean
- SolrConverter getConverter()
<T> T execute(SolrCallback<T> action)
action
- SchemaOperations getSchemaOperations(String collection)
SchemaOperations
executable.collection
- Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.