Restore readUnsignedLeb128 method as requested in #710

ClickHouse · Oct 10, 2021 · a8ac5b2 · a8ac5b2
1 parent 7e3fc8f
commit a8ac5b2
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/clickhouse-jdbc/src/main/java/ru/yandex/clickhouse/util/ClickHouseRowBinaryInputStream.java b/clickhouse-jdbc/src/main/java/ru/yandex/clickhouse/util/ClickHouseRowBinaryInputStream.java
@@ -69,6 +69,10 @@ public List<ClickHouseColumnInfo> getColumns() {
         return this.columns;
     }
 
+    public int readUnsignedLeb128() throws IOException {
+        return Utils.readUnsignedLeb128(in);
+    }
+
     public void readBytes(byte[] bytes) throws IOException {
         readBytes(bytes, 0, bytes.length);
     }

diff --git a/...ouse-jdbc/src/test/java/ru/yandex/clickhouse/util/ClickHouseRowBinaryInputStreamTest.java b/...ouse-jdbc/src/test/java/ru/yandex/clickhouse/util/ClickHouseRowBinaryInputStreamTest.java
@@ -110,6 +110,12 @@ public void testFixedString() throws Exception {
 		assertEquals(inputZeroPaddedString.readFixedString(10), "hello\0\0\0\0\0");
 	}
 
+	@Test(groups = "unit")
+	public void testUnsignedLeb128() throws Exception {
+        ClickHouseRowBinaryInputStream input = prepareStream(new byte[] { -128, -62, -41, 47 });
+        assertEquals(input.readUnsignedLeb128(), 100000000);
+    }
+
 	@Test(groups = "unit")
 	public void testOne() throws Exception {
 		ClickHouseRowBinaryInputStream input = prepareStream(new byte[]{5, 97, 46, 98, 46, 99, 123, 20, -82, 71, -31, 26, 69, 64, 34, 87, -13, 88, 120, 67, 48, 116, -13, 88});