fixed hasValue to not throw exception

Author: chernser

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

@@ -569,12 +569,19 @@ public Object[] getObjectArray(String colName) {
 
     @Override
     public boolean hasValue(int colIndex) {
+        if (colIndex < 1 || colIndex > currentRecord.length) {
+            return false;
+        }
         return currentRecord[colIndex - 1] != null;
     }
 
     @Override
     public boolean hasValue(String colName) {
-        return hasValue(schema.nameToColumnIndex(colName));
+        try {
+            return hasValue(schema.nameToColumnIndex(colName));
+        } catch (NoSuchColumnException e) {
+            return false;
+        }
     }
 
     @Override

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

@@ -2,6 +2,7 @@
 
 import com.clickhouse.client.api.ClientException;
 import com.clickhouse.client.api.internal.DataTypeConverter;
+import com.clickhouse.client.api.metadata.NoSuchColumnException;
 import com.clickhouse.client.api.metadata.TableSchema;
 import com.clickhouse.client.api.query.GenericRecord;
 import com.clickhouse.client.api.query.NullValueException;
@@ -310,7 +311,11 @@ public String[] getStringArray(String colName) {
 
     @Override
     public boolean hasValue(int colIndex) {
-        return hasValue(schema.columnIndexToName(colIndex));
+        try {
+            return hasValue(schema.columnIndexToName(colIndex));
+        } catch (NoSuchColumnException e) {
+            return false;
+        }
     }
 
     @Override

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

@@ -694,6 +694,41 @@ public void testQueryRecordsReadsAllValues() throws Exception {
         }
     }
 
+    @Test(groups = {"integration"})
+    public void testSimpleResultSetReadWithBinaryReader() throws Exception {
+        QuerySettings settings = new QuerySettings().setFormat(ClickHouseFormat.RowBinaryWithNamesAndTypes);
+
+        try (QueryResponse response = client.query("SELECT 1 a, null::Nullable(Int32) b", settings).get(3, TimeUnit.SECONDS)) {
+            ClickHouseBinaryFormatReader reader = client.newBinaryFormatReader(response);
+
+            Assert.assertTrue(reader.hasNext());
+            reader.next();
+            Assert.assertEquals(reader.getInteger(1), 1);
+
+            Assert.assertTrue(reader.hasValue(1));
+            Assert.assertFalse(reader.hasValue(2));
+            Assert.assertFalse(reader.hasValue(3));
+
+            Assert.assertTrue(reader.hasValue("a"));
+            Assert.assertFalse(reader.hasValue("b"));
+            Assert.assertFalse(reader.hasValue("c"));
+        }
+
+        List<GenericRecord> records = client.queryAll("SELECT 1 a, null::Nullable(Int32) b", settings);
+
+        GenericRecord record = records.get(0);
+
+        Assert.assertEquals(record.getInteger(1), 1);
+
+        Assert.assertTrue(record.hasValue(1));
+        Assert.assertFalse(record.hasValue(2));
+        Assert.assertFalse(record.hasValue(3));
+
+        Assert.assertTrue(record.hasValue("a"));
+        Assert.assertFalse(record.hasValue("b"));
+        Assert.assertFalse(record.hasValue("c"));
+    }
+
     private final static List<String> NULL_DATASET_COLUMNS = Arrays.asList(
             "id UInt32",
             "col1 UInt32 NULL",