aboutsummaryrefslogtreecommitdiff
path: root/src/pkg/database/sql/sql.go
diff options
context:
space:
mode:
authorBrad Fitzpatrick <bradfitz@golang.org>2013-08-13 14:56:40 -0700
committerBrad Fitzpatrick <bradfitz@golang.org>2013-08-13 14:56:40 -0700
commitca3ed9f3520de7998dcc009eca8d35eefec55412 (patch)
tree23309e7cfddb8e549e099c71461c933907b9345e /src/pkg/database/sql/sql.go
parentc7d352c9412de57ac5c9f5d7895540336ebaab5c (diff)
downloadgo-ca3ed9f3520de7998dcc009eca8d35eefec55412.tar.xz
database/sql: add a disabled broken test
Update #6081 R=golang-dev, gri CC=golang-dev https://golang.org/cl/12810043
Diffstat (limited to 'src/pkg/database/sql/sql.go')
-rw-r--r--src/pkg/database/sql/sql.go5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/pkg/database/sql/sql.go b/src/pkg/database/sql/sql.go
index 35d5338c56..352a7e82d9 100644
--- a/src/pkg/database/sql/sql.go
+++ b/src/pkg/database/sql/sql.go
@@ -1372,6 +1372,8 @@ func (rs *Rows) Scan(dest ...interface{}) error {
return nil
}
+var rowsCloseHook func(*Rows, *error)
+
// Close closes the Rows, preventing further enumeration. If the
// end is encountered, the Rows are closed automatically. Close
// is idempotent.
@@ -1381,6 +1383,9 @@ func (rs *Rows) Close() error {
}
rs.closed = true
err := rs.rowsi.Close()
+ if fn := rowsCloseHook; fn != nil {
+ fn(rs, &err)
+ }
if rs.closeStmt != nil {
rs.closeStmt.Close()
}