postgres

Documentation

Index

• func New(config *Config) *query.QueryDb
• type Config
  • func (config *Config) URI() string
• type Proxy
  • func NewProxy() *Proxy
  • func (proxy *Proxy) Read() *query.QueryDb
  • func (proxy *Proxy) SetRead(query *query.QueryDb)
  • func (proxy *Proxy) SetWrite(query *query.QueryDb)
  • func (proxy *Proxy) Write() *query.QueryDb
• type ProxyPool
  • func NewProxyPool() *ProxyPool
  • func (proxypool *ProxyPool) NameSpace(group string) *Proxy
  • func (proxypool *ProxyPool) SetNameSpace(group string, proxy *Proxy)

Functions

func New

func New(config *Config) *query.QueryDb

New 新连接

Types

type Config

type Config struct {
	Username        string        //账号 root
	Password        string        //密码
	Host            string        //host localhost
	Port            string        //端口 3306
	Charset         string        //字符编码 utf8mb4
	Database        string        //默认连接数据库
	ConnMaxLifetime time.Duration //设置一个连接的最长生命周期，因为数据库本身对连接有一个超时时间的设置，如果超时时间到了数据库会单方面断掉连接，此时再用连接池内的连接进行访问就会出错, 因此这个值往往要小于数据库本身的连接超时时间
	ConnMaxIdleTime time.Duration //设置连接的生命周期的最大
	MaxIdleConns    int           //设置闲置的连接数,连接池里面允许Idel的最大连接数, 这些Idel的连接 就是并发时可以同时获取的连接,也是用完后放回池里面的互用的连接, 从而提升性能
	MaxOpenConns    int           //设置最大打开的连接数，默认值为0表示不限制。控制应用于数据库建立连接的数量，避免过多连接压垮数据库。
	DriverName      string
	Trace           bool
}

Config 数据库配置

func (*Config) URI

func (config *Config) URI() string

URI 构造数据库连接

type Proxy

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

Proxy 代理

func NewProxy

func NewProxy() *Proxy

NewProxy 代理池

func (*Proxy) Read

func (proxy *Proxy) Read() *query.QueryDb

Read 获取读库

func (*Proxy) SetRead

func (proxy *Proxy) SetRead(query *query.QueryDb)

SetRead 设置读库

func (*Proxy) SetWrite

func (proxy *Proxy) SetWrite(query *query.QueryDb)

SetWrite 设置写库

func (*Proxy) Write

func (proxy *Proxy) Write() *query.QueryDb

Write 获取写库

type ProxyPool

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

ProxyPool 代理池

func NewProxyPool

func NewProxyPool() *ProxyPool

NewProxyPool 代理池

func (*ProxyPool) NameSpace

func (proxypool *ProxyPool) NameSpace(group string) *Proxy

NameSpace 获取分组

func (*ProxyPool) SetNameSpace

func (proxypool *ProxyPool) SetNameSpace(group string, proxy *Proxy)

SetNameSpace 设置组