|
@@ -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)
|
|
|
}
|