Skip to content

Commit 75c330a

Browse files
add complex types integration tests
Signed-off-by: varun-edachali-dbx <varun.edachali@databricks.com>
1 parent c288da4 commit 75c330a

File tree

1 file changed

+21
-4
lines changed

1 file changed

+21
-4
lines changed

tests/e2e/test_complex_types.py

Lines changed: 21 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,10 +54,19 @@ def table_fixture(self, connection_details):
5454
("map_array_col", list),
5555
],
5656
)
57-
def test_read_complex_types_as_arrow(self, field, expected_type, table_fixture):
57+
@pytest.mark.parametrize(
58+
"extra_params",
59+
[
60+
{},
61+
{"use_sea": True},
62+
],
63+
)
64+
def test_read_complex_types_as_arrow(
65+
self, field, expected_type, table_fixture, extra_params
66+
):
5867
"""Confirms the return types of a complex type field when reading as arrow"""
5968

60-
with self.cursor() as cursor:
69+
with self.cursor(extra_params=extra_params) as cursor:
6170
result = cursor.execute(
6271
"SELECT * FROM pysql_test_complex_types_table LIMIT 1"
6372
).fetchone()
@@ -75,10 +84,18 @@ def test_read_complex_types_as_arrow(self, field, expected_type, table_fixture):
7584
("map_array_col"),
7685
],
7786
)
78-
def test_read_complex_types_as_string(self, field, table_fixture):
87+
@pytest.mark.parametrize(
88+
"extra_params",
89+
[
90+
{},
91+
{"use_sea": True},
92+
],
93+
)
94+
def test_read_complex_types_as_string(self, field, table_fixture, extra_params):
7995
"""Confirms the return type of a complex type that is returned as a string"""
96+
extra_params = {**extra_params, "_use_arrow_native_complex_types": False}
8097
with self.cursor(
81-
extra_params={"_use_arrow_native_complex_types": False}
98+
extra_params=extra_params,
8299
) as cursor:
83100
result = cursor.execute(
84101
"SELECT * FROM pysql_test_complex_types_table LIMIT 1"

0 commit comments

Comments
 (0)