##########################################################
def logToDb(e):
    global dbConnectionPool
    conn = dbConnectionPool.get_connection()
    #conn = MySQLdb.connect(pogiCore.dbServer,pogiCore.dbLogin,pogiCore.dbPassword,pogiCore.dbName)
    cursor = conn.cursor()

    historyId = str(uuid.uuid4())

    sql = "INSERT INTO history (historyId,sessionId,reader,antenna,tag,state,eventDate,recieved,rssi,weight,retVal,xmitDate,zone) VALUES(%s,%s,%s, %s, %s,%s, %s,NOW(), %s, %s, %s, %s,(SELECT zone_name FROM zone_mux WHERE reader = %s AND antenna = %s  ))"

    #print e.xmitDate

    sEd = e.eventDate #.strftime('%Y-%m-%d %H:%M:%S')
    #sEr = str(e.recieved.strftime('%Y-%m-%d %H:%M:%S'))
    #p.apply_async(cursor.execute, args=(sql, [historyId, e.sessionId, e.reader, e.antenna, e.tag, e.state, sEd, e.rssi, e.weight, e.retVal, e.xmitDate,  e.reader, e.antenna]))
    cursor.execute(sql, [historyId, e.sessionId, e.reader, e.antenna, e.tag, e.state, sEd, e.rssi, e.weight, e.retVal, e.xmitDate,  e.reader, e.antenna])

    # update state
    sql = "INSERT INTO state (tag_id,zone,state,update_date) SELECT VALUES WHERE NOT EXISTS (SELECT 1 FROM state WHERE tag_id = %s ) VALUES(%s,(SELECT zone_name FROM zone_mux WHERE reader = %s AND antenna = %s),%s,NOW())"
    cursor.execute(sql, [e.tag,e.tag,e.reader,e.antenna,e.state])

    conn.commit()
    conn.close()