diff --git a/src/client/src/TSDBJNIConnector.c b/src/client/src/TSDBJNIConnector.c
index 5127aaf665b8059a12ef0985140c2a01ea328bfa..32a07b3aad20d8399620b13bf8c4fdb440a8e106 100644
--- a/src/client/src/TSDBJNIConnector.c
+++ b/src/client/src/TSDBJNIConnector.c
@@ -547,6 +547,11 @@ JNIEXPORT jint JNICALL Java_com_taosdata_jdbc_TSDBJNIConnector_fetchRowImp(JNIEn
                                jniFromNCharToByteArray(env, (char *)row[i], length[i]));
         break;
       }
+      case TSDB_DATA_TYPE_JSON: {
+        (*env)->CallVoidMethod(env, rowobj, g_rowdataSetByteArrayFp, i,
+                               jniFromNCharToByteArray(env, (char *)row[i], length[i]));
+        break;
+      }
       case TSDB_DATA_TYPE_TIMESTAMP: {
         int precision = taos_result_precision(result);
         (*env)->CallVoidMethod(env, rowobj, g_rowdataSetTimestampFp, i, (jlong) * ((int64_t *)row[i]), precision);
diff --git a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/JsonTagTest.java b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/JsonTagTest.java
new file mode 100644
index 0000000000000000000000000000000000000000..9bca28a7f50f8363ca0bc35fafa7eac0d6e41377
--- /dev/null
+++ b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/JsonTagTest.java
@@ -0,0 +1,1169 @@
+package com.taosdata.jdbc;
+
+import com.google.common.collect.Lists;
+import org.checkerframework.checker.units.qual.A;
+import org.junit.*;
+import org.junit.runners.MethodSorters;
+
+import java.sql.*;
+import java.util.List;
+
+/**
+ * test json tag
+ */
+@FixMethodOrder(MethodSorters.NAME_ASCENDING)
+public class JsonTagTest {
+    private static String dbname = "json_tag_test";
+    private static Connection connection;
+    private static Statement statement;
+    private static final String superSql = "create table if not exists jsons1(ts timestamp, dataInt int, dataBool bool, dataStr nchar(50), dataStrBin binary(150)) tags(jtag json)";
+    private static final String[] sql = {
+            "insert into jsons1_1 using jsons1 tags('{\"tag1\":\"fff\",\"tag2\":5, \"tag3\":true}') values(now, 1, false, 'json1', '你是') (1591060608000, 23, true, '等等', 'json')",
+            "insert into jsons1_2 using jsons1 tags('{\"tag1\":5,\"tag2\":\"beijing\"}') values (1591060628000, 2, true, 'json2', 'sss')",
+            "insert into jsons1_3 using jsons1 tags('{\"tag1\":false,\"tag2\":\"beijing\"}') values (1591060668000, 3, false, 'json3', 'efwe')",
+            "insert into jsons1_4 using jsons1 tags('{\"tag1\":null,\"tag2\":\"shanghai\",\"tag3\":\"hello\"}') values (1591060728000, 4, true, 'json4', '323sd')",
+            "insert into jsons1_5 using jsons1 tags('{\"tag1\":1.232, \"tag2\":null}') values(1591060928000, 1, false, '你就会', 'ewe')",
+            "insert into jsons1_6 using jsons1 tags('{\"tag1\":11,\"tag2\":\"\",\"tag2\":null}') values(1591061628000, 11, false, '你就会','')",
+            "insert into jsons1_7 using jsons1 tags('{\"tag1\":\"收到货\",\"tag2\":\"\",\"tag3\":null}') values(1591062628000, 2, NULL, '你就会', 'dws')",
+            // test duplicate key using the first one.
+            "CREATE TABLE if not exists jsons1_8 using jsons1 tags('{\"tag1\":null, \"tag1\":true, \"tag1\":45, \"1tag$\":2, \" \":90}')",
+
+    };
+
+    private static final String[] invalidJsonInsertSql = {
+            // test empty json string, save as tag is NULL
+            "insert into jsons1_9  using jsons1 tags('\t') values (1591062328000, 24, NULL, '你就会', '2sdw')",
+    };
+
+    private static final String[] invalidJsonCreateSql = {
+            "CREATE TABLE if not exists jsons1_10 using jsons1 tags('')",
+            "CREATE TABLE if not exists jsons1_11 using jsons1 tags(' ')",
+            "CREATE TABLE if not exists jsons1_12 using jsons1 tags('{}')",
+            "CREATE TABLE if not exists jsons1_13 using jsons1 tags('null')",
+    };
+
+    // test invalidate json
+    private static final String[] errorJsonInsertSql = {
+            "CREATE TABLE if not exists jsons1_14 using jsons1 tags('\"efwewf\"')",
+            "CREATE TABLE if not exists jsons1_14 using jsons1 tags('3333')",
+            "CREATE TABLE if not exists jsons1_14 using jsons1 tags('33.33')",
+            "CREATE TABLE if not exists jsons1_14 using jsons1 tags('false')",
+            "CREATE TABLE if not exists jsons1_14 using jsons1 tags('[1,true]')",
+            "CREATE TABLE if not exists jsons1_14 using jsons1 tags('{222}')",
+            "CREATE TABLE if not exists jsons1_14 using jsons1 tags('{\"fe\"}')",
+    };
+
+    private static final String[] errorSelectSql = {
+            "select * from jsons1 where jtag->tag1='beijing'",
+            "select * from jsons1 where jtag->'location'",
+            "select * from jsons1 where jtag->''",
+            "select * from jsons1 where jtag->''=9",
+            "select -> from jsons1",
+            "select ? from jsons1",
+            "select * from jsons1 where ?",
+            "select * from jsons1 where jtag->",
+            "select jtag->location from jsons1",
+            "select jtag?location from jsons1",
+            "select * from jsons1 where jtag?location",
+            "select * from jsons1 where jtag?''",
+            "select * from jsons1 where jtag?'location'='beijing'",
+            // test where with json tag
+            "select * from jsons1_1 where jtag is not null",
+            "select * from jsons1 where jtag='{\"tag1\":11,\"tag2\":\"\"}'",
+            "select * from jsons1 where jtag->'tag1'={}"
+    };
+
+    @Test
+    public void case01_InsertTest() throws SQLException {
+        for (String sql : sql) {
+            statement.execute(sql);
+        }
+        for (String sql : invalidJsonInsertSql) {
+            statement.execute(sql);
+        }
+        for (String sql : invalidJsonCreateSql) {
+            statement.execute(sql);
+        }
+    }
+
+    @Test
+    public void case02_InvalidJsonInsertTest() {
+        int count = 0;
+        for (String sql : errorJsonInsertSql) {
+            try {
+                statement.execute(sql);
+            } catch (SQLException e) {
+                count++;
+            }
+        }
+        Assert.assertEquals(errorJsonInsertSql.length, count);
+    }
+
+    // test invalidate json key, key must can be printed assic char
+    @Test(expected = SQLException.class)
+    public void case02_ArrayErrorTest() throws SQLException {
+        statement.execute("CREATE TABLE if not exists jsons1_14 using jsons1 tags('{\"tag1\":[1,true]}')");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case02_EmptyKeyErrorTest() throws SQLException {
+        statement.execute("CREATE TABLE if not exists jsons1_14 using jsons1 tags('{\"\":\"fff\"}')");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case02_EmptyValueErrorTest() throws SQLException {
+        statement.execute("CREATE TABLE if not exists jsons1_14 using jsons1 tags('{\"tag1\":{}}')");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case02_AbnormalKeyErrorTest1() throws SQLException {
+        statement.execute("CREATE TABLE if not exists jsons1_14 using jsons1 tags('{\"。loc\":\"fff\"}')");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case02_AbnormalKeyErrorTest2() throws SQLException {
+        statement.execute("CREATE TABLE if not exists jsons1_14 using jsons1 tags('{\"\t\":\"fff\"}')");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case02_AbnormalKeyErrorTest3() throws SQLException {
+        statement.execute("CREATE TABLE if not exists jsons1_14 using jsons1 tags('{\"试试\":\"fff\"}')");
+    }
+
+    @Test
+    public void case03_AlterTag() throws SQLException {
+        statement.execute("ALTER TABLE jsons1_1 SET TAG jtag='{\"tag1\":\"femail\",\"tag2\":35,\"tag3\":true}'");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case03_AddTagErrorTest() throws SQLException {
+        statement.execute("ALTER STABLE jsons1 add tag tag2 nchar(20)");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case03_dropTagErrorTest() throws SQLException {
+        statement.execute("ALTER STABLE jsons1 drop tag jtag");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case03_AlterTagErrorTest() throws SQLException {
+        statement.execute("ALTER TABLE jsons1_1 SET TAG jtag=4");
+    }
+
+    // test error syntax
+    @Test
+    public void case04_SelectErrorTest() {
+        int count = 0;
+        for (String sql : errorSelectSql) {
+            try {
+                statement.execute(sql);
+            } catch (SQLException e) {
+                count++;
+            }
+        }
+        Assert.assertEquals(errorSelectSql.length, count);
+    }
+
+    // test select normal column
+    @Test
+    public void case04_select01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select dataint from jsons1");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(sql.length + invalidJsonInsertSql.length, count);
+        close(resultSet);
+    }
+
+    // test select json tag
+    @Test
+    public void case04_select02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(sql.length + invalidJsonInsertSql.length, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag from jsons1");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(sql.length + invalidJsonInsertSql.length + invalidJsonCreateSql.length, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag from jsons1 where jtag is null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(invalidJsonInsertSql.length + invalidJsonCreateSql.length, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select05() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag from jsons1 where jtag is not null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(sql.length, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select06() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag from jsons1_8");
+        resultSet.next();
+        String result = resultSet.getString(1);
+        Assert.assertEquals("{\"tag1\":null,\"1tag$\":2,\" \":90}", result);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select07() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag from jsons1_1");
+        resultSet.next();
+        String result = resultSet.getString(1);
+        Assert.assertEquals("{\"tag1\":\"femail\",\"tag2\":35,\"tag3\":true}", result);
+        close(resultSet);
+    }
+
+    // test jtag is NULL
+    @Test
+    public void case04_select08() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag from jsons1_9");
+        resultSet.next();
+        String result = resultSet.getString(1);
+        Assert.assertNull(result);
+        close(resultSet);
+    }
+
+    // test select json tag->'key', value is string
+    @Test
+    public void case04_select09() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag1' from jsons1_1");
+        resultSet.next();
+        String result = resultSet.getString(1);
+        Assert.assertEquals("\"femail\"", result);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select10() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag2' from jsons1_6");
+        resultSet.next();
+        String result = resultSet.getString(1);
+        Assert.assertEquals("\"\"", result);
+        close(resultSet);
+    }
+
+    // test select json tag->'key', value is int
+    @Test
+    public void case04_select11() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag2' from jsons1_1");
+        resultSet.next();
+        String string = resultSet.getString(1);
+        Assert.assertEquals("35", string);
+        close(resultSet);
+    }
+
+    // test select json tag->'key', value is bool
+    @Test
+    public void case04_select12() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag3' from jsons1_1");
+        resultSet.next();
+        String string = resultSet.getString(1);
+        Assert.assertEquals("true", string);
+        close(resultSet);
+    }
+
+    // test select json tag->'key', value is null
+    @Test
+    public void case04_select13() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag1' from jsons1_4");
+        resultSet.next();
+        String string = resultSet.getString(1);
+        Assert.assertEquals("null", string);
+        close(resultSet);
+    }
+
+    // test select json tag->'key', value is double
+    @Test
+    public void case04_select14() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag1' from jsons1_5");
+        resultSet.next();
+        String string = resultSet.getString(1);
+        Assert.assertEquals("1.232000000", string);
+        close(resultSet);
+    }
+
+    // test select json tag->'key', key is not exist
+    @Test
+    public void case04_select15() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag10' from jsons1_4");
+        resultSet.next();
+        String string = resultSet.getString(1);
+        Assert.assertNull(string);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select16() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag1' from jsons1");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(sql.length + invalidJsonCreateSql.length + invalidJsonInsertSql.length, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select17() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag1' from jsons1");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(sql.length + invalidJsonCreateSql.length + invalidJsonInsertSql.length, count);
+        close(resultSet);
+    }
+
+    // where json value is string
+    @Test
+    public void case04_select19() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2'='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select20() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select dataint,tbname,jtag->'tag1',jtag from jsons1 where jtag->'tag2'='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select21() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case04_select23() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'='收到货'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case05_symbolOperation01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2'>'beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case05_symbolOperation02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2'>='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case05_symbolOperation03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2'<'beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case05_symbolOperation04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2'<='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(4, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case05_symbolOperation05() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2'!='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case05_symbolOperation06() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2'=''");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    // where json value is int
+    @Test
+    public void case06_selectValue01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=5");
+        int count = 0;
+        while (resultSet.next()) {
+            System.out.println(resultSet.getString(1));
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case06_selectValue02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'<54");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case06_selectValue03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'<=11");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case06_selectValue04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'>4");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case06_selectValue05() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'>=5");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case06_selectValue06() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'!=5");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case06_selectValue07() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'!=55");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case06_selectValue08() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=10");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    // where json value is double
+    @Test
+    public void case07_selectValue01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=1.232");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case07_doubleOperation01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'<1.232");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case07_doubleOperation02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'<=1.232");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case07_doubleOperation03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'>1.23");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case07_doubleOperation04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'>=1.232");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case07_doubleOperation05() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'!=1.232");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case07_doubleOperation06() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'!=3.232");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(3, count);
+        close(resultSet);
+    }
+
+    @Test(expected = SQLException.class)
+    public void case07_doubleOperation07() throws SQLException {
+        statement.executeQuery("select * from jsons1 where jtag->'tag1'/0=3");
+    }
+
+    @Test(expected = SQLException.class)
+    public void case07_doubleOperation08() throws SQLException {
+        statement.executeQuery("select * from jsons1 where jtag->'tag1'/5=1");
+    }
+
+    @Test
+    public void case08_boolOperation01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=true");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case08_boolOperation02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=false");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case08_boolOperation03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'!=false");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test(expected = SQLException.class)
+    public void case08_boolOperation04() throws SQLException {
+        statement.executeQuery("select * from jsons1 where jtag->'tag1'>false");
+    }
+
+    // where json value is null
+    @Test
+    public void case09_select01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag is null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag is not null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(8, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag_no_exist'=3");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select05() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1' is null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(invalidJsonInsertSql.length, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select06() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag4' is null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(sql.length + invalidJsonInsertSql.length, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select07() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag3' is not null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(4, count);
+        close(resultSet);
+    }
+
+    // test ?
+    @Test
+    public void case09_select10() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag?'tag1'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(8, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select11() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag?'tag3'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(4, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case09_select12() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag?'tag_no_exist'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    // test json tag in where condition with and/or
+    @Test
+    public void case10_selectAndOr01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=false and jtag->'tag2'='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case10_selectAndOr02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=false or jtag->'tag2'='beijing'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case10_selectAndOr03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=false and jtag->'tag2'='shanghai'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case10_selectAndOr04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'=13 or jtag->'tag2'>35");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case10_selectAndOr05() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1' is not null and jtag?'tag3'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(4, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case10_selectAndOr06() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1'='femail' and jtag?'tag3'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    // test with tbname/normal column
+    @Test
+    public void case11_selectTbName01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where tbname = 'jsons1_1'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case11_selectTbName02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where tbname = 'jsons1_1' and jtag?'tag3'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case11_selectTbName03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where tbname = 'jsons1_1' and jtag?'tag3' and dataint=3");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case11_selectTbName04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where tbname = 'jsons1_1' and jtag?'tag3' and dataint=23");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    // test where condition like
+    @Test
+    public void case12_selectWhere01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select *,tbname from jsons1 where jtag->'tag2' like 'bei%'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case12_selectWhere02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select *,tbname from jsons1 where jtag->'tag1' like 'fe%' and jtag->'tag2' is not null");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    // test where condition in  no support in
+    @Test(expected = SQLException.class)
+    public void case12_selectWhere03() throws SQLException {
+        statement.executeQuery("select * from jsons1 where jtag->'tag1' in ('beijing')");
+    }
+
+    // test where condition match
+    @Test
+    public void case12_selectWhere04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1' match 'ma'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case12_selectWhere05() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1' match 'ma$'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case12_selectWhere06() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag2' match 'jing$'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(2, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case12_selectWhere07() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from jsons1 where jtag->'tag1' match '收到'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    // test distinct
+    @Test
+    public void case13_selectDistinct01() throws SQLException {
+        statement.execute("insert into jsons1_14 using jsons1 tags('{\"tag1\":\"收到货\",\"tag2\":\"\",\"tag3\":null}') values(1591062628000, 2, NULL, '你就会', 'dws')");
+    }
+
+    @Test
+    public void case13_selectDistinct02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select distinct jtag->'tag1' from jsons1");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(8, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case13_selectDistinct03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select distinct jtag from jsons1");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(9, count);
+        close(resultSet);
+    }
+
+    // test dumplicate key with normal colomn
+    @Test
+    public void case14_selectDump01() throws SQLException {
+        statement.execute("INSERT INTO jsons1_15 using jsons1 tags('{\"tbname\":\"tt\",\"databool\":true,\"datastr\":\"是是是\"}') values(1591060828000, 4, false, 'jjsf', \"你就会\")");
+    }
+
+    @Test
+    public void case14_selectDump02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select *,tbname,jtag from jsons1 where jtag->'datastr' match '是' and datastr match 'js'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(1, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case14_selectDump03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select tbname,jtag->'tbname' from jsons1 where jtag->'tbname'='tt' and tbname='jsons1_14'");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(0, count);
+        close(resultSet);
+    }
+
+    // test join
+    @Test
+    public void case15_selectJoin01() throws SQLException {
+        statement.execute("create table if not exists jsons2(ts timestamp, dataInt int, dataBool bool, dataStr nchar(50), dataStrBin binary(150)) tags(jtag json)");
+        statement.execute("insert into jsons2_1 using jsons2 tags('{\"tag1\":\"fff\",\"tag2\":5, \"tag3\":true}') values(1591060618000, 2, false, 'json2', '你是2')");
+        statement.execute("insert into jsons2_2 using jsons2 tags('{\"tag1\":5,\"tag2\":null}') values (1591060628000, 2, true, 'json2', 'sss')");
+
+        statement.execute("create table if not exists jsons3(ts timestamp, dataInt int, dataBool bool, dataStr nchar(50), dataStrBin binary(150)) tags(jtag json)");
+        statement.execute("insert into jsons3_1 using jsons3 tags('{\"tag1\":\"fff\",\"tag2\":5, \"tag3\":true}') values(1591060618000, 3, false, 'json3', '你是3')");
+        statement.execute("insert into jsons3_2 using jsons3 tags('{\"tag1\":5,\"tag2\":\"beijing\"}') values (1591060638000, 2, true, 'json3', 'sss')");
+    }
+
+    // TODO check result
+    @Test
+    public void case15_selectJoin02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select 'sss',33,a.jtag->'tag3' from jsons2 a,jsons3 b where a.ts=b.ts and a.jtag->'tag1'=b.jtag->'tag1'");
+
+        close(resultSet);
+    }
+
+    // test group by & order by  json tag
+    // TODO check other result
+    @Test
+    public void case16_selectGroupOrder01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select count(*) from jsons1 group by jtag->'tag1' order by jtag->'tag1' desc");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(8, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case16_selectGroupOrder02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select count(*) from jsons1 group by jtag->'tag1' order by jtag->'tag1' asc");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(8, count);
+        close(resultSet);
+    }
+
+    // test stddev with group by json tag
+    // TODO check result
+    @Test
+    public void case17_selectStddev01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select stddev(dataint) from jsons1 group by jtag->'tag1'");
+        String s = "";
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+            s = resultSet.getString(2);
+
+        }
+        Assert.assertEquals(8, count);
+        Assert.assertEquals("\"femail\"", s);
+        close(resultSet);
+    }
+
+    // subquery with json tag
+    @Test
+    public void case18_selectSubquery01() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select * from (select jtag, dataint from jsons1)");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(11, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case18_selectSubquery02() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag1' from (select jtag->'tag1', dataint from jsons1)");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(11, count);
+        close(resultSet);
+    }
+
+    @Test
+    public void case18_selectSubquery03() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select jtag->'tag1' from (select jtag->'tag1', dataint from jsons1)");
+        ResultSetMetaData metaData = resultSet.getMetaData();
+        String columnName = metaData.getColumnName(1);
+        Assert.assertEquals("jtag->'tag1'", columnName);
+        close(resultSet);
+    }
+
+    @Test
+    public void case18_selectSubquery04() throws SQLException {
+        ResultSet resultSet = statement.executeQuery("select ts,tbname,jtag->'tag1' from (select jtag->'tag1',tbname,ts from jsons1 order by ts)");
+        int count = 0;
+        while (resultSet.next()) {
+            count++;
+        }
+        Assert.assertEquals(11, count);
+        close(resultSet);
+    }
+
+    private void close(ResultSet resultSet) {
+        try {
+            if (null != resultSet) {
+                resultSet.close();
+            }
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+    @BeforeClass
+    public static void beforeClass() {
+        String host = "127.0.0.1";
+        final String url = "jdbc:TAOS://" + host + ":6030/?user=root&password=taosdata";
+        try {
+            connection = DriverManager.getConnection(url);
+            statement = connection.createStatement();
+            statement.execute("drop database if exists " + dbname);
+            statement.execute("create database if not exists " + dbname);
+            statement.execute("use " + dbname);
+            statement.execute(superSql);
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+    @AfterClass
+    public static void afterClass() {
+        try {
+            if (null != statement) {
+                statement.execute("drop database " + dbname);
+                statement.close();
+            }
+            if (null != connection) {
+                connection.close();
+            }
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+
+    }
+}