2015-03-23 03:14:00 +08:00
|
|
|
package sqlstore
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
|
"github.com/grafana/grafana/pkg/bus"
|
|
|
|
|
m "github.com/grafana/grafana/pkg/models"
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
func init() {
|
|
|
|
|
bus.AddHandler("sql", GetSystemStats)
|
2015-09-29 19:47:56 +08:00
|
|
|
bus.AddHandler("sql", GetDataSourceStats)
|
2016-01-25 13:18:17 +08:00
|
|
|
bus.AddHandler("sql", GetAdminStats)
|
2015-09-29 19:47:56 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func GetDataSourceStats(query *m.GetDataSourceStatsQuery) error {
|
|
|
|
|
var rawSql = `SELECT COUNT(*) as count, type FROM data_source GROUP BY type`
|
|
|
|
|
query.Result = make([]*m.DataSourceStats, 0)
|
|
|
|
|
err := x.Sql(rawSql).Find(&query.Result)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return err
|
2015-03-23 03:14:00 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func GetSystemStats(query *m.GetSystemStatsQuery) error {
|
|
|
|
|
var rawSql = `SELECT
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("user") + `
|
|
|
|
|
) AS user_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("org") + `
|
|
|
|
|
) AS org_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("dashboard") + `
|
2016-01-26 04:39:04 +08:00
|
|
|
) AS dashboard_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("playlist") + `
|
|
|
|
|
) AS playlist_count
|
2015-03-23 03:14:00 +08:00
|
|
|
`
|
|
|
|
|
|
|
|
|
|
var stats m.SystemStats
|
|
|
|
|
_, err := x.Sql(rawSql).Get(&stats)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
query.Result = &stats
|
|
|
|
|
return err
|
|
|
|
|
}
|
2016-01-25 03:01:33 +08:00
|
|
|
|
|
|
|
|
func GetAdminStats(query *m.GetAdminStatsQuery) error {
|
2016-01-25 13:18:17 +08:00
|
|
|
var rawSql = `SELECT
|
2016-01-25 03:01:33 +08:00
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("user") + `
|
|
|
|
|
) AS user_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("org") + `
|
|
|
|
|
) AS org_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("dashboard") + `
|
|
|
|
|
) AS dashboard_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("dashboard_snapshot") + `
|
|
|
|
|
) AS db_snapshot_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("dashboard_tag") + `
|
|
|
|
|
) AS db_tag_count,
|
|
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("data_source") + `
|
2016-01-25 13:18:17 +08:00
|
|
|
) AS data_source_count,
|
2016-01-25 03:01:33 +08:00
|
|
|
(
|
|
|
|
|
SELECT COUNT(*)
|
|
|
|
|
FROM ` + dialect.Quote("playlist") + `
|
|
|
|
|
) AS playlist_count,
|
|
|
|
|
(
|
2016-01-25 13:18:17 +08:00
|
|
|
SELECT COUNT (DISTINCT ` + dialect.Quote("dashboard_id") + ` )
|
2016-01-25 03:01:33 +08:00
|
|
|
FROM ` + dialect.Quote("star") + `
|
2016-01-25 16:39:31 +08:00
|
|
|
) AS starred_db_count,
|
|
|
|
|
(
|
2016-01-26 06:30:36 +08:00
|
|
|
SELECT COUNT(*)
|
2016-01-25 16:39:31 +08:00
|
|
|
FROM ` + dialect.Quote("user") + `
|
2016-01-26 06:30:36 +08:00
|
|
|
WHERE ` + dialect.Quote("is_admin") + ` = 1
|
2016-01-25 16:39:31 +08:00
|
|
|
) AS grafana_admin_count
|
2016-01-25 03:01:33 +08:00
|
|
|
`
|
|
|
|
|
|
2016-01-25 13:18:17 +08:00
|
|
|
var stats m.AdminStats
|
|
|
|
|
_, err := x.Sql(rawSql).Get(&stats)
|
|
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
2016-01-25 03:01:33 +08:00
|
|
|
|
2016-01-25 13:18:17 +08:00
|
|
|
query.Result = &stats
|
|
|
|
|
return err
|
2016-01-25 03:01:33 +08:00
|
|
|
}
|