func ExecDb()

in database/Database.go [79:97]


func ExecDb(ctx context.Context, db *sql.DB, query string, args ...interface{}) (sql.Result, error) {
	logger := ctxlogger.GetLogger(ctx)
	logger.Info("Executing query to db.")
	result, err := db.ExecContext(ctx, query, args...)
	if err != nil {
		log.Info("Error executing query: " + query + ". With error: " + err.Error())
		return nil, err
	}

	if rows, err := result.RowsAffected(); rows == 0 {
		log.Error("No rows were affected!")
		return nil, errors.New("No rows were affected!")
	} else if err != nil {
		log.Error("Error checking the number of affected rows.")
		return nil, err
	}

	return result, nil
}