Fix time logging for QueryEx

fixes #341
2017-10-28 13:05:46 -05:00
parent 0d3b378440
commit 2b4558fe22
1 changed files with 1 additions and 2 deletions
@@ -367,6 +367,7 @@ type QueryExOptions struct {
 }

 func (c *Conn) QueryEx(ctx context.Context, sql string, options *QueryExOptions, args ...interface{}) (rows *Rows, err error) {
+	c.lastActivityTime = time.Now()
 	rows = c.getRows(sql, args)

 	err = c.waitForPreviousCancelQuery(ctx)
@@ -380,8 +381,6 @@ func (c *Conn) QueryEx(ctx context.Context, sql string, options *QueryExOptions,
 		return rows, err
 	}

-	c.lastActivityTime = time.Now()
-
 	if err := c.lock(); err != nil {
 		rows.fatal(err)
 		return rows, err