经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » Go语言 » 查看文章
Go微服务实践之增删改查
来源:cnblogs  作者:Kevin Wan  时间:2020/12/14 17:25:39  对本文有异议

从此篇文章开始,我们来陆续介绍 go-zero 开发一个项目所需要的组件和开发实践。

首先我们从 model 层开始,来说说go-zero 的API以及封装细节。首先 model 层连接的API集中在core/stores。我们先来看看操作 mysql 这类数据库,API方法我们来到 core/stores/sqlx,所以接下来用几篇的文章总体介绍一下 sqlx 的使用和设计思想。

快速使用

  1. func main() {
  2. // 1
  3. const datasource = "user:password@/dbname"
  4. mysqlDB := sqlx.NewMysql(datasource)
  5. // 2
  6. um := model.NewUserModel(mysqlDB,"User")
  7. // 3
  8. ul := logic.NewUserLogic(um)
  9. // 4
  10. engine.AddRoutes(nginxApi(ul))
  11. engine.Start()
  12. }
  13. // NewUserModel,NewUserLogic 类似
  14. func NewUserModel(conn sqlx.SqlConn, table string) *UserModel {
  15. return &UserModel{conn: conn, table: table}
  16. }
  17. // nginxApi将logic注入到handle,同时绑定路由和handler
  18. func nginxApi(ul *logic.UserLogic) []rest.Route {
  19. return []rest.Route{
  20. {
  21. Method: http.MethodGet,
  22. Path: "/user/:id", // /user/54er6;
  23. Handler: handler.NewUserHandler(ul).GetUserById,
  24. }
  25. }

总结一下:

  1. NewMysql 创建数据库连接
  2. 创建相应的 model,并将连接传入「相应的 NewModel 需要开发者编写」
  3. model 是为上一层 logic 提供服务
  4. logic 注入到 handler 中,同时 handler 与路由绑定,开启 Server

这样 model-logic-handler 最简单的结构就出来了。然后来看看在 model 层如何进行数据操作:

  1. var userBuilderQueryRows = strings.Join(builderx.FieldNames(&User{}), ",")
  2. type User struct {
  3. Avatar string `db:"avatar"` // 头像
  4. UserName string `db:"user_name"` // 姓名
  5. Sex int `db:"sex"` // 1男,2女
  6. MobilePhone string `db:"mobile_phone"` // 手机号
  7. }
  8. func (um *UserModel) Insert(user *User) (int64, error) {
  9. const insertsql = `insert into `+um.table+` (`+userBuilderQueryRows+`) values(?, ?, ?)`
  10. // insert「delete使用方式一致」
  11. res, err := um.conn.Exec(insertsql, user.Avatar, user.UserName, user.Sex, user.MobilePhone)
  12. if err != nil {
  13. logx.Errorf("insert User Position Model Model err, err=%v", err)
  14. return -1, err
  15. }
  16. id, err := res.LastInsertId()
  17. if err != nil {
  18. logx.Errorf("insert User Model to Id parse id err,err=%v", err)
  19. return -1, err
  20. }
  21. return id, nil
  22. }
  23. func (um *UserModel) FindOne(uid int64) (*User, error) {
  24. var user User
  25. // query
  26. const querysql = `select `+userBuilderQueryRows+` from `+um.table+` where id=? limit 1`
  27. err := um.conn.QueryRow(&user, querysql, uid)
  28. if err != nil {
  29. logx.Errorf("userModile.findOne error ,id=%d,err=%s", uid, err.Error())
  30. if err == sqlx.ErrNotFound {
  31. return nil, ErrNotFound
  32. }
  33. return nil, err
  34. }
  35. return &user, nil
  36. }
  • insert/update/deleteconn.Exec(insertsql/updatesql/deletesql, args...)
  • queryconn.QueryRow(&model, querysql, args...)

上述就是最简单的 crud 的结构:首先是构建 model ,然后操作 model 进行操作。

代码结构

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

sqlconn.go 的相互接口关系:

可以看出:commonSqlConntxSession 是真正实现的地方。先从 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-zerosqlx 屏蔽了go原生的sql操作,开发者只需关注sql编写和业务封装的数据对象,不需要像原生开发中需要手动prepare,赋值数据时Scan。

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

参考

欢迎大家使用 go-zero

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

如果觉得文章不错,欢迎 github 点个 star ??

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

原文链接:http://www.cnblogs.com/kevinwan/p/14101691.html

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号