diff --git a/tests/integration/dbapi/async/test_queries_async.py b/tests/integration/dbapi/async/test_queries_async.py index 90c1b665e9d..3fd749a7ad9 100644 --- a/tests/integration/dbapi/async/test_queries_async.py +++ b/tests/integration/dbapi/async/test_queries_async.py @@ -195,20 +195,13 @@ async def test_long_query( assert len(data) == 360, "Invalid data size returned by fetchall" -async def test_drop_create( - connection: Connection, create_drop_description: List[Column] -) -> None: +async def test_drop_create(connection: Connection) -> None: """Create and drop table/index queries are handled properly.""" async def test_query(c: Cursor, query: str) -> None: - assert await c.execute(query) == 1, "Invalid row count returned" - assert c.rowcount == 1, "Invalid rowcount value" - assert_deep_eq( - c.description, - create_drop_description, - "Invalid create table query description", - ) - assert len(await c.fetchall()) == 1, "Invalid data returned" + await c.execute(query) + assert c.description == None + assert c.rowcount == -1 """Create table query is handled properly""" with connection.cursor() as c: diff --git a/tests/integration/dbapi/sync/test_queries.py b/tests/integration/dbapi/sync/test_queries.py index a409dea4729..8af7f781984 100644 --- a/tests/integration/dbapi/sync/test_queries.py +++ b/tests/integration/dbapi/sync/test_queries.py @@ -146,20 +146,13 @@ def test_long_query( assert len(data) == 360, "Invalid data size returned by fetchall" -def test_drop_create( - connection: Connection, create_drop_description: List[Column] -) -> None: +def test_drop_create(connection: Connection) -> None: """Create and drop table/index queries are handled properly.""" def test_query(c: Cursor, query: str) -> None: - assert c.execute(query) == 1, "Invalid row count returned" - assert c.rowcount == 1, "Invalid rowcount value" - assert_deep_eq( - c.description, - create_drop_description, - "Invalid create table query description", - ) - assert len(c.fetchall()) == 1, "Invalid data returned" + c.execute(query) + assert c.description == None + assert c.rowcount == -1 """Create table query is handled properly""" with connection.cursor() as c: