go語(yǔ)言 xorm框架 postgresql 的用法及詳細(xì)注解
更新時(shí)間：2020年12月19日 09:53:55 作者：fwhezfwhez
這篇文章主要介紹了go語(yǔ)言 xorm框架 postgresql 的用法及詳細(xì)注解，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
xorm用于在golang中鏈接數(shù)據(jù)庫(kù)，并完成增刪改差操作，不管是orm還是raw方式都十分的新穎簡(jiǎn)單。
sql語(yǔ)句
postgresql pgadmin
/*表結(jié)構(gòu)*/
CREATE TABLE public.user
(
id serial primary key,
name varchar(20)
);
ALTER TABLE public.user ADD COLUMN created timestamp default now();
ALTER TABLE public.user ADD COLUMN class_id integer default 1;
insert into public.user(name) values('ft');
insert into public.user(name) values('ft2');
insert into public.user(name,class_id) values('ft8',2)
CREATE TABLE public.class
(
id serial primary key,
name varchar(20)
);
insert into public.class(name) values('高中一班');
insert into public.class(name) values('高中二班');
/*常用到的操作*/
select * from public.class;
select * from public.user;
select u.id,u.name,c.name from public.user as u left join public.class as c on u.class_id=c.id;
main.go
每個(gè)功能都使用了if語(yǔ)句來(lái)方便開(kāi)關(guān)，測(cè)試那塊就打開(kāi)哪塊~~~
package main
import (
_ "github.com/lib/pq"
"github.com/xormplus/xorm"
"fmt"
"time"
"strconv"
)
//用戶(hù)表結(jié)構(gòu)
type User struct {
Id int `xorm:"not null pk autoincr INTEGER"`
Name string `xorm:"VARCHAR(20)"`
Created time.Time `xorm:"default 'now()' DATETIME"`
ClassId int `xorm:"default 1 INTEGER"`
}
//Class表結(jié)構(gòu)
type Class struct {
Id int `xorm:"not null pk autoincr INTEGER"`
Name string `xorm:"VARCHAR(20)"`
}
//臨時(shí)表結(jié)構(gòu)
type UserClass struct{
User `xorm:"extends"`
Name string
}
//此方法僅用于orm查詢(xún)時(shí)，查詢(xún)表認(rèn)定
func (UserClass) TableName() string {
return "public.user"
}
func main() {
//1.創(chuàng)建db引擎
db, err := xorm.NewPostgreSQL("postgres://postgres:123@localhost:5432/test?sslmode=disable")
if err != nil {
fmt.Println(err)
}
//2.顯示sql語(yǔ)句
db.ShowSQL(true)
//3.設(shè)置連接數(shù)
db.SetMaxIdleConns(2000)
db.SetMaxOpenConns(1000)
cacher := xorm.NewLRUCacher(xorm.NewMemoryStore(), 500)//緩存的條數(shù)
db.SetDefaultCacher(cacher)
//4.執(zhí)行插入語(yǔ)句的幾種方式
//4.1 orm插入方式:不好控制，如果僅僅插入的對(duì)象的屬性是name='ftq',那么其他的零值會(huì)一同insert，orm方式對(duì)零值的處理有點(diǎn)不太好
if false {
user := new(User)
user.Name = "ftq"
_, err = db.Insert(user)
if err != nil {
fmt.Println(err)
}
}
//4.2 命令插入方式
//4.2.1 db.Exec():單事務(wù)單次提交
if false{
sql:="insert into public.user(name) values(?)"
db.Exec(sql,"ft4")
}
//4.2.2 db.SQL().Execute():單事務(wù)準(zhǔn)備了Statement處理sql語(yǔ)句
if false{
sql:="insert into public.user(name) values(?)"
db.SQL(sql,"ft5").Execute()
}
//4.2.3使用sql配置文件管理語(yǔ)句,兩種載入配置的方式LoadSqlMap()和RegisterSqlMap(),以及SqlMapClient()替代SQL()
if false {
err = db.LoadSqlMap("./sql.xml")
//err = db.RegisterSqlMap(xorm.Xml("./","sql.xml"))
if err != nil {
fmt.Println(err)
}
db.SqlMapClient("insert_1","ft7").Execute()
}
//5.執(zhí)行查詢(xún)的幾種方式
//5.1 orm查詢(xún):在user初始化的時(shí)候,該orm查詢(xún)直接通過(guò)掃描user類(lèi)型確定表名;組合使用Where(),Get()
if false {
user := new(User)
boolget ,err2 :=db.Where("id=?",5).Get(user)
fmt.Println(boolget,err2,user)
}
//5.2 orm查詢(xún):組合使用Where(),Get(),And()
if false {
user := new(User)
boolget ,err2 :=db.Where("id=?",5).And("name=?","ft7").And("id>?",3).Get(user)
fmt.Println(boolget,err2,user)
}
//5.3 orm查詢(xún): AllCols()查詢(xún)所有列，Cols()查詢(xún)部分列，F(xiàn)ind()解析多行結(jié)果,Get()解析單行結(jié)果
if false {
users := new ([]User)
err = db.AllCols().Find(users)
//err = db.Cols("id","name").Find(users)
if err !=nil {
fmt.Println(err)
}
fmt.Println(users)
}
//5.4 orm查詢(xún):連接查詢(xún)Join()
if false {
users := new([]UserClass)
db.Join("INNER","class","user.class_id=class.id").Find(users)
//db.SQL("select u.id,u.name,c.name from public.user as u left join public.class as c on u.class_id=c.id").Find(users)
fmt.Println(users)
}
//5.5 sql查詢(xún)略
if false {
//和insert類(lèi)似,Find查找多行結(jié)果，Get獲取 單行結(jié)果
users := new([]UserClass)
db.SQL("select u.id,u.name,c.name from public.user as u left join public.class as c on u.class_id=c.id").Find(users)
fmt.Println(users)
}
//5.6 鏈?zhǔn)讲檎?
if false {
//值得一提的是，支持查找某行的某個(gè)字段，不過(guò)一般在sql語(yǔ)句中就可以完成過(guò)濾，如果sql語(yǔ)句過(guò)于復(fù)雜，可以鏈?zhǔn)讲檎疫^(guò)濾
id := db.SQL("select * from public.user").Query().Results[0]["id"]
fmt.Println(id)
}
//6.執(zhí)行更新
//6.1 ORM方式: 只有非0值的屬性會(huì)被更新，user的id和created都是默認(rèn)零值，不被處理
if false {
user :=new(User)
user.Name="ftx"
//[xorm] [info] 2018/02/08 12:04:01.330624 [SQL] UPDATE "user" SET "name" = $1 WHERE "id"=$2 []interface {}{"ftx", 4}
db.Id(4).Update(user)
}
//6.2 SQL方式略,和insert類(lèi)似
//7.事務(wù)
//7.1簡(jiǎn)單事務(wù)
if false {
session :=db.NewSession()
defer session.Close()
session.Begin()
//業(yè)務(wù):新添加學(xué)生，并且創(chuàng)建新的班級(jí)，如果班級(jí)因?yàn)橹麈I沖突創(chuàng)建失敗，則整個(gè)事務(wù)回滾
_,err =session.SQL("insert into public.user(name,class_id) values('ft13',2)").Execute()
//表中已經(jīng)有id=3的班級(jí)了
_,err =session.SQL("insert into public.class(id,name) values(3,'高中3班')").Execute()
if err!=nil {
session.Rollback()
}
session.Commit()
}
//7.2嵌套事務(wù)
if false {
session := db.NewSession()
defer session.Close()
session.Begin()
_,err=session.Exec("insert into public.user(name,class_id) values('ft23',2)")
if err!=nil {
session.Rollback()
}
_,err=session.Exec("insert into public.user(id,name,class_id) values(1,'ft24',2)")
if err!=nil {
session.Rollback()
}
tx,_:=session.BeginTrans()
_,err=tx.Session().Exec("insert into public.user(name,class_id) values('ft25',2)")
if err!=nil {
tx.RollbackTrans()
}
tx.CommitTrans()
session.Commit()
}
//8.緩存:使用Raw方式修改以后，需要清理緩存
if true {
//建立500條數(shù)據(jù)
session := db.NewSession()
defer session.Close()
if false {
session.Begin()
for i := 30; i < 530; i++ {
value := "ft" + strconv.Itoa(i)
_, err = session.Exec("insert into public.user(name) values(?)", value)
if err != nil {
session.Rollback()
}
}
session.Commit()
}
//查詢(xún)前531條數(shù)據(jù)，并隨意輸出其中一條
users := make([]User,10)
db.SQL("select * from public.user where id<531 order by id").Find(&users)
fmt.Println("讀第一遍:","id:",users[50].Id,"name:",users[50].Name)
db.SQL("select * from public.user where id<531 order by id").Find(&users)
fmt.Println("讀第二遍:","id:",users[50].Id,"name:",users[50].Name)
var step int =1
stepString := users[50].Name + strconv.Itoa(step)
session.Exec("update public.user set name=? where id =45",stepString)
//清理緩存
db.ClearCache(new(User))
time.Sleep(5*time.Second)
session.SQL("select * from public.user where id<531 order by id").Find(&users)
fmt.Println("讀第三遍:","id:",users[50].Id,"name:",users[50].Name)
//雖然很不好意思，但是就算開(kāi)啟了緩存數(shù)據(jù)也是臟了
}
//9.讀寫(xiě)分離
if false {
//假設(shè)有多臺(tái)服務(wù)器用來(lái)響應(yīng)客戶(hù)的讀請(qǐng)求
var dbGroup *xorm.EngineGroup
conns :=[]string {
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
"postgres://postgres:123@localhost:5432/test?sslmode=disable",
}
//負(fù)載均衡策略:(特性自行百度)
// 1.xorm.RandomPolicy()隨機(jī)訪(fǎng)問(wèn)負(fù)載均衡,
// 2.xorm.WeightRandomPolicy([]int{2, 3,4})權(quán)重隨機(jī)負(fù)載均衡
// 3.xorm.RoundRobinPolicy() 輪詢(xún)?cè)L問(wèn)負(fù)載均衡
// 4.xorm.WeightRoundRobinPolicy([]int{2, 3,4}) 權(quán)重輪訓(xùn)負(fù)載均衡
// 5.xorm.LeastConnPolicy()最小連接數(shù)負(fù)載均衡
dbGroup, err = xorm.NewEngineGroup("postgres", conns, xorm.RoundRobinPolicy())
//dbGroup使用方法和db一致
//簡(jiǎn)單查詢(xún)
dbGroup.SQL("inser into public.users(name) values('ft2000')").Execute()
dbGroup.Exec("inser into public.users(name) values('ft2001')")
//事務(wù)查詢(xún)
session :=dbGroup.NewSession()
defer session.Close()
session.Begin()
_,err = session.Exec("inser into public.users(name) values('ft2001')")
if err!=nil {
session.Rollback()
}
session.Commit()
}
}
//注意:
//1.postgresql好像不會(huì)默認(rèn)按id增長(zhǎng)排序，所以書(shū)寫(xiě)sql語(yǔ)句要提前寫(xiě)好order by id ，樓主沒(méi)怎么寫(xiě)，咳咳
//2. [5.4] postgresql建表會(huì)建在public策略的table里，所以查詢(xún)語(yǔ)句表明寫(xiě)的是public.xxxx,這也造成了連表orm查詢(xún)會(huì)發(fā)生前綴報(bào)錯(cuò),比如變成了"SELECT * FROM "public"."user" INNER JOIN "class" ON user.class_id=class.id 這和內(nèi)部的split有關(guān)，
//3.[8.]帶的緩存好像很容易失效,在創(chuàng)建500個(gè)數(shù)據(jù)后，經(jīng)過(guò)查查改查的操作，查詢(xún)到的結(jié)果是一樣的始終是一樣的，本來(lái)改值之后應(yīng)該最后一遍查會(huì)變化，然而并沒(méi)有,緩存功能即使清理了緩存，還是會(huì)讀到臟的
補(bǔ)充：golang xorm框架對(duì)應(yīng)pg數(shù)據(jù)庫(kù)字段類(lèi)型參照表
1.左邊是golang字段類(lèi)型，右邊是pg數(shù)據(jù)庫(kù)字段類(lèi)型
int integer time.Time timestamp int8 smallint float64 numeric(8,3) (只要是numeric統(tǒng)統(tǒng)使用float64) string text string varchar
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教。
相關(guān)文章
下面小編就為大家?guī)?lái)一篇go1.8之安裝配置具體步驟。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-06-06
Go語(yǔ)言獲取本機(jī)邏輯CPU數(shù)量的方法
這篇文章主要介紹了Go語(yǔ)言獲取本機(jī)邏輯CPU數(shù)量的方法,實(shí)例分析了runtime庫(kù)的操作技巧,需要的朋友可以參考下2015-03-03
解決Go中攔截HTTP流數(shù)據(jù)時(shí)字段丟失的問(wèn)題
在開(kāi)發(fā)高并發(fā)的Web應(yīng)用時(shí),尤其是在處理HTTP代理和流數(shù)據(jù)攔截的場(chǎng)景下,遇到數(shù)據(jù)丟失的問(wèn)題并不罕見(jiàn),最近,在一個(gè)項(xiàng)目中,我遇到了一個(gè)棘手的問(wèn)題：在攔截并轉(zhuǎn)發(fā)HTTP流數(shù)據(jù)的過(guò)程中,某些數(shù)據(jù)字段因?yàn)樘幚磉^(guò)快而被丟失,所以本文給大家介紹如何解決這個(gè)問(wèn)題2024-08-08
記一次go語(yǔ)言使用time.Duration類(lèi)型踩過(guò)的坑
本文主要介紹了記一次go語(yǔ)言使用time.Duration類(lèi)型踩過(guò)的坑，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2022-01-01
GoLang日志監(jiān)控系統(tǒng)實(shí)現(xiàn)
這篇文章主要介紹了GoLang日志監(jiān)控系統(tǒng)的實(shí)現(xiàn)流程，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧2022-12-12
詳解用Go語(yǔ)言實(shí)現(xiàn)工廠(chǎng)模式(Golang經(jīng)典編程案例)
這篇文章主要介紹了詳解用Go語(yǔ)言實(shí)現(xiàn)工廠(chǎng)模式(Golang經(jīng)典編程案例),文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-04-04
Go基礎(chǔ)教程系列之defer、panic和recover詳解
這篇文章主要介紹了Go基礎(chǔ)教程系列之defer、panic和recover,需要的朋友可以參考下2022-04-04
golang?select?機(jī)制和超時(shí)問(wèn)題
golang 中的協(xié)程使用非常方便，但是協(xié)程什么時(shí)候結(jié)束是一個(gè)控制問(wèn)題，可以用 select 配合使用，這篇文章主要介紹了golang?select?機(jī)制和超時(shí)問(wèn)題,需要的朋友可以參考下2022-06-06
Python?中非常知名的爬蟲(chóng)框架有Scrapy，Go?中也有一些?star?數(shù)較高的爬蟲(chóng)框架，colly就是其中的佼佼者，它?API?簡(jiǎn)潔，性能優(yōu)良，開(kāi)箱即用，今天就來(lái)快速學(xué)習(xí)一下吧2023-07-07
這篇文章主要介紹了GO語(yǔ)言延遲函數(shù)defer用法,較為詳細(xì)的分析了GO語(yǔ)言的特性與具體用法,并給出了一個(gè)比較典型的應(yīng)用實(shí)例,具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2014-12-12