diff --git a/sqlx-runner/exec.go b/sqlx-runner/exec.go index 54f1194..ac8ffd7 100644 --- a/sqlx-runner/exec.go +++ b/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 } diff --git a/sqlx-runner/queryable.go b/sqlx-runner/queryable.go index 4db2025..b61849a 100644 --- a/sqlx-runner/queryable.go +++ b/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