Skip to content

Commit dea7f05

Browse files
Update query_utxo for db-sync 13.6.0.5
`utxo_view` was dropped in release 13.6.0.5 of cardano-db-sync
1 parent d292a77 commit dea7f05

File tree

1 file changed

+10
-7
lines changed

1 file changed

+10
-7
lines changed

cardano_node_tests/utils/dbsync_queries.py

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -984,13 +984,16 @@ def query_utxo(address: str) -> tp.Generator[UTxODBRow, None, None]:
984984
"""Query UTxOs for payment address in db-sync."""
985985
query = (
986986
"SELECT"
987-
" tx.hash, utxo_view.index, utxo_view.address, stake_address.view,"
988-
" utxo_view.address_has_script, utxo_view.value, utxo_view.data_hash "
989-
"FROM utxo_view "
990-
"INNER JOIN tx ON utxo_view.tx_id = tx.id "
991-
"LEFT JOIN stake_address ON utxo_view.stake_address_id = stake_address.id "
992-
"WHERE utxo_view.address = %s "
993-
"ORDER BY utxo_view.id;"
987+
" tx.hash, tx_out.index, tx_out.address, stake_address.view AS stake_address,"
988+
" tx_out.address_has_script, tx_out.value, tx_out.data_hash "
989+
"FROM tx_out "
990+
"INNER JOIN tx ON tx_out.tx_id = tx.id "
991+
"LEFT JOIN stake_address ON tx_out.stake_address_id = stake_address.id "
992+
"LEFT JOIN tx_in "
993+
"ON tx_out.tx_id = tx_in.tx_out_id AND tx_out.index = tx_in.tx_out_index "
994+
"WHERE tx_in.tx_out_id IS NULL " # Only unspent UTXOs
995+
"AND tx_out.address = %s "
996+
"ORDER BY tx_out.id;"
994997
)
995998

996999
with execute(query=query, vars=(address,)) as cur:

0 commit comments

Comments
 (0)