這篇文章主要介紹“Go微服務(wù)實踐之如何使用增刪改查”，在日常操作中，相信很多人在Go微服務(wù)實踐之如何使用增刪改查問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”Go微服務(wù)實踐之如何使用增刪改查”的疑惑有所幫助！接下來，請跟著小編一起來學習吧！
富錦網(wǎng)站建設(shè)公司成都創(chuàng)新互聯(lián),富錦網(wǎng)站設(shè)計制作，有大型網(wǎng)站制作公司豐富經(jīng)驗。已為富錦上1000家提供企業(yè)網(wǎng)站建設(shè)服務(wù)。企業(yè)網(wǎng)站搭建\成都外貿(mào)網(wǎng)站制作要多少錢，請找那個售后服務(wù)好的富錦做網(wǎng)站的公司定做！
首先我們從 model 層開始，來說說go-zero 的API以及封裝細節(jié)。首先 model 層連接的API集中在core/stores。我們先來看看操作 MySQL 這類數(shù)據(jù)庫，API方法我們來到 core/stores/sqlx，所以接下來用幾篇的文章總體介紹一下 sqlx 的使用和設(shè)計思想。
重慶分公司
重慶分公司
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,
}
}總結(jié)一下：
NewMysql 創(chuàng)建數(shù)據(jù)庫連接
創(chuàng)建相應(yīng)的 model，并將連接傳入「相應(yīng)的 NewModel 需要開發(fā)者編寫」
model 是為上一層 logic 提供服務(wù)
將 logic 注入到 handler 中，同時 handler 與路由綁定，開啟 Server
這樣 model-logic-handler 最簡單的結(jié)構(gòu)就出來了。然后來看看在 model 層如何進行數(shù)據(jù)操作：
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 的結(jié)構(gòu)：首先是構(gòu)建 model ，然后操作 model 進行操作。
| 文件名 | 作用 |
|---|---|
| bulkinserter.go | 批量插入 |
| mysql.go | NewMysql |
| orm.go | 解析，序列化model的操作 |
| sqlconn.go | 抽象crud操作的接口 |
| tx.go | 事務(wù)操作 |
從 sqlconn.go 的相互接口關(guān)系：
可以看出：commonSqlConn 和 txSession 是真正實現(xiàn)的地方。先從 API 的功能整體介紹一下：
| API | 參數(shù) | 作用 |
|---|---|---|
| Exec(query, args...) | sql, sql參數(shù) | insert/update/delete |
| Prepare(query) | sql | 預編譯sql |
| QueryRow(&model, query, args...) | model, sql, sql參數(shù) | 查詢一行數(shù)據(jù)同時賦值給「model」 |
| QueryRowPartial(&model, query, args...) | model, sql, sql參數(shù) | 功能同上，但是select sql可以只選取model的部分column「映襯Partial」 |
| QueryRows/QueryRowsPartial | 同上 | 查詢多行API |
| Transact(func(session Session) error) | 事務(wù)操作 | 將參數(shù)中的操作用事務(wù)包裹，開發(fā)者只需專注參數(shù)中的函數(shù)編寫 |
到此，關(guān)于“Go微服務(wù)實踐之如何使用增刪改查”的學習就結(jié)束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續(xù)學習更多相關(guān)知識，請繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>
新聞標題：Go微服務(wù)實踐之如何使用增刪改查
新聞來源：http://weahome.cn/article/peceho.html
