从此篇文章开始，咱们来陆续介绍 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，同时绑定路由和handlerfunc 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.goNewMysql
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