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
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tsingson/gotoolkit

Links

Open Source Insights

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