generate_data.py 文件源码

def prepare_tables(pg):
    tables = [db.post, db.tag, db.comment]
    await delete_tables(pg, tables)
    async with pg.acquire() as conn:
        for table in tables:
            create_expr = CreateTable(table)
            await conn.execute(create_expr)