p17860254
/
categraf
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

bugfix: use sql.RawBytes instead of string for mysql row parser

This commit is contained in:
Ulric Qin 2022-04-27 17:35:30 +08:00
parent 28ddaabccb
commit 7f9e81eada
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
inputs/mysql/custom_queries.go
View File

@ -3,7 +3,6 @@ package mysql
import (
"context"
"database/sql"
"fmt"
"log"
"strings"
"sync"
@ -52,7 +51,7 @@ func (m *MySQL) gatherOneQuery(slist *list.SafeList, ins *Instance, db *sql.DB,
}
for rows.Next() {
columns := make([]interface{}, len(cols))
columns := make([]sql.RawBytes, len(cols))
columnPointers := make([]interface{}, len(cols))
for i := range columns {
columnPointers[i] = &columns[i]
@ -66,8 +65,8 @@ func (m *MySQL) gatherOneQuery(slist *list.SafeList, ins *Instance, db *sql.DB,
row := make(map[string]string)
for i, colName := range cols {
val := columnPointers[i].(*interface{})
row[strings.ToLower(colName)] = fmt.Sprint(*val)
val := columnPointers[i].(*sql.RawBytes)
row[strings.ToLower(colName)] = string(*val)
}
if err = m.parseRow(row, query, slist, globalTags); err != nil {