diff --git a/src/main/java/ru/yandex/metrika/clickhouse/CHStatementImpl.java b/src/main/java/ru/yandex/metrika/clickhouse/CHStatementImpl.java
index afddcb257904cb099c8470b8e094d10110cba8f0..f551e1f0c26143ceb3647badf438e3efbac4ef65 100644
--- a/src/main/java/ru/yandex/metrika/clickhouse/CHStatementImpl.java
+++ b/src/main/java/ru/yandex/metrika/clickhouse/CHStatementImpl.java
@@ -125,12 +125,15 @@ public class CHStatementImpl implements CHStatement {
 
     @Override
     public boolean execute(String sql) throws SQLException {
-        executeQuery(sql);
+        ResultSet rs = null;
+        try {
+            rs = executeQuery(sql);
+        } finally {
+            CopypasteUtils.close(rs);
+        }
         return true;
     }
 
-
-
     @Override
     public void close() throws SQLException {
         if (currentResult != null) {
diff --git a/src/main/java/ru/yandex/metrika/clickhouse/copypaste/CHResultSet.java b/src/main/java/ru/yandex/metrika/clickhouse/copypaste/CHResultSet.java
index 6aeff1918877f5120a4b0370bfec9e4ca87f43ed..ea899a59bf863db804f729e65542eed117f8210f 100644
--- a/src/main/java/ru/yandex/metrika/clickhouse/copypaste/CHResultSet.java
+++ b/src/main/java/ru/yandex/metrika/clickhouse/copypaste/CHResultSet.java
@@ -127,7 +127,7 @@ public class CHResultSet extends AbstractResultSet {
         return columns;
     }
 
-    Map<String, Integer> getCol() {
+    public Map<String, Integer> getCol() {
         return col;
     }
 
@@ -440,4 +440,8 @@ public class CHResultSet extends AbstractResultSet {
     public <T> T getObject(String columnLabel, Class<T> type) throws SQLException {
         return getObject(asColNum(columnLabel), type);
     }
+
+    public ByteFragment[] getValues() {
+        return values;
+    }
 }