database.py 文件源码

def __init__(self, engine_cls, instance, *args, **kwargs):
        """
        Initiate database.

        :param engine_cls: Engine class
        :param instance: Instance of the app.
        :param args: *
        :param kwargs: **
        :type instance: pyplanet.core.instance.Instance
        """
        self.engine = engine_cls(*args, **kwargs)
        self.instance = instance
        self.migrator = Migrator(self.instance, self)
        self.registry = Registry(self.instance, self)
        self.objects = peewee_async.Manager(self.engine, loop=self.instance.loop)

        # Don't allow any sync code.
        if hasattr(self.engine, 'allow_sync'):
            self.engine.allow_sync = False

        Proxy.initialize(self.engine)