1717
1818import numpy as np
1919import pytest
20- from sqlalchemy import (
21- create_engine ,
22- text ,
23- )
24- from sqlalchemy .engine import Engine
2520
2621from pandas ._config import using_string_dtype
2722
@@ -312,6 +307,7 @@ def create_and_load_types_postgresql(conn, types_data: list[dict]):
312307
313308def create_and_load_types (conn , types_data : list [dict ], dialect : str ):
314309 from sqlalchemy import insert
310+ from sqlalchemy .engine import Engine
315311
316312 types = types_table_metadata (dialect )
317313
@@ -337,6 +333,7 @@ def create_and_load_postgres_datetz(conn):
337333 Table ,
338334 insert ,
339335 )
336+ from sqlalchemy .engine import Engine
340337
341338 metadata = MetaData ()
342339 datetz = Table ("datetz" , metadata , Column ("DateColWithTz" , DateTime (timezone = True )))
@@ -1215,6 +1212,7 @@ def test_read_iris_query_expression_with_parameter(conn, request):
12151212 from sqlalchemy import (
12161213 MetaData ,
12171214 Table ,
1215+ create_engine ,
12181216 select ,
12191217 )
12201218
@@ -1329,6 +1327,8 @@ def test_read_procedure(conn, request):
13291327 # GH 7324
13301328 # Although it is more an api test, it is added to the
13311329 # mysql tests as sqlite does not have stored procedures
1330+ from sqlalchemy import text
1331+ from sqlalchemy .engine import Engine
13321332
13331333 df = DataFrame ({"a" : [1 , 2 , 3 ], "b" : [0.1 , 0.2 , 0.3 ]})
13341334 df .to_sql (name = "test_frame" , con = conn , index = False )
@@ -1402,6 +1402,7 @@ def test_insertion_method_on_conflict_do_nothing(conn, request):
14021402 conn = request .getfixturevalue (conn )
14031403
14041404 from sqlalchemy .dialects .postgresql import insert
1405+ from sqlalchemy .engine import Engine
14051406 from sqlalchemy .sql import text
14061407
14071408 def insert_on_conflict (table , conn , keys , data_iter ):
@@ -1483,6 +1484,7 @@ def test_insertion_method_on_conflict_update(conn, request):
14831484 conn = request .getfixturevalue (conn )
14841485
14851486 from sqlalchemy .dialects .mysql import insert
1487+ from sqlalchemy .engine import Engine
14861488 from sqlalchemy .sql import text
14871489
14881490 def insert_on_conflict (table , conn , keys , data_iter ):
@@ -1534,6 +1536,7 @@ def test_read_view_postgres(conn, request):
15341536 # GH 52969
15351537 conn = request .getfixturevalue (conn )
15361538
1539+ from sqlalchemy .engine import Engine
15371540 from sqlalchemy .sql import text
15381541
15391542 table_name = f"group_{ uuid .uuid4 ().hex } "
@@ -2464,6 +2467,8 @@ def test_read_sql_delegate(conn, request):
24642467
24652468def test_not_reflect_all_tables (sqlite_conn ):
24662469 conn = sqlite_conn
2470+ from sqlalchemy import text
2471+ from sqlalchemy .engine import Engine
24672472
24682473 # create invalid table
24692474 query_list = [
@@ -2607,6 +2612,7 @@ def test_query_by_text_obj(conn, request):
26072612 # WIP : GH10846
26082613 conn_name = conn
26092614 conn = request .getfixturevalue (conn )
2615+ from sqlalchemy import text
26102616
26112617 if "postgres" in conn_name :
26122618 name_text = text ('select * from iris where "Name"=:name' )
@@ -3273,6 +3279,9 @@ def test_get_schema_create_table(conn, request, test_frame3):
32733279
32743280 conn = request .getfixturevalue (conn )
32753281
3282+ from sqlalchemy import text
3283+ from sqlalchemy .engine import Engine
3284+
32763285 tbl = "test_get_schema_create_table"
32773286 create_sql = sql .get_schema (test_frame3 , tbl , con = conn )
32783287 blank_test_df = test_frame3 .iloc [:0 ]
@@ -3425,6 +3434,7 @@ def test_connectable_issue_example(conn, request):
34253434
34263435 # This tests the example raised in issue
34273436 # https://github.com/pandas-dev/pandas/issues/10104
3437+ from sqlalchemy .engine import Engine
34283438
34293439 def test_select (connection ):
34303440 query = "SELECT test_foo_data FROM test_foo_data"
0 commit comments