OrgGo/Mainflux.mainflux
1
0
Fork 0
mirror of https://github.com/mainflux/mainflux.git synced 2025-04-29 13:49:28 +08:00
Code Issues Projects Releases Wiki Activity

NOISSUE - Move invariant statements out of loop for cassandra-writer (#1596)

Browse Source 
Signed-off-by: fuzhy <fuzhy1997@outlook.com>
This commit is contained in:
fuzhy 2022-04-26 14:57:02 +08:00 committed by GitHub
parent 92d8fb99bf
commit 188778710f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
consumers/writers/cassandra/consumer.go
View File

@ -75,13 +75,13 @@ func (cr *cassandraRepository) saveJSON(msgs mfjson.Messages) error {
} }
func (cr *cassandraRepository) insertJSON(msgs mfjson.Messages) error { func (cr *cassandraRepository) insertJSON(msgs mfjson.Messages) error {
cql := `INSERT INTO %s (id, channel, created, subtopic, publisher, protocol, payload) VALUES (?, ?, ?, ?, ?, ?, ?)`
cql = fmt.Sprintf(cql, msgs.Format)
for _, msg := range msgs.Data { for _, msg := range msgs.Data {
pld, err := json.Marshal(msg.Payload) pld, err := json.Marshal(msg.Payload)
if err != nil { if err != nil {
return err return err
} }
cql := `INSERT INTO %s (id, channel, created, subtopic, publisher, protocol, payload) VALUES (?, ?, ?, ?, ?, ?, ?)`
cql = fmt.Sprintf(cql, msgs.Format)
id := gocql.TimeUUID() id := gocql.TimeUUID()
err = cr.session.Query(cql, id, msg.Channel, msg.Created, msg.Subtopic, msg.Publisher, msg.Protocol, string(pld)).Exec() err = cr.session.Query(cql, id, msg.Channel, msg.Created, msg.Subtopic, msg.Publisher, msg.Protocol, string(pld)).Exec()