Add websocket endpoint for sql text queries
This commit is contained in:
parent
529c1028a3
commit
01621d74fe
1 changed files with 25 additions and 0 deletions
|
@ -117,6 +117,31 @@ func routes(s *fibre.Fibre) {
|
||||||
return c.Send(200, res)
|
return c.Send(200, res)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
s.Get("/sql", func(c *fibre.Context) error {
|
||||||
|
|
||||||
|
if err := c.Upgrade(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
for {
|
||||||
|
|
||||||
|
_, msg, err := c.Socket().Read()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
if res, err := db.Execute(c, msg, nil); err != nil {
|
||||||
|
c.Socket().SendText(err.Error())
|
||||||
|
} else {
|
||||||
|
c.Socket().SendJSON(res)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
|
||||||
|
})
|
||||||
|
|
||||||
// --------------------------------------------------
|
// --------------------------------------------------
|
||||||
// Endpoints for manipulating multiple records
|
// Endpoints for manipulating multiple records
|
||||||
// --------------------------------------------------
|
// --------------------------------------------------
|
||||||
|
|
Loading…
Reference in a new issue