mirror of
https://github.com/kevin-DL/services.git
synced 2026-01-21 23:15:06 +00:00
. (#137)
* [WIP] DB service * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * F * fixup db and return id in create response * add delete method and some error checking * Add the update method * fix panic * use record for the data field Co-authored-by: Janos Dobronszki <dobronszki@gmail.com>
This commit is contained in:
@@ -71,14 +71,17 @@ func (e *Db) Update(ctx context.Context, req *db.UpdateRequest, rsp *db.UpdateRe
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// do we really need to remarshal this?
|
||||||
|
data, _ := json.Marshal(m)
|
||||||
|
|
||||||
// where ID is specified do a single update record update
|
// where ID is specified do a single update record update
|
||||||
if id, ok := m["ID"].(string); ok {
|
if id, ok := m["ID"].(string); ok {
|
||||||
// apply the update to a single record
|
// apply the update to a single record
|
||||||
return db.Table(req.Table).First(&Record{ID: id}).Updates(m).Error
|
return db.Table(req.Table).First(&Record{ID: id}).Updates(Record{Data: data}).Error
|
||||||
}
|
}
|
||||||
|
|
||||||
// apply all the updates
|
// apply all the updates
|
||||||
return db.Table(req.Table).Updates(m).Error
|
return db.Table(req.Table).Updates(Record{Data: data}).Error
|
||||||
}
|
}
|
||||||
|
|
||||||
func (e *Db) Read(ctx context.Context, req *db.ReadRequest, rsp *db.ReadResponse) error {
|
func (e *Db) Read(ctx context.Context, req *db.ReadRequest, rsp *db.ReadResponse) error {
|
||||||
|
|||||||
Reference in New Issue
Block a user