diff --git a/src/connector/jdbc/pom.xml b/src/connector/jdbc/pom.xml
index 7a421eff2296cc8b61ec6e07174747ef8e224ff0..f1e013e864f4617e04be0c8c5b892c4396c66e79 100755
--- a/src/connector/jdbc/pom.xml
+++ b/src/connector/jdbc/pom.xml
@@ -102,6 +102,7 @@
                         <include>**/*Test.java</include>
                     </includes>
                     <excludes>
+                        <exclude>**/DatetimeBefore1970Test.java</exclude>
                         <exclude>**/AppMemoryLeakTest.java</exclude>
                         <exclude>**/AuthenticationTest.java</exclude>
                         <exclude>**/TaosInfoMonitorTest.java</exclude>
diff --git a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBJNIConnectorTest.java b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBJNIConnectorTest.java
new file mode 100644
index 0000000000000000000000000000000000000000..5e4f16a73c3c93456ed67450752af094cd96938c
--- /dev/null
+++ b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBJNIConnectorTest.java
@@ -0,0 +1,130 @@
+package com.taosdata.jdbc;
+
+import org.junit.Test;
+
+import java.sql.SQLException;
+import java.sql.SQLWarning;
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.junit.Assert.*;
+
+public class TSDBJNIConnectorTest {
+
+    public static void main(String[] args) {
+        try {
+            TSDBJNIConnector.init("/etc/taos/taos.cfg", "en_US.UTF-8", "", "");
+            TSDBJNIConnector connector = new TSDBJNIConnector();
+            connector.connect("127.0.0.1", 6030, "test", "root", "taosdata");
+            long pSql = connector.executeQuery("show dnodes");
+            // if pSql is create/insert/update/delete/alter SQL
+            if (connector.isUpdateQuery(pSql)) {
+                connector.freeResultSet(pSql);
+                throw TSDBError.createSQLException(TSDBErrorNumbers.ERROR_INVALID_WITH_EXECUTEQUERY);
+            }
+
+            List<ColumnMetaData> columnMetaDataList = new ArrayList<>();
+
+            int code = connector.getSchemaMetaData(pSql, columnMetaDataList);
+            if (code == TSDBConstants.JNI_CONNECTION_NULL) {
+                throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_CONNECTION_NULL));
+            }
+            if (code == TSDBConstants.JNI_RESULT_SET_NULL) {
+                throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_RESULT_SET_NULL));
+            }
+            if (code == TSDBConstants.JNI_NUM_OF_FIELDS_0) {
+                throw new SQLException(TSDBConstants.FixErrMsg(TSDBConstants.JNI_NUM_OF_FIELDS_0));
+            }
+
+        } catch (SQLWarning throwables) {
+            throwables.printStackTrace();
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+
+    @Test
+    public void isClosed() {
+    }
+
+    @Test
+    public void isResultsetClosed() {
+    }
+
+    @Test
+    public void init() {
+    }
+
+    @Test
+    public void initImp() {
+    }
+
+    @Test
+    public void setOptions() {
+    }
+
+    @Test
+    public void getTsCharset() {
+    }
+
+    @Test
+    public void connect() {
+    }
+
+    @Test
+    public void executeQuery() {
+    }
+
+    @Test
+    public void getErrCode() {
+    }
+
+    @Test
+    public void getErrMsg() {
+    }
+
+    @Test
+    public void isUpdateQuery() {
+    }
+
+    @Test
+    public void freeResultSet() {
+    }
+
+    @Test
+    public void getAffectedRows() {
+    }
+
+    @Test
+    public void getSchemaMetaData() {
+    }
+
+    @Test
+    public void fetchRow() {
+    }
+
+    @Test
+    public void fetchBlock() {
+    }
+
+    @Test
+    public void closeConnection() {
+    }
+
+    @Test
+    public void subscribe() {
+    }
+
+    @Test
+    public void consume() {
+    }
+
+    @Test
+    public void unsubscribe() {
+    }
+
+    @Test
+    public void validateCreateTableSql() {
+    }
+}
\ No newline at end of file