diff --git a/plugins/inputs/postgresql_extensible/postgresql_extensible.go b/plugins/inputs/postgresql_extensible/postgresql_extensible.go index a247b603a..c2bcb7b60 100644 --- a/plugins/inputs/postgresql_extensible/postgresql_extensible.go +++ b/plugins/inputs/postgresql_extensible/postgresql_extensible.go @@ -121,7 +121,7 @@ func (p *Postgresql) Gather(acc telegraf.Accumulator) error { ) // Retreiving the database version - query = `select substring(setting from 1 for 3) as version from pg_settings where name='server_version_num'` + query = `SELECT setting::integer / 100 AS version FROM pg_settings WHERE name = 'server_version_num'` if err = p.DB.QueryRow(query).Scan(&db_version); err != nil { db_version = 0 }