适配了Gorm的v1.20.0版本,迁移初始表的注册函数至gorm.go并优化了代码,注释了sqlite的初始化,需要的自行打开注释,默认使用mysql
This commit is contained in:
+56
-27
@@ -2,16 +2,18 @@ package initialize
|
||||
|
||||
import (
|
||||
"gin-vue-admin/global"
|
||||
"gin-vue-admin/model"
|
||||
"go.uber.org/zap"
|
||||
"gorm.io/driver/mysql"
|
||||
"gorm.io/driver/postgres"
|
||||
"gorm.io/driver/sqlite"
|
||||
"gorm.io/driver/sqlserver"
|
||||
"gorm.io/gorm"
|
||||
"gorm.io/gorm/logger"
|
||||
"os"
|
||||
)
|
||||
|
||||
var err error
|
||||
|
||||
// Gorm 初始化数据库并产生数据库全局变量
|
||||
func Gorm() {
|
||||
switch global.GVA_CONFIG.System.DbType {
|
||||
@@ -19,17 +21,44 @@ func Gorm() {
|
||||
GormMysql()
|
||||
case "postgresql":
|
||||
GormPostgreSql()
|
||||
case "sqlite":
|
||||
GormSqlite()
|
||||
//case "sqlite": // sqlite需要gcc支持 windows用户需要自行安装gcc 如需使用打开注释即可
|
||||
// GormSqlite()
|
||||
case "sqlserver":
|
||||
GormSqlServer()
|
||||
}
|
||||
}
|
||||
|
||||
// GormDBTables 注册数据库表专用
|
||||
func GormDBTables(db *gorm.DB) {
|
||||
err := db.AutoMigrate(
|
||||
model.SysUser{},
|
||||
model.SysAuthority{},
|
||||
model.SysApi{},
|
||||
model.SysBaseMenu{},
|
||||
model.SysBaseMenuParameter{},
|
||||
model.JwtBlacklist{},
|
||||
model.SysWorkflow{},
|
||||
model.SysWorkflowStepInfo{},
|
||||
model.SysDictionary{},
|
||||
model.SysDictionaryDetail{},
|
||||
model.ExaFileUploadAndDownload{},
|
||||
model.ExaFile{},
|
||||
model.ExaFileChunk{},
|
||||
model.ExaSimpleUploader{},
|
||||
model.ExaCustomer{},
|
||||
model.SysOperationRecord{},
|
||||
)
|
||||
if err != nil {
|
||||
global.GVA_LOG.Error("register table failed", zap.Any("err", err))
|
||||
os.Exit(0)
|
||||
}
|
||||
global.GVA_LOG.Debug("register table success")
|
||||
}
|
||||
|
||||
// GormMysql 初始化Mysql数据库
|
||||
func GormMysql() {
|
||||
m := global.GVA_CONFIG.Mysql
|
||||
dsn := m.Username + ":" + m.Password + "@(" + m.Path + ")/" + m.Dbname + "?" + m.Config
|
||||
dsn := m.Username + ":" + m.Password + "@tcp(" + m.Path + ")/" + m.Dbname + "?" + m.Config
|
||||
mysqlConfig := mysql.Config{
|
||||
DSN: dsn, // DSN data source name
|
||||
DefaultStringSize: 191, // string 类型字段的默认长度
|
||||
@@ -39,12 +68,12 @@ func GormMysql() {
|
||||
SkipInitializeWithVersion: false, // 根据版本自动配置
|
||||
}
|
||||
gormConfig := config(m.LogMode)
|
||||
if db, err := gorm.Open(mysql.New(mysqlConfig), gormConfig); err != nil {
|
||||
if global.GVA_DB, err = gorm.Open(mysql.New(mysqlConfig), gormConfig); err != nil {
|
||||
global.GVA_LOG.Error("MySQL启动异常", zap.Any("err", err))
|
||||
os.Exit(0)
|
||||
} else {
|
||||
global.GVA_DB = db
|
||||
sqlDB, _ := db.DB()
|
||||
GormDBTables(global.GVA_DB)
|
||||
sqlDB, _ := global.GVA_DB.DB()
|
||||
sqlDB.SetMaxIdleConns(m.MaxIdleConns)
|
||||
sqlDB.SetMaxOpenConns(m.MaxOpenConns)
|
||||
}
|
||||
@@ -59,42 +88,42 @@ func GormPostgreSql() {
|
||||
PreferSimpleProtocol: p.PreferSimpleProtocol, // 禁用隐式 prepared statement
|
||||
}
|
||||
gormConfig := config(p.Logger)
|
||||
if db, err := gorm.Open(postgres.New(postgresConfig), gormConfig); err != nil {
|
||||
if global.GVA_DB, err = gorm.Open(postgres.New(postgresConfig), gormConfig); err != nil {
|
||||
global.GVA_LOG.Error("PostgreSql启动异常", zap.Any("err", err))
|
||||
os.Exit(0)
|
||||
} else {
|
||||
global.GVA_DB = db
|
||||
sqlDB, _ := db.DB()
|
||||
GormDBTables(global.GVA_DB)
|
||||
sqlDB, _ := global.GVA_DB.DB()
|
||||
sqlDB.SetMaxIdleConns(p.MaxIdleConns)
|
||||
sqlDB.SetMaxOpenConns(p.MaxOpenConns)
|
||||
}
|
||||
}
|
||||
|
||||
// GormSqlite 初始化Sqlite数据库
|
||||
func GormSqlite() {
|
||||
s := global.GVA_CONFIG.Sqlite
|
||||
gormConfig := config(s.Logger)
|
||||
if db, err := gorm.Open(sqlite.Open(s.Path), gormConfig); err != nil {
|
||||
global.GVA_LOG.Error("Sqlite启动异常", zap.Any("err", err))
|
||||
os.Exit(0)
|
||||
} else {
|
||||
global.GVA_DB = db
|
||||
sqlDB, _ := db.DB()
|
||||
sqlDB.SetMaxIdleConns(s.MaxIdleConns)
|
||||
sqlDB.SetMaxOpenConns(s.MaxOpenConns)
|
||||
}
|
||||
}
|
||||
// GormSqlite 初始化Sqlite数据库 sqlite需要gcc支持 windows用户需要自行安装gcc 如需使用打开注释即可
|
||||
//func GormSqlite() {
|
||||
// s := global.GVA_CONFIG.Sqlite
|
||||
// gormConfig := config(s.Logger)
|
||||
// if global.GVA_DB, err = gorm.Open(sqlite.Open(s.Path), gormConfig); err != nil {
|
||||
// global.GVA_LOG.Error("Sqlite启动异常", zap.Any("err", err))
|
||||
// os.Exit(0)
|
||||
// } else {
|
||||
// GormDBTables(global.GVA_DB)
|
||||
// sqlDB, _ := global.GVA_DB.DB()
|
||||
// sqlDB.SetMaxIdleConns(s.MaxIdleConns)
|
||||
// sqlDB.SetMaxOpenConns(s.MaxOpenConns)
|
||||
// }
|
||||
//}
|
||||
|
||||
// GormSqlite 初始化Sqlite数据库
|
||||
func GormSqlServer() {
|
||||
ss := global.GVA_CONFIG.Sqlserver
|
||||
dsn := "sqlserver://" + ss.Username + ":" + ss.Password + "@" + ss.Path + "?database=gorm"
|
||||
if db, err := gorm.Open(sqlserver.Open(dsn), &gorm.Config{}); err != nil {
|
||||
if global.GVA_DB, err = gorm.Open(sqlserver.Open(dsn), &gorm.Config{}); err != nil {
|
||||
global.GVA_LOG.Error("SqlServer启动异常", zap.Any("err", err))
|
||||
os.Exit(0)
|
||||
} else {
|
||||
global.GVA_DB = db
|
||||
sqlDB, _ := db.DB()
|
||||
GormDBTables(global.GVA_DB)
|
||||
sqlDB, _ := global.GVA_DB.DB()
|
||||
sqlDB.SetMaxIdleConns(ss.MaxIdleConns)
|
||||
sqlDB.SetMaxOpenConns(ss.MaxOpenConns)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user