From 1cc4e2a34039e28bc703fe314740e6888e776c7b Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Mon, 7 Jun 2021 10:36:01 +0100 Subject: [PATCH] set tenant based table for delete --- db/handler/db.go | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/db/handler/db.go b/db/handler/db.go index 98ae89a..6b0df6e 100644 --- a/db/handler/db.go +++ b/db/handler/db.go @@ -203,12 +203,19 @@ func (e *Db) Delete(ctx context.Context, req *db.DeleteRequest, rsp *db.DeleteRe return errors.BadRequest("db.delete", "missing id") } + tenantId, ok := tenant.FromContext(ctx) + if !ok { + tenantId = "micro" + } + + tenantId = strings.Replace(tenantId, "/", "_", -1) + db, err := e.GetDBConn(ctx) if err != nil { return err } - return db.Table(req.Table).Delete(Record{ + return db.Table(tenantId + "_" + req.Table).Delete(Record{ ID: req.Id, }).Error }