def query_each(cursor, sql, param=()):
    cursor.execute(sql, param)
    while True:
        fetch = cursor.fetchone()
        if fetch is None:
            break
        yield fetch