go-zero
modelgo-zeromodelcore/storesmysqlcore/stores/sqlxsqlx

疾速应用

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,
    }
}

总结一下：

NewMysqlmodelNewModelmodellogiclogichandlerhandlerServer
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/deleteconn.Exec(insertsql/updatesql/deletesql, args...)queryconn.QueryRow(&model, querysql, args...)
crudmodelmodel

代码构造

modelcrud
sqlconn.go
commonSqlConntxSessionAPI
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-zerosqlx

本节只是简略介绍了接口的互相关系以及开发者平时关注的API，下节将着重剖析go-zero是怎么帮你赋值数据，同时在并发大的状况下，如何不让流量间接把你的数据库打死。

参考

go-zero

如果感觉文章不错，欢送 github 点个 star ????

我的项目地址：
https://github.com/tal-tech/go-zero