Method Update

pkg/storage/driver/sql.go:579–619

Update updates a release.

(key string, rel release.Releaser)

// Update updates a release.
func (s *SQL) Update(key string, rel release.Releaser) error {
	rls, err := releaserToV1Release(rel)
	if err != nil {
		return err
	}
	namespace := rls.Namespace
	if namespace == "" {
		namespace = defaultNamespace
	}
	s.namespace = namespace

	body, err := encodeRelease(rls)
	if err != nil {
		s.Logger().Debug("failed to encode release", slog.Any("error", err))
		return err
	}

	query, args, err := s.statementBuilder.
		Update(sqlReleaseTableName).
		Set(sqlReleaseTableBodyColumn, body).
		Set(sqlReleaseTableNameColumn, rls.Name).
		Set(sqlReleaseTableVersionColumn, int(rls.Version)).
		Set(sqlReleaseTableStatusColumn, rls.Info.Status.String()).
		Set(sqlReleaseTableOwnerColumn, sqlReleaseDefaultOwner).
		Set(sqlReleaseTableModifiedAtColumn, int(time.Now().Unix())).
		Where(sq.Eq{sqlReleaseTableKeyColumn: key}).
		Where(sq.Eq{sqlReleaseTableNamespaceColumn: namespace}).
		ToSql()

	if err != nil {
		s.Logger().Debug("failed to build update query", slog.Any("error", err))
		return err
	}

	if _, err := s.db.Exec(query, args...); err != nil {
		s.Logger().Debug("failed to update release in SQL database", slog.String("key", key), slog.Any("error", err))
		return err
	}

	return nil
}

// Delete deletes a release or returns ErrReleaseNotFound.
func (s *SQL) Delete(key string) (release.Releaser, error) {