db

Documentation

Index

• Constants
• Variables
• func DbSurvive(db *gorm.DB) error
• func GetDB(c *gin.Context, dbNmae ...string) *gorm.DB
• func InitDB(dsn string, dsn1 ...string) (db *gorm.DB, err error)
• func InitEsClient(addr, username, password string) (db *elastic.Client, err error)
• func InitKafkaConsumer(dsn, username, password string) (db *sarama.Consumer, err error)
• func InitKafkaProducer(dsn, username, password string) (db *sarama.SyncProducer, err error)
• func InitMongoDb(dns string, maxsize, timeOut int) (db *mongo.Client, err error)
• func InitRdb(addr, password string, num int) (db *redis.Client, err error)
• func Initialize(db *gorm.DB) (err error)
• func RdbSurvive(db *redis.Client) error
• type DbPoolCfg

Constants

const (
	LevelInfo  = "info"
	LevelWarn  = "warn"
	LevelError = "error"
)

Variables

var DB *gorm.DB

Functions

func DbSurvive

func DbSurvive(db *gorm.DB) error

DbSurvive mysql survive

func GetDB

func GetDB(c *gin.Context, dbNmae ...string) *gorm.DB

func InitDB

func InitDB(dsn string, dsn1 ...string) (db *gorm.DB, err error)

InitDB init db dsn string 示例 "账号:密码@tcp(服务器IP:端口)/数据库名?charset=utf8&parseTime=True&loc=Local" dsn1 支持多个，后面为从库

func InitEsClient

func InitEsClient(addr, username, password string) (db *elastic.Client, err error)

InitEsClient ES初始化 dsn string http://127.0.0.1:9200 username 账号 可传空 password 密码

func InitKafkaConsumer

func InitKafkaConsumer(dsn, username, password string) (db *sarama.Consumer, err error)

*InitKafkaConsumer 获取消费端 dsn string localhost:9093 username 账号 可传空 password 密码

func InitKafkaProducer

func InitKafkaProducer(dsn, username, password string) (db *sarama.SyncProducer, err error)

* InitKafkaProducer 获取kafka生产端 dsn string localhost:9093 username 账号 可传空 password 密码

func InitMongoDb

func InitMongoDb(dns string, maxsize, timeOut int) (db *mongo.Client, err error)

InitMongoDb mongodb 初始化 dns string 示例 "mongodb://root:123456@127.0.0.1:27627" maxsize 连接池空闲连接数量 timeOut 空闲时间

func InitRdb

func InitRdb(addr, password string, num int) (db *redis.Client, err error)

InitRdb 初始化redis addr string "127.0.0.1:6379" password 密码 可传空 num int DB 库

func Initialize

func Initialize(db *gorm.DB) (err error)

func RdbSurvive

func RdbSurvive(db *redis.Client) error

RdbSurvive redis存活检测

Types

type DbPoolCfg

type DbPoolCfg struct {
	MaxIdleConn int `json:"max_idle_conn"` //空闲连接数
	MaxOpenConn int `json:"max_open_conn"` //最大连接数
	MaxLifeTime int `json:"max_life_time"` //连接可重用的最大时间
	MaxIdleTime int `json:"max_idle_time"` //在关闭连接之前,连接可能处于空闲状态的最大时间
}