db_convert.py 文件源码

def handle(self, *args, **options):
        if options['source_db_password'] is None:
            options['source_db_password'] = getpass('Database Password: ')

        instance = Controller.prepare(options['pool']).instance
        converter = get_converter(
            options['source_format'], instance=instance, db_name=options['source_db_name'],
            db_type=options['source_db_type'], db_user=options['source_db_username'],
            db_port=options['source_db_port'], db_password=options['source_db_password'],
            db_host=options['source_db_host'], prefix=options['source_db_prefix']
        )

        instance.loop.run_until_complete(self.convert(instance, converter))