diff --git a/Tests/SparkConnectTests/Resources/queries/variant.sql b/Tests/SparkConnectTests/Resources/queries/variant.sql new file mode 100644 index 0000000..ae81f1e --- /dev/null +++ b/Tests/SparkConnectTests/Resources/queries/variant.sql @@ -0,0 +1,5 @@ +FROM VALUES parse_json('{"a": true, "b": 1, "c": "swift"}') T(v) +|> SELECT v, + variant_get(v, '$.a', 'boolean') as a, + variant_get(v, '$.b', 'int') as b, + variant_get(v, '$.c', 'string') as c diff --git a/Tests/SparkConnectTests/Resources/queries/variant.sql.answer b/Tests/SparkConnectTests/Resources/queries/variant.sql.answer new file mode 100644 index 0000000..c50602e --- /dev/null +++ b/Tests/SparkConnectTests/Resources/queries/variant.sql.answer @@ -0,0 +1,5 @@ ++----------------------------+----+---+-----+ +| v| a| b| c| ++----------------------------+----+---+-----+ +|{"a":true,"b":1,"c":"swift"}|true| 1|swift| ++----------------------------+----+---+-----+ \ No newline at end of file diff --git a/Tests/SparkConnectTests/SQLTests.swift b/Tests/SparkConnectTests/SQLTests.swift index a9c6b71..1b9be5f 100644 --- a/Tests/SparkConnectTests/SQLTests.swift +++ b/Tests/SparkConnectTests/SQLTests.swift @@ -85,6 +85,7 @@ struct SQLTests { "create_table_function.sql", "pipesyntax.sql", "explain.sql", + "variant.sql", ] #if !os(Linux)