kamikazechaser/cic-internal-integration
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Refactors to row by row update.

Browse Source
This commit is contained in:
PhilipWafula 2021-04-26 13:09:23 +03:00
parent f544e80b31
commit 3ae9b3e4eb
Signed by untrusted user: mango-habanero
GPG Key ID: B00CE9034DA19FB7
1 changed files with 8 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
apps/contract-migration/scripts/cic_ussd/import_task.py
View File

@ -93,7 +93,6 @@ def resolve_phone(self, phone):
def generate_metadata(self, address, phone):
old_address = old_address_from_phone(self.import_dir, phone)
logg.debug('>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> foo')
logg.debug('address {}'.format(address))
old_address_upper = strip_0x(old_address).upper()
metadata_path = '{}/old/{}/{}/{}.json'.format(
@ -232,13 +231,15 @@ def set_pins(config: dict, phone_to_pins: list):
)
db_cursor = db_conn.cursor()
# batch updates
extras.execute_values(db_cursor,
'UPDATE account \
SET password_hash = update_data.password_hash \
FROM (VALUES %s) AS update_data (phone, password_hash) \
WHERE phone_number = update_data.phone', phone_to_pins)
# update db
for element in phone_to_pins:
sql = f'UPDATE account SET password_hash = %s WHERE phone_number = %s'
db_cursor.execute(sql, (element[1], element[0]))
logg.debug(f'Updating: {element[0]} with: {element[1]}')
# commit changes
db_conn.commit()
# close connections
db_cursor.close()
db_conn.close()