database.go 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839
  1. package config
  2. import (
  3. "fmt"
  4. "github.com/spf13/viper"
  5. "go.uber.org/zap"
  6. "gorm.io/driver/mysql"
  7. "gorm.io/gorm"
  8. "time"
  9. )
  10. var Mdb *gorm.DB
  11. var err error
  12. func init() {
  13. dsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=True&loc=Local", viper.GetString("database.username"), viper.GetString("database.password"), viper.GetString("database.host"), viper.GetInt("database.port"), viper.GetString("database.name"))
  14. Mdb, err = gorm.Open(mysql.Open(dsn), &gorm.Config{
  15. SkipDefaultTransaction: true, // 禁用默认事务(提高运行速度)
  16. DisableForeignKeyConstraintWhenMigrating: true, // 禁用自动创建外键约束
  17. })
  18. if err != nil {
  19. zap.L().Error("数据库连接出错 " + err.Error())
  20. panic("数据库连接出错,请检查参数: " + err.Error())
  21. }
  22. // 获取通用数据库对象 sql.DB ,然后使用其提供的功能
  23. sqlDB, _ := Mdb.DB()
  24. // SetMaxIdleConns 用于设置连接池中空闲连接的最大数量。
  25. sqlDB.SetMaxIdleConns(10)
  26. // SetMaxOpenConns 设置打开数据库连接的最大数量。
  27. sqlDB.SetMaxOpenConns(100)
  28. // SetConnMaxLifetime 设置了连接可复用的最大时间。
  29. sqlDB.SetConnMaxLifetime(59 * time.Second)
  30. }