old_contents: import aiopg
  
  # Only a cursor can execute sql.
  async def test_cursor():
      # Create connection directly
      conn = await aiopg.connect()
      cur = await conn.cursor()
      await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
      # Create connection via pool
      async with aiopg.create_pool() as pool:
          # Create Cursor via Connection
          async with pool.acquire() as conn:
              async with conn.cursor() as cur:
                  await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
          # Create Cursor directly
          async with pool.cursor() as cur:
              await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
      # variants using as few `async with` as possible
      pool = await aiopg.create_pool()
      conn = pool.acquire()
      cur = await conn.cursor()
      await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
  # Test SQLAlchemy integration
  from aiopg.sa import create_engine
  
  async def test_engine():
      engine = await create_engine()
      conn = await engine.acquire()
      await conn.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
new_contents: import aiopg
  
  # Only a cursor can execute sql.
  async def test_cursor():
      # Create connection directly
      conn = await aiopg.connect()
      cur = await conn.cursor()
      await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
      # Create connection via pool
      async with aiopg.create_pool() as pool:
          # Create Cursor via Connection
          async with pool.acquire() as conn:
              async with conn.cursor() as cur:
                  await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
          # Create Cursor directly
          async with pool.cursor() as cur:
              await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
      # variants using as few `async with` as possible
      pool = await aiopg.create_pool()
      conn = await pool.acquire()
      cur = await conn.cursor()
      await cur.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
  # Test SQLAlchemy integration
  from aiopg.sa import create_engine
  
  async def test_engine():
      engine = await create_engine()
      conn = await engine.acquire()
      await conn.execute("sql")  # $ getSql="sql" constructedSql="sql"
  
subject: Fix test