def save_customers_data()

in functions/source/bootstrap_redshift/bootstrap_redshift.py [0:0]


def save_customers_data(csv_data, cursor, connection):
    customers = []
    count = 1
    for row in csv_data:
        if count > 1 and len(row) >= 13:
            if row[11].lower() == 'null' or row[11] == '':
                row[11] = None
            data = {'customernumber': row[0], 'customername': row[1], \
                    'contactlastname': row[2], \
                    'contactfirstname': row[3], \
                    'phone': row[4], 'addressline1': row[5], 'addressline2': row[6], 'city': row[7], 'state': row[8],
                    'postalcode': row[9], 'country': row[10], 'salesrepemployeenumber': row[11], 'creditlimit': row[12]}
            customers.append(data)
        else:
            count = count + 1
    query = """ insert into customers(customernumber,customername,contactlastname,contactfirstname,phone,addressline1,addressline2,city,state,postalcode,country,salesrepemployeenumber,creditlimit)
               values (%(customernumber)s,%(customername)s,%(contactlastname)s,%(contactfirstname)s,%(phone)s,%(addressline1)s,%(addressline2)s,%(city)s,%(state)s,%(postalcode)s,%(country)s,%(salesrepemployeenumber)s,%(creditlimit)s)  """
    cursor.executemany(query, customers)
    connection.commit()