orm

Documentation

Index

• Constants
• Variables
• func AppendEntity(entity ...interface{})
• func ApplyMigrate() error
• func DefaulViewSql(tablePrefix, view, query string) string
• func DisableGormLogger() gormlogger.Interface
• func InitDB(sub string, logger *zap.Logger) *gorm.DB
• func InitDBWithPrefix(sub string, prefix string) *gorm.DB
• func InitDefaultDB(logger *zap.Logger) *gorm.DB
• func InitMysqlViews(tx *gorm.DB, logger *zap.Logger) error
• func MigrateTableAndView(db *gorm.DB, logger *zap.Logger, bus EventBus.Bus)
• func NewGormLogger(slowThreshold time.Duration, logLeveal string) gormlogger.Interface
• func ReplaceTablePrefix(raw string, prefixes ...string) string
• func SessionWithConfig(slowThreshold time.Duration, ignoredNotFound bool) *gorm.Session
• type GetViewSql
• type GormLogger
  • func (l *GormLogger) Error(ctx context.Context, msg string, data ...interface{})
  • func (l *GormLogger) Info(ctx context.Context, msg string, data ...interface{})
  • func (l *GormLogger) LogMode(level gormlogger.LogLevel) gormlogger.Interface
  • func (l *GormLogger) Trace(ctx context.Context, begin time.Time, ...)
  • func (l *GormLogger) Warn(ctx context.Context, msg string, data ...interface{})
• type HealthController
  • func (h *HealthController) Ping(c *gin.Context)
• type OrmDialector

Constants

const (
	KeyInitDB      = ginshared.KeyInitDB
	KeyTablePrefix = "database.tablePrefix"
)

const (
	HealthURIKey   = "healthz"
	HealthURIValue = "/healthz"
)

const ViewMysqlTmp = "CREATE OR REPLACE ALGORITHM = UNDEFINED VIEW %s%s AS %s"

Variables

var DialectorMap = make(map[string]OrmDialector)

var ViewMap = make(map[string]GetViewSql)

Functions

func AppendEntity

func AppendEntity(entity ...interface{})

func ApplyMigrate

func ApplyMigrate() error

func DefaulViewSql

func DefaulViewSql(tablePrefix, view, query string) string

func DisableGormLogger

func DisableGormLogger() gormlogger.Interface

func InitDB

func InitDB(sub string, logger *zap.Logger) *gorm.DB

func InitDBWithPrefix

func InitDBWithPrefix(sub string, prefix string) *gorm.DB

func InitDefaultDB

func InitDefaultDB(logger *zap.Logger) *gorm.DB

func InitMysqlViews

func InitMysqlViews(tx *gorm.DB, logger *zap.Logger) error

func MigrateTableAndView

func MigrateTableAndView(db *gorm.DB, logger *zap.Logger, bus EventBus.Bus)

func NewGormLogger

func NewGormLogger(slowThreshold time.Duration, logLeveal string) gormlogger.Interface

func ReplaceTablePrefix

func ReplaceTablePrefix(raw string, prefixes ...string) string

func SessionWithConfig

func SessionWithConfig(slowThreshold time.Duration, ignoredNotFound bool) *gorm.Session

Types

type GetViewSql

type GetViewSql func(tablePrefix, view, query string) string

type GormLogger

type GormLogger struct {
	ZapLogger *zap.Logger
	Config    gormlogger.Config
}

func (*GormLogger) Error

func (l *GormLogger) Error(ctx context.Context, msg string, data ...interface{})

func (*GormLogger) Info

func (l *GormLogger) Info(ctx context.Context, msg string, data ...interface{})

func (*GormLogger) LogMode

func (l *GormLogger) LogMode(level gormlogger.LogLevel) gormlogger.Interface

func (*GormLogger) Trace

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

func (*GormLogger) Warn

func (l *GormLogger) Warn(ctx context.Context, msg string, data ...interface{})

type HealthController

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

func (*HealthController) Ping

func (h *HealthController) Ping(c *gin.Context)

type OrmDialector

type OrmDialector func(dsn string) gorm.Dialector