gopackage/mgoapi
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

db interface

Browse Source
This commit is contained in:
Sebastian Frank
2022-02-09 20:21:08 +01:00
parent 2b4f13f807
commit d116f5d938
8 changed files with 82 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
handler.go
View File

@@ -143,7 +143,7 @@ func (api *API) collectionGetHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
queryCount := c.Query("count")
if queryCount == "1" || strings.ToLower(queryCount) == "true" {
count, err := mgocrud.ReadCollectionCount(db, m, validFilter)
count, err := db.ReadCollectionCount(m, validFilter)
if err != nil {
c.JSON(500, errorObject(err))
return
@@ -169,7 +169,7 @@ func (api *API) collectionGetHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
}
}
err = mgocrud.ReadCollection(db, results, validFilter, validSelect, offset, limit, clearedSort, pipelineModFunc)
err = db.ReadCollection(results, validFilter, validSelect, offset, limit, clearedSort, pipelineModFunc)
if err != nil {
c.JSON(500, errorObject(err))
return
@@ -218,7 +218,7 @@ func (api *API) collectionPostHandler(m mgocrud.ModelInterface) gin.HandlerFunc
return
}
err := mgocrud.CreateDocument(db, newM)
err := db.CreateDocument(newM)
if err != nil {
c.JSON(500, errorObject(err))
return
@@ -226,7 +226,7 @@ func (api *API) collectionPostHandler(m mgocrud.ModelInterface) gin.HandlerFunc
readM := newModelOf(newM).(mgocrud.ModelInterface)
readM.SetID(newM.GetID())
err = mgocrud.ReadDocument(db, readM, nil)
err = db.ReadDocument(readM, nil)
if err != nil {
c.JSON(500, errorObject(err))
return
@@ -358,7 +358,7 @@ func (api *API) collectionPutHandler(m mgocrud.ModelInterface) gin.HandlerFunc {
return
}
err = mgocrud.UpdateDocument(db, orgM, changes)
err = db.UpdateDocument(orgM, changes)
if err != nil {
c.JSON(500, errorObject(err))
return
@@ -413,7 +413,7 @@ func (api *API) collectionDeleteHandler(m mgocrud.ModelInterface) gin.HandlerFun
return
}
err = mgocrud.DeleteDocument(db, orgM)
err = db.DeleteDocument(orgM)
if err != nil {
c.JSON(500, errorObject(err))
}