dbv5

package

v0.1.3 Latest Latest Go to latest Published: Oct 25, 2023 License: MIT Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tsingson/gotoolkit

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
_example
postgresconfig5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL