fix(query): NDJSON copy into allow cast bool and number to string (#1…

…5308)

src/query/formats/src/field_decoder/json_ast.rs

@@ -236,11 +236,24 @@ impl FieldJsonAstDecoder {
         match value {
             Value::String(s) => {
                 column.put_str(s.as_str());
-                column.commit_row();
-                Ok(())
             }
-            _ => Err(ErrorCode::BadBytes("Incorrect json value, must be string")),
+            Value::Bool(v) => {
+                if *v {
+                    column.put_str("true");
+                } else {
+                    column.put_str("false");
+                }
+            }
+            Value::Number(n) => {
+                column.put_str(n.to_string().as_str());
+            }
+            Value::Null => {
+                column.put_str("null");
+            }
+            _ => return Err(ErrorCode::BadBytes("Incorrect json value, must be string")),
         }
+        column.commit_row();
+        Ok(())
     }
 
     fn read_date(&self, column: &mut Vec<i32>, value: &Value) -> Result<()> {

tests/data/ndjson/cast_sample.ndjson

@@ -0,0 +1,3 @@
+{"name":"data1","tags":{"env":"test1","length":"ok"}}
+{"name":"data2","tags":{"env":"test2","length":true}}
+{"name":"data3","tags":{"env":"test3","length":10}}

tests/sqllogictests/suites/stage/formats/ndjson/ndjson_cast.test

@@ -0,0 +1,17 @@
+statement ok
+drop table if exists cast_ndjson
+
+statement ok
+CREATE TABLE cast_ndjson (name String, tags Map(String, String))
+
+query 
+copy into cast_ndjson from @data/ndjson/cast_sample.ndjson file_format = (type = NDJSON) ON_ERROR=continue
+----
+ndjson/cast_sample.ndjson 3 0 NULL NULL
+
+query 
+select * from cast_ndjson
+----
+data1 {'env':'test1','length':'ok'}
+data2 {'env':'test2','length':'true'}
+data3 {'env':'test3','length':'10'}