From 3f508f002a87cee8b790ac8a467cf2356094018a Mon Sep 17 00:00:00 2001
From: Zhiyu Yang <69311263+zyyang-taosdata@users.noreply.github.com>
Date: Fri, 27 Aug 2021 15:05:27 +0800
Subject: [PATCH] [TD-6389]<test>: test jdbc use now insert timestamp (#7624)

---
 .../jdbc/cases/UseNowInsertTimestampTest.java | 84 +++++++++++++++++++
 1 file changed, 84 insertions(+)
 create mode 100644 src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/UseNowInsertTimestampTest.java

diff --git a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/UseNowInsertTimestampTest.java b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/UseNowInsertTimestampTest.java
new file mode 100644
index 0000000000..fbce021d1b
--- /dev/null
+++ b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/cases/UseNowInsertTimestampTest.java
@@ -0,0 +1,84 @@
+package com.taosdata.jdbc.cases;
+
+import org.junit.Before;
+import org.junit.Test;
+
+import java.sql.*;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+
+public class UseNowInsertTimestampTest {
+    String url = "jdbc:TAOS://127.0.0.1:6030/?user=root&password=taosdata";
+
+    @Test
+    public void millisec() {
+        try (Connection conn = DriverManager.getConnection(url)) {
+            Statement stmt = conn.createStatement();
+            stmt.execute("drop database if exists test");
+            stmt.execute("create database if not exists test precision 'ms'");
+            stmt.execute("use test");
+            stmt.execute("create table weather(ts timestamp, f1 int)");
+            stmt.execute("insert into weather values(now, 1)");
+
+            ResultSet rs = stmt.executeQuery("select * from weather");
+            rs.next();
+            Timestamp ts = rs.getTimestamp("ts");
+            assertEquals(13, Long.toString(ts.getTime()).length());
+
+            int nanos = ts.getNanos();
+            assertEquals(0, nanos % 1000_000);
+
+            stmt.execute("drop database if exists test");
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Test
+    public void microsec() {
+        try (Connection conn = DriverManager.getConnection(url)) {
+            Statement stmt = conn.createStatement();
+            stmt.execute("drop database if exists test");
+            stmt.execute("create database if not exists test precision 'us'");
+            stmt.execute("use test");
+            stmt.execute("create table weather(ts timestamp, f1 int)");
+            stmt.execute("insert into weather values(now, 1)");
+
+            ResultSet rs = stmt.executeQuery("select * from weather");
+            rs.next();
+            Timestamp ts = rs.getTimestamp("ts");
+            int nanos = ts.getNanos();
+
+            assertEquals(0, nanos % 1000);
+
+            stmt.execute("drop database if exists test");
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Test
+    public void nanosec() {
+        try (Connection conn = DriverManager.getConnection(url)) {
+            Statement stmt = conn.createStatement();
+            stmt.execute("drop database if exists test");
+            stmt.execute("create database if not exists test precision 'ns'");
+            stmt.execute("use test");
+            stmt.execute("create table weather(ts timestamp, f1 int)");
+            stmt.execute("insert into weather values(now, 1)");
+
+            ResultSet rs = stmt.executeQuery("select * from weather");
+            rs.next();
+
+            Timestamp ts = rs.getTimestamp("ts");
+
+            int nanos = ts.getNanos();
+            assertTrue(nanos % 1000 != 0);
+
+            stmt.execute("drop database if exists test");
+        } catch (SQLException e) {
+            e.printStackTrace();
+        }
+    }
+}
-- 
GitLab