Added some null pointer checks

Author: Paultagoras

client-v2/src/main/java/com/clickhouse/client/api/data_formats/internal/AbstractBinaryFormatReader.java

@@ -99,6 +99,10 @@ protected AbstractBinaryFormatReader(InputStream inputStream, QuerySettings quer
      * @throws IOException
      */
     public boolean readToPOJO(Map<String, POJOSetter> deserializers, Object obj ) throws IOException {
+        if (columns == null || columns.length == 0) {
+            return false;
+        }
+
         boolean firstColumn = true;
 
         for (ClickHouseColumn column : columns) {
@@ -135,6 +139,10 @@ public boolean readToPOJO(Map<String, POJOSetter> deserializers, Object obj ) th
      * @throws IOException
      */
     public boolean readRecord(Map<String, Object> record) throws IOException {
+        if (columns == null || columns.length == 0) {
+            return false;
+        }
+
         boolean firstColumn = true;
         for (ClickHouseColumn column : columns) {
             try {
@@ -157,6 +165,10 @@ public boolean readRecord(Map<String, Object> record) throws IOException {
     }
 
     protected boolean readRecord(Object[] record) throws IOException {
+        if (columns == null || columns.length == 0) {
+            return false;
+        }
+
         boolean firstColumn = true;
         for (int i = 0; i < columns.length; i++) {
             try {

client-v2/src/test/java/com/clickhouse/client/query/QueryTests.java

@@ -344,6 +344,14 @@ public void testQueryAllTableNames() {
         Assert.assertTrue(tableNames.containsAll(expectedTableNames));
     }
 
+    @Test(groups = {"integration"})
+    public void testQueryAllInsertSelect() {
+        client.queryAll("CREATE TABLE IF NOT EXISTS nums (number Int16) ENGINE = MergeTree() ORDER BY number;");
+        String sql = "INSERT INTO nums SELECT * FROM system.numbers LIMIT 100";
+        List<GenericRecord> records = client.queryAll(sql);
+        Assert.assertTrue(records.isEmpty());
+    }
+
     @Test(groups = {"integration"})
     public void testQueryJSONEachRow() throws ExecutionException, InterruptedException {
         Map<String, Object> datasetRecord = prepareSimpleDataSet();