Revision 44420
Added by Claudio Atzori over 7 years ago
| modules/dnet-data-provision-services/trunk/src/main/java/eu/dnetlib/index/actors/IndexFeedActorImpl.java | ||
|---|---|---|
| 120 | 120 |
* @throws IndexServiceException the index service exception |
| 121 | 121 |
*/ |
| 122 | 122 |
private void deleteByVersion(final IndexCollection indexCollection, final String dsId, final String version) throws IndexServiceException {
|
| 123 |
indexCollection.deleteByQuery(String.format("%s:[* TO %s}", IndexFieldUtility.DS_VERSION, version), dsId);
|
|
| 123 |
final String query = String.format("%s:[* TO %s}", IndexFieldUtility.DS_VERSION, version);
|
|
| 124 |
indexCollection.deleteByQuery(query, dsId); |
|
| 124 | 125 |
} |
| 125 | 126 |
|
| 126 | 127 |
/** |
| ... | ... | |
| 131 | 132 |
* @throws IndexServiceException the index service exception |
| 132 | 133 |
*/ |
| 133 | 134 |
public void cleanMarkedDocuments(final IndexCollection indexCollection, final String dsId) throws IndexServiceException {
|
| 134 |
|
|
| 135 |
final String cqlQuery = IndexFieldUtility.DELETE_DOCUMENT + " all true "; |
|
| 136 |
deleteByVersion(indexCollection, dsId, cqlQuery); |
|
| 135 |
final String query = IndexFieldUtility.DELETE_DOCUMENT + ":true "; |
|
| 136 |
indexCollection.deleteByQuery(query, dsId); |
|
| 137 | 137 |
} |
| 138 | 138 |
|
| 139 | 139 |
} |
Also available in: Unified diff
damn Sandro! fixed delete by this and that here and there