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:
            cur = await conn.cursor()
            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"

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:
            cur = await conn.cursor()
            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"

from aiopg.sa import create_engine

async def test_engine():
    engine = await create_engine()
    conn = await engine.acquire()
    await conn.execute("sql")  # $ MISSING: getSql="sql" constructedSql="sql"

test `aiopg.sa`