From 5a7f3ce35c21e1a48aa7abcea4345bf65e082ece Mon Sep 17 00:00:00 2001 From: 4tochka Date: Fri, 3 May 2019 14:12:41 +0400 Subject: [PATCH] connector --- pybtc/connector.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/pybtc/connector.py b/pybtc/connector.py index 5b50e6a..7a50938 100644 --- a/pybtc/connector.py +++ b/pybtc/connector.py @@ -785,9 +785,11 @@ class UTXO(): # insert to db async with self._db_pool.acquire() as conn: async with conn.transaction(): - await conn.execute("DELETE FROM connector_utxo WHERE " - "outpoint = ANY($1);", r) - await conn.copy_records_to_table('connector_utxo', columns=["outpoint", "data"], records=rs) + if r: + await conn.execute("DELETE FROM connector_utxo WHERE " + "outpoint = ANY($1);", r) + if rs: + await conn.copy_records_to_table('connector_utxo', columns=["outpoint", "data"], records=rs) if lb: await conn.execute("UPDATE connector_utxo_state SET value = $1 " "WHERE name = 'last_block';", lb)