#!/usr/bin/env python3
import mysql.connector
import csv
import os
source = os.path.join('source_files', 'aws_bills', 'test_data.csv')
def main():
    # See which headers are available
    mydb = mysql.connector.connect(user='xxxx', password='xxxxx',
                                host='xxxxx',
                                database='aws_bill')
    cursor = mydb.cursor()
    try:
        with open(source) as csv_file:
            csv_reader = csv.reader(csv_file, delimiter=',')
            sql = "INSERT INTO billing_info (InvoiceId) VALUES (%s)"
            for row in csv_reader:
                row = (', '.join(row))
                print(row)
                #cursor.execute(sql, (row[0],))
    except:
        mydb.rollback()
    finally:
        mydb.close()

if __name__ == "__main__":
    main()