Last active
March 4, 2025 00:25
-
-
Save mashingan/4212d447f857cfdfbbba4f5436b779ac to your computer and use it in GitHub Desktop.
Revisions
-
mashingan revised this gist
Jan 17, 2019 . 1 changed file with 137 additions and 0 deletions.There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode charactersOriginal file line number Diff line number Diff line change @@ -0,0 +1,137 @@ package main /* This version using `dbops` as separate object that handle operation to database. This can be expanded as a core functionality to separate handler and model/logic and encourage separation of core business logic and transport. */ import ( "fmt" "net/http" "strconv" "github.com/jinzhu/gorm" _ "github.com/jinzhu/gorm/dialects/sqlite" "github.com/labstack/echo" ) type User struct { gorm.Model `json:"model"` Name string `json:"name"` Email string `json:"email"` } type dbops struct { db *gorm.DB } func (d dbops) findAll(users *[]User) error { return d.db.Find(users).Error } func (d dbops) create(user *User) error { return d.db.Create(user).Error } func (d dbops) findByPage(users *[]User, page, view int) error { return d.db.Limit(view).Offset(view * (page - 1)).Find(&users).Error } func (d dbops) updateByName(name, email string) error { var user User d.db.Where("name=?", name).Find(&user) user.Email = email return d.db.Save(&user).Error } func (d dbops) deleteByName(name string) error { var user User d.db.Where("name=?", name).Find(&user) return d.db.Delete(&user).Error } func handlerFunc(msg string) func(echo.Context) error { return func(c echo.Context) error { return c.String(http.StatusOK, msg) } } func allUsers(dbobj dbops) func(echo.Context) error { return func(c echo.Context) error { var users []User dbobj.findAll(&users) fmt.Println("{}", users) return c.JSON(http.StatusOK, users) } } func newUser(dbobj dbops) func(echo.Context) error { return func(c echo.Context) error { name := c.Param("name") email := c.Param("email") dbobj.create(&User{Name: name, Email: email}) return c.String(http.StatusOK, name+" user successfully created") } } func deleteUser(dbobj dbops) func(echo.Context) error { return func(c echo.Context) error { name := c.Param("name") dbobj.deleteByName(name) return c.String(http.StatusOK, name+" user successfully deleted") } } func updateUser(dbobj dbops) func(echo.Context) error { return func(c echo.Context) error { name := c.Param("name") email := c.Param("email") dbobj.updateByName(name, email) return c.String(http.StatusOK, name+" user successfully updated") } } func usersByPage(dbobj dbops) func(echo.Context) error { return func(c echo.Context) error { limit, _ := strconv.Atoi(c.QueryParam("limit")) page, _ := strconv.Atoi(c.QueryParam("page")) var result []User dbobj.findByPage(&result, page, limit) return c.JSON(http.StatusOK, result) } } func handleRequest(dbgorm *gorm.DB) { e := echo.New() db := dbops{dbgorm} e.GET("/users", allUsers(db)) e.GET("/user", usersByPage(db)) e.POST("/user/:name/:email", newUser(db)) e.DELETE("/user/:name", deleteUser(db)) e.PUT("/user/:name/:email", updateUser(db)) e.Logger.Fatal(e.Start(":3000")) } func initialMigration(db *gorm.DB) { db.AutoMigrate(&User{}) } func main() { fmt.Println("Go ORM tutorial") db, err := gorm.Open("sqlite3", "sqlite3gorm.db") if err != nil { fmt.Println(err.Error()) panic("failed to connect database") } defer db.Close() initialMigration(db) handleRequest(db) } -
Oct 28, 2018 .There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters. Learn more about bidirectional Unicode charactersOriginal file line number Diff line number Diff line change @@ -0,0 +1,105 @@ package main import ( "fmt" "net/http" "strconv" "github.com/jinzhu/gorm" _ "github.com/jinzhu/gorm/dialects/sqlite" "github.com/labstack/echo" ) type User struct { gorm.Model `json:"model"` Name string `json:"name"` Email string `json:"email"` } func handlerFunc(msg string) func(echo.Context) error { return func(c echo.Context) error { return c.String(http.StatusOK, msg) } } func allUsers(db *gorm.DB) func(echo.Context) error { return func(c echo.Context) error { var users []User db.Find(&users) fmt.Println("{}", users) return c.JSON(http.StatusOK, users) } } func newUser(db *gorm.DB) func(echo.Context) error { return func(c echo.Context) error { name := c.Param("name") email := c.Param("email") db.Create(&User{Name: name, Email: email}) return c.String(http.StatusOK, name+" user successfully created") } } func deleteUser(db *gorm.DB) func(echo.Context) error { return func(c echo.Context) error { name := c.Param("name") var user User db.Where("name = ?", name).Find(&user) db.Delete(&user) return c.String(http.StatusOK, name+" user successfully deleted") } } func updateUser(db *gorm.DB) func(echo.Context) error { return func(c echo.Context) error { name := c.Param("name") email := c.Param("email") var user User db.Where("name=?", name).Find(&user) user.Email = email db.Save(&user) return c.String(http.StatusOK, name+" user successfully updated") } } func usersByPage(db *gorm.DB) func(echo.Context) error { return func(c echo.Context) error { limit, _ := strconv.Atoi(c.QueryParam("limit")) page, _ := strconv.Atoi(c.QueryParam("page")) var result []User db.Limit(limit).Offset(limit * (page - 1)).Find(&result) return c.JSON(http.StatusOK, result) } } func handleRequest(db *gorm.DB) { e := echo.New() e.GET("/users", allUsers(db)) e.GET("/user", usersByPage(db)) e.POST("/user/:name/:email", newUser(db)) e.DELETE("/user/:name", deleteUser(db)) e.PUT("/user/:name/:email", updateUser(db)) e.Logger.Fatal(e.Start(":3000")) } func initialMigration(db *gorm.DB) { db.AutoMigrate(&User{}) } func main() { fmt.Println("Go ORM tutorial") db, err := gorm.Open("sqlite3", "sqlite3gorm.db") if err != nil { fmt.Println(err.Error()) panic("failed to connect database") } defer db.Close() initialMigration(db) handleRequest(db) }