这篇文章主要介绍“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微服务实践之如何使用增删改查”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注亿速云网站，小编会继续努力为大家带来更多实用的文章！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：https://my.oschina.net/kevwan/blog/4780775
