collection.py 文件源码

def __executefile(self, filepath):
        if self.dry_run:
            info("[DRY-RUN] Executing {}".format(filepath))
            return
        schema_path = os.path.join(os.path.dirname(sys.argv[0]), filepath)
        with open(schema_path, "r") as s:
            with self.pg.cursor(cursor_factory=NamedTupleCursor) as cursor:
                cursor.execute(s.read())