xdb

Documentation

Index

• Constants
• func DB() *gorm.DB
• func GetAutoSliceDB(db *gorm.DB, userId int64, sf SP) *gorm.DB
• func InitQpsDB(limit int, interval time.Duration)
• func OpenMysqlDB(dbType string, dbUrl string, config *gorm.Config, ...) (instance *gorm.DB, err error)
• func QpsDB() *gorm.DB
• func SetMainDB(main *gorm.DB, DSN string)
• type SP

Constants

const (
	EmptyVal    = ""
	PartOnlyOne = 1
)

const (
	// MYSQL dbType
	MYSQL = "mysql"
	// PG dbType
	PG = "postgres"
)

Functions

func DB

func DB() *gorm.DB

DB 获取数据库链接

func GetAutoSliceDB

func GetAutoSliceDB(db *gorm.DB, userId int64, sf SP) *gorm.DB

GetAutoSliceDB 获取自动分表

func InitQpsDB

func InitQpsDB(limit int, interval time.Duration)

InitQpsDB 初始化同步等待QPS DB

func OpenMysqlDB

func OpenMysqlDB(dbType string, dbUrl string, config *gorm.Config, maxIdleConns, maxOpenConns int, models ...interface{}) (instance *gorm.DB, err error)

OpenMysqlDB gorm v2 dbUrl = username:password@tcp(localhost:3306)/db_name?charset=utf8mb4&parseTime=True&loc=Local

func QpsDB

func QpsDB() *gorm.DB

QpsDB 获取DB对象，若超时则返回nil

func SetMainDB

func SetMainDB(main *gorm.DB, DSN string)

SetMainDB 设置主DB

Types

type SP

type SP struct {
	Value  interface{}
	Part   int64  // 用户ID取余分表
	ByDate string // 通过日期2022-01-01分表，按月，按日
}