cco/go-scopes
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

start using Track interface when accessing database

Browse source
This commit is contained in:
Helmut Merz 2024-05-02 12:13:17 +02:00
parent b38d22f1bb
commit 4db9a95cd7
1 changed files with 7 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
storage/tracking/tracking.go
View file

@ -251,11 +251,12 @@ func (cont *Container) NewTrack(h []string, data lib.Map) *track {
return tr return tr
} }
func (cont *Container) Save(tr *track) *track { func (cont *Container) Save(tr Track) Track {
return tr return tr
} }
func (cont *Container) Insert(tr *track) *track { func (cont *Container) Insert(trk Track) Track {
tr := trk.Base()
quSpec := &querySpec{ quSpec := &querySpec{
Scols: append(cont.HeadFields, "Data"), Scols: append(cont.HeadFields, "Data"),
} }
@ -274,12 +275,13 @@ func (cont *Container) Insert(tr *track) *track {
return err return err
} }
if err := cont.Storage.Query(proc, sql, values...); err == nil { if err := cont.Storage.Query(proc, sql, values...); err == nil {
return tr return trk
} }
return nil return nil
} }
func (cont *Container) Update(tr *track) *track { func (cont *Container) Update(trk Track) Track {
tr := trk.Base()
if tr.timeStamp == nil { if tr.timeStamp == nil {
ts := time.Now() ts := time.Now()
tr.timeStamp = &ts tr.timeStamp = &ts
@ -298,7 +300,7 @@ func (cont *Container) Update(tr *track) *track {
vals = append(vals, b) vals = append(vals, b)
n, _ := cont.Storage.Exec(sql, vals...) n, _ := cont.Storage.Exec(sql, vals...)
if n == 1 { if n == 1 {
return tr return trk
} }
return nil return nil
} }