Fix null on jdbc (#93)

* Fix null on jdbc

* Add unittest

Author: koxudaxi

local_data_api/resources/jdbc/__init__.py

@@ -105,7 +105,9 @@ def get_filed_from_jdbc_type(self, value: Any, jdbc_type: Optional[int]) -> Fiel
             except ValueError:
                 pass
         if type_:
-            if type_ in LONG:
+            if value is None:
+                return Field(isNull=True)
+            elif type_ in LONG:
                 return Field(longValue=value)
             elif type_ in DOUBLE:
                 return Field(doubleValue=value)

scripts/integration-test.sh

@@ -102,6 +102,15 @@ function test {
     --include-result-metadata \
     --sql $'SELECT CAST(\'2021-03-10 22:41:04.068123+02\' AS TIMESTAMPTZ) AS value' \
       | jq -e '.records[0][0].stringValue == "2021-03-10 20:41:04.068"'
+
+      aws rds-data execute-statement \
+    --endpoint-url 'http://localhost:8080' \
+    --database 'test' \
+    --resource-arn $RDS_DATA_API_CLIENT_RESOURCE_ARN \
+    --secret-arn $RDS_DATA_API_CLIENT_SECRETARN \
+    --include-result-metadata \
+    --sql $'SELECT CAST(null AS TIMESTAMPTZ) AS value' \
+      | jq -e '.records[0][0].isNull == true'
     fi
 
     if [ "$db" = "mysql" ]
@@ -114,6 +123,16 @@ function test {
     --include-result-metadata \
     --sql $'SELECT CAST(\'2021-03-10 22:41:04.968123\' AS DATETIME) AS value' \
       | jq -e '.records[0][0].stringValue == "2021-03-10 22:41:05"'
+
+    aws rds-data execute-statement \
+    --endpoint-url 'http://localhost:8080' \
+    --database 'test' \
+    --resource-arn $RDS_DATA_API_CLIENT_RESOURCE_ARN \
+    --secret-arn $RDS_DATA_API_CLIENT_SECRETARN \
+    --include-result-metadata \
+    --sql $'SELECT CAST(null AS DATETIME) AS value' \
+      | jq -e '.records[0][0].isNull == true'
+
     fi
 
     # TODO list, JSON, enum

tests/test_resource/test_jdbc/test_jdbc.py

@@ -175,6 +175,11 @@ def test_create_connection_maker_error(mocker):
             JDBCType.TIMESTAMP,
             {'stringValue': '2021-03-10 22:41:04.968'},
         ),
+        (
+            None,
+            JDBCType.TIMESTAMP,
+            {'isNull': True},
+        ),
     ],
 )
 def test_get_filed_from_jdbc_type(value, jdbc_type, expected):