orm

Documentation

Index

• Variables
• func GetDatabaseConfig(connectionName []string, config *config.Config) config.Database
• func GetDatabaseSourceDns(config *config.Config, connectionName ...string) string
• func GetSqlDb(driver string, dsn string) (*sql.DB, error)
• func GetTablePrefix(options ...string) string
• type DBManager
  • func NewDBManager(cfg *config.Config) (*DBManager, error)
  • func (m *DBManager) Close() error
  • func (m *DBManager) DB(name ...string) (*sql.DB, error)
  • func (m *DBManager) DefaultName() string
  • func (m *DBManager) GetDB() *sql.DB
  • func (m *DBManager) Ping(ctx context.Context) error

Variables

var ProviderSet = wire.NewSet(NewDBManager)

ProviderSet 是 orm 包的 Wire provider 集合，用于依赖注入

Functions

func GetDatabaseConfig

func GetDatabaseConfig(connectionName []string, config *config.Config) config.Database

func GetDatabaseSourceDns

func GetDatabaseSourceDns(config *config.Config, connectionName ...string) string

GetDatabaseSourceDns 根据配置生成数据库连接字符串 connectionName 参数用于指定要使用的数据库连接名称，默认值为空字符串

func GetSqlDb

func GetSqlDb(driver string, dsn string) (*sql.DB, error)

func GetTablePrefix

func GetTablePrefix(options ...string) string

Types

type DBManager

type DBManager struct {
	// contains filtered or unexported fields
}

DBManager 数据库连接池管理器：支持按名管理多个数据库连接（惰性创建 + 并发安全单例）

func NewDBManager

func NewDBManager(cfg *config.Config) (*DBManager, error)

NewDBManager 创建并配置数据库连接池管理器 接收 *config.Config 作为显式依赖，便于 Wire 进行依赖注入 启动时立即创建默认连接，连接失败尽早暴露

func (*DBManager) Close

func (m *DBManager) Close() error

Close 优雅关闭所有已创建的数据库连接

func (*DBManager) DB

func (m *DBManager) DB(name ...string) (*sql.DB, error)

DB 按名获取数据库连接（无参 = 默认连接），首次访问惰性创建 配置了多个 database.connections 时，可用此方法切换不同连接（如读写分离、多库）

func (*DBManager) DefaultName

func (m *DBManager) DefaultName() string

DefaultName 返回默认连接名

func (*DBManager) GetDB

func (m *DBManager) GetDB() *sql.DB

GetDB 获取默认 *sql.DB 实例（兼容旧 API）

func (*DBManager) Ping

func (m *DBManager) Ping(ctx context.Context) error

Ping 执行数据库健康检查（默认连接）