Add query to solr response log if available (delete)
diff --git a/core/org.eclipse.smila.solr/code/src/org/eclipse/smila/solr/update/SolrUpdatePipelet.java b/core/org.eclipse.smila.solr/code/src/org/eclipse/smila/solr/update/SolrUpdatePipelet.java
index e509c9c..8a36d4e 100755
--- a/core/org.eclipse.smila.solr/code/src/org/eclipse/smila/solr/update/SolrUpdatePipelet.java
+++ b/core/org.eclipse.smila.solr/code/src/org/eclipse/smila/solr/update/SolrUpdatePipelet.java
@@ -99,6 +99,7 @@
final Operation operation = params.getOperation();
final int commitWithinMs = params.getCommitWithinMs(true);
UpdateResponse response = null;
+ String query = null;
switch (operation) {
case ADD:
final SolrInputDocument document = convertToSolrInputDocument(record, params);
@@ -108,7 +109,7 @@
response = server.deleteById(id, commitWithinMs);
break;
case DELETE_BY_QUERY:
- final String query = params.getDeleteQeuery();
+ query = params.getDeleteQeuery();
if (query == null) {
throw new ProcessingException(
"Parameter '" + UpdateParams.DELETE_QUERY + "' is required when using operation DELETE_BY_QUERY");
@@ -118,7 +119,7 @@
default:
throw new NotImplementedException(operation.toString());
}
- processResponse(response, index, operation.toString(), id);
+ processResponse(response, index, operation.toString(), id, query);
results.addResult(id);
} catch (Exception exception) {
results.addFailedResult(id, exception);
@@ -127,14 +128,21 @@
}
private void processResponse(final UpdateResponse response, final String index, final String operation,
- final String id) {
+ final String id, final String query) {
final int status = response.getStatus();
if (status == 0) {
if (_log.isInfoEnabled()) {
final long duration = response.getElapsedTime();
- final String message =
- String.format("Process record on Solr server: _recordid: %s; index: %s; operation: %s; duration: %sms.",
- id, index, operation, duration);
+ String message = null;
+ if (query != null) {
+ message = String.format(
+ "Process record on Solr server: _recordid: '%s'; index: '%s'; operation: %s; query: '%s'; duration: %sms.",
+ id, index, operation, query, duration);
+ } else {
+ message = String.format(
+ "Process record on Solr server: _recordid: '%s'; index: '%s'; operation: %s; duration: %sms.", id,
+ index, operation, duration);
+ }
_log.info(message);
}
} else {