go語言 xorm框架 postgresql 的用法及詳細註解
阿新 • • 發佈：2020-12-25
xorm用於在golang中連結資料庫，並完成增刪改差操作，不管是orm還是raw方式都十分的新穎簡單。
sql語句
postgresql pgadmin
/*表結構*/
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
每個功能都使用了if語句來方便開關，測試那塊就開啟哪塊~~~
package main
import (
_ "github.com/lib/pq"
"github.com/xormplus/xorm"
"fmt"
"time"
"strconv"
)
//使用者表結構
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表結構
type Class struct {
Id int `xorm:"not null pk autoincr INTEGER"`
Name string `xorm:"VARCHAR(20)"`
}
//臨時表結構
type UserClass struct{
User `xorm:"extends"`
Name string
}
//此方法僅用於orm查詢時，查詢表認定
func (UserClass) TableName() string {
return "public.user"
}
func main() {
//1.建立db引擎
db,err := xorm.NewPostgreSQL("postgres://postgres:123@localhost:5432/test?sslmode=disable")
if err != nil {
fmt.Println(err)
}
//2.顯示sql語句
db.ShowSQL(true)
//3.設定連線數
db.SetMaxIdleConns(2000)
db.SetMaxOpenConns(1000)
cacher := xorm.NewLRUCacher(xorm.NewMemoryStore(),500)//快取的條數
db.SetDefaultCacher(cacher)
//4.執行插入語句的幾種方式
//4.1 orm插入方式:不好控制，如果僅僅插入的物件的屬性是name='ftq',那麼其他的零值會一同insert，orm方式對零值的處理有點不太好
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():單事務單次提交
if false{
sql:="insert into public.user(name) values(?)"
db.Exec(sql,"ft4")
}
//4.2.2 db.SQL().Execute():單事務準備了Statement處理sql語句
if false{
sql:="insert into public.user(name) values(?)"
db.SQL(sql,"ft5").Execute()
}
//4.2.3使用sql配置檔案管理語句,兩種載入配置的方式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.執行查詢的幾種方式
//5.1 orm查詢:在user初始化的時候,該orm查詢直接通過掃描user型別確定表名;組合使用Where(),Get()
if false {
user := new(User)
boolget,err2 :=db.Where("id=?",5).Get(user)
fmt.Println(boolget,err2,user)
}
//5.2 orm查詢:組合使用Where(),Get(),And()
if false {
user := new(User)
boolget,5).And("name=?","ft7").And("id>?",3).Get(user)
fmt.Println(boolget,user)
}
//5.3 orm查詢: AllCols()查詢所有列，Cols()查詢部分列，Find()解析多行結果,Get()解析單行結果
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查詢:連線查詢Join()
if false {
users := new([]UserClass)
db.Join("INNER","class","user.class_id=class.id").Find(users)
//db.SQL("select u.id,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查詢略
if false {
//和insert類似,Find查詢多行結果，Get獲取 單行結果
users := new([]UserClass)
db.SQL("select u.id,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 鏈式查詢
if false {
//值得一提的是，支援查詢某行的某個欄位，不過一般在sql語句中就可以完成過濾，如果sql語句過於複雜，可以鏈式查詢過濾
id := db.SQL("select * from public.user").Query().Results[0]["id"]
fmt.Println(id)
}
//6.執行更新
//6.1 ORM方式: 只有非0值的屬性會被更新，user的id和created都是預設零值，不被處理
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類似
//7.事務
//7.1簡單事務
if false {
session :=db.NewSession()
defer session.Close()
session.Begin()
//業務:新新增學生，並且建立新的班級，如果班級因為主鍵衝突建立失敗，則整個事務回滾
_,err =session.SQL("insert into public.user(name,class_id) values('ft13',2)").Execute()
//表中已經有id=3的班級了
_,err =session.SQL("insert into public.class(id,name) values(3,'高中3班')").Execute()
if err!=nil {
session.Rollback()
}
session.Commit()
}
//7.2巢狀事務
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條資料
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()
}
//查詢前531條資料，並隨意輸出其中一條
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("讀第二遍:",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("讀第三遍:",users[50].Name)
//雖然很不好意思，但是就算開啟了快取資料也是髒了
}
//9.讀寫分離
if false {
//假設有多臺伺服器用來響應客戶的讀請求
var dbGroup *xorm.EngineGroup
conns :=[]string {
"postgres://postgres:123@localhost:5432/test?sslmode=disable","postgres://postgres:123@localhost:5432/test?sslmode=disable",}
//負載均衡策略:(特性自行百度)
// 1.xorm.RandomPolicy()隨機訪問負載均衡,// 2.xorm.WeightRandomPolicy([]int{2,3,4})權重隨機負載均衡
// 3.xorm.RoundRobinPolicy() 輪詢訪問負載均衡
// 4.xorm.WeightRoundRobinPolicy([]int{2,4}) 權重輪訓負載均衡
// 5.xorm.LeastConnPolicy()最小連線數負載均衡
dbGroup,err = xorm.NewEngineGroup("postgres",conns,xorm.RoundRobinPolicy())
//dbGroup使用方法和db一致
//簡單查詢
dbGroup.SQL("inser into public.users(name) values('ft2000')").Execute()
dbGroup.Exec("inser into public.users(name) values('ft2001')")
//事務查詢
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好像不會預設按id增長排序，所以書寫sql語句要提前寫好order by id ，樓主沒怎麼寫，咳咳
//2. [5.4] postgresql建表會建在public策略的table裡，所以查詢語句表明寫的是public.xxxx,這也造成了連表orm查詢會發生字首報錯,比如變成了"SELECT * FROM "public"."user" INNER JOIN "class" ON user.class_id=class.id 這和內部的split有關，
//3.[8.]帶的快取好像很容易失效,在建立500個數據後，經過查查改查的操作，查詢到的結果是一樣的始終是一樣的，本來改值之後應該最後一遍查會變化，然而並沒有,快取功能即使清理了快取，還是會讀到髒的
補充：golang xorm框架對應pg資料庫欄位型別參照表
1.左邊是golang欄位型別，右邊是pg資料庫欄位型別
int integer time.Time timestamp int8 smallint float64 numeric(8,3) (只要是numeric統統使用float64) string text string varchar
以上為個人經驗，希望能給大家一個參考，也希望大家多多支援我們。如有錯誤或未考慮完全的地方，望不吝賜教。