"Time datatype support for actual value type"

Author: Shubhangi-cs

src/main/java/io/cdap/plugin/servicenow/apiclient/ServiceNowTableAPIClientImpl.java

@@ -309,6 +309,9 @@ public Schema fetchTableSchema(String tableName, String accessToken, SourceValue
       if (valueType.equals(SourceValueType.SHOW_DISPLAY_VALUE) &&
         !Objects.equals(field.getType(), field.getInternalType())) {
         columns.add(new ServiceNowColumn(field.getName(), field.getType()));
+      } else if (valueType.equals(SourceValueType.SHOW_ACTUAL_VALUE) &&
+        "glide_time".equalsIgnoreCase(field.getInternalType())) {
+        columns.add(new ServiceNowColumn(field.getName(), "datetime"));
       } else {
         columns.add(new ServiceNowColumn(field.getName(), field.getInternalType()));
       }

src/main/java/io/cdap/plugin/servicenow/util/SchemaBuilder.java

@@ -75,6 +75,7 @@ private Schema createSchema(ServiceNowColumn column) {
       case "glide_date":
         return Schema.of(Schema.LogicalType.DATE);
       case "glide_date_time":
+      case "datetime":
         return Schema.of(Schema.LogicalType.DATETIME);
       case "glide_time":
         return Schema.of(Schema.LogicalType.TIME_MICROS);

src/test/java/io/cdap/plugin/servicenow/apiclient/ServiceNowTableAPIClientImplTest.java

@@ -117,6 +117,42 @@ public void testFetchTableSchema_ActualValueType() throws Exception {
       schema.getField("user_name").getSchema().getUnionSchemas().get(0).getType());
   }
 
+  @Test
+  public void testFetchTableSchema_GlideTimeFieldWithActualValueType() throws Exception {
+    ServiceNowConnectorConfig mockConfig = Mockito.mock(ServiceNowConnectorConfig.class);
+    ServiceNowTableAPIClientImpl impl = new ServiceNowTableAPIClientImpl(mockConfig);
+    ServiceNowTableAPIClientImpl implSpy = Mockito.spy(impl);
+
+    String jsonResponse = "{\n" +
+      "  \"result\": {\n" +
+      "    \"columns\": {\n" +
+      "      \"u_start_time\": {\n" +
+      "        \"label\": \"Start Time\",\n" +
+      "        \"name\": \"u_start_time\",\n" +
+      "        \"type\": \"string\",\n" +
+      "        \"internal_type\": \"glide_time\"\n" +
+      "      }\n" +
+      "    }\n" +
+      "  }\n" +
+      "}";
+
+    RestAPIResponse mockResponse = new RestAPIResponse(Collections.emptyMap(), jsonResponse, null);
+    Mockito.doReturn(mockResponse).when(implSpy).executeGetWithRetries(Mockito.any());
+
+    Schema schema = implSpy.fetchTableSchema("u_custom_table", "dummy-access-token", SourceValueType.SHOW_ACTUAL_VALUE);
+
+    Assert.assertNotNull(schema);
+    Assert.assertEquals("record", schema.getDisplayName());
+    Assert.assertEquals(1, schema.getFields().size());
+
+    Schema.Field field = schema.getField("u_start_time");
+    Assert.assertNotNull(field);
+
+    Schema fieldSchema = field.getSchema().getUnionSchemas().get(0);
+    Assert.assertEquals(Schema.LogicalType.DATETIME, fieldSchema.getLogicalType());
+  }
+
+
   @Test
   public void testFetchTableSchema_DisplayValueType() throws Exception {
     ServiceNowConnectorConfig mockConfig = Mockito.mock(ServiceNowConnectorConfig.class);