diff options
| author | Brad Fitzpatrick <bradfitz@golang.org> | 2013-03-25 16:50:27 -0700 |
|---|---|---|
| committer | Brad Fitzpatrick <bradfitz@golang.org> | 2013-03-25 16:50:27 -0700 |
| commit | 209f6b1d2ca84541505c29c6158cde9d5a0bbd57 (patch) | |
| tree | bfd6a94040ee537004c6a23bb64843b51008253d /src/pkg/database/sql/sql_test.go | |
| parent | f20f8b8b0a4236c7438c830261a5860cbd9efe80 (diff) | |
| download | go-209f6b1d2ca84541505c29c6158cde9d5a0bbd57.tar.xz | |
database/sql: don't close a driver.Conn until its Stmts are closed
Fixes #5046
R=golang-dev, r
CC=golang-dev
https://golang.org/cl/8016044
Diffstat (limited to 'src/pkg/database/sql/sql_test.go')
| -rw-r--r-- | src/pkg/database/sql/sql_test.go | 54 |
1 files changed, 54 insertions, 0 deletions
diff --git a/src/pkg/database/sql/sql_test.go b/src/pkg/database/sql/sql_test.go index 2a9592e104..54aad3a5d0 100644 --- a/src/pkg/database/sql/sql_test.go +++ b/src/pkg/database/sql/sql_test.go @@ -65,6 +65,12 @@ func closeDB(t *testing.T, db *DB) { fmt.Printf("Panic: %v\n", e) panic(e) } + defer setHookpostCloseConn(nil) + setHookpostCloseConn(func(_ *fakeConn, err error) { + if err != nil { + t.Errorf("Error closing fakeConn: %v", err) + } + }) err := db.Close() if err != nil { t.Fatalf("error closing DB: %v", err) @@ -790,3 +796,51 @@ func TestMaxIdleConns(t *testing.T) { t.Errorf("freeConns = %d; want 0", got) } } + +// golang.org/issue/5046 +func TestCloseConnBeforeStmts(t *testing.T) { + defer setHookpostCloseConn(nil) + setHookpostCloseConn(func(_ *fakeConn, err error) { + if err != nil { + t.Errorf("Error closing fakeConn: %v", err) + } + }) + + db := newTestDB(t, "people") + + stmt, err := db.Prepare("SELECT|people|name|") + if err != nil { + t.Fatal(err) + } + + if len(db.freeConn) != 1 { + t.Fatalf("expected 1 freeConn; got %d", len(db.freeConn)) + } + dc := db.freeConn[0] + if dc.closed { + t.Errorf("conn shouldn't be closed") + } + + err = db.Close() + if err != nil { + t.Errorf("db Close = %v", err) + } + if !dc.closed { + t.Errorf("after db.Close, driverConn should be closed") + } + if dc.ci == nil { + t.Errorf("after db.Close, driverConn should still have its Conn interface") + } + + err = stmt.Close() + if err != nil { + t.Errorf("Stmt close = %v", err) + } + + if !dc.closed { + t.Errorf("conn should be closed") + } + if dc.ci != nil { + t.Errorf("after Stmt Close, driverConn's Conn interface should be nil") + } +} |
