collection.py 文件源码

def __fetch(self, fetch_all, sql=None, mf=MusicFilter(), cursor_factory=NamedTupleCursor):
        if sql is None:
            sql = '''select * from do_filter(%s::filter)'''
        if mf is None:
            mf = MusicFilter()
        if cursor_factory is None:
            cursor_factory = NamedTupleCursor
        arg = [mf.tuple()]
        with self.pg.cursor(cursor_factory=cursor_factory) as cursor:
            debug('Query: {}'.format(cursor.mogrify(sql, arg)))
            with benchmark("Fetching:"):
                cursor.execute(sql, arg)
                if fetch_all:
                    s = cursor.fetchall()
                else:
                    s = cursor.fetchone()
            # debug(s)
            return s