added records query example

Author: chernser

examples/client-v2/src/main/java/com/clickhouse/examples/client_v2/Main.java

@@ -37,6 +37,8 @@ public static void main(String[] args) {
 
         // Read data back
         SimpleReader reader = new SimpleReader(endpoint, user, password, database);
+        reader.readDataUsingBinaryFormat();
+        reader.readDataAll();
         reader.readData();
 
         // Insert data using POJO

examples/client-v2/src/main/java/com/clickhouse/examples/client_v2/SimpleReader.java

@@ -4,9 +4,10 @@
 import com.clickhouse.client.api.data_formats.ClickHouseBinaryFormatReader;
 import com.clickhouse.client.api.data_formats.RowBinaryWithNamesAndTypesFormatReader;
 import com.clickhouse.client.api.metrics.ClientMetrics;
+import com.clickhouse.client.api.query.GenericRecord;
 import com.clickhouse.client.api.query.QueryResponse;
 import com.clickhouse.client.api.query.QuerySettings;
-import com.clickhouse.data.ClickHouseFormat;
+import com.clickhouse.client.api.query.Records;
 import lombok.extern.slf4j.Slf4j;
 
 import java.util.concurrent.Future;
@@ -53,7 +54,7 @@ public boolean isServerAlive() {
         return client.ping();
     }
 
-    public void readData() {
+    public void readDataUsingBinaryFormat() {
         try {
             // Read data from the table
             log.info("Reading data from table: {}", TABLE_NAME);
@@ -78,4 +79,38 @@ public void readData() {
             log.error("Failed to read data", e);
         }
     }
+
+    public void readDataAll() {
+        try {
+            log.info("Reading whole table and process record by record");
+            final String sql = "select * from " + TABLE_NAME + " where title <> ''";
+            client.queryAll(sql).forEach(row -> {
+                double id = row.getDouble("id");
+                String title = row.getString("title");
+                String url = row.getString("url");
+
+                log.info("id: {}, title: {}, url: {}", id, title, url);
+            });
+        } catch (Exception e) {
+            log.error("Failed to read data", e);
+        }
+    }
+
+    public void readData() {
+        try {
+            log.info("Reading data from table: {} using Records iterator", TABLE_NAME);
+            final String sql = "select * from " + TABLE_NAME + " where title <> '' limit 10";
+            Records records = client.queryRecords(sql).get(3, TimeUnit.SECONDS);
+
+            for (GenericRecord record : records) {
+                double id = record.getDouble("id");
+                String title = record.getString("title");
+                String url = record.getString("url");
+
+                log.info("id: {}, title: {}, url: {}", id, title, url);
+            }
+        } catch (Exception e) {
+            log.error("Failed to read data", e);
+        }
+    }
 }