Skip to content

Commit 7f51700

Browse files
committed
Fix issue when querying with the connection pool
1 parent f09380e commit 7f51700

File tree

1 file changed

+3
-12
lines changed

1 file changed

+3
-12
lines changed

pool.go

Lines changed: 3 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -157,12 +157,9 @@ func (p *Pool) Exec(q Query) error {
157157

158158
if c.isBad() {
159159
pc.MarkUnusable()
160-
break
161160
}
162161

163-
if err == nil {
164-
break
165-
}
162+
break
166163
}
167164

168165
return err
@@ -186,11 +183,9 @@ func (p *Pool) Query(q Query) (*Cursor, error) {
186183

187184
if err == nil {
188185
cursor.releaseConn = releaseConn(c, pc)
189-
190-
break
191186
}
192187

193-
pc.Close()
188+
break
194189
}
195190

196191
return cursor, err
@@ -209,18 +204,14 @@ func (p *Pool) Server() (ServerResponse, error) {
209204
if err != nil {
210205
break
211206
}
212-
defer pc.Close()
213207

214208
response, err = c.Server()
215209

216210
if c.isBad() {
217211
pc.MarkUnusable()
218-
break
219212
}
220213

221-
if err == nil {
222-
break
223-
}
214+
break
224215
}
225216

226217
return response, err

0 commit comments

Comments
 (0)