From fe8593b9a1803ed44c20f2f7cda6c6e56101b4d8 Mon Sep 17 00:00:00 2001
From: Thomas Menard <menardorama@gmail.com>
Date: Thu, 17 Mar 2016 15:01:08 +0100
Subject: [PATCH] Remove the columns used as tag

---
 .../inputs/postgresql_extensible/postgresql_extensible.go | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/plugins/inputs/postgresql_extensible/postgresql_extensible.go b/plugins/inputs/postgresql_extensible/postgresql_extensible.go
index 44c452e0b..67097db4b 100644
--- a/plugins/inputs/postgresql_extensible/postgresql_extensible.go
+++ b/plugins/inputs/postgresql_extensible/postgresql_extensible.go
@@ -241,14 +241,16 @@ func (p *Postgresql) accRow(row scanner, acc telegraf.Accumulator) error {
 	tags := map[string]string{}
 	tags["server"] = tagAddress
 	tags["db"] = dbname.String()
-
+	var isATag int
 	fields := make(map[string]interface{})
 	for col, val := range columnMap {
 		_, ignore := ignoredColumns[col]
 		//if !ignore && *val != "" {
 		if !ignore {
+			isATag = 0
 			for tag := range p.AdditionalTags {
 				if col == p.AdditionalTags[tag] {
+					isATag = 1
 					value_type_p := fmt.Sprintf(`%T`, *val)
 					if value_type_p == "[]uint8" {
 						tags[col] = fmt.Sprintf(`%s`, *val)
@@ -257,7 +259,9 @@ func (p *Postgresql) accRow(row scanner, acc telegraf.Accumulator) error {
 					}
 				}
 			}
-			fields[col] = *val
+			if isATag == 0 {
+				fields[col] = *val
+			}
 		}
 	}
 	acc.AddFields("postgresql", fields, tags)