raw_update.py

import os
import time


def test_raw_update(n=100000):
    init_sqlalchemy(False)
    t0 = time.time()
    f = open('customers_to_insert', 'w')
    for i in xrange(1, n+1):
        f.write(
            "{0},{1}\n".format(
                i, 'NEW_NAME ' + str(i)
            )
        )
    f.close()
    os.system(
        './raw_update_script.sh \
        {file_name} {table_name} {db_name} {username} {password}'.format(
            file_name  = 'customers_to_insert',
            table_name = 'customer',
            db_name    = 'example',
            username   = 'example',
            password   = 'example_password'
        )
    )
    os.remove('./customers_to_insert')
    print(
        "mysql raw update: Total time for " + str(n) +
        " records " + str(time.time() - t0) + " sec")