#89 #93 rollback: reset block buffers and close connection

ClickHouse · Mar 5, 2018 · 204d131 · 204d131
1 parent d6c12a4
commit 204d131
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/clickhouse.go b/clickhouse.go
@@ -154,9 +154,13 @@ func (ch *clickhouse) Rollback() error {
 	if !ch.inTransaction {
 		return sql.ErrTxDone
 	}
+	if ch.block != nil {
+		ch.block.Reset()
+	}
 	ch.block = nil
+	ch.buffer = nil
 	ch.inTransaction = false
-	return nil
+	return ch.conn.Close()
 }
 
 func (ch *clickhouse) CheckNamedValue(nv *driver.NamedValue) error {