mirror
/
moonstream
kopia lustrzana https://github.com/bugout-dev/moonstream
1
0
Forkuj 0
Kod Zgłoszenia Projekty Wydania Wiki Aktywność

Removed offset for labels checksum address migration

pull/349/head
kompotkot 2021-11-02 15:00:07 +00:00
rodzic 05f9234ed4
commit 30b918a7ca
1 zmienionych plików z 1 dodań i 5 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

6
backend/moonstream/admin/migrations/checksum_address.py
Wyświetl plik

@ -59,16 +59,13 @@ def checksum_all_labels_addresses(db_session: Session, web3: Web3) -> None:
Docs for SQLAlchemy mapping: Docs for SQLAlchemy mapping:
https://docs.sqlalchemy.org/en/14/orm/session_api.html#sqlalchemy.orm.Session.bulk_update_mappings https://docs.sqlalchemy.org/en/14/orm/session_api.html#sqlalchemy.orm.Session.bulk_update_mappings
""" """
query_limit = 30 query_limit = 500
query_index = 0
while True: while True:
query = ( query = (
db_session.query(EthereumLabel.id, EthereumLabel.address) db_session.query(EthereumLabel.id, EthereumLabel.address)
.filter(EthereumLabel.address == func.lower(EthereumLabel.address)) .filter(EthereumLabel.address == func.lower(EthereumLabel.address))
.order_by(EthereumLabel.address)
.limit(query_limit) .limit(query_limit)
.offset(query_index * query_limit)
) )
address_list = query.all() address_list = query.all()
address_list_len = len(address_list) address_list_len = len(address_list)
@ -87,4 +84,3 @@ def checksum_all_labels_addresses(db_session: Session, web3: Web3) -> None:
db_session.commit() db_session.commit()
mappings[:] = [] mappings[:] = []
query_index += 1