def initialize_database(self, database_fn=''):
        if database_fn:
            database_fn = os.path.join(self.dispersy.working_directory, database_fn)
        self.data_manager = BlockchainDataManager(database_fn)
        self.data_manager.initialize()