import mysql.connector

cnx = mysql.connector.connect(user='rt_bot', password='mp.work.',
                                      host='tripnomicsdb.cloudapp.net',
                                      database='Alternatefare')
cnx.autocommit = True
cursor = cnx.cursor()

cursor.execute("SELECT PNR FROM meta.toShow WHERE toShow = '0' ")

rows = cursor.fetchall()

pnrsToProcess = [str(x[0]) for x in rows]
pnrsToProcessString = ",".join(pnrsToProcess)

for pnr in pnrsToProcess:
    cursor.execute("""
    SELECT CONCAT("UPDATE meta.itineraryPlaces SET Int_Dom ='",SUM(IF(UPPER(Int_Dom) <> 'DOMESTIC',1,0)),"' WHERE PNR='",PNR,"' AND TktNumber='",TktNumber,"';") FROM PNR_Trigger.PNR_Ticket_Details WHERE Customer = 'Viacom' AND PNR='"""+pnr+"""'   GROUP BY PNR,TktNumber
    """)
    rows = cursor.fetchall()
    for row in rows:
        cursor.execute(str(row[0]))
    
    cursor.execute("""
    SELECT CONCAT("UPDATE meta.itineraryPlaces SET ClassOfBooking ='",Cabin_Class,"' WHERE PNR='",PNR,"' AND TktNumber='",TktNumber,"';") FROM PNR_Trigger.PNR_Ticket_Details WHERE PNR = '"""+pnr+"""' GROUP BY PNR,TktNumber
    """)
    rows = cursor.fetchall()
    for row in rows:
        cursor.execute(str(row[0]))