diff --git a/db.go b/db.go index 2fc0ffd3c..9ec70da4d 100644 --- a/db.go +++ b/db.go @@ -788,7 +788,9 @@ func WithReadOnlyReplica(dbs ...*sql.DB) ReadWriteConnResolverOption { } func (r *ReadWriteConnResolver) Close() error { - r.closed.Store(true) + if r.closed.Swap(true) { + return nil + } var firstErr error for _, db := range r.replicas {