liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

禁用事务

This commit is contained in:
ziming 2025-03-26 14:18:26 +08:00
parent c6e72948e0
commit 5243d6b063
1 changed files with 7 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
internal/data/gorm.go
View File

@ -1,7 +1,6 @@
package data package data
import ( import (
"fmt"
"gorm.io/driver/mysql" "gorm.io/driver/mysql"
"gorm.io/gorm" "gorm.io/gorm"
"gorm.io/gorm/logger" "gorm.io/gorm/logger"
@ -12,17 +11,13 @@ type GormDb struct {
Client *gorm.DB Client *gorm.DB
} }
func NewGormDb(c *conf.Bootstrap) (*GormDb, func()) { func NewGormDb(c *conf.Bootstrap) *GormDb {
db1, mf := db(c.Data.Db)
cleanup := func() {
mf()
}
return &GormDb{ return &GormDb{
Client: db1, Client: db(c.Data.Db),
}, cleanup }
} }
func db(data *conf.Data_Database) (*gorm.DB, func()) { func db(data *conf.Data_Database) *gorm.DB {
gormDB, err := gorm.Open( gormDB, err := gorm.Open(
mysql.Open(data.Source), mysql.Open(data.Source),
@ -41,16 +36,10 @@ func db(data *conf.Data_Database) (*gorm.DB, func()) {
panic("failed to gormDB " + err.Error()) panic("failed to gormDB " + err.Error())
} }
sqlDB.SetMaxIdleConns(1000) sqlDB.SetMaxIdleConns(500)
sqlDB.SetMaxOpenConns(1000) sqlDB.SetMaxOpenConns(2000)
return gormDB, func() { return gormDB
if gormDB != nil {
fmt.Println("关闭 db")
}
}
} }
//func db(data *conf.Data_Database) (*gorm.DB, func()) { //func db(data *conf.Data_Database) (*gorm.DB, func()) {