Add the parser to parse time.

src/common/algorithm/test/CMakeLists.txt

@@ -6,6 +6,8 @@
 nebula_add_test(
     NAME reservoir_sampling_test
     SOURCES ReservoirSamplingTest.cpp
-    OBJECTS $<TARGET_OBJECTS:time_obj>
+    OBJECTS
+        $<TARGET_OBJECTS:base_obj>
+        $<TARGET_OBJECTS:time_obj>
     LIBRARIES gtest gtest_main
 )

src/common/concurrent/test/CMakeLists.txt

@@ -9,6 +9,7 @@ nebula_add_test(
     SOURCES
         BarrierTest.cpp LatchTest.cpp
     OBJECTS
+        $<TARGET_OBJECTS:base_obj>
         $<TARGET_OBJECTS:concurrent_obj>
         $<TARGET_OBJECTS:thread_obj>
         $<TARGET_OBJECTS:time_obj>

src/common/datatypes/Date.cpp

@@ -13,6 +13,11 @@
 
 namespace nebula {
 
+static inline std::string decimal(const std::string &number) {
+    auto find = std::find(number.begin(), number.end(), '.');
+    return std::string(find, number.end());
+}
+
 const int64_t kDaysSoFar[] = {0, 31, 59, 90, 120, 151, 181, 212, 243, 273, 304, 334, 365};
 const int64_t kLeapDaysSoFar[] = {0, 31, 60, 91, 121, 152, 182, 213, 244, 274, 305, 335, 366};
 
@@ -101,21 +106,25 @@ std::string Date::toString() const {
 }
 
 std::string Time::toString() const {
+    auto microsecStr = folly::stringPrintf("%.9f", static_cast<uint32_t>(microsec) / 1000000.0);
+    auto decimalPart = decimal(microsecStr);
     // It's in current timezone already
-    return folly::stringPrintf("%02d:%02d:%02d.%06d", hour, minute, sec, microsec);
+    return folly::stringPrintf("%02d:%02d:%02d%s", hour, minute, sec, decimalPart.c_str());
 }
 
 std::string DateTime::toString() const {
+    auto microsecStr = folly::stringPrintf("%.9f", static_cast<uint32_t>(microsec) / 1000000.0);
+    auto decimalPart = decimal(microsecStr);
     // It's in current timezone already
     return folly::stringPrintf("%hd-%02hhu-%02hhu"
-                               "T%02hhu:%02hhu:%02hhu.%u",
+                               "T%02hhu:%02hhu:%02hhu%s",
                                static_cast<int16_t>(year),
                                static_cast<uint8_t>(month),
                                static_cast<uint8_t>(day),
                                static_cast<uint8_t>(hour),
                                static_cast<uint8_t>(minute),
                                static_cast<uint8_t>(sec),
-                               static_cast<uint32_t>(microsec));
+                               decimalPart.c_str());
 }
 
 }   // namespace nebula

src/common/function/test/FunctionManagerTest.cpp

@@ -305,7 +305,7 @@ TEST_F(FunctionManagerTest, functionCall) {
         TEST_FUNCTION(toString, args_["toString_bool"], "true");
         TEST_FUNCTION(toString, args_["string"], "AbcDeFG");
         TEST_FUNCTION(toString, args_["date"], "1984-10-11");
-        TEST_FUNCTION(toString, args_["datetime"], "1984-10-11T12:31:14.341");
+        TEST_FUNCTION(toString, args_["datetime"], "1984-10-11T12:31:14.000341000");
         TEST_FUNCTION(toString, args_["nullvalue"], Value::kNullValue);
     }
     {

src/common/thread/test/CMakeLists.txt

@@ -11,6 +11,7 @@ nebula_add_test(
         GenericWorkerTest.cpp
         GenericThreadPoolTest.cpp
     OBJECTS
+        $<TARGET_OBJECTS:base_obj>
         $<TARGET_OBJECTS:thread_obj>
         $<TARGET_OBJECTS:concurrent_obj>
         $<TARGET_OBJECTS:time_obj>

src/common/time/CMakeLists.txt

@@ -14,6 +14,7 @@ nebula_add_library(
     time_utils_obj OBJECT
     TimeUtils.cpp
     TimezoneInfo.cpp
+    TimeParser.cpp
     TimeConversion.cpp
 )