Go微服務實踐之增刪改查

今後篇文章開始，咱們來陸續介紹 go-zero 開發一個項目所須要的組件和開發實踐。

首先咱們從 model 層開始，來講說go-zero 的API以及封裝細節。首先 model 層鏈接的API集中在core/stores。咱們先來看看操做 mysql 這類數據庫，API方法咱們來到 core/stores/sqlx，因此接下來用幾篇的文章整體介紹一下 sqlx 的使用和設計思想。

快速使用

func main() {
  // 1
  const datasource = "user:password@/dbname"
  mysqlDB := sqlx.NewMysql(datasource)
  // 2
  um := model.NewUserModel(mysqlDB,"User")
  // 3
  ul := logic.NewUserLogic(um)
  // 4
  engine.AddRoutes(nginxApi(ul))
  engine.Start()
}

// NewUserModel，NewUserLogic 相似
func NewUserModel(conn sqlx.SqlConn, table string) *UserModel {
	return &UserModel{conn: conn, table: table}
}

// nginxApi將logic注入到handle，同時綁定路由和handler
func nginxApi(ul *logic.UserLogic) []rest.Route {
	return []rest.Route{
		{
			Method:  http.MethodGet,
			Path:    "/user/:id", // /user/54er6;
			Handler: handler.NewUserHandler(ul).GetUserById,
    }
}

總結一下：

1. NewMysql 建立數據庫鏈接
2. 建立相應的 model，並將鏈接傳入「相應的 NewModel 須要開發者編寫」
3. model 是爲上一層 logic 提供服務
4. 將 logic 注入到 handler 中，同時 handler 與路由綁定，開啓 Server

這樣 model-logic-handler 最簡單的結構就出來了。而後來看看在 model 層如何進行數據操做：

var userBuilderQueryRows = strings.Join(builderx.FieldNames(&User{}), ",")

type User struct {
  Avatar string `db:"avatar"` // 頭像
  UserName string `db:"user_name"` // 姓名
  Sex int `db:"sex"` // 1男,2女
  MobilePhone string `db:"mobile_phone"` // 手機號
}

func (um *UserModel) Insert(user *User) (int64, error) {
  const insertsql = `insert into `+um.table+` (`+userBuilderQueryRows+`) values(?, ?, ?)`
  // insert「delete使用方式一致」
  res, err := um.conn.Exec(insertsql, user.Avatar, user.UserName, user.Sex, user.MobilePhone)
  if err != nil {
    logx.Errorf("insert User Position Model Model err, err=%v", err)
    return -1, err
  }
  id, err := res.LastInsertId()
	if err != nil {
		logx.Errorf("insert User Model to Id  parse id err,err=%v", err)
		return -1, err
	}
	return id, nil
}

func (um *UserModel) FindOne(uid int64) (*User, error) {
  var user User
  // query
  const querysql = `select `+userBuilderQueryRows+` from `+um.table+` where id=? limit 1`
	err := um.conn.QueryRow(&user, querysql, uid)
	if err != nil {
		logx.Errorf("userModile.findOne error ,id=%d,err=%s", uid, err.Error())
		if err == sqlx.ErrNotFound {
			return nil, ErrNotFound
		}
		return nil, err
	}
	return &user, nil
}

• insert/update/delete：conn.Exec(insertsql/updatesql/deletesql, args...)
• query：conn.QueryRow(&model, querysql, args...)

上述就是最簡單的 crud 的結構：首先是構建 model ，而後操做 model 進行操做。

代碼結構

文件名	做用
bulkinserter.go	批量插入
mysql.go	NewMysql
orm.go	解析，序列化model的操做
sqlconn.go	抽象crud操做的接口
tx.go	事務操做

從 sqlconn.go 的相互接口關係：

能夠看出：commonSqlConn 和 txSession 是真正實現的地方。先從 API 的功能總體介紹一下：

API	參數	做用
Exec(query, args...)	sql, sql參數	insert/update/delete
Prepare(query)	sql	預編譯sql
QueryRow(&model, query, args...)	model, sql, sql參數	查詢一行數據同時賦值給「model」
QueryRowPartial(&model, query, args...)	model, sql, sql參數	功能同上，可是select sql能夠只選取model的部分column「映託Partial」
QueryRows/QueryRowsPartial	同上	查詢多行API
Transact(func(session Session) error)	事務操做	將參數中的操做用事務包裹，開發者只需專一參數中的函數編寫

總結

go-zero 的 sqlx 屏蔽了go原生的sql操做，開發者只需關注sql編寫和業務封裝的數據對象，不須要像原生開發中須要手動prepare，賦值數據時Scan。

本節只是簡略介紹了接口的相互關係以及開發者平時關注的API，下節將着重分析go-zero是怎麼幫你賦值數據，同時在併發大的狀況下，如何不讓流量直接把你的數據庫打死。

參考

• go-zero sqlx
• Go database/sql tutorial

歡迎你們使用 go-zero

項目地址：https://github.com/tal-tech/go-zero

若是以爲文章不錯，歡迎 github 點個 star 🤝

項目地址：
https://github.com/tal-tech/go-zero