diff --git a/compose/internal/repository/chart.go b/compose/internal/repository/chart.go index cf8ebb413..38783c0aa 100644 --- a/compose/internal/repository/chart.go +++ b/compose/internal/repository/chart.go @@ -109,7 +109,7 @@ func (r chart) Create(mod *types.Chart) (*types.Chart, error) { func (r chart) Update(mod *types.Chart) (*types.Chart, error) { now := time.Now().Truncate(time.Second) mod.UpdatedAt = &now - return mod, r.db().Replace(r.table(), mod) + return mod, r.db().Update(r.table(), mod, "id") } func (r chart) DeleteByID(namespaceID, chartID uint64) error { diff --git a/compose/internal/repository/namespace.go b/compose/internal/repository/namespace.go index 48149f464..7eb3b3ee0 100644 --- a/compose/internal/repository/namespace.go +++ b/compose/internal/repository/namespace.go @@ -112,7 +112,7 @@ func (r *namespace) Update(mod *types.Namespace) (*types.Namespace, error) { now := time.Now() mod.UpdatedAt = &now - return mod, r.db().Replace(r.table(), mod) + return mod, r.db().Update(r.table(), mod, "id") } func (r *namespace) DeleteByID(namespaceID uint64) error { diff --git a/compose/internal/repository/page.go b/compose/internal/repository/page.go index 13579a027..83042a247 100644 --- a/compose/internal/repository/page.go +++ b/compose/internal/repository/page.go @@ -173,7 +173,7 @@ func (r page) Update(mod *types.Page) (*types.Page, error) { now := time.Now().Truncate(time.Second) mod.UpdatedAt = &now - return mod, r.db().Replace(r.table(), mod) + return mod, r.db().Update(r.table(), mod, "id") } func (r page) DeleteByID(namespaceID, pageID uint64) error { diff --git a/compose/internal/repository/record.go b/compose/internal/repository/record.go index f81743768..19bcc3501 100644 --- a/compose/internal/repository/record.go +++ b/compose/internal/repository/record.go @@ -260,7 +260,7 @@ func (r record) Create(record *types.Record) (*types.Record, error) { } func (r record) Update(record *types.Record) (*types.Record, error) { - if err := r.db().Replace("compose_record", record); err != nil { + if err := r.db().Update("compose_record", record, "id"); err != nil { return nil, errors.Wrap(err, "could not update record") } diff --git a/compose/internal/repository/trigger.go b/compose/internal/repository/trigger.go index 8abaffc25..35f29705f 100644 --- a/compose/internal/repository/trigger.go +++ b/compose/internal/repository/trigger.go @@ -110,7 +110,7 @@ func (r trigger) Create(mod *types.Trigger) (*types.Trigger, error) { func (r trigger) Update(mod *types.Trigger) (*types.Trigger, error) { now := time.Now().Truncate(time.Second) mod.UpdatedAt = &now - return mod, r.db().Replace(r.table(), mod) + return mod, r.db().Update(r.table(), mod, "id") } func (r trigger) DeleteByID(namespaceID, triggerID uint64) error {