Revision 32589
Added by Michele Artini over 9 years ago
| SolrIndexCollection.java | ||
|---|---|---|
| 7 | 7 |
import org.apache.commons.logging.Log; |
| 8 | 8 |
import org.apache.commons.logging.LogFactory; |
| 9 | 9 |
import org.apache.solr.client.solrj.SolrServerException; |
| 10 |
import org.apache.solr.client.solrj.impl.CloudSolrServer; |
|
| 11 | 10 |
import org.apache.solr.client.solrj.impl.HttpSolrServer; |
| 12 | 11 |
import org.apache.solr.client.solrj.response.QueryResponse; |
| 13 | 12 |
import org.apache.solr.client.solrj.response.UpdateResponse; |
| ... | ... | |
| 49 | 48 |
|
| 50 | 49 |
/** |
| 51 | 50 |
* The Constructor. |
| 52 |
* |
|
| 51 |
*
|
|
| 53 | 52 |
* @param newServer |
| 54 | 53 |
* the server |
| 55 | 54 |
* @param queryResponseFactory |
| ... | ... | |
| 63 | 62 |
|
| 64 | 63 |
/** |
| 65 | 64 |
* {@inheritDoc}
|
| 66 |
* |
|
| 65 |
*
|
|
| 67 | 66 |
* @see eu.dnetlib.functionality.index.IndexCollection#add(eu.dnetlib.functionality.index.model.document.IndexDocument) |
| 68 | 67 |
*/ |
| 69 | 68 |
@Override |
| ... | ... | |
| 79 | 78 |
|
| 80 | 79 |
/** |
| 81 | 80 |
* {@inheritDoc}
|
| 82 |
* |
|
| 81 |
*
|
|
| 83 | 82 |
* @see eu.dnetlib.functionality.index.IndexCollection#addAll(java.util.Iterator) |
| 84 | 83 |
*/ |
| 85 | 84 |
@Override |
| ... | ... | |
| 104 | 103 |
|
| 105 | 104 |
/** |
| 106 | 105 |
* {@inheritDoc}
|
| 107 |
* |
|
| 106 |
*
|
|
| 108 | 107 |
* @see eu.dnetlib.functionality.index.IndexCollection#addAll(java.util.Collection) |
| 109 | 108 |
*/ |
| 110 | 109 |
@Override |
| ... | ... | |
| 114 | 113 |
|
| 115 | 114 |
/** |
| 116 | 115 |
* {@inheritDoc}
|
| 117 |
* |
|
| 116 |
*
|
|
| 118 | 117 |
* @see eu.dnetlib.functionality.index.IndexCollection#deleteIndex(java.lang.String) |
| 119 | 118 |
*/ |
| 120 | 119 |
@Override |
| ... | ... | |
| 124 | 123 |
|
| 125 | 124 |
/** |
| 126 | 125 |
* {@inheritDoc}
|
| 127 |
* |
|
| 126 |
*
|
|
| 128 | 127 |
* @see eu.dnetlib.functionality.index.IndexCollection#deleteByQuery(java.lang.String, java.lang.String) |
| 129 | 128 |
*/ |
| 130 | 129 |
@Override |
| 131 | 130 |
public boolean deleteByQuery(final String query, final String dsId) throws IndexServiceException {
|
| 132 |
if (StringUtils.isBlank(dsId)) return doDelete(query);
|
|
| 131 |
if (StringUtils.isBlank(dsId)) { return doDelete(query); }
|
|
| 133 | 132 |
return doDelete(query + " AND " + IndexFieldUtility.DS_ID + " : \"" + dsId + "\""); |
| 134 | 133 |
} |
| 135 | 134 |
|
| 136 | 135 |
/** |
| 137 | 136 |
* Do delete. |
| 138 |
* |
|
| 137 |
*
|
|
| 139 | 138 |
* @param query |
| 140 | 139 |
* the query |
| 141 | 140 |
* @return true, if do delete |
| ... | ... | |
| 153 | 152 |
|
| 154 | 153 |
/** |
| 155 | 154 |
* {@inheritDoc}
|
| 156 |
* |
|
| 155 |
*
|
|
| 157 | 156 |
* @see eu.dnetlib.functionality.index.IndexCollection#commit() |
| 158 | 157 |
*/ |
| 159 | 158 |
@Override |
| ... | ... | |
| 167 | 166 |
|
| 168 | 167 |
/** |
| 169 | 168 |
* {@inheritDoc}
|
| 170 |
* |
|
| 169 |
*
|
|
| 171 | 170 |
* @see eu.dnetlib.functionality.index.IndexCollection#lookup(eu.dnetlib.functionality.index.query.IndexQuery, |
| 172 | 171 |
* eu.dnetlib.functionality.index.utils.MetadataReference) |
| 173 | 172 |
*/ |
Also available in: Unified diff
new locators, increased major version