diff --git a/db/influxdb.go b/db/influxdb.go index 37e7118..6d063df 100644 --- a/db/influxdb.go +++ b/db/influxdb.go @@ -127,7 +127,8 @@ func (ad *InfluxDBAdapter) Save(channels []core.Channel) error { err = ad.client.Write(initContext, []byte(sb.String())) if err != nil { - panic(err) + return err } + return nil } diff --git a/db/sqlite3.go b/db/sqlite3.go index 32ba75f..e2a62c8 100644 --- a/db/sqlite3.go +++ b/db/sqlite3.go @@ -4,7 +4,6 @@ import ( "database/sql" "errors" "fmt" - "log" "sync" "th7/data/config" @@ -83,7 +82,7 @@ func (ad *SQLite3Adapter) Save(channels []core.Channel) error { _, err = statement.Exec(id, thermo, gain, offset, value, timestamp) if err != nil { - log.Fatalln(err.Error()) + return err } fmt.Printf("[%s] SQLite3 log: id=%d, type=%s, gain=%.2f, offset=%.2f, value=%.2f\n", timestamp, id, thermo, gain, offset, value)