connection

package

v1.4.2 Latest Latest Go to latest Published: Nov 24, 2022 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func AddDatabaseToPool(name string, DB *sqlx.DB)

AddDatabaseToPool add connection to pool

func Get() (*sqlx.DB, error)

Get get postgres connection

func GetDatabase() string

GetDatabase get current database in use

func GetFromPool(dbName string) (*sqlx.DB, error)

GetFromPool tries to get the db name from the db pool will return error if not found

func GetURI(DBName string) string

GetURI postgres connection URI

func MustGet() *sqlx.DB

MustGet get postgres connection

func SetDatabase(name string)

SetDatabase set current database in use

type Pool struct {
	Mtx *sync.Mutex
	DB  map[string]*sqlx.DB
}

Pool struct

func GetPool() *Pool

GetPool of connection