@@ -14,7 +14,7 @@ def table_fixture(self, connection_details):
14
14
# Create the table
15
15
cursor .execute (
16
16
"""
17
- CREATE TABLE IF NOT EXISTS pysql_test_complex_types_table (
17
+ CREATE TABLE IF NOT EXISTS pysql_e2e_test_complex_types_table (
18
18
array_col ARRAY<STRING>,
19
19
map_col MAP<STRING, INTEGER>,
20
20
struct_col STRUCT<field1: STRING, field2: INTEGER>
@@ -24,7 +24,7 @@ def table_fixture(self, connection_details):
24
24
# Insert a record
25
25
cursor .execute (
26
26
"""
27
- INSERT INTO pysql_test_complex_types_table
27
+ INSERT INTO pysql_e2e_test_complex_types_table
28
28
VALUES (
29
29
ARRAY('a', 'b', 'c'),
30
30
MAP('a', 1, 'b', 2, 'c', 3),
@@ -34,7 +34,7 @@ def table_fixture(self, connection_details):
34
34
)
35
35
yield
36
36
# Clean up the table after the test
37
- cursor .execute ("DROP TABLE IF EXISTS pysql_test_complex_types_table " )
37
+ cursor .execute ("DROP TABLE IF EXISTS pysql_e2e_test_complex_types_table " )
38
38
39
39
@pytest .mark .parametrize (
40
40
"field,expected_type" ,
@@ -45,7 +45,7 @@ def test_read_complex_types_as_arrow(self, field, expected_type, table_fixture):
45
45
46
46
with self .cursor () as cursor :
47
47
result = cursor .execute (
48
- "SELECT * FROM pysql_test_complex_types_table LIMIT 1"
48
+ "SELECT * FROM pysql_e2e_test_complex_types_table LIMIT 1"
49
49
).fetchone ()
50
50
51
51
assert isinstance (result [field ], expected_type )
@@ -57,7 +57,7 @@ def test_read_complex_types_as_string(self, field, table_fixture):
57
57
extra_params = {"_use_arrow_native_complex_types" : False }
58
58
) as cursor :
59
59
result = cursor .execute (
60
- "SELECT * FROM pysql_test_complex_types_table LIMIT 1"
60
+ "SELECT * FROM pysql_e2e_test_complex_types_table LIMIT 1"
61
61
).fetchone ()
62
62
63
63
assert isinstance (result [field ], str )
0 commit comments