kzkzzzz
/
mycommon
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update

main
kzkzzzz 2024-06-01 18:17:41 +08:00
parent e9756f7f54
commit 0b36406c6f
4 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
mymysql/mysql.go
View File

@ -15,9 +15,9 @@ var (
DefaultConfig = &Config{ DefaultConfig = &Config{
Dsn: "root:root@tcp(127.0.0.1:3306)/?loc=Local&charset=utf8mb4&parseTime=true", Dsn: "root:root@tcp(127.0.0.1:3306)/?loc=Local&charset=utf8mb4&parseTime=true",
MaxOpenConn: 32, MaxOpenConn: 32,
MaxIdleConn: 16, MaxIdleConn: 8,
MaxLifeTime: "1h", MaxLifeTime: "4h",
MaxIdleTime: "10m", MaxIdleTime: "15m",
Debug: true, Debug: true,
GormLogger: gormLogger.Default.LogMode(gormLogger.Info), GormLogger: gormLogger.Default.LogMode(gormLogger.Info),
} }
@ -37,7 +37,7 @@ type (
} }
) )
func Instance(key ...string) *gorm.DB { func DB(key ...string) *gorm.DB {
var key0 string var key0 string
if len(key) > 0 { if len(key) > 0 {
@ -139,7 +139,7 @@ func NewGormLogger(writer gormLogger.Writer, gormLoggerConfig gormLogger.Config)
} }
func CloseInstance(key string) { func CloseInstance(key string) {
db, _ := Instance(key).DB() db, _ := DB(key).DB()
db.Close() db.Close()
} }

2
mymysql/mysql_test.go
View File

@ -23,7 +23,7 @@ func TestMysql(t *testing.T) {
defer CloseAllInstance() defer CloseAllInstance()
var res = make(map[string]interface{}) var res = make(map[string]interface{})
err = Instance().Table("image").Limit(1).Take(&res).Error err = DB().Table("image").Limit(1).Take(&res).Error
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
return return

8
myredis/redis.go
View File

@ -17,8 +17,8 @@ var (
DB: 0, DB: 0,
PoolSize: 16, PoolSize: 16,
MinIdleConn: 4, MinIdleConn: 4,
MaxConnAge: "1h", MaxConnAge: "4h",
IdleTimeout: "10m", IdleTimeout: "15m",
} }
instanceMap = make(map[string]*MyRedis) instanceMap = make(map[string]*MyRedis)
@ -40,7 +40,7 @@ type (
} }
) )
func Instance(key ...string) *MyRedis { func DB(key ...string) *MyRedis {
var key0 string var key0 string
if len(key) > 0 { if len(key) > 0 {
@ -170,7 +170,7 @@ func (r *MyRedis) SetJson(key string, value interface{}, t ...time.Duration) (st
} }
func CloseInstance(key string) { func CloseInstance(key string) {
Instance(key).Client.Close() DB(key).Client.Close()
} }
func CloseAllInstance() { func CloseAllInstance() {

4
myredis/redis_test.go
View File

@ -23,14 +23,14 @@ func TestRedis(t *testing.T) {
} }
defer CloseAllInstance() defer CloseAllInstance()
set, err := Instance().Set(context.Background(), "name", "qwe123", time.Minute).Result() set, err := DB().Set(context.Background(), "name", "qwe123", time.Minute).Result()
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
return return
} }
fmt.Println(set) fmt.Println(set)
get, err := Instance().Get(context.Background(), "name").Result() get, err := DB().Get(context.Background(), "name").Result()
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
return return