diff --git a/src/main/java/com/alibaba/druid/pool/ElasticSearchConnection.java b/src/main/java/com/alibaba/druid/pool/ElasticSearchConnection.java
index c148f7d2..8dca04e6 100644
--- a/src/main/java/com/alibaba/druid/pool/ElasticSearchConnection.java
+++ b/src/main/java/com/alibaba/druid/pool/ElasticSearchConnection.java
@@ -23,6 +23,8 @@
 public class ElasticSearchConnection implements Connection {
 
     private Client client;
+    //关闭标识
+    private boolean closeStatus = true;
 
     public ElasticSearchConnection(String jdbcUrl, Properties info) {
 
@@ -41,6 +43,7 @@ public ElasticSearchConnection(String jdbcUrl, Properties info) {
                 transportClient.addTransportAddress(new TransportAddress(InetAddress.getByName(host), Integer.parseInt(port)));
             }
             client = transportClient;
+            closeStatus = false;
         } catch (UnknownHostException e) {
             e.printStackTrace();
         }
@@ -586,12 +589,14 @@ public void rollback() throws SQLException {
 
     @Override
     public void close() throws SQLException {
+        this.getClient().close();
+        closeStatus = true;
 
     }
 
     @Override
     public boolean isClosed() throws SQLException {
-        return false;
+        return closeStatus;
     }
 
     @Override