Skip to content

Commit 38f30ca

Browse files
committed
Fixed failing test
1 parent b713d74 commit 38f30ca

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

connection.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,8 @@ func (c *Connection) Query(q Query) (*Response, *Cursor, error) {
110110
// Add token if query is a START/NOREPLY_WAIT
111111
if q.Type == p.Query_START || q.Type == p.Query_NOREPLY_WAIT || q.Type == p.Query_SERVER_INFO {
112112
q.Token = c.nextToken()
113+
}
114+
if q.Type == p.Query_START || q.Type == p.Query_NOREPLY_WAIT {
113115
if c.opts.Database != "" {
114116
var err error
115117
q.Opts["db"], err = DB(c.opts.Database).build()

0 commit comments

Comments
 (0)