Method Delete

pkg/storage/driver/sql.go:622–692

Delete deletes a release or returns ErrReleaseNotFound.

(key string)

// Delete deletes a release or returns ErrReleaseNotFound.
func (s *SQL) Delete(key string) (release.Releaser, error) {
	transaction, err := s.db.Beginx()
	if err != nil {
		s.Logger().Debug("failed to start SQL transaction", slog.Any("error", err))
		return nil, fmt.Errorf("error beginning transaction: %v", err)
	}

	selectQuery, args, err := s.statementBuilder.
		Select(sqlReleaseTableBodyColumn).
		From(sqlReleaseTableName).
		Where(sq.Eq{sqlReleaseTableKeyColumn: key}).
		Where(sq.Eq{sqlReleaseTableNamespaceColumn: s.namespace}).
		ToSql()
	if err != nil {
		s.Logger().Debug("failed to build select query", slog.Any("error", err))
		return nil, err
	}

	var record SQLReleaseWrapper
	err = transaction.Get(&record, selectQuery, args...)
	if err != nil {
		s.Logger().Debug("release not found", slog.String("key", key), slog.Any("error", err))
		return nil, ErrReleaseNotFound
	}

	release, err := decodeRelease(record.Body)
	if err != nil {
		s.Logger().Debug("failed to decode release", slog.String("key", key), slog.Any("error", err))
		transaction.Rollback()
		return nil, err
	}
	defer transaction.Commit()

	deleteQuery, args, err := s.statementBuilder.
		Delete(sqlReleaseTableName).
		Where(sq.Eq{sqlReleaseTableKeyColumn: key}).
		Where(sq.Eq{sqlReleaseTableNamespaceColumn: s.namespace}).
		ToSql()
	if err != nil {
		s.Logger().Debug("failed to build delete query", slog.Any("error", err))
		return nil, err
	}

	_, err = transaction.Exec(deleteQuery, args...)
	if err != nil {
		s.Logger().Debug("failed perform delete query", slog.Any("error", err))
		return release, err
	}

	if release.Labels, err = s.getReleaseCustomLabels(key, s.namespace); err != nil {
		s.Logger().Debug(
			"failed to get release custom labels",
			slog.String("namespace", s.namespace),
			slog.String("key", key),
			slog.Any("error", err))
		return nil, err
	}