Revision 48922
Added by Claudio Atzori over 6 years ago
OpenaireIdResolver.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.SolrQuery; |
10 |
import org.apache.solr.client.solrj.impl.CloudSolrServer;
|
|
10 |
import org.apache.solr.client.solrj.impl.CloudSolrClient;
|
|
11 | 11 |
import org.apache.solr.client.solrj.response.QueryResponse; |
12 | 12 |
import org.apache.solr.common.SolrDocument; |
13 | 13 |
import org.apache.solr.common.SolrDocumentList; |
... | ... | |
47 | 47 |
} |
48 | 48 |
|
49 | 49 |
protected List<String> findOriginalIds(final String id) { |
50 |
CloudSolrServer solrCore = null; |
|
50 |
|
|
51 | 51 |
final SolrQuery q = new SolrQuery("objidentifier:\"" + id + "\""); |
52 |
QueryResponse response = null; |
|
53 |
try { |
|
54 |
solrCore = new CloudSolrServer(getIndexEndpoint()); |
|
52 |
|
|
53 |
try (final CloudSolrClient solrCore = new CloudSolrClient.Builder().withZkHost(getIndexEndpoint()).build()) { |
|
55 | 54 |
solrCore.setDefaultCollection(getPublicIndexCollection() + SOLR_COLLECTION_POSTFIX); |
56 |
response = solrCore.query(q); |
|
55 |
final QueryResponse response = solrCore.query(q);
|
|
57 | 56 |
final SolrDocumentList results = response.getResults(); |
58 | 57 |
if (results.isEmpty()) { |
59 | 58 |
log.debug("Query " + q + " returned 0 documents"); |
... | ... | |
65 | 64 |
} catch (final Exception e) { |
66 | 65 |
log.error("Can't get original ids for " + id + "\n ", e); |
67 | 66 |
throw new RuntimeException("Can't get original ids for " + id + "\n " + e); |
68 |
} finally { |
|
69 |
solrCore.shutdown(); |
|
70 | 67 |
} |
71 | 68 |
} |
72 | 69 |
|
Also available in: Unified diff
upgraded solr version to 6.6.0, inherit from snapshot parent