database

Documentation

Index

• Constants
• func GetGorm(name string) (db *gorm.DB, put func(), err error)
• func GetMongo(name string) (db *mgo.Database, put func(), err error)
• func GetMysql(name string) (db *gorm.DB, put func(), err error)
• func GetPostgre(name string) (db *pgo.DB, put func(), err error)
• func GetRedis(name string) (db redis.Conn, put func(), err error)
• func PutConn(put func())
• func RegisterAll()
• type DataBase
  • func NewGorm() DataBase
  • func NewMongo() DataBase
  • func NewMysql() DataBase
  • func NewPostgre() DataBase
  • func NewRedis() DataBase
• type GormDB
  • func (my *GormDB) Register(name string)
  • func (my *GormDB) RegisterAll()
• type MongoDB
  • func (mo *MongoDB) Register(name string)
  • func (mo *MongoDB) RegisterAll()
• type MysqlDB
  • func (my *MysqlDB) Register(name string)
  • func (my *MysqlDB) RegisterAll()
• type PostgreDB
  • func (pg *PostgreDB) Register(name string)
  • func (pg *PostgreDB) RegisterAll()
• type RedisDB
  • func (re *RedisDB) Register(name string)
  • func (re *RedisDB) RegisterAll()

Constants

const (
	MySQL      = "mysql"
	PostgreSQL = "postgres"
	SQLite     = "sqlite"
	SQLServer  = "sqlserver"
	Clickhouse = "clickhouse"
)

Functions

func GetGorm

func GetGorm(name string) (db *gorm.DB, put func(), err error)

GetGorm 获取一个 gorm 连接

func GetMongo

func GetMongo(name string) (db *mgo.Database, put func(), err error)

GetMongo 获取一个 mongodb连接

func GetMysql

func GetMysql(name string) (db *gorm.DB, put func(), err error)

GetMysql 获取一个mysql db连接

func GetPostgre

func GetPostgre(name string) (db *pgo.DB, put func(), err error)

GetPostgre 获取一个GetPostgre连接

func GetRedis

func GetRedis(name string) (db redis.Conn, put func(), err error)

GetRedis 获取一个db连接

func PutConn

func PutConn(put func())

PutConn 将连接放回连接池方法

func RegisterAll

func RegisterAll()

RegisterAll 注册所有支持的驱动

Types

type DataBase

type DataBase interface {
	RegisterAll()
	Register(string)
	// contains filtered or unexported methods
}

func NewGorm

func NewGorm() DataBase

NewGorm 初始化 gorm 连接

func NewMongo

func NewMongo() DataBase

NewMysql 初始化mysql连接

func NewMysql

func NewMysql() DataBase

NewMysql 初始化mysql连接

func NewPostgre

func NewPostgre() DataBase

NewPostgre 初始化Postgre连接

func NewRedis

func NewRedis() DataBase

NewRedis 初始化 redis 连接

type GormDB

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

func (*GormDB) Register

func (my *GormDB) Register(name string)

Register 注册一个db配置

func (*GormDB) RegisterAll

func (my *GormDB) RegisterAll()

注册所有已配置的db

type MongoDB

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

func (*MongoDB) Register

func (mo *MongoDB) Register(name string)

Register 注册一个mongo配置

func (*MongoDB) RegisterAll

func (mo *MongoDB) RegisterAll()

注册所有已配置的 mongo

type MysqlDB

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

func (*MysqlDB) Register

func (my *MysqlDB) Register(name string)

NewMysql 注册一个mysql配置

func (*MysqlDB) RegisterAll

func (my *MysqlDB) RegisterAll()

注册所有已配置的mysql

type PostgreDB

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

func (*PostgreDB) Register

func (pg *PostgreDB) Register(name string)

Register 注册一个postgre配置

func (*PostgreDB) RegisterAll

func (pg *PostgreDB) RegisterAll()

注册所有已配置的 postgre

type RedisDB

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

func (*RedisDB) Register

func (re *RedisDB) Register(name string)

RegisterRedis 注册一个redis配置

func (*RedisDB) RegisterAll

func (re *RedisDB) RegisterAll()

注册所有已配置的 redis