import mysql.connector as mysql   
import time

def connect_db(host,user,password,db):
    connection = None
    try:
        connection = mysql.connect(
            host= host,
            user= user,
            passwd= password,
            database = db
            )
        
        print("connection success")
    except Exception as e:
        print(f'Error {e} occured')    
    return connection

def execute_query(connection,query):
    cursor = connection.cursor()
    result = None
    try:
        print(cursor.execute(query))  
        connection.commit()
        result = cursor.fetchall()
        return result
    except Exception as e:
        print(f'Error {e} occured')
        
def updateCrawlerStatus(host,user,password,db,crawler_id,dev_owner,update_user, scheduled_time, scheduled_timezone, active_flag,crawler_name):
    print("here")
    connection = connect_db(
            host = host,
            user = user,
            password = password,
            db = db
            )
    last_update_time = time.strftime("%Y-%m-%d %H:%M:%S", time.gmtime())

    query = f'''update v3_algocred_crawler 
            set dev_owner = "{dev_owner}" ,
            update_user = "{update_user}", 
            last_update_time = "{last_update_time}",
            scheduled_time = "{scheduled_time}", 
            schedued_timezone = "{scheduled_timezone}",
            active_flag = "{active_flag}" 
            where id={crawler_id};'''
    execute_query(connection,query)
    query = f'''insert into v3_algocred_crawler_history values ({crawler_id},"{crawler_name}","{scheduled_time}","{last_update_time}");'''
    execute_query(connection,query)