import connection

def getConn():
    c = connection.conn()
    return c

def closeConnection(connection,cursor):
    if connection:
        cursor.close()
        connection.close()
    #     print("POstgres connection closed successfully")
    # print("Connection was closed before")



# Insert a ticket if not exsists
def insertTicket(fid, ticket):
    connection = getConn()
    cursor = connection.cursor()

    postgres_insert_query = """ INSERT INTO tickets (fid, ticket) VALUES (%s,%s)"""
    record_to_insert = (fid, ticket)
    cursor.execute(postgres_insert_query, record_to_insert)

    connection.commit()
    count = cursor.rowcount
    if count <1:
        closeConnection(connection,cursor)
        return False
    print(count, "Record inserted successfully into ticket table")


    closeConnection(connection,cursor)
    return True


def getTicketsByTid(tid):
    connection = getConn()
    cursor = connection.cursor()

    postgreSQL_select_Query = """select * from tickets join filters on tickets.fid  = filters.fid where filters.tid = %s order by filters.tid"""
    record_to_insert = (tid,)
    cursor.execute(postgreSQL_select_Query, record_to_insert)
    publisher_records = cursor.fetchall()
 
    closeConnection(connection,cursor)
    return publisher_records

# Returns all the ticket by filter id and ticket
def getTickets(fid, ticket):
    connection = getConn()
    cursor = connection.cursor()

    postgreSQL_select_Query = """select * from tickets where tickets.fid = %s and tickets.ticket = %s"""
    record_to_insert = (fid, ticket)
    cursor.execute(postgreSQL_select_Query, record_to_insert)
    publisher_records = cursor.fetchall()
 
    closeConnection(connection,cursor)
    return publisher_records


def getTicketForTid(tid, ticket):
    connection = getConn()
    cursor = connection.cursor()

    postgreSQL_select_Query = """
        select tickets.*
        from tickets
        join filters on tickets.fid = filters.fid
        where filters.tid = %s and tickets.ticket = %s
        limit 1
    """
    record_to_insert = (tid, ticket)
    cursor.execute(postgreSQL_select_Query, record_to_insert)
    publisher_records = cursor.fetchall()

    closeConnection(connection,cursor)
    return publisher_records



# print(getTicketsByTid(145645559))