orm

Documentation

Index

• func GetBaseConfig(c framework.Container) *contract.DBConfig
• func NewHadeGorm(params ...interface{}) (interface{}, error)
• func WithConfigPath(configPath string) contract.DBOption
• func WithDryRun() contract.DBOption
• func WithFullSaveAssociations() contract.DBOption
• func WithGormConfig(f func(options *contract.DBConfig)) contract.DBOption
• type GormProvider
  • func (h *GormProvider) Boot(container framework.Container) error
  • func (h *GormProvider) IsDefer() bool
  • func (h *GormProvider) Name() string
  • func (h *GormProvider) Params(container framework.Container) []interface{}
  • func (h *GormProvider) Register(container framework.Container) framework.NewInstance
• type HadeGorm
  • func (app *HadeGorm) CanConnect(ctx context.Context, db *gorm.DB) (bool, error)
  • func (app *HadeGorm) GetDB(option ...contract.DBOption) (*gorm.DB, error)
  • func (app *HadeGorm) GetTableColumns(ctx context.Context, db *gorm.DB, table string) ([]contract.TableColumn, error)
  • func (app *HadeGorm) GetTables(ctx context.Context, db *gorm.DB) ([]string, error)
  • func (app *HadeGorm) HasTable(ctx context.Context, db *gorm.DB, table string) (bool, error)
• type OrmLogger
  • func NewOrmLogger(logger contract.Log) *OrmLogger
  • func (o *OrmLogger) Error(ctx context.Context, s string, i ...interface{})
  • func (o *OrmLogger) Info(ctx context.Context, s string, i ...interface{})
  • func (o *OrmLogger) LogMode(level logger.LogLevel) logger.Interface
  • func (o *OrmLogger) Trace(ctx context.Context, begin time.Time, ...)
  • func (o *OrmLogger) Warn(ctx context.Context, s string, i ...interface{})

Functions

func GetBaseConfig

func GetBaseConfig(c framework.Container) *contract.DBConfig

GetBaseConfig 读取database.yaml根目录结构

func NewHadeGorm

func NewHadeGorm(params ...interface{}) (interface{}, error)

NewHadeGorm 代表实例化Gorm

func WithConfigPath

func WithConfigPath(configPath string) contract.DBOption

WithConfigPath 加载配置文件地址

func WithDryRun

func WithDryRun() contract.DBOption

WithDryRun 设置空跑模式

func WithFullSaveAssociations

func WithFullSaveAssociations() contract.DBOption

WithFullSaveAssociations 设置保存时候关联

func WithGormConfig

func WithGormConfig(f func(options *contract.DBConfig)) contract.DBOption

WithGormConfig 表示自行配置Gorm的配置信息

Types

type GormProvider

type GormProvider struct {
}

GormProvider 提供App的具体实现方法

func (*GormProvider) Boot

func (h *GormProvider) Boot(container framework.Container) error

Boot 启动调用

func (*GormProvider) IsDefer

func (h *GormProvider) IsDefer() bool

IsDefer 是否延迟初始化

func (*GormProvider) Name

func (h *GormProvider) Name() string

Name 获取字符串凭证

func (*GormProvider) Params

func (h *GormProvider) Params(container framework.Container) []interface{}

Params 获取初始化参数

func (*GormProvider) Register

func (h *GormProvider) Register(container framework.Container) framework.NewInstance

Register 注册方法

type HadeGorm

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

HadeGorm 代表hade框架的orm实现

func (*HadeGorm) CanConnect

func (app *HadeGorm) CanConnect(ctx context.Context, db *gorm.DB) (bool, error)

func (*HadeGorm) GetDB

func (app *HadeGorm) GetDB(option ...contract.DBOption) (*gorm.DB, error)

GetDB 获取DB实例

func (*HadeGorm) GetTableColumns

func (app *HadeGorm) GetTableColumns(ctx context.Context, db *gorm.DB, table string) ([]contract.TableColumn, error)

func (*HadeGorm) GetTables

func (app *HadeGorm) GetTables(ctx context.Context, db *gorm.DB) ([]string, error)

func (*HadeGorm) HasTable

func (app *HadeGorm) HasTable(ctx context.Context, db *gorm.DB, table string) (bool, error)

type OrmLogger

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

OrmLogger orm的日志实现类, 实现了gorm.Logger.Interface

func NewOrmLogger

func NewOrmLogger(logger contract.Log) *OrmLogger

NewOrmLogger 初始化一个ormLogger,

func (*OrmLogger) Error

func (o *OrmLogger) Error(ctx context.Context, s string, i ...interface{})

Error 对接hade的Error输出

func (*OrmLogger) Info

func (o *OrmLogger) Info(ctx context.Context, s string, i ...interface{})

Info 对接hade的info输出

func (*OrmLogger) LogMode

func (o *OrmLogger) LogMode(level logger.LogLevel) logger.Interface

LogMode 什么都不实现，日志级别完全依赖hade的日志定义

func (*OrmLogger) Trace

func (o *OrmLogger) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error)

Trace 对接hade的Trace输出

func (*OrmLogger) Warn

func (o *OrmLogger) Warn(ctx context.Context, s string, i ...interface{})

Warn 对接hade的Warn输出