From e162a0bbcb014a056e05aaa73ea4af900e5f77df Mon Sep 17 00:00:00 2001
From: Jack Christensen <jack@jackchristensen.com>
Date: Sat, 13 Jul 2013 09:04:38 -0400
Subject: [PATCH] Update tx status on ready for query message

---
 connection.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/connection.go b/connection.go
index 0b03f50c..addb4e7b 100644
--- a/connection.go
+++ b/connection.go
@@ -99,6 +99,7 @@ func Connect(parameters ConnectionParameters) (c *Connection, err error) {
 					return nil, err
 				}
 			case readyForQuery:
+				c.rxReadyForQuery(r)
 				return c, nil
 			default:
 				if err = c.processContextFreeMsg(t, r); err != nil {
@@ -132,6 +133,7 @@ func (c *Connection) SelectFunc(sql string, onDataRow func(*DataRowReader) error
 		if t, r, rxErr := c.rxMsg(); rxErr == nil {
 			switch t {
 			case readyForQuery:
+				c.rxReadyForQuery(r)
 				return
 			case rowDescription:
 				fields = c.rxRowDescription(r)
@@ -268,6 +270,7 @@ func (c *Connection) Prepare(name, sql string) (err error) {
 					}
 				}
 			case readyForQuery:
+				c.rxReadyForQuery(r)
 				c.preparedStatements[name] = &ps
 				return
 			default:
@@ -394,6 +397,7 @@ func (c *Connection) Execute(sql string, arguments ...interface{}) (commandTag s
 		if t, r, rxErr := c.rxMsg(); rxErr == nil {
 			switch t {
 			case readyForQuery:
+				c.rxReadyForQuery(r)
 				return
 			case rowDescription:
 			case dataRow: