RanchiMall/pyflo
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connector

Browse Source
This commit is contained in:
4tochka 2019-05-03 14:12:41 +04:00
parent e3be178c41
commit 5a7f3ce35c
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pybtc/connector.py
View File

@ -785,9 +785,11 @@ class UTXO():
# insert to db # insert to db
async with self._db_pool.acquire() as conn: async with self._db_pool.acquire() as conn:
async with conn.transaction(): async with conn.transaction():
await conn.execute("DELETE FROM connector_utxo WHERE " if r:
"outpoint = ANY($1);", r) await conn.execute("DELETE FROM connector_utxo WHERE "
await conn.copy_records_to_table('connector_utxo', columns=["outpoint", "data"], records=rs) "outpoint = ANY($1);", r)
if rs:
await conn.copy_records_to_table('connector_utxo', columns=["outpoint", "data"], records=rs)
if lb: if lb:
await conn.execute("UPDATE connector_utxo_state SET value = $1 " await conn.execute("UPDATE connector_utxo_state SET value = $1 "
"WHERE name = 'last_block';", lb) "WHERE name = 'last_block';", lb)