Merge pull request #42 from kalaiyarasiganeshalingam/query

Update the conversion error message
ballerina-platform · Sep 6, 2023 · 95eca2d · 95eca2d
2 parents 2ae8448 + ba4c64b
commit 95eca2d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml
@@ -100,9 +100,6 @@ dependencies = [
 	{org = "ballerina", name = "jballerina.java"},
 	{org = "ballerina", name = "lang.value"}
 ]
-modules = [
-	{org = "ballerina", packageName = "io", moduleName = "io"}
-]
 
 [[package]]
 org = "ballerina"
@@ -439,7 +436,6 @@ org = "ballerinax"
 name = "persist.sql"
 version = "1.2.0"
 dependencies = [
-	{org = "ballerina", name = "io"},
 	{org = "ballerina", name = "jballerina.java"},
 	{org = "ballerina", name = "log"},
 	{org = "ballerina", name = "persist"},

diff --git a/ballerina/stream_types.bal b/ballerina/stream_types.bal
@@ -67,8 +67,12 @@ public class PersistSQLStream {
                         _ = value.remove(keyField);
                     }
                 }
-
-                record {|record {} value;|} nextRecord = {value: checkpanic value.cloneWithType(self.targetType)};
+                record {}|error result = value.cloneWithType(self.targetType);
+                if result is error {
+                    return error persist:Error("Error occurred while converting to the record: " +
+                                result.detail().toString());
+                }
+                record {|record {} value;|} nextRecord = {value: result};
                 return nextRecord;
             }
         } else {