diff --git a/source/net/yacy/cora/federate/solr/connector/EmbeddedSolrConnector.java b/source/net/yacy/cora/federate/solr/connector/EmbeddedSolrConnector.java index 669378853d..87bf4dbc17 100644 --- a/source/net/yacy/cora/federate/solr/connector/EmbeddedSolrConnector.java +++ b/source/net/yacy/cora/federate/solr/connector/EmbeddedSolrConnector.java @@ -109,6 +109,7 @@ public void clearCaches() { @SuppressWarnings("unchecked") SolrCache documentCache = solrConfig.documentCacheConfig == null ? null : solrConfig.documentCacheConfig.newInstance(); if (documentCache != null) documentCache.clear(); + this.core.getInfoRegistry().clear(); // don't know what this is for - but this is getting huge! } public SolrInstance getInstance() { @@ -237,9 +238,14 @@ public void close() { @Override public long getCountByQuery(String querystring) { - DocListSearcher docListSearcher = new DocListSearcher(querystring, 0, 0, CollectionSchema.id.getSolrFieldName()); - int numFound = docListSearcher.response.matches(); - docListSearcher.close(); + int numFound = 0; + DocListSearcher docListSearcher = null; + try { + docListSearcher = new DocListSearcher(querystring, 0, 0, CollectionSchema.id.getSolrFieldName()); + numFound = docListSearcher.response.matches(); + } finally { + if (docListSearcher != null) docListSearcher.close(); + } return numFound; } @@ -276,20 +282,23 @@ public Set existsByIds(Set ids) { @Override public String getFieldById(final String id, final String field) throws IOException { - DocListSearcher docListSearcher = new DocListSearcher("{!raw f=" + CollectionSchema.id.getSolrFieldName() + "}" + id, 0, 1, CollectionSchema.id.getSolrFieldName()); - int numFound = docListSearcher.response.matches(); - if (numFound == 0) return null; - Set solrFields = new HashSet(); - solrFields.add(field); - try { - Document doc = docListSearcher.request.getSearcher().doc(docListSearcher.response.iterator().nextDoc(), solrFields); - return doc.get(field); + String ret = null; + DocListSearcher docListSearcher = null; + try { + docListSearcher = new DocListSearcher("{!raw f=" + CollectionSchema.id.getSolrFieldName() + "}" + id, 0, 1, CollectionSchema.id.getSolrFieldName()); + int numFound = docListSearcher.response.matches(); + if (numFound > 0) { + Set solrFields = new HashSet(); + solrFields.add(field); + Document doc = docListSearcher.request.getSearcher().doc(docListSearcher.response.iterator().nextDoc(), solrFields); + ret = doc.get(field); + } } catch (IOException e) { e.printStackTrace(); } finally { - docListSearcher.close(); + if (docListSearcher != null) docListSearcher.close(); } - return null; + return ret; } @Override @@ -299,27 +308,27 @@ public BlockingQueue concurrentIDsByQuery(final String querystring, fina final Thread t = new Thread() { @Override public void run() { - int o = offset; + int o = offset, responseCount = 0; + DocListSearcher docListSearcher = null; while (System.currentTimeMillis() < endtime) { try { - DocListSearcher docListSearcher = new DocListSearcher(querystring, o, pagesize, CollectionSchema.id.getSolrFieldName()); - int responseCount = docListSearcher.response.size(); + responseCount = 0; + docListSearcher = new DocListSearcher(querystring, o, pagesize, CollectionSchema.id.getSolrFieldName()); + responseCount = docListSearcher.response.size(); SolrIndexSearcher searcher = docListSearcher.request.getSearcher(); DocIterator iterator = docListSearcher.response.iterator(); - try { - for (int i = 0; i < responseCount; i++) { - Document doc = searcher.doc(iterator.nextDoc(), SOLR_ID_FIELDS); - try {queue.put(doc.get(CollectionSchema.id.getSolrFieldName()));} catch (final InterruptedException e) {break;} - } - } catch (IOException e) { - } finally { - docListSearcher.close(); + for (int i = 0; i < responseCount; i++) { + Document doc = searcher.doc(iterator.nextDoc(), SOLR_ID_FIELDS); + try {queue.put(doc.get(CollectionSchema.id.getSolrFieldName()));} catch (final InterruptedException e) {break;} } - if (responseCount < pagesize) break; - o += pagesize; } catch (final SolrException e) { break; + } catch (IOException e) { + } finally { + if (docListSearcher != null) docListSearcher.close(); } + if (responseCount < pagesize) break; + o += pagesize; } try {queue.put(AbstractSolrConnector.POISON_ID);} catch (final InterruptedException e1) {} }