Replce query with SQL_INSERT_DATA

laudio · Nov 25, 2019 · 1a61ef2 · 1a61ef2
1 parent 061823e
commit 1a61ef2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/examples/data-transfer-pg/main.py b/examples/data-transfer-pg/main.py
@@ -98,7 +98,7 @@ def transfer_data(source_db_cursor, dest_db_cursor, dest_db_conn):
 
     print(f'Transferring users data to destination database.')
     for row in rows:
-        dest_db_cursor.execute('INSERT INTO users VALUES (?, ?, ?)', (row.id, row.name, row.city))
+        dest_db_cursor.execute(SQL_INSERT_DATA, (row.id, row.name, row.city))
     dest_db_conn.commit()
 
     print(f"Transferred {len(rows)} rows of users data from source database to destination database.")