You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xu...@apache.org on 2022/01/17 12:40:45 UTC
[iotdb] 01/01: fix bug and add test
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 <15...@smail.nju.edu.cn>
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);
+ }
}