Method Create

pkg/storage/driver/sql.go:467–576

Create creates a new release.

(key string, rel release.Releaser)

// Create creates a new release.
func (s *SQL) Create(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
	}

	transaction, err := s.db.Beginx()
	if err != nil {
		s.Logger().Debug("failed to start SQL transaction", slog.Any("error", err))
		return fmt.Errorf("error beginning transaction: %v", err)
	}

	insertQuery, args, err := s.statementBuilder.
		Insert(sqlReleaseTableName).
		Columns(
			sqlReleaseTableKeyColumn,
			sqlReleaseTableTypeColumn,
			sqlReleaseTableBodyColumn,
			sqlReleaseTableNameColumn,
			sqlReleaseTableNamespaceColumn,
			sqlReleaseTableVersionColumn,
			sqlReleaseTableStatusColumn,
			sqlReleaseTableOwnerColumn,
			sqlReleaseTableCreatedAtColumn,
		).
		Values(
			key,
			sqlReleaseDefaultType,
			body,
			rls.Name,
			namespace,
			int(rls.Version),
			rls.Info.Status.String(),
			sqlReleaseDefaultOwner,
			int(time.Now().Unix()),
		).ToSql()
	if err != nil {
		s.Logger().Debug("failed to build insert query", slog.Any("error", err))
		return err
	}

	if _, err := transaction.Exec(insertQuery, args...); err != nil {
		defer transaction.Rollback()

		selectQuery, args, buildErr := s.statementBuilder.
			Select(sqlReleaseTableKeyColumn).