pg_api

package
v1.0.56 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 16, 2025 License: MPL-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TxKey key = "tx"
)

Variables

This section is empty.

Functions

func MakeContextTx 

func MakeContextTx(ctx context.Context, tx pgx.Tx) context.Context

Types

type NamedQueryExecutor 

type NamedQueryExecutor interface {
	ScanOneContext(ctx context.Context, dest interface{}, q Query, args ...interface{}) error
	ScanAllContext(ctx context.Context, dest interface{}, q Query, args ...interface{}) error
}

type PG 

type PG struct {
	API *pgxpool.Pool
}

func (PG) BeginTx 

func (pg PG) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)

func (PG) Close 

func (pg PG) Close() error

func (PG) ExecContext 

func (pg PG) ExecContext(ctx context.Context, q Query, args ...interface{}) (pgconn.CommandTag, error)

func (PG) ExecDelete 

func (pg PG) ExecDelete(ctx context.Context, builder sq.DeleteBuilder) int64

func (PG) ExecUpdate 

func (pg PG) ExecUpdate(ctx context.Context, builder sq.UpdateBuilder) int64

func (PG) Ping 

func (pg PG) Ping(ctx context.Context) error

func (PG) QueryContext 

func (pg PG) QueryContext(ctx context.Context, q Query, args ...interface{}) (pgx.Rows, error)

func (PG) QueryContextSelect 

func (pg PG) QueryContextSelect(ctx context.Context, builder sq.SelectBuilder, where map[string]interface{}) pgx.Rows

func (PG) QueryRowContext 

func (pg PG) QueryRowContext(ctx context.Context, q Query, args ...interface{}) pgx.Row

func (PG) QueryRowContextInsert 

func (pg PG) QueryRowContextInsert(ctx context.Context, builder sq.InsertBuilder) pgx.Row

func (PG) QueryRowContextSelect 

func (pg PG) QueryRowContextSelect(ctx context.Context, builder sq.SelectBuilder) pgx.Row

func (PG) RunTransaction added in v1.0.42 

func (pg PG) RunTransaction(ctx context.Context, txOptions transaction.TxOptions, f TransactionalFlow) error

func (PG) UpdateReturning 

func (pg PG) UpdateReturning(ctx context.Context, builder sq.UpdateBuilder) pgx.Row

type PgDbClient added in v1.0.38 

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

func NewPgDBClient added in v1.0.38 

func NewPgDBClient(ctx context.Context, dsn string) (PgDbClient, error)

func (PgDbClient) API added in v1.0.38 

func (c PgDbClient) API() PG

func (PgDbClient) BeginTx added in v1.0.49 

func (c PgDbClient) BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)

func (PgDbClient) Close added in v1.0.38 

func (c PgDbClient) Close() error

func (PgDbClient) ExecDelete added in v1.0.49 

func (c PgDbClient) ExecDelete(ctx context.Context, builder sq.DeleteBuilder) int64

func (PgDbClient) ExecUpdate added in v1.0.49 

func (c PgDbClient) ExecUpdate(ctx context.Context, builder sq.UpdateBuilder) int64

func (PgDbClient) Ping added in v1.0.49 

func (c PgDbClient) Ping(ctx context.Context) error

func (PgDbClient) QueryContextSelect added in v1.0.49 

func (c PgDbClient) QueryContextSelect(ctx context.Context, builder sq.SelectBuilder, where map[string]interface{}) pgx.Rows

func (PgDbClient) QueryRowContextInsert added in v1.0.49 

func (c PgDbClient) QueryRowContextInsert(ctx context.Context, builder sq.InsertBuilder) pgx.Row

func (PgDbClient) QueryRowContextSelect added in v1.0.49 

func (c PgDbClient) QueryRowContextSelect(ctx context.Context, builder sq.SelectBuilder) pgx.Row

func (PgDbClient) RunTransaction added in v1.0.38 

func (c PgDbClient) RunTransaction(ctx context.Context, txOpts transaction.TxOptions, f TransactionalFlow) error

func (PgDbClient) UpdateReturning added in v1.0.49 

func (c PgDbClient) UpdateReturning(ctx context.Context, builder sq.UpdateBuilder) pgx.Row

type PgTransactionManager 

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

func NewPgTransactionManager 

func NewPgTransactionManager(db Transactor) *PgTransactionManager

func (*PgTransactionManager) Transaction 

func (m *PgTransactionManager) Transaction(ctx context.Context, opts transaction.TxOptions, fn TransactionalFlow) (err error)

type Pinger 

type Pinger interface {
	Ping(ctx context.Context) error
}

type Query 

type Query struct {
	Name     string
	QueryRaw string
}

type QueryExecutor 

type QueryExecutor interface {
	UpdateReturning(ctx context.Context, builder squirrel.UpdateBuilder) pgx.Row
	ExecDelete(ctx context.Context, builder squirrel.DeleteBuilder) int64
	ExecUpdate(ctx context.Context, builder squirrel.UpdateBuilder) int64
	QueryContextSelect(ctx context.Context, builder squirrel.SelectBuilder, where map[string]interface{}) pgx.Rows
	QueryRowContextSelect(ctx context.Context, builder squirrel.SelectBuilder) pgx.Row
	QueryRowContextInsert(ctx context.Context, builder squirrel.InsertBuilder) pgx.Row
	RunTransaction(ctx context.Context, txOptions transaction.TxOptions, f TransactionalFlow) error
}

type SQLExecutor 

type SQLExecutor interface {
	//NamedQueryExecutor
	QueryExecutor
	Pinger
}

type TransactionalFlow 

type TransactionalFlow func(ctx context.Context) error

type Transactor 

type Transactor interface {
	BeginTx(ctx context.Context, txOptions pgx.TxOptions) (pgx.Tx, error)
}

type TxManager 

type TxManager interface {
	Transaction(ctx context.Context, opts transaction.TxOptions, f TransactionalFlow) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.