forked from LBRYCommunity/lbry-sdk
move db.commit()
This commit is contained in:
parent
2b73d3d109
commit
0b8c67f2f0
1 changed files with 2 additions and 1 deletions
|
@ -273,6 +273,7 @@ class BaseDatabase(SQLiteMixin):
|
||||||
}))
|
}))
|
||||||
|
|
||||||
await self._set_address_history(address, history)
|
await self._set_address_history(address, history)
|
||||||
|
await self.db.commit()
|
||||||
|
|
||||||
async def reserve_outputs(self, txos, is_reserved=True):
|
async def reserve_outputs(self, txos, is_reserved=True):
|
||||||
txoids = [txo.id for txo in txos]
|
txoids = [txo.id for txo in txos]
|
||||||
|
@ -460,7 +461,7 @@ class BaseDatabase(SQLiteMixin):
|
||||||
"UPDATE pubkey_address SET history = ?, used_times = ? WHERE address = ?",
|
"UPDATE pubkey_address SET history = ?, used_times = ? WHERE address = ?",
|
||||||
(history, history.count(':')//2, address)
|
(history, history.count(':')//2, address)
|
||||||
)
|
)
|
||||||
await self.db.commit()
|
|
||||||
|
|
||||||
async def set_address_history(self, address, history):
|
async def set_address_history(self, address, history):
|
||||||
await self._set_address_history(address, history)
|
await self._set_address_history(address, history)
|
||||||
|
await self.db.commit()
|
||||||
|
|
Loading…
Add table
Reference in a new issue