orm

Documentation

Index

• Constants
• Variables
• func AppendEntity(entity ...interface{})
• func ApplyMigrate() error
• func DefaulViewSql(tablePrefix, view, query string) string
• func DoCleanup(settingkey string, tables []string, col string, duration string) interface{}
• func InitDB(sub string, logger *zap.Logger) *gorm.DB
• func InitDefaultDB(logger *zap.Logger) *gorm.DB
• func InitMysqlViews(tx *gorm.DB, logger *zap.Logger) error
• func InitScheduleCleanupJob(settingkey string) interface{}
• func MigrateTableAndView(db *gorm.DB, logger *zap.Logger)
• func SessionWithConfig(slowThreshold time.Duration, ignoredNotFound bool) *gorm.Session
• type CleanupService
  • func (cs *CleanupService) Cleanup(req *DBCleanupReq) error
  • func (cs *CleanupService) GetDefaultRequest() *DBCleanupReq
  • func (cs *CleanupService) RegConnection(name string, db *gorm.DB)
• type DBCleanupReq
• type DBCronJob
  • func (job *DBCronJob) FireJob()
• type GetViewSql
• 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 DoCleanup

func DoCleanup(settingkey string, tables []string, col string, duration string) interface{}

func InitDB

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

func InitDefaultDB

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

func InitMysqlViews

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

func InitScheduleCleanupJob

func InitScheduleCleanupJob(settingkey string) interface{}

func MigrateTableAndView

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

func SessionWithConfig

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

Types

type CleanupService

type CleanupService struct {
	DBMap map[string]*gorm.DB
	// contains filtered or unexported fields
}

func (*CleanupService) Cleanup

func (cs *CleanupService) Cleanup(req *DBCleanupReq) error

func (*CleanupService) GetDefaultRequest

func (cs *CleanupService) GetDefaultRequest() *DBCleanupReq

func (*CleanupService) RegConnection

func (cs *CleanupService) RegConnection(name string, db *gorm.DB)

type DBCleanupReq

type DBCleanupReq struct {
	Cnn          string   //connection name
	Tables       []string //tables to be clean
	DeletedField string   //field name, default is deletedAt
	Duration     string   // only delete DeletedAt <  now - duration
	Batch        int      // batch per deleted
}

type DBCronJob

type DBCronJob struct {
	Name     string
	Schedule string
	Sql      string
	// contains filtered or unexported fields
}

func (*DBCronJob) FireJob

func (job *DBCronJob) FireJob()

type GetViewSql

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

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