From 77a94353be60978080512fb7f5ff4d8042108886 Mon Sep 17 00:00:00 2001 From: Evan Langlais Date: Mon, 29 Apr 2019 15:04:02 -0400 Subject: [PATCH] Implementing different query gen, with more debug outputs --- gateway.go | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/gateway.go b/gateway.go index f2974f0..eac69fb 100644 --- a/gateway.go +++ b/gateway.go @@ -216,14 +216,18 @@ func (ws *socketConn) handleStatus(updates Packet) { table = "generator_statuses" } + var query = "" + if value == 0 { - if _, err := dbConn.Exec("DELETE FROM `sd5-state`.$1 WHERE gen_id = $2 AND status_code = '$3'", table, generatorId, statusCode); err != nil { - fmt.Printf("Error removing status/fault: %v\n", err) - } + query = fmt.Sprintf("DELETE FROM `sd5-state`.%s WHERE gen_id = %d AND status_code = '%s'", table, generatorId, statusCode) } else { - if _, err := dbConn.Exec("INSERT INTO `sd5-state`.$1 (gen_id, status_code) VALUES ($2, $3) ON DUPLICATE KEY UPDATE gen_id = VALUES(gen_id), status_code = VALUES(status_code)", table, generatorId, statusCode); err != nil { - fmt.Printf("Error setting status/fault: %v\n", err) - } + query = fmt.Sprintf("INSERT INTO `sd5-state`.%s (gen_id, status_code) VALUES (%d, %s) ON DUPLICATE KEY UPDATE gen_id = VALUES(gen_id), status_code = VALUES(status_code)", table, generatorId, statusCode) + } + + fmt.Println(query) + + if _, err := dbConn.Exec(query); err != nil { + fmt.Printf("Error processing statuses/faults: %v\n", err) } var metricData = avro.NewMetricData()