From a4e5b7ec15788d06a6c52906129b0236b80e6e6f Mon Sep 17 00:00:00 2001 From: "aleksandr.afanasiev" Date: Mon, 20 Jun 2016 14:14:59 +0300 Subject: [PATCH] failfast if can't get db connection for reading --- .../elasticsearch/jdbc/strategy/standard/StandardSource.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/main/java/org/xbib/elasticsearch/jdbc/strategy/standard/StandardSource.java b/src/main/java/org/xbib/elasticsearch/jdbc/strategy/standard/StandardSource.java index 3a20bdbb..713ab2c0 100644 --- a/src/main/java/org/xbib/elasticsearch/jdbc/strategy/standard/StandardSource.java +++ b/src/main/java/org/xbib/elasticsearch/jdbc/strategy/standard/StandardSource.java @@ -687,6 +687,8 @@ private void execute(SQLCommand command) throws Exception { .shouldDetectGeo(shouldDetectGeo()) .shouldDetectJson(shouldDetectJson()); merge(command, results, listener); + } else { + throw new SQLException("can't connect to source " + url); } } else { // use write connection