這篇文章主要介紹“Go微服務實踐之如何使用增刪改查”,在日常操作中,相信很多人在Go微服務實踐之如何使用增刪改查問題上存在疑惑,小編查閱了各式資料,整理出簡單好用的操作方法,希望對大家解答”Go微服務實踐之如何使用增刪改查”的疑惑有所幫助!接下來,請跟著小編一起來學習吧!
富錦網站建設公司成都創(chuàng)新互聯(lián),富錦網站設計制作,有大型網站制作公司豐富經驗。已為富錦上1000家提供企業(yè)網站建設服務。企業(yè)網站搭建\成都外貿網站制作要多少錢,請找那個售后服務好的富錦做網站的公司定做!
首先我們從 model 層開始,來說說go-zero 的API以及封裝細節(jié)。首先 model 層連接的API集中在core/stores。我們先來看看操作 MySQL 這類數(shù)據庫,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 創(chuàng)建數(shù)據庫連接
創(chuàng)建相應的 model,并將連接傳入「相應的 NewModel 需要開發(fā)者編寫」
model 是為上一層 logic 提供服務
將 logic 注入到 handler 中,同時 handler 與路由綁定,開啟 Server
這樣 model-logic-handler 最簡單的結構就出來了。然后來看看在 model 層如何進行數(shù)據操作:
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 是真正實現(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ù)據同時賦值給「model」 |
| QueryRowPartial(&model, query, args...) | model, sql, sql參數(shù) | 功能同上,但是select sql可以只選取model的部分column「映襯Partial」 |
| QueryRows/QueryRowsPartial | 同上 | 查詢多行API |
| Transact(func(session Session) error) | 事務操作 | 將參數(shù)中的操作用事務包裹,開發(fā)者只需專注參數(shù)中的函數(shù)編寫 |
到此,關于“Go微服務實踐之如何使用增刪改查”的學習就結束了,希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習,快去試試吧!若想繼續(xù)學習更多相關知識,請繼續(xù)關注創(chuàng)新互聯(lián)網站,小編會繼續(xù)努力為大家?guī)砀鄬嵱玫奈恼拢?/p>
文章題目:Go微服務實踐之如何使用增刪改查
文章鏈接:http://www.chinadenli.net/article40/peceho.html
成都網站建設公司_創(chuàng)新互聯(lián),為您提供商城網站、網站設計公司、、微信小程序、響應式網站、網站收錄
聲明:本網站發(fā)布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創(chuàng)新互聯(lián)