dbv5

Documentation

Index

• func Connect(ctx context.Context, pCfg *postgresconfig5.PostgresConfig, ...) (conn *pgx.Conn, err error)
• func ConnectPool(ctx context.Context, pCfg *postgresconfig5.PostgresConfig, ...) (*pgxpool.Pool, error)
• type AfterConnectFunc
• type AfterConnectList
  • func NewAfterConnectList(opts ...AfterConnectFunc) AfterConnectList
  • func (c AfterConnectList) AfterConnect(ctx context.Context, conn *pgx.Conn) error
• type DbPool
  • func NewDbPool(ctx context.Context, cfg *postgresconfig5.PostgresConfig, ...) (*DbPool, error)
  • func (s *DbPool) Acquire(ctx context.Context) (*pgxpool.Conn, error)
  • func (s *DbPool) Check(ctx context.Context, tid int64) (bool, error)
  • func (s *DbPool) Close()
  • func (s *DbPool) GetPool() *pgxpool.Pool

Functions

func Connect

func Connect(ctx context.Context, pCfg *postgresconfig5.PostgresConfig,
	afterConnect func(context.Context, *pgx.Conn) error, log *logger.ZapLogger,
) (conn *pgx.Conn, err error)

Connect connect to database in pgx v4

func ConnectPool

func ConnectPool(ctx context.Context, pCfg *postgresconfig5.PostgresConfig,
	afterConnect func(context.Context, *pgx.Conn) error, log *logger.ZapLogger,
) (*pgxpool.Pool, error)

ConnectPool connect pool to postgres in pgx v4

Types

type AfterConnectFunc

type AfterConnectFunc func(ctx context.Context, conn *pgx.Conn) error

type AfterConnectList

type AfterConnectList []AfterConnectFunc

func NewAfterConnectList

func NewAfterConnectList(opts ...AfterConnectFunc) AfterConnectList

func (AfterConnectList) AfterConnect

func (c AfterConnectList) AfterConnect(ctx context.Context, conn *pgx.Conn) error

type DbPool

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

DbPool dbo

func NewDbPool

func NewDbPool(ctx context.Context, cfg *postgresconfig5.PostgresConfig, log *logger.ZapLogger, opts ...AfterConnectFunc) (*DbPool, error)

func (*DbPool) Acquire

func (s *DbPool) Acquire(ctx context.Context) (*pgxpool.Conn, error)

Acquire get connect

func (*DbPool) Check

func (s *DbPool) Check(ctx context.Context, tid int64) (bool, error)

Check check pg exist

func (*DbPool) Close

func (s *DbPool) Close()

Close pgx connection

func (*DbPool) GetPool

func (s *DbPool) GetPool() *pgxpool.Pool