from fixtures.log_helper import log
from fixtures.neon_fixtures import NeonEnv, check_restored_datadir_content


# Test subtransactions
#
# The pg_subxact SLRU is not preserved on restarts, and doesn't need to be
# maintained in the pageserver, so subtransactions are not very exciting for
# Neon. They are included in the commit record though and updated in the
# CLOG.
def test_subxacts(neon_simple_env: NeonEnv, test_output_dir):
    env = neon_simple_env
    env.neon_cli.create_branch("test_subxacts", "empty")
    endpoint = env.endpoints.create_start("test_subxacts")

    log.info("postgres is running on 'test_subxacts' branch")
    pg_conn = endpoint.connect()
    cur = pg_conn.cursor()

    cur.execute(
        """
        CREATE TABLE t1(i int, j int);
    """
    )

    cur.execute("select pg_switch_wal();")

    # Issue 100 transactions, with 1000 subtransactions in each.
    for i in range(100):
        cur.execute("begin")
        for j in range(1000):
            cur.execute(f"savepoint sp{j}")
            cur.execute(f"insert into t1 values ({i}, {j})")
        cur.execute("commit")

    check_restored_datadir_content(test_output_dir, env, endpoint)