@classmethod
async def create(cls, connection) -> 'AddressManagerStore':
    self = cls()
    self.db = connection
    (await self.db.commit())
    (await self.db.execute('CREATE TABLE IF NOT EXISTS peer_metadata(key text,value text)'))
    (await self.db.commit())
    (await self.db.execute('CREATE TABLE IF NOT EXISTS peer_nodes(node_id int,value text)'))
    (await self.db.commit())
    (await self.db.execute('CREATE TABLE IF NOT EXISTS peer_new_table(node_id int,bucket int)'))
    (await self.db.commit())
    return self
@classmethod
async def create(cls, connection) -> 'AddressManagerStore':
    self = cls()
    self.db = connection
    (await self.db.commit())
    (await self.db.execute('CREATE TABLE IF NOT EXISTS peer_metadata(key text,value text)'))
    (await self.db.commit())
    (await self.db.execute('CREATE TABLE IF NOT EXISTS peer_nodes(node_id int,value text)'))
    (await self.db.commit())
    (await self.db.execute('CREATE TABLE IF NOT EXISTS peer_new_table(node_id int,bucket int)'))
    (await self.db.commit())
    return self