orm.py 文件源码

def fetchone(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)
    try:
        cur.execute(query+" LIMIT 1", params)
    except ProgrammingError as e:
        print("incorrectly formulated model definition :\n{0}".format(e))
        sys.exit(1)
    line = cur.fetchone()
    line = dict(line) if line else None
    cur.close()
    return line