log SQL on Exec error

Author: Mario L Gutierrez

sqlx-runner/exec.go

@@ -60,9 +60,9 @@ func logExecutionTime(start time.Time, sql string, args []interface{}) {
 		elapsed := time.Since(start)
 		if LogQueriesThreshold > 0 && elapsed.Nanoseconds() > LogQueriesThreshold.Nanoseconds() {
 			if len(args) > 0 {
-				logger.Warn("SLOW query time", "elapsed", fmt.Sprintf("%s", elapsed), "sql", sql, "args", toOutputStr(args))
+				logger.Warn("SLOW query", "elapsed", fmt.Sprintf("%s", elapsed), "sql", sql, "args", toOutputStr(args))
 			} else {
-				logger.Warn("SLOW query time", "elapsed", fmt.Sprintf("%s", elapsed), "sql", sql)
+				logger.Warn("SLOW query", "elapsed", fmt.Sprintf("%s", elapsed), "sql", sql)
 			}
 			logged = true
 		}

sqlx-runner/queryable.go

@@ -48,7 +48,7 @@ func (q *Queryable) Exec(cmd string, args ...interface{}) (*dat.Result, error) {
 		result, err = q.runner.Exec(cmd, args...)
 	}
 	if err != nil {
-		return nil, err
+		return nil, logSQLError(err, "Exec", cmd, args)
 	}
 	rowsAffected, err := result.RowsAffected()
 	return &dat.Result{RowsAffected: rowsAffected}, nil
@@ -66,7 +66,10 @@ func (q *Queryable) ExecBuilder(b dat.Builder) error {
 	} else {
 		_, err = q.runner.Exec(sql, args...)
 	}
-	return err
+	if err != nil {
+		return logSQLError(err, "ExecBuilder", sql, args)
+	}
+	return nil
 }
 
 // ExecMulti executes multiple SQL statements returning the number of