database/sql: add test for Conn.Validator interface

This addresses comments made by Russ after
https://golang.org/cl/174122 was merged. It addes a test
for the connection validator and renames the interface to just
"Validator".

Change-Id: Iea53e9b250c9be2e86e9b75906e7353e26437c5c
Reviewed-on: https://go-review.googlesource.com/c/go/+/223963
Reviewed-by: Emmanuel Odeke <emm.odeke@gmail.com>
This commit is contained in:
Daniel Theophanes 2020-03-18 10:03:51 -07:00
parent 2ba00e4754
commit 5aef51a729
4 changed files with 39 additions and 8 deletions

View file

@ -261,15 +261,15 @@ type SessionResetter interface {
ResetSession(ctx context.Context) error ResetSession(ctx context.Context) error
} }
// ConnectionValidator may be implemented by Conn to allow drivers to // Validator may be implemented by Conn to allow drivers to
// signal if a connection is valid or if it should be discarded. // signal if a connection is valid or if it should be discarded.
// //
// If implemented, drivers may return the underlying error from queries, // If implemented, drivers may return the underlying error from queries,
// even if the connection should be discarded by the connection pool. // even if the connection should be discarded by the connection pool.
type ConnectionValidator interface { type Validator interface {
// ValidConnection is called prior to placing the connection into the // IsValid is called prior to placing the connection into the
// connection pool. The connection will be discarded if false is returned. // connection pool. The connection will be discarded if false is returned.
ValidConnection() bool IsValid() bool
} }
// Result is the result of a query execution. // Result is the result of a query execution.

View file

@ -396,9 +396,9 @@ func (c *fakeConn) ResetSession(ctx context.Context) error {
return nil return nil
} }
var _ driver.ConnectionValidator = (*fakeConn)(nil) var _ driver.Validator = (*fakeConn)(nil)
func (c *fakeConn) ValidConnection() bool { func (c *fakeConn) IsValid() bool {
return !c.isBad() return !c.isBad()
} }

View file

@ -512,8 +512,8 @@ func (dc *driverConn) validateConnection(needsReset bool) bool {
if needsReset { if needsReset {
dc.needReset = true dc.needReset = true
} }
if cv, ok := dc.ci.(driver.ConnectionValidator); ok { if cv, ok := dc.ci.(driver.Validator); ok {
return cv.ValidConnection() return cv.IsValid()
} }
return true return true
} }

View file

@ -1543,6 +1543,37 @@ func TestConnTx(t *testing.T) {
} }
} }
// TestConnIsValid verifies that a database connection that should be discarded,
// is actually discarded and does not re-enter the connection pool.
// If the IsValid method from *fakeConn is removed, this test will fail.
func TestConnIsValid(t *testing.T) {
db := newTestDB(t, "people")
defer closeDB(t, db)
db.SetMaxOpenConns(1)
ctx := context.Background()
c, err := db.Conn(ctx)
if err != nil {
t.Fatal(err)
}
err = c.Raw(func(raw interface{}) error {
dc := raw.(*fakeConn)
dc.stickyBad = true
return nil
})
if err != nil {
t.Fatal(err)
}
c.Close()
if len(db.freeConn) > 0 && db.freeConn[0].ci.(*fakeConn).stickyBad {
t.Fatal("bad connection returned to pool; expected bad connection to be discarded")
}
}
// Tests fix for issue 2542, that we release a lock when querying on // Tests fix for issue 2542, that we release a lock when querying on
// a closed connection. // a closed connection.
func TestIssue2542Deadlock(t *testing.T) { func TestIssue2542Deadlock(t *testing.T) {