Merge branch 'main' into fix_testing_client_v2

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

@@ -74,6 +74,7 @@
 import java.util.function.Function;
 import java.util.function.Supplier;
 import java.util.stream.BaseStream;
+import java.util.stream.IntStream;
 import java.util.stream.Collectors;
 
 public class QueryTests extends BaseIntegrationTest {
@@ -149,7 +150,7 @@ public void testSimpleQueryWithTSV() {
     @Test(groups = {"integration"})
     public void testReadRecords() throws Exception {
         List<Map<String, Object>> dataset = prepareDataSet(DATASET_TABLE, DATASET_COLUMNS, DATASET_VALUE_GENERATORS, 10);
-        
+
         Records records = client.queryRecords("SELECT * FROM " + DATASET_TABLE).get(3, TimeUnit.SECONDS);
         Assert.assertEquals(records.getResultRows(), 10, "Unexpected number of rows");
 
@@ -164,6 +165,22 @@ public void testReadRecords() throws Exception {
         }
     }
 
+    @Test(groups = {"integration"})
+    public void testBigUnsignedInt() throws Exception {
+        final BigInteger expected128 = BigInteger.valueOf(2).pow(128).subtract(BigInteger.ONE).subtract(BigInteger.ONE);
+        final BigInteger expected256 = BigInteger.valueOf(2).pow(256).subtract(BigInteger.ONE).subtract(BigInteger.ONE);
+
+        String sqlQuery = "SELECT toUInt128('" + expected128 + "') as i128, toUInt256('" + expected256 + "') as i256";
+        System.out.println(sqlQuery);
+        Records records = client.queryRecords(sqlQuery).get(3, TimeUnit.SECONDS);
+
+        GenericRecord firstRecord = records.iterator().next();
+
+        System.out.println(firstRecord.getBigInteger("i128"));
+        Assert.assertEquals(firstRecord.getBigInteger("i128"), expected128);
+        Assert.assertEquals(firstRecord.getBigInteger("i256"), expected256);
+    }
+
     @Test(groups = {"integration"})
     public void testReadRecordsWithStreamAPI() throws Exception {
         final int tables = 10;