def save_orders_data()

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


def save_orders_data(csv_data, cursor, connection):
    orders = []
    count = 1
    for row in csv_data:
        if count > 1 and len(row) >= 8:
            row2 = row[2]
            row2d = dateutil.parser.parse(row2).date()
            row3 = row[3]
            row3d = ''
            if row3.lower() == 'null':
                row3d = None
            else:
                row3d = dateutil.parser.parse(row3).date()
            row1 = row[1]
            row1d = ''
            if row1.lower() == 'null':
                row1d = None
            else:
                row1d = dateutil.parser.parse(row1).date()
            data = {'ordernumber': row[0], 'orderdate': row1d, 'requireddate': row2d, 'shippeddate': row3d,
                    'status': row[4], 'comments': row[5], 'customernumber': row[6], 'current_year': row[7]}
            orders.append(data)
            logger.info('Order Date ..+++++++++' + row[1])
        else:
            count = count + 1
    query = """ insert into orders(ordernumber,orderdate,requireddate,shippeddate,status,comments,customernumber,current_year) values (%(ordernumber)s,%(orderdate)s,%(requireddate)s,%(shippeddate)s,%(status)s,%(comments)s,%(customernumber)s,%(current_year)s) """
    cursor.executemany(query, orders)
    connection.commit()