Method CreateDatabaseDefault

backend/store/database.go:260–289

CreateDatabaseDefault creates a new database in the default project.

(ctx context.Context, create *DatabaseMessage)

// CreateDatabaseDefault creates a new database in the default project.
func (s *Store) CreateDatabaseDefault(ctx context.Context, create *DatabaseMessage) (*DatabaseMessage, error) {
	q := qb.Q().Space(`
		INSERT INTO db (
			instance,
			project,
			name,
			deleted
		)
		VALUES (?, ?, ?, ?)
		ON CONFLICT (instance, name) DO UPDATE SET
			deleted = EXCLUDED.deleted`,
		create.InstanceID,
		create.ProjectID,
		create.DatabaseName,
		false,
	)

	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	if _, err := s.GetDB().ExecContext(ctx, query, args...); err != nil {
		return nil, err
	}

	// Invalidate and update the cache.
	s.removeDatabaseCache(ctx, create.InstanceID, create.DatabaseName)
	return s.GetDatabase(ctx, &FindDatabaseMessage{InstanceID: &create.InstanceID, DatabaseName: &create.DatabaseName, ShowDeleted: true})
}

// UpsertDatabase upserts a database.
func (s *Store) UpsertDatabase(ctx context.Context, create *DatabaseMessage) (*DatabaseMessage, error) {