You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

98 lines
2.8 KiB

  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. model.WorkflowMove{},
  43. model.ExaWfLeave{},
  44. )
  45. if err != nil {
  46. global.GVA_LOG.Error("register table failed", zap.Any("err", err))
  47. os.Exit(0)
  48. }
  49. global.GVA_LOG.Info("register table success")
  50. }
  51. // GormMysql 初始化Mysql数据库
  52. func GormMysql() *gorm.DB {
  53. m := global.GVA_CONFIG.Mysql
  54. dsn := m.Username + ":" + m.Password + "@tcp(" + m.Path + ")/" + m.Dbname + "?" + m.Config
  55. mysqlConfig := mysql.Config{
  56. DSN: dsn, // DSN data source name
  57. DefaultStringSize: 191, // string 类型字段的默认长度
  58. DisableDatetimePrecision: true, // 禁用 datetime 精度,MySQL 5.6 之前的数据库不支持
  59. DontSupportRenameIndex: true, // 重命名索引时采用删除并新建的方式,MySQL 5.7 之前的数据库和 MariaDB 不支持重命名索引
  60. DontSupportRenameColumn: true, // 用 `change` 重命名列,MySQL 8 之前的数据库和 MariaDB 不支持重命名列
  61. SkipInitializeWithVersion: false, // 根据版本自动配置
  62. }
  63. if db, err := gorm.Open(mysql.New(mysqlConfig), gormConfig(m.LogMode)); err != nil {
  64. global.GVA_LOG.Error("MySQL启动异常", zap.Any("err", err))
  65. os.Exit(0)
  66. return nil
  67. } else {
  68. sqlDB, _ := db.DB()
  69. sqlDB.SetMaxIdleConns(m.MaxIdleConns)
  70. sqlDB.SetMaxOpenConns(m.MaxOpenConns)
  71. return db
  72. }
  73. }
  74. // gormConfig 根据配置决定是否开启日志
  75. func gormConfig(mod bool) *gorm.Config {
  76. if global.GVA_CONFIG.Mysql.LogZap {
  77. return &gorm.Config{
  78. Logger: Default.LogMode(logger.Info),
  79. DisableForeignKeyConstraintWhenMigrating: true,
  80. }
  81. }
  82. if mod {
  83. return &gorm.Config{
  84. Logger: logger.Default.LogMode(logger.Info),
  85. DisableForeignKeyConstraintWhenMigrating: true,
  86. }
  87. } else {
  88. return &gorm.Config{
  89. Logger: logger.Default.LogMode(logger.Silent),
  90. DisableForeignKeyConstraintWhenMigrating: true,
  91. }
  92. }
  93. }