Module utils 

Functions

create_base_tables 🔒

Create the tables defined in testdata, along with some mviews. TODO: Generate indexes and sinks.

create_mviews 🔒

Create the tables defined in testdata, along with some mviews. TODO: Generate indexes and sinks.

drop_mview_table 🔒

Drops mview tables.

drop_tables 🔒

Drops mview tables and seed tables. Queries the system catalog to find all existing MVs (catching any that were created server-side after a client-side timeout). Drops leaf MVs (those with no dependents) each iteration without CASCADE, so genuine dependency bugs surface as real errors rather than being silently swallowed.

format_drop_mview 🔒

generate_rng 🔒

get_seed_table_sql 🔒

populate_tables 🔒

run_query 🔒

run_query_inner 🔒

Run query, handle permissible errors For recovery error, just do bounded retry. For other errors, validate them accordingly, skipping if they are permitted. Otherwise just return success. If takes too long return the query which timed out + execution time + timeout error Returns: Number of skipped queries, number of rows returned.

set_variable 🔒

test_batch_queries 🔒

Test batch queries, returns skipped query statistics Runs in distributed mode, since queries can be complex and cause overflow in local execution mode.

test_population_count 🔒

Expects at least 50% of inserted rows included.

test_session_variable 🔒

test_sqlsmith 🔒

Sanity checks for sqlsmith

test_stream_queries 🔒

Test stream queries, returns skipped query statistics

update_base_tables 🔒

validate_response 🔒

Validate client responses, returning a count of skipped queries, number of result rows.

Type Aliases

PgResult 🔒

Result 🔒