Merge pull request #26 from WhiteEagle88/master

Fixed collection of RowBinary rows
nikepan · Mar 6, 2020 · 621adc9 · 621adc9
2 parents 1051982 + bdc8f95
commit 621adc9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/collector.go b/collector.go
@@ -61,7 +61,11 @@ func NewCollector(sender Sender, count int, interval int) (c *Collector) {
 
 // Content - get text content of rowsfor query
 func (t *Table) Content() string {
-	return t.Query + "\n" + strings.Join(t.Rows, "\n")
+	rowDelimiter := "\n"
+	if t.Format == "RowBinary" {
+		rowDelimiter = ""
+	}
+	return t.Query + "\n" + strings.Join(t.Rows, rowDelimiter)
 }
 
 // Flush - sends collected data in table to clickhouse