1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
// SPDX-License-Identifier: GPL-3.0-or-later
package mysql
import (
"strings"
)
const queryShowUserStatistics = "SHOW USER_STATISTICS;"
func (m *MySQL) collectUserStatistics(mx map[string]int64) error {
// https://mariadb.com/kb/en/user-statistics/
// https://mariadb.com/kb/en/information-schema-user_statistics-table/
q := queryShowUserStatistics
m.Debugf("executing query: '%s'", q)
var user, prefix string
_, err := m.collectQuery(q, func(column, value string, _ bool) {
switch column {
case "User":
user = value
prefix = "userstats_" + user + "_"
if !m.collectedUsers[user] {
m.collectedUsers[user] = true
m.addUserStatisticsCharts(user)
}
case "Cpu_time":
mx[strings.ToLower(prefix+column)] = int64(parseFloat(value) * 1000)
case
"Total_connections",
"Lost_connections",
"Denied_connections",
"Empty_queries",
"Binlog_bytes_written",
"Rows_read",
"Rows_sent",
"Rows_deleted",
"Rows_inserted",
"Rows_updated",
"Rows_fetched", // Percona
"Select_commands",
"Update_commands",
"Other_commands",
"Access_denied",
"Commit_transactions",
"Rollback_transactions":
mx[strings.ToLower(prefix+column)] = parseInt(value)
}
})
return err
}
|
