database.go 663 B

12345678910111213141516171819202122232425262728293031323334
  1. // Project: go-orm
  2. // File: pkg/database/database.go
  3. // Package database 数据库连接
  4. package database
  5. import (
  6. "database/sql"
  7. "fmt"
  8. "gorm.io/gorm"
  9. gormlgger "gorm.io/gorm/logger"
  10. )
  11. // DB 数据库连接实例
  12. var DB *gorm.DB
  13. var SQLDB *sql.DB
  14. func Connect(dbConfig gorm.Dialector, _logger gormlgger.Interface) {
  15. // 使用 gorm.Open 连接数据库
  16. var err error
  17. DB, err = gorm.Open(dbConfig, &gorm.Config{
  18. Logger: _logger,
  19. })
  20. // 处理错误
  21. if err != nil {
  22. fmt.Println("数据库连接失败", err.Error())
  23. }
  24. // 获取底层的 sql.DB 实例
  25. SQLDB, err = DB.DB()
  26. if err != nil {
  27. fmt.Println("数据库连接失败", err.Error())
  28. }
  29. }