剛把go編程基礎(chǔ)知識(shí)學(xué)習(xí)完了咳促，學(xué)習(xí)的時(shí)間很短衅斩，可能還有的沒有完全吸收绑青。不過還是在項(xiàng)目中發(fā)現(xiàn)知識(shí)，然后在去回顧已學(xué)的知識(shí)屋群，現(xiàn)在利用gin這個(gè)web框架做一個(gè)簡(jiǎn)單的CRUD操作闸婴。

1.Go Web框架的技術(shù)選型

Top 6 web frameworks for Go as of 2017，可以看看這個(gè)go語言中Web框架的對(duì)比和老大的推薦芍躏，我選擇gin框架作為學(xué)習(xí)go語言的框架邪乍。

image.png

2.Gin介紹

gin框架的中文文檔，這個(gè)文檔相當(dāng)好对竣，清晰明了解釋gin框架的整個(gè)用法庇楞。下面是gin框架的全部特性：

image.png

3.建立一個(gè)web服務(wù)實(shí)現(xiàn)Hello Word

首先需要安裝ginweb框架和gorm作為ORM層，然后利用go-sql數(shù)據(jù)庫(kù)驅(qū)動(dòng)否纬，前提是要配置Gopath環(huán)境變量吕晌，使用go get安裝即可：gin安裝地址

//使用github上的gin托管地址
$ go get -u github.com/gin-gonic/gin
$ go get -u github.com/jinzhu/gorm
$ go get github.com/go-sql-driver/mysql

使用Gin實(shí)現(xiàn)Hello world非常簡(jiǎn)單，創(chuàng)建一個(gè)router（路由）临燃，然后執(zhí)行Run方法即可：

package main
import (
    "github.com/gin-gonic/gin"
    "net/http"
)
func main() {
    router:=gin.Default()
    router.GET("/", func(c *gin.Context) {
        c.String(http.StatusOK,"Hello World")
    })
    router.Run(":8080")
}

結(jié)果如下：

image.png

image.png

是不是比Java方便多了睛驳！下面來仔細(xì)分析下上面的代碼結(jié)構(gòu)：

• 1、router:=gin.Default()：這是默認(rèn)的服務(wù)器谬俄。使用gin的Default方法創(chuàng)建一個(gè)路由Handler柏靶；
• 2、然后通過Http方法綁定路由規(guī)則和路由函數(shù)溃论。不同于net/http庫(kù)的路由函數(shù)屎蜓，gin進(jìn)行了封裝，把request和response都封裝到了gin.Context的上下文環(huán)境中钥勋。
• 3炬转、最后啟動(dòng)路由的Run方法監(jiān)聽端口。還可以用http.ListenAndServe(":8080", router)算灸，或者自定義Http服務(wù)器配置扼劈。

4.基于database/sql的CURD操作

1.建立數(shù)據(jù)庫(kù)表

image.png

2.CURD操作，以查詢?yōu)槔?/h4>

參考人世間

package main

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
    "log"
    "net/http"
    "github.com/gin-gonic/gin"
)
//利用的是原生的SQL的ORM層
var db *sql.DB

//定義person類型結(jié)構(gòu)
type Person struct {
    Id int `json:"id"`
    FirstName string `json:"first_name"`
    LastName string `json:"last_name"`
}

//定義一個(gè)getALL函數(shù)用于回去全部的信息
func (p Person) getAll() (persons []Person,err error) {
    rows,err:=db.Query("SELECT id, first_name, last_name FROM person")
    if err!=nil {
        return
    }
    for rows.Next()  {
        var person Person
        //遍歷表中所有行的信息
        rows.Scan(&person.Id,&person.FirstName,&person.LastName)
        //將person添加到persons中
        persons=append(persons,person)
    }
    //最后關(guān)閉連接
    defer rows.Close()
    return
}

func main() {
    var err error
    db,err =sql.Open("mysql","root:123456@tcp(127.0.0.1:3306)/test?parseTime=true")
    //錯(cuò)誤檢查
    if err!=nil{
        log.Fatal(err.Error())
    }
    //推遲數(shù)據(jù)庫(kù)連接的關(guān)閉
    defer db.Close()

    //
    err = db.Ping()
    if err != nil {
        log.Fatal(err.Error())
    }
    //創(chuàng)建一個(gè)路由Handler
    router:=gin.Default()

    //get方法的查詢
    router.GET("/person", func(c *gin.Context) {
        p:=Person{}
        persons,err:= p.getAll()
        if err !=nil {
            log.Fatal(err)
        }
        //H is a shortcut for map[string]interface{}
        c.JSON(http.StatusOK,gin.H{
            "result":persons,
            "count":len(persons),
        })
    })
    router.Run(":8080")
}

3.測(cè)試結(jié)果如下

image.png

image.png

完整代碼如下：

package main

import (
    "database/sql"
    _ "github.com/go-sql-driver/mysql"
    "log"
    "net/http"
    "github.com/gin-gonic/gin"
    "strconv"
    "fmt"
)

var db *sql.DB

//定義person類型結(jié)構(gòu)
type Person struct {
    Id        int    `json:"id"`
    FirstName string `json:"first_name"`
    LastName  string `json:"last_name"`
}

//定義一個(gè)getALL函數(shù)用于回去全部的信息
func (p Person) getAll() (persons []Person, err error) {
    rows, err := db.Query("SELECT id, first_name, last_name FROM person")
    if err != nil {
        return
    }
    for rows.Next() {
        var person Person
        //遍歷表中所有行的信息
        rows.Scan(&person.Id, &person.FirstName, &person.LastName)
        //將person添加到persons中
        persons = append(persons, person)
    }
    //最后關(guān)閉連接
    defer rows.Close()
    return
}

//通過id查詢
func (p Person) get() (person Person, err error) {
    row := db.QueryRow("SELECT id, first_name, last_name FROM person WHERE id=?", p.Id)
    err = row.Scan(&person.Id, &person.FirstName, &person.LastName)
    if err != nil {
        return
    }
    return
}
func (p Person) add() (Id int, err error) {
    stmt, err := db.Prepare("INSERT INTO person(first_name, last_name) VALUES (?, ?)")
    if err != nil {
        return
    }
    //執(zhí)行插入操作
    rs, err := stmt.Exec(p.FirstName, p.LastName)
    if err != nil {
        return
    }
    //返回插入的id
    id, err := rs.LastInsertId()
    if err != nil {
        log.Fatalln(err)
    }
    //將id類型轉(zhuǎn)換
    Id = int(id)
    defer stmt.Close()
    return
}
//通過id刪除
func (p Person) del() (rows int, err error) {
    stmt, err := db.Prepare("DELETE FROM person WHERE id=?")
    if err != nil {
        log.Fatalln(err)
    }

    rs, err := stmt.Exec(p.Id)
    if err != nil {
        log.Fatalln(err)
    }
    //刪除的行數(shù)
    row, err := rs.RowsAffected()
    if err != nil {
        log.Fatalln(err)
    }
    defer stmt.Close()
    rows = int(row)
    return
}

func main() {

    var err error
    db, err = sql.Open("mysql", "root:123456@tcp(127.0.0.1:3306)/test?parseTime=true")
    //錯(cuò)誤檢查
    if err != nil {
        log.Fatal(err.Error())
    }
    //推遲數(shù)據(jù)庫(kù)連接的關(guān)閉
    defer db.Close()

    //
    err = db.Ping()
    if err != nil {
        log.Fatal(err.Error())
    }
    //創(chuàng)建一個(gè)路由Handler
    router := gin.Default()

    //get方法的查詢
    router.GET("/person", func(c *gin.Context) {
        p := Person{}
        persons, err := p.getAll()
        if err != nil {
            log.Fatal(err)
        }
        //H is a shortcut for map[string]interface{}
        c.JSON(http.StatusOK, gin.H{
            "result": persons,
            "count":  len(persons),
        })
    })
    //利用get方法通過id查詢
    router.GET("/person/:id", func(c *gin.Context) {
        var result gin.H
        //c.Params方法可以獲取到/person/:id中的id值
        id := c.Param("id")
        Id, err := strconv.Atoi(id)
        if err != nil {
            log.Fatal(err)
        }
        //定義person結(jié)構(gòu)
        p := Person{
            Id: Id,
        }
        person, err := p.get()
        if err != nil {
            result = gin.H{
                "result": nil,
                "count":  0,
            }
        } else {
            result = gin.H{
                "result": person,
                "count":  1,
            }
        }
        c.JSON(http.StatusOK, result)

    })
    //利用post方法新增數(shù)據(jù)
    router.POST("/person", func(c *gin.Context) {
        var p Person
        err := c.Bind(&p)
        if err != nil {
            log.Fatal(err)
        }
        Id, err := p.add()
        fmt.Print("id=", Id)
        name := p.FirstName + " " + p.LastName
        c.JSON(http.StatusOK, gin.H{
            "message": fmt.Sprintf("%s 插入成功", name),
        })
    })
    //利用DELETE請(qǐng)求方法通過id刪除
    router.DELETE("/person/:id", func(c *gin.Context) {
        id := c.Param("id")

        Id, err := strconv.ParseInt(id, 10, 10)
        if err != nil {
            log.Fatalln(err)
        }
        p := Person{Id: int(Id)}
        rows, err := p.del()
        if err != nil {
            log.Fatalln(err)
        }
        fmt.Println("delete rows ", rows)

        c.JSON(http.StatusOK, gin.H{
            "message": fmt.Sprintf("Successfully deleted user: %s", id),
        })
    })
    router.Run(":8080")
}

下一篇博客在學(xué)習(xí)下實(shí)際項(xiàng)目中的基于gorm的ORM層的SQL寫法菲驴，以及規(guī)范的項(xiàng)目結(jié)構(gòu)分層荐吵！

參考資料

https://godoc.org/github.com/gin-gonic/gin

https://gist.github.com/rsj217/26492af115a083876570f003c64df118