这篇文章主要介绍“Go微服务实践之如何使用增删改查”,在日常操作中,相信很多人在Go微服务实践之如何使用增删改查问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Go微服务实践之如何使用增删改查”的疑惑有所帮助!接下来,请跟着小编一起来学习吧!
首先我们从 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, } }
总结一下:
NewMysql
创建数据库连接
创建相应的 model
,并将连接传入「相应的 NewModel
需要开发者编写」
model
是为上一层 logic
提供服务
将 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微服务实践之如何使用增删改查”的学习就结束了,希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习,快去试试吧!若想继续学习更多相关知识,请继续关注亿速云网站,小编会继续努力为大家带来更多实用的文章!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。