db_connect_warp.py 文件源码

def require_db_connection(f):
    @wraps(f)
    def decorated_function(*args, **kwargs):
        ####?????
        if hasattr(g, 'conn') and g.conn != None and hasattr(g, 'cursor') and g.cursor != None:
            print 'has db connect, do nothing'
        else:
            (g.conn, g.cursor) = _connect_db()
            print 'create new db connect'

        #????
        func = f(*args, **kwargs)

        ###???????
        if hasattr(g, 'conn') and g.conn != None and hasattr(g, 'cursor') and g.cursor != None:
            g.cursor.close()
            g.cursor = None 
            g.conn.close()
            g.conn = None
            print 'close db connect'
        else:
            print 'no db connect, no need to close...'

        return func
    return decorated_function