1Panel/core/init/db/db.go

60 lines
1.3 KiB
Go
Raw Normal View History

2024-07-19 19:04:11 +08:00
package db
import (
"fmt"
"log"
"os"
"path"
2024-07-19 19:04:11 +08:00
"time"
"github.com/1Panel-dev/1Panel/core/global"
"github.com/glebarez/sqlite"
"gorm.io/gorm"
"gorm.io/gorm/logger"
)
func Init() {
dbPath := path.Join(global.CONF.System.BaseDir, "1panel/db")
if _, err := os.Stat(dbPath); err != nil {
if err := os.MkdirAll(dbPath, os.ModePerm); err != nil {
2024-07-19 19:04:11 +08:00
panic(fmt.Errorf("init db dir failed, err: %v", err))
}
}
fullPath := path.Join(dbPath, global.CONF.System.DbCoreFile)
2024-07-19 19:04:11 +08:00
if _, err := os.Stat(fullPath); err != nil {
f, err := os.Create(fullPath)
if err != nil {
panic(fmt.Errorf("init db file failed, err: %v", err))
}
_ = f.Close()
}
newLogger := logger.New(
log.New(os.Stdout, "\r\n", log.LstdFlags),
logger.Config{
SlowThreshold: time.Second,
LogLevel: logger.Silent,
IgnoreRecordNotFoundError: true,
Colorful: false,
},
)
db, err := gorm.Open(sqlite.Open(fullPath), &gorm.Config{
DisableForeignKeyConstraintWhenMigrating: true,
Logger: newLogger,
})
if err != nil {
panic(err)
}
sqlDB, dbError := db.DB()
if dbError != nil {
panic(dbError)
}
sqlDB.SetConnMaxIdleTime(10)
sqlDB.SetMaxOpenConns(100)
sqlDB.SetConnMaxLifetime(time.Hour)
global.DB = db
global.LOG.Info("init db successfully")
}