orm.py 文件源码

def fetch(conn, query, params=[]):
    if conn[TYPE] == 'postgresql':
        cur = conn[CONN].cursor(cursor_factory=postgresql_extras.DictCursor)
    if conn[TYPE] == 'mysql':
        cur = conn[CONN].cursor(mysql.cursors.DictCursor)
    cur.execute(query, params)
    while True:
        line = cur.fetchone()
        if not line: break
        yield dict(line)
    cur.close()