solr query for delete
This commit is contained in:
parent
b9b29e2b2c
commit
b92e18171f
|
@ -87,10 +87,10 @@ public class ScheduledActions {
|
||||||
final IndexDsInfo info = isLookupClient.currentIndexDsInfo();
|
final IndexDsInfo info = isLookupClient.currentIndexDsInfo();
|
||||||
final SolrIndexClient solr = solrIndexClientFactory.getClient(info);
|
final SolrIndexClient solr = solrIndexClientFactory.getClient(info);
|
||||||
|
|
||||||
// TODO: verificare query
|
list.stream().map(RecordInfo::getId).forEach(id -> {
|
||||||
list.stream().map(RecordInfo::getId).map(id -> "objIdentifier=" + id).forEach(t -> {
|
|
||||||
try {
|
try {
|
||||||
solr.deleteByQuery(t);
|
final String query = String.format("objidentifier:\"%s\" OR resultdupid:\"%s\"", id, id);
|
||||||
|
solr.deleteByQuery(query);
|
||||||
} catch (final DirectIndexApiException e) {
|
} catch (final DirectIndexApiException e) {
|
||||||
log.error(e);
|
log.error(e);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue