@@ -47,9 +47,9 @@ def test_select_query(presto_connection):
47
47
48
48
def test_select_query_result_iteration (presto_connection ):
49
49
cur = presto_connection .cursor ()
50
- cur .execute ('select custkey from tcph .sf1.customer LIMIT 10' )
50
+ cur .execute ('select custkey from tpch .sf1.customer LIMIT 10' )
51
51
rows0 = cur .genall ()
52
- cur .execute ('select custkey from tcph .sf1.customer LIMIT 10' )
52
+ cur .execute ('select custkey from tpch .sf1.customer LIMIT 10' )
53
53
rows1 = cur .fetchall ()
54
54
55
55
assert len (list (rows0 )) == len (rows1 )
@@ -64,7 +64,7 @@ def test_select_query_no_result(presto_connection):
64
64
65
65
def test_select_query_stats (presto_connection ):
66
66
cur = presto_connection .cursor ()
67
- cur .execute ('SELECT * FROM tcph .sf1.customer' )
67
+ cur .execute ('SELECT * FROM tpch .sf1.customer' )
68
68
69
69
query_id = cur .stats ['queryId' ]
70
70
completed_splits = cur .stats ['completedSplits' ]
@@ -99,16 +99,16 @@ def test_select_failed_query(presto_connection):
99
99
cur .fetchall ()
100
100
101
101
102
- def test_select_tcph_1000 (presto_connection ):
102
+ def test_select_tpch_1000 (presto_connection ):
103
103
cur = presto_connection .cursor ()
104
- cur .execute ('SELECT * FROM tcph .sf1.customer LIMIT 1000' )
104
+ cur .execute ('SELECT * FROM tpch .sf1.customer LIMIT 1000' )
105
105
rows = cur .fetchall ()
106
106
assert len (rows ) == 1000
107
107
108
108
109
109
def test_cancel_query (presto_connection ):
110
110
cur = presto_connection .cursor ()
111
- cur .execute ('select * from tcph .sf1.customer' )
111
+ cur .execute ('select * from tpch .sf1.customer' )
112
112
cur .cancel ()
113
113
114
114
with pytest .raises (prestodb .exceptions .PrestoUserError ) as cancel_error :
0 commit comments