setup.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162
  1. package models
  2. import (
  3. "fmt"
  4. "log/slog"
  5. )
  6. import (
  7. "gorm.io/driver/postgres"
  8. "gorm.io/gorm"
  9. )
  10. import (
  11. "resource-server/common"
  12. "resource-server/logger"
  13. )
  14. var (
  15. DB *gorm.DB
  16. err error
  17. )
  18. func panicHelper(err error) {
  19. if err != nil {
  20. panic(err)
  21. }
  22. }
  23. func migrate() {
  24. panicHelper(DB.AutoMigrate(&ConfigItem{}))
  25. var count int64
  26. DB.Model(&ConfigItem{}).Count(&count)
  27. if count == 0 {
  28. panicHelper(initConfigItem())
  29. }
  30. }
  31. func SetupGorm(m bool) {
  32. slog.Info("setup gorm")
  33. dsn := fmt.Sprintf("host=%s user=%s password=%s dbname=%s port=%d sslmode=disable TimeZone=Asia/Shanghai",
  34. common.PostgresConfig.Ip,
  35. common.PostgresConfig.Username,
  36. common.PostgresConfig.Password,
  37. common.PostgresConfig.Name,
  38. common.PostgresConfig.Port,
  39. )
  40. if common.LoggerConfig.LogLevel == "debug" {
  41. DB, err = gorm.Open(postgres.Open(dsn), &gorm.Config{
  42. Logger: logger.NewGormLogger(logger.WithGroup("gorm")),
  43. })
  44. } else {
  45. DB, err = gorm.Open(postgres.Open(dsn), &gorm.Config{})
  46. }
  47. if err != nil {
  48. panic(err)
  49. }
  50. if m {
  51. migrate()
  52. }
  53. slog.Info("setup gorm ok")
  54. }