gorm.go 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990
  1. package initialize
  2. import (
  3. "gin-vue-admin/global"
  4. "gin-vue-admin/model"
  5. "go.uber.org/zap"
  6. "gorm.io/driver/mysql"
  7. "gorm.io/gorm"
  8. "gorm.io/gorm/logger"
  9. "os"
  10. )
  11. // Gorm 初始化数据库并产生数据库全局变量
  12. func Gorm() *gorm.DB {
  13. switch global.GVA_CONFIG.System.DbType {
  14. case "mysql":
  15. return GormMysql()
  16. default:
  17. return GormMysql()
  18. }
  19. }
  20. // MysqlTables 注册数据库表专用
  21. func MysqlTables(db *gorm.DB) {
  22. err := db.AutoMigrate(
  23. model.SysUser{},
  24. model.SysAuthority{},
  25. model.SysApi{},
  26. model.SysBaseMenu{},
  27. model.SysBaseMenuParameter{},
  28. model.JwtBlacklist{},
  29. model.SysDictionary{},
  30. model.SysDictionaryDetail{},
  31. model.ExaFileUploadAndDownload{},
  32. model.ExaFile{},
  33. model.ExaFileChunk{},
  34. model.ExaSimpleUploader{},
  35. model.ExaCustomer{},
  36. model.SysOperationRecord{},
  37. model.WorkflowProcess{},
  38. model.WorkflowNode{},
  39. model.WorkflowEdge{},
  40. model.WorkflowStartPoint{},
  41. model.WorkflowEndPoint{},
  42. )
  43. if err != nil {
  44. global.GVA_LOG.Error("register table failed", zap.Any("err", err))
  45. os.Exit(0)
  46. }
  47. global.GVA_LOG.Info("register table success")
  48. }
  49. // GormMysql 初始化Mysql数据库
  50. func GormMysql() *gorm.DB {
  51. m := global.GVA_CONFIG.Mysql
  52. dsn := m.Username + ":" + m.Password + "@tcp(" + m.Path + ")/" + m.Dbname + "?" + m.Config
  53. mysqlConfig := mysql.Config{
  54. DSN: dsn, // DSN data source name
  55. DefaultStringSize: 191, // string 类型字段的默认长度
  56. DisableDatetimePrecision: true, // 禁用 datetime 精度,MySQL 5.6 之前的数据库不支持
  57. DontSupportRenameIndex: true, // 重命名索引时采用删除并新建的方式,MySQL 5.7 之前的数据库和 MariaDB 不支持重命名索引
  58. DontSupportRenameColumn: true, // 用 `change` 重命名列,MySQL 8 之前的数据库和 MariaDB 不支持重命名列
  59. SkipInitializeWithVersion: false, // 根据版本自动配置
  60. }
  61. if db, err := gorm.Open(mysql.New(mysqlConfig), gormConfig(m.LogMode)); err != nil {
  62. global.GVA_LOG.Error("MySQL启动异常", zap.Any("err", err))
  63. os.Exit(0)
  64. return nil
  65. } else {
  66. sqlDB, _ := db.DB()
  67. sqlDB.SetMaxIdleConns(m.MaxIdleConns)
  68. sqlDB.SetMaxOpenConns(m.MaxOpenConns)
  69. return db
  70. }
  71. }
  72. // gormConfig 根据配置决定是否开启日志
  73. func gormConfig(mod bool) *gorm.Config {
  74. if mod {
  75. return &gorm.Config{
  76. Logger: logger.Default.LogMode(logger.Info),
  77. DisableForeignKeyConstraintWhenMigrating: true,
  78. }
  79. } else {
  80. return &gorm.Config{
  81. Logger: logger.Default.LogMode(logger.Silent),
  82. DisableForeignKeyConstraintWhenMigrating: true,
  83. }
  84. }
  85. }