public class SolrTemplate extends Object implements SolrOperations, InitializingBean, ApplicationContextAware
SolrOperations
Constructor and Description |
---|
SolrTemplate(org.apache.solr.client.solrj.SolrServer solrServer) |
SolrTemplate(SolrServerFactory solrServerFactory) |
SolrTemplate(SolrServerFactory solrServerFactory,
SolrConverter solrConverter) |
SolrTemplate(org.apache.solr.client.solrj.SolrServer solrServer,
String core) |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
protected void |
assertNoCollection(Object o) |
void |
commit()
Send commit command
SolrServer.commit() |
org.apache.solr.common.SolrInputDocument |
convertBeanToSolrInputDocument(Object bean)
Convert given bean into a solrj InputDocument
|
<T> List<T> |
convertQueryResponseToBeans(org.apache.solr.client.solrj.response.QueryResponse response,
Class<T> targetClass) |
<T> List<T> |
convertSolrDocumentListToBeans(org.apache.solr.common.SolrDocumentList documents,
Class<T> targetClass) |
<T> T |
convertSolrDocumentToBean(org.apache.solr.common.SolrDocument document,
Class<T> targetClass) |
long |
count(SolrDataQuery query)
return number of elements found by for given query
|
org.apache.solr.client.solrj.response.UpdateResponse |
delete(SolrDataQuery query)
Find and delete all objects matching the provided Query
|
org.apache.solr.client.solrj.response.UpdateResponse |
deleteById(Collection<String> ids)
Delete objects with given ids
|
org.apache.solr.client.solrj.response.UpdateResponse |
deleteById(String id)
Detele the one object with provided id
|
<T> T |
execute(SolrCallback<T> action)
Execute action within callback
|
<T> Collection<T> |
getById(Collection<? extends Serializable> ids,
Class<T> clazz)
Executes a realtime get using given ids.
|
<T> T |
getById(Serializable id,
Class<T> clazz)
Executes a realtime get using given id.
|
SolrConverter |
getConverter() |
static PersistenceExceptionTranslator |
getExceptionTranslator() |
Set<SolrPersistentEntitySchemaCreator.Feature> |
getSchemaCreationFeatures() |
String |
getSchemaName(String collectionName) |
String |
getSolrCore() |
org.apache.solr.client.solrj.SolrServer |
getSolrServer()
Get the underlying SolrServer instance
|
org.apache.solr.client.solrj.response.SolrPingResponse |
ping()
Execute ping against solrServer and return duration in msec
|
<T> Cursor<T> |
queryForCursor(Query query,
Class<T> clazz)
|
<T> FacetPage<T> |
queryForFacetPage(FacetQuery query,
Class<T> clazz)
Execute a facet query against solr facet result will be returned along with query result within the FacetPage
|
<T> GroupPage<T> |
queryForGroupPage(Query query,
Class<T> clazz)
Execute the query against solr and return result as
GroupPage |
<T> HighlightPage<T> |
queryForHighlightPage(HighlightQuery query,
Class<T> clazz)
Execute a query and highlight matches in result
|
<T> T |
queryForObject(Query query,
Class<T> clazz)
Execute the query against solr and return the first returned object
|
<T> ScoredPage<T> |
queryForPage(Query query,
Class<T> clazz)
Execute the query against solr and retrun result as
Page |
<T> StatsPage<T> |
queryForStatsPage(Query query,
Class<T> clazz)
Execute the query against Solr and return result as
StatsPage . |
TermsPage |
queryForTermsPage(TermsQuery query)
Execute query using terms handler
|
void |
registerQueryParser(Class<? extends SolrDataQuery> clazz,
QueryParser queryParser) |
void |
rollback()
send rollback command
SolrServer.rollback() |
org.apache.solr.client.solrj.response.UpdateResponse |
saveBean(Object obj)
Execute add operation against solr, which will do either insert or update
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveBean(Object objectToAdd,
int commitWithinMs)
Execute add operation against solr, which will do either insert or update with support for commitWithin strategy
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveBeans(Collection<?> beans)
Add a collection of beans to solr, which will do either insert or update
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveBeans(Collection<?> beansToAdd,
int commitWithinMs)
Add a collection of beans to solr, which will do either insert or update with support for commitWithin strategy
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveDocument(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(org.apache.solr.common.SolrInputDocument documentToAdd,
int commitWithinMs)
Add a solrj input document to solr, which will do either insert or update with support for commitWithin strategy
|
org.apache.solr.client.solrj.response.UpdateResponse |
saveDocuments(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(Collection<org.apache.solr.common.SolrInputDocument> documentsToAdd,
int commitWithinMs)
Add multiple solrj input documents to solr, which will do either insert or update with support for commitWithin
strategy
|
void |
setApplicationContext(ApplicationContext applicationContext) |
void |
setMappingContext(MappingContext<? extends SolrPersistentEntity<?>,SolrPersistentProperty> mappingContext) |
void |
setSchemaCreationFeatures(Collection<SolrPersistentEntitySchemaCreator.Feature> schemaCreationFeatures) |
void |
setSolrConverter(SolrConverter solrConverter) |
void |
setSolrCore(String solrCore) |
void |
softCommit()
Send soft commmit command
SolrServer.commit(boolean, boolean, boolean) |
public SolrTemplate(org.apache.solr.client.solrj.SolrServer solrServer)
public SolrTemplate(org.apache.solr.client.solrj.SolrServer solrServer, String core)
public SolrTemplate(SolrServerFactory solrServerFactory)
public SolrTemplate(SolrServerFactory solrServerFactory, SolrConverter solrConverter)
public <T> T execute(SolrCallback<T> action)
SolrOperations
execute
in interface SolrOperations
public org.apache.solr.client.solrj.response.SolrPingResponse ping()
SolrOperations
ping
in interface SolrOperations
public long count(SolrDataQuery query)
SolrOperations
count
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveBean(Object obj)
SolrOperations
saveBean
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveBean(Object objectToAdd, int commitWithinMs)
SolrOperations
saveBean
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveBeans(Collection<?> beans)
SolrOperations
saveBeans
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveBeans(Collection<?> beansToAdd, int commitWithinMs)
SolrOperations
saveBeans
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveDocument(org.apache.solr.common.SolrInputDocument document)
SolrOperations
saveDocument
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveDocument(org.apache.solr.common.SolrInputDocument documentToAdd, int commitWithinMs)
SolrOperations
saveDocument
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveDocuments(Collection<org.apache.solr.common.SolrInputDocument> documents)
SolrOperations
saveDocuments
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse saveDocuments(Collection<org.apache.solr.common.SolrInputDocument> documentsToAdd, int commitWithinMs)
SolrOperations
saveDocuments
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse delete(SolrDataQuery query)
SolrOperations
delete
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse deleteById(String id)
SolrOperations
deleteById
in interface SolrOperations
public org.apache.solr.client.solrj.response.UpdateResponse deleteById(Collection<String> ids)
SolrOperations
deleteById
in interface SolrOperations
public <T> T queryForObject(Query query, Class<T> clazz)
SolrOperations
queryForObject
in interface SolrOperations
public <T> ScoredPage<T> queryForPage(Query query, Class<T> clazz)
SolrOperations
Page
queryForPage
in interface SolrOperations
public <T> GroupPage<T> queryForGroupPage(Query query, Class<T> clazz)
SolrOperations
GroupPage
queryForGroupPage
in interface SolrOperations
public <T> StatsPage<T> queryForStatsPage(Query query, Class<T> clazz)
SolrOperations
StatsPage
.queryForStatsPage
in interface SolrOperations
query
- must not be null.clazz
- must not be null.public <T> FacetPage<T> queryForFacetPage(FacetQuery query, Class<T> clazz)
SolrOperations
queryForFacetPage
in interface SolrOperations
public <T> HighlightPage<T> queryForHighlightPage(HighlightQuery query, Class<T> clazz)
SolrOperations
queryForHighlightPage
in interface SolrOperations
public TermsPage queryForTermsPage(TermsQuery query)
SolrOperations
queryForTermsPage
in interface SolrOperations
public void commit()
SolrOperations
SolrServer.commit()
commit
in interface SolrOperations
public void softCommit()
SolrOperations
SolrServer.commit(boolean, boolean, boolean)
softCommit
in interface SolrOperations
public void rollback()
SolrOperations
SolrServer.rollback()
rollback
in interface SolrOperations
public org.apache.solr.common.SolrInputDocument convertBeanToSolrInputDocument(Object bean)
SolrOperations
convertBeanToSolrInputDocument
in interface SolrOperations
public String getSchemaName(String collectionName)
collectionName
- public <T> Cursor<T> queryForCursor(Query query, Class<T> clazz)
SolrOperations
Query
and returns an open Cursor
allowing to iterate of results, dynamically
fetching additional ones if required.queryForCursor
in interface SolrOperations
public <T> Collection<T> getById(Collection<? extends Serializable> ids, Class<T> clazz)
SolrOperations
getById
in interface SolrOperations
public <T> T getById(Serializable id, Class<T> clazz)
SolrOperations
getById
in interface SolrOperations
public <T> List<T> convertQueryResponseToBeans(org.apache.solr.client.solrj.response.QueryResponse response, Class<T> targetClass)
public <T> List<T> convertSolrDocumentListToBeans(org.apache.solr.common.SolrDocumentList documents, Class<T> targetClass)
public <T> T convertSolrDocumentToBean(org.apache.solr.common.SolrDocument document, Class<T> targetClass)
protected void assertNoCollection(Object o)
public final org.apache.solr.client.solrj.SolrServer getSolrServer()
SolrOperations
getSolrServer
in interface SolrOperations
public SolrConverter getConverter()
getConverter
in interface SolrOperations
public static PersistenceExceptionTranslator getExceptionTranslator()
public void setApplicationContext(ApplicationContext applicationContext)
setApplicationContext
in interface ApplicationContextAware
public void registerQueryParser(Class<? extends SolrDataQuery> clazz, QueryParser queryParser)
public void setSolrConverter(SolrConverter solrConverter)
public String getSolrCore()
public void setSolrCore(String solrCore)
public void afterPropertiesSet()
afterPropertiesSet
in interface InitializingBean
public void setMappingContext(MappingContext<? extends SolrPersistentEntity<?>,SolrPersistentProperty> mappingContext)
mappingContext
- public void setSchemaCreationFeatures(Collection<SolrPersistentEntitySchemaCreator.Feature> schemaCreationFeatures)
schemaCreationFeatures
- public Set<SolrPersistentEntitySchemaCreator.Feature> getSchemaCreationFeatures()
Copyright © 2011-2015–2015 Pivotal Software, Inc.. All rights reserved.