db

package

v4.75.4 Latest Latest Go to latest Published: May 4, 2024 License: MIT Imports: 13 Imported by: 7

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/ViBiOh/httputils

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func StoreTx(ctx context.Context, tx pgx.Tx) context.Context
type Config
- func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) *Config
type Database
type Service
- func New(ctx context.Context, config *Config, tracerProvider trace.TracerProvider) (Service, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrNoHost        = errors.New("no host for database connection")
	ErrNoTransaction = errors.New("no transaction in context, please wrap with DoAtomic()")
	SQLTimeout       = time.Second * 5
)

Functions ¶

func StoreTx ¶

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

Types ¶

type Config ¶

type Config struct {
	Host    string
	User    string
	Pass    string
	Name    string
	SSLMode string
	Port    uint
	MinConn uint
	MaxConn uint
}

func Flags ¶

func Flags(fs *flag.FlagSet, prefix string, overrides ...flags.Override) *Config

type Database ¶ added in v4.24.0

type Database interface {
	Ping(context.Context) error
	Close()
	Begin(context.Context) (pgx.Tx, error)
	Query(context.Context, string, ...any) (pgx.Rows, error)
	QueryRow(context.Context, string, ...any) pgx.Row
	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
}

type Service ¶ added in v4.64.0

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

func New ¶

func New(ctx context.Context, config *Config, tracerProvider trace.TracerProvider) (Service, error)

func (Service) Bulk ¶ added in v4.64.0

func (s Service) Bulk(ctx context.Context, fetcher func() ([]any, error), schema, table string, columns ...string) (err error)

func (Service) Close ¶ added in v4.64.0

func (s Service) Close()

func (Service) Create ¶ added in v4.64.0

func (s Service) Create(ctx context.Context, query string, args ...any) (id uint64, err error)

func (Service) DoAtomic ¶ added in v4.64.0

func (s Service) DoAtomic(ctx context.Context, action func(context.Context) error) (err error)

func (Service) Enabled ¶ added in v4.64.0

func (s Service) Enabled() bool

func (Service) Exec ¶ added in v4.64.0

func (s Service) Exec(ctx context.Context, query string, args ...any) error

func (Service) Get ¶ added in v4.64.0

func (s Service) Get(ctx context.Context, scanner func(pgx.Row) error, query string, args ...any) error

func (Service) List ¶ added in v4.64.0

func (s Service) List(ctx context.Context, scanner func(pgx.Rows) error, query string, args ...any) error

func (Service) One ¶ added in v4.64.0

func (s Service) One(ctx context.Context, query string, args ...any) error

func (Service) Ping ¶ added in v4.64.0

func (s Service) Ping(ctx context.Context) error

func (Service) Query ¶ added in v4.64.0

func (s Service) Query(ctx context.Context, query string, args ...any) (rows pgx.Rows, err error)

func (Service) QueryRow ¶ added in v4.64.0

func (s Service) QueryRow(ctx context.Context, query string, args ...any) pgx.Row

Source Files ¶

View all Source files

db.go

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