This is an automated email from the ASF dual-hosted git repository. xuekaifeng pushed a commit to branch fix_jdbc_bug_xkf in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e7252bca21824454c6f62f125c2bff5ef263d137 Author: 151250176 <[email protected]> AuthorDate: Mon Jan 17 20:21:56 2022 +0800 fix bug and add test --- jdbc/src/main/java/org/apache/iotdb/jdbc/Utils.java | 2 +- .../src/test/java/org/apache/iotdb/jdbc/UtilsTest.java | 18 ++++++++++++------ 2 files changed, 13 insertions(+), 7 deletions(-) diff --git a/jdbc/src/main/java/org/apache/iotdb/jdbc/Utils.java b/jdbc/src/main/java/org/apache/iotdb/jdbc/Utils.java index 2a965b8..17c30a1 100644 --- a/jdbc/src/main/java/org/apache/iotdb/jdbc/Utils.java +++ b/jdbc/src/main/java/org/apache/iotdb/jdbc/Utils.java @@ -102,7 +102,7 @@ public class Utils { switch (key) { case RPC_COMPRESS: if ("true".equalsIgnoreCase(value) || "false".equalsIgnoreCase(value)) { - Config.rpcThriftCompressionEnable = Boolean.getBoolean(value); + Config.rpcThriftCompressionEnable = Boolean.parseBoolean(value); } else { return false; } diff --git a/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java b/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java index 82d1e5a..3c888ca 100644 --- a/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java +++ b/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java @@ -18,19 +18,18 @@ */ package org.apache.iotdb.jdbc; +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertTrue; +import static org.junit.Assert.fail; + +import java.util.Properties; import org.apache.iotdb.rpc.RpcUtils; import org.apache.iotdb.rpc.TSStatusCode; import org.apache.iotdb.service.rpc.thrift.TSStatus; - import org.junit.After; import org.junit.Before; import org.junit.Test; -import java.util.Properties; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.fail; - public class UtilsTest { @Before @@ -125,4 +124,11 @@ public class UtilsTest { } fail(); } + + @Test + public void testRpcCompress() throws IoTDBURLException { + Properties properties = new Properties(); + Utils.parseUrl("jdbc:iotdb://127.0.0.1:6667?rpc_compress=true", properties); + assertTrue(Config.rpcThriftCompressionEnable); + } }
