之前用 beego 中自帶的 orm,感覺有一些不是很滿足需求的地方,而且想要嘗試一些新的 orm,寫一篇記錄一下。

目前成都創(chuàng)新互聯(lián)公司已為上千的企業(yè)提供了網(wǎng)站建設(shè)、域名、虛擬空間、網(wǎng)站運(yùn)營、企業(yè)網(wǎng)站設(shè)計(jì)、文縣網(wǎng)站維護(hù)等服務(wù),公司將堅(jiān)持客戶導(dǎo)向、應(yīng)用為本的策略,正道將秉承"和諧、參與、激情"的文化,與客戶和合作伙伴齊心協(xié)力一起成長,共同發(fā)展。
在 xorm 和 gorm 之間對比了一下:
p.s. 需要說明的是,對比非常初級,而且項(xiàng)目處于很早期,也抱著嘗試一下不行再改的心理,并沒有想要得到一個孰優(yōu)孰劣的結(jié)論。
想來想去,對于一個成熟的項(xiàng)目可能 gorm 更適合,但是 xorm 好像近期在頻繁 commit,有一種想要追趕的意思。
那我先試試 xorm ,不知道為什么選的這個,可能是想試試看新款吧。(大霧
2017/07/04
可怕,xorm 不支持外鍵關(guān)系。一對一啥的。
Gorm是Go語言開發(fā)用的比較多的一個ORM。它的功能比較全:
但是這篇文章中并不會直接看Gorm的源碼,我們會先從database/sql分析。原因是Gorm也是基于這個包來封裝的一些功能。所以只有先了解了database/sql包才能更加好的理解Gorm源碼。
database/sql 其實(shí)也是一個對于mysql驅(qū)動的上層封裝。”github.com/go-sql-driver/mysql”就是一個對于mysql的驅(qū)動,database/sql 就是在這個基礎(chǔ)上做的基本封裝包含連接池的使用
下面這個是最基本的增刪改查操作
操作分下面幾個步驟:
因?yàn)镚orm的連接池就是使用database/sql包中的連接池,所以這里我們需要學(xué)習(xí)一下包里的連接池的源碼實(shí)現(xiàn)。其實(shí)所有連接池最重要的就是連接池對象、獲取函數(shù)、釋放函數(shù)下面來看一下database/sql中的連接池。
DB對象
獲取方法
釋放連接方法
連接池的實(shí)現(xiàn)有很多方法,在database/sql包中使用的是chan阻塞 使用map記錄等待列表,等到有連接釋放的時候再把連接傳入等待列表中的chan 不在阻塞返回連接。
之前我們看到的Redigo是使用一個chan 來阻塞,然后釋放的時候放入空閑列表,在往這一個chan中傳入struct{}{},讓程序繼續(xù) 獲取的時候再從空閑列表中獲取。并且使用的是鏈表的結(jié)構(gòu)來存儲空閑列表。
database/sql 是對于mysql驅(qū)動的封裝,然而Gorm則是對于database/sql的再次封裝。讓我們可以更加簡單的實(shí)現(xiàn)對于mysql數(shù)據(jù)庫的操作。
這幾天golang社區(qū)對泛型的討論非常多的,一片熱火朝天的景象。對我們廣大gopher來說總歸是好事。
泛型很有可能會顛覆我們之前的很多設(shè)計(jì),帶著這種疑問和沖動,我準(zhǔn)備嘗試用golang泛型實(shí)現(xiàn)幾個orm的常見功能。
本文并沒完全實(shí)現(xiàn)通用的orm,只是探討其實(shí)現(xiàn)的一種方式提供各位讀者做借鑒。
雖然golang有了泛型,但是目前在標(biāo)準(zhǔn)庫sql底層還沒有改造,目前還有很多地方需要用到reflect。
調(diào)用方式
這個部分跟傳統(tǒng)的orm使用上沒有太大區(qū)別,沒辦法不使用反射的情況下,泛型的方式可能變得有點(diǎn)繁瑣。
調(diào)用方式
和創(chuàng)建table類似,寫入數(shù)據(jù)好像比沒有之前的orm有優(yōu)勢。
讀取數(shù)據(jù)是非常高頻的操作,所以我們稍作封裝。
調(diào)用方式
稍微比原先的orm方式有了多一點(diǎn)想象空間,比如 在[T any]做更明確的約束,比如要求實(shí)現(xiàn)Filter定制方法。
鑒于本人能力還認(rèn)證有限,目前還沒有發(fā)現(xiàn)泛型對orm劇烈的改進(jìn)和突破的可能。未來如果go對底層sql做出改動,或者實(shí)現(xiàn)諸如Rust那種Enum方式,可能會帶來更多的驚喜。
目前beego的ORM支持三種數(shù)據(jù)庫:
1.Sqlite
2.PostgreSql
3.MySql
如果要使用其中的數(shù)據(jù)庫必須要把對應(yīng)的drive(go語言對于的數(shù)據(jù)庫引擎)加入到import中:
import (
_ "github.com/go-sql-driver/mysql"
_ "github.com/lib/pq"
_ "github.com/mattn/go-sqlite3"
models.go
============================
package main
import (
"github.com/astaxie/beego/orm"
)
type User struct {
Id int
Name string
Profile *Profile `orm:"rel(one)"` // OneToOne relation
}
type Profile struct {
Id int
Age int16
User *User `orm:"reverse(one)"` // 設(shè)置反向關(guān)系(可選)
}
func init() {
// 需要在init中注冊定義的model
orm.RegisterModel(new(User), new(Profile))
}
main.go
==============
package main
import (
"fmt"
"github.com/astaxie/beego/orm"
_ "github.com/go-sql-driver/mysql"
)
func init() {
//orm.RegisterModel(new(User))
orm.RegisterDataBase("default", "mysql", "ta3:ta3@/ta3?charset=utf8")
orm.RunSyncdb("default", false, true) // true 改成false,如果表存在則會給出提示,如果改成false則不會提示 , 這句話沒有會報(bào)主鍵不存在的錯誤
}
func main() {
o := orm.NewOrm()
o.Using("default") // 默認(rèn)使用 default,你可以指定為其他數(shù)據(jù)庫
user := User{Id: 1}
err := o.Read(user)
if err == orm.ErrNoRows {
fmt.Println("查詢不到")
} else if err == orm.ErrMissPK {
fmt.Println("找不到主鍵")
} else {
fmt.Println(user.Id, user.Name)
}
}
執(zhí)行結(jié)果:
create table `user`
-- --------------------------------------------------
-- Table Structure for `main.User`
-- --------------------------------------------------
CREATE TABLE IF NOT EXISTS `user` (
`id` integer AUTO_INCREMENT NOT NULL PRIMARY KEY,
`name` varchar(255) NOT NULL,
`profile_id` integer NOT NULL UNIQUE
) ENGINE=InnoDB;
create table `profile`
-- --------------------------------------------------
-- Table Structure for `main.Profile`
-- --------------------------------------------------
CREATE TABLE IF NOT EXISTS `profile` (
`id` integer AUTO_INCREMENT NOT NULL PRIMARY KEY,
`age` smallint NOT NULL
) ENGINE=InnoDB;
查詢不到
第二次再執(zhí)行:
table `user` already exists, skip
table `profile` already exists, skip
查詢不到
如果 orm.RunSyncdb("default", false, true)改成 orm.RunSyncdb("default", false, false)
則執(zhí)行結(jié)果不會提示。
網(wǎng)頁名稱:go語言orm分庫,gorm 分庫分表
文章地址:http://chinadenli.net/article15/dsehcdi.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供標(biāo)簽優(yōu)化、企業(yè)建站、網(wǎng)站內(nèi)鏈、靜態(tài)網(wǎng)站、云服務(wù)器、關(guān)鍵詞優(yōu)化
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)