update table structure

oemdaro · oemdaro · commit f573266415b3 · 2018-02-04T00:42:05.000+07:00
diff --git a/data-service/workque/worker.go b/data-service/workque/worker.go
@@ -5,8 +5,6 @@ import (
 	"log"
 	"sync"
 	"time"
-
-	"github.com/gocql/gocql"
 )
 
 var quit = make(chan *sync.WaitGroup, 1)
@@ -73,8 +71,8 @@ func (j *Job) InsertIntoDB() error {
 		return err
 	}
 
-	if err := j.DB.Query(`INSERT INTO data (id, username, temperature, humidity, timestamp) VALUES (?, ?, ?, ?, ?)`,
-		gocql.TimeUUID(), j.Message.Key, data.Temperature, data.Humidity, time.Now()).Exec(); err != nil {
+	if err := j.DB.Query(`INSERT INTO data (station_id, temperature, humidity, event_time) VALUES (?, ?, ?, ?)`,
+		"123abc", data.Temperature, data.Humidity, time.Now()).Exec(); err != nil {
 		return err
 	}
 	log.Println("work done")

Original file line number	Diff line number	Diff line change
`@@ -5,8 +5,6 @@ import (`
`5`	`5`	`"log"`
`6`	`6`	`"sync"`
`7`	`7`	`"time"`
`8`		`-`
`9`		`- "github.com/gocql/gocql"`
`10`	`8`	`)`
`11`	`9`
`12`	`10`	`var quit = make(chan *sync.WaitGroup, 1)`
`@@ -73,8 +71,8 @@ func (j *Job) InsertIntoDB() error {`
`73`	`71`	`return err`
`74`	`72`	`}`
`75`	`73`
`76`		- if err := j.DB.Query(`INSERT INTO data (id, username, temperature, humidity, timestamp) VALUES (?, ?, ?, ?, ?)`,
`77`		`- gocql.TimeUUID(), j.Message.Key, data.Temperature, data.Humidity, time.Now()).Exec(); err != nil {`
	`74`	+ if err := j.DB.Query(`INSERT INTO data (station_id, temperature, humidity, event_time) VALUES (?, ?, ?, ?)`,
	`75`	`+ "123abc", data.Temperature, data.Humidity, time.Now()).Exec(); err != nil {`
`78`	`76`	`return err`
`79`	`77`	`}`
`80`	`78`	`log.Println("work done")`