Skip to content

Commit

Permalink
test: removed join index queries (#343)
Browse files Browse the repository at this point in the history
  • Loading branch information
stepansergeevitch authored Jan 30, 2024
1 parent 872c393 commit 33de2c7
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 44 deletions.
11 changes: 0 additions & 11 deletions tests/integration/dbapi/async/V1/test_queries_async.py
Original file line number Diff line number Diff line change
Expand Up @@ -200,7 +200,6 @@ async def test_query(c: Cursor, query: str) -> None:
"""Create table query is handled properly"""
with connection.cursor() as c:
# Cleanup
await c.execute("DROP JOIN INDEX IF EXISTS test_drop_create_async_db_join_idx")
await c.execute(
"DROP AGGREGATING INDEX IF EXISTS test_drop_create_async_db_agg_idx"
)
Expand All @@ -221,23 +220,13 @@ async def test_query(c: Cursor, query: str) -> None:
", f float, d date, dt datetime, b bool, a array(int))",
)

# Create join index
await test_query(
c,
"CREATE JOIN INDEX test_db_join_idx ON "
"test_drop_create_async_dim(id, sn, f)",
)

# Create aggregating index
await test_query(
c,
"CREATE AGGREGATING INDEX test_db_agg_idx ON "
"test_drop_create_async(id, sum(f), count(dt))",
)

# Drop join index
await test_query(c, "DROP JOIN INDEX test_db_join_idx")

# Drop aggregating index
await test_query(c, "DROP AGGREGATING INDEX test_db_agg_idx")

Expand Down
11 changes: 0 additions & 11 deletions tests/integration/dbapi/async/V2/test_queries_async.py
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,6 @@ async def test_query(c: Cursor, query: str) -> None:
"""Create table query is handled properly"""
with connection.cursor() as c:
# Cleanup
await c.execute("DROP JOIN INDEX IF EXISTS test_db_join_idx")
await c.execute("DROP AGGREGATING INDEX IF EXISTS test_db_agg_idx")
await c.execute("DROP TABLE IF EXISTS test_drop_create_async")
await c.execute("DROP TABLE IF EXISTS test_drop_create_async_dim")
Expand All @@ -148,23 +147,13 @@ async def test_query(c: Cursor, query: str) -> None:
", f float, d date, dt datetime, b bool, a array(int))",
)

# Create join index
await test_query(
c,
"CREATE JOIN INDEX test_db_join_idx ON "
"test_drop_create_async_dim(id, sn, f)",
)

# Create aggregating index
await test_query(
c,
"CREATE AGGREGATING INDEX test_db_agg_idx ON "
"test_drop_create_async(id, sum(f), count(dt))",
)

# Drop join index
await test_query(c, "DROP JOIN INDEX test_db_join_idx")

# Drop aggregating index
await test_query(c, "DROP AGGREGATING INDEX test_db_agg_idx")

Expand Down
11 changes: 0 additions & 11 deletions tests/integration/dbapi/sync/V1/test_queries.py
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,6 @@ def test_query(c: Cursor, query: str) -> None:
"""Create table query is handled properly"""
with connection.cursor() as c:
# Cleanup
c.execute("DROP JOIN INDEX IF EXISTS test_drop_create_db_join_idx")
c.execute("DROP AGGREGATING INDEX IF EXISTS test_drop_create_db_agg_idx")
c.execute("DROP TABLE IF EXISTS test_drop_create_tb")
c.execute("DROP TABLE IF EXISTS test_drop_create_tb_dim")
Expand All @@ -169,23 +168,13 @@ def test_query(c: Cursor, query: str) -> None:
", f float, d date, dt datetime, b bool, a array(int))",
)

# Create join index
test_query(
c,
"CREATE JOIN INDEX test_drop_create_db_join_idx ON "
"test_drop_create_tb_dim(id, sn, f)",
)

# Create aggregating index
test_query(
c,
"CREATE AGGREGATING INDEX test_drop_create_db_agg_idx ON "
"test_drop_create_tb(id, sum(f), count(dt))",
)

# Drop join index
test_query(c, "DROP JOIN INDEX test_drop_create_db_join_idx")

# Drop aggregating index
test_query(c, "DROP AGGREGATING INDEX test_drop_create_db_agg_idx")

Expand Down
11 changes: 0 additions & 11 deletions tests/integration/dbapi/sync/V2/test_queries.py
Original file line number Diff line number Diff line change
Expand Up @@ -135,7 +135,6 @@ def test_query(c: Cursor, query: str) -> None:
"""Create table query is handled properly"""
with connection.cursor() as c:
# Cleanup
c.execute("DROP JOIN INDEX IF EXISTS test_drop_create_db_join_idx")
c.execute("DROP AGGREGATING INDEX IF EXISTS test_drop_create_db_agg_idx")
c.execute("DROP TABLE IF EXISTS test_drop_create_tb")
c.execute("DROP TABLE IF EXISTS test_drop_create_tb_dim")
Expand All @@ -154,23 +153,13 @@ def test_query(c: Cursor, query: str) -> None:
", f float, d date, dt datetime, b bool, a array(int))",
)

# Create join index
test_query(
c,
"CREATE JOIN INDEX test_drop_create_db_join_idx ON "
"test_drop_create_tb_dim(id, sn, f)",
)

# Create aggregating index
test_query(
c,
"CREATE AGGREGATING INDEX test_drop_create_db_agg_idx ON "
"test_drop_create_tb(id, sum(f), count(dt))",
)

# Drop join index
test_query(c, "DROP JOIN INDEX test_drop_create_db_join_idx")

# Drop aggregating index
test_query(c, "DROP AGGREGATING INDEX test_drop_create_db_agg_idx")

Expand Down

0 comments on commit 33de2c7

Please sign in to comment.