Ensure Query and Insert occur in a single txn.
diff --git a/listener.go b/listener.go index d397171..451fe07 100644 --- a/listener.go +++ b/listener.go
@@ -63,12 +63,12 @@ var numApidClusters int tx, err := db.Begin() if err != nil { - log.Panicf("Unable to open DB txn: %v", err) + log.Panicf("Unable to open DB txn: {%v}", err.Error()) } err = tx.QueryRow("SELECT COUNT(*) FROM edgex_apid_cluster").Scan(&numApidClusters) if err != nil { - log.Panicf("Unable to read database: %s", err.Error()) + log.Panicf("Unable to read database: {%s}", err.Error()) } if numApidClusters != 1 { @@ -81,13 +81,13 @@ tx.Rollback() return } else { - log.Panicf("Unable to create last_sequence column on DB. Unrecoverable error ", err) + log.Panicf("Unable to create last_sequence column on DB. Error {%v}", err.Error()) } } _, err = prep.Exec() if err != nil { - log.Debugf("Snapshot processing DB exec failed. Err: %v", err) + log.Errorf("Snapshot processing DB exec failed. Err: {%v}", err) prep.Close() tx.Rollback() return