mrpostgres

Documentation

Index

• type ConnAdapter
  • func New() *ConnAdapter
  • func (c *ConnAdapter) Begin(ctx context.Context) (mrstorage.DbTransaction, error)
  • func (c *ConnAdapter) Cli() *pgxpool.Pool
  • func (c *ConnAdapter) Close() error
  • func (c *ConnAdapter) Connect(opt Options) error
  • func (c *ConnAdapter) Exec(ctx context.Context, sql string, args ...any) error
  • func (c *ConnAdapter) Ping(ctx context.Context) error
  • func (c *ConnAdapter) Query(ctx context.Context, sql string, args ...any) (mrstorage.DbQueryRows, error)
  • func (c *ConnAdapter) QueryRow(ctx context.Context, sql string, args ...any) mrstorage.DbQueryRow
  • func (c *ConnAdapter) SqExec(ctx context.Context, query mrstorage.DbSqlizer) error
  • func (c *ConnAdapter) SqQuery(ctx context.Context, query mrstorage.DbSqlizer) (mrstorage.DbQueryRows, error)
  • func (c *ConnAdapter) SqQueryRow(ctx context.Context, query mrstorage.DbSqlizer) mrstorage.DbQueryRow
• type Options
• type Transaction
  • func (t *Transaction) Commit(ctx context.Context) error
  • func (t *Transaction) Exec(ctx context.Context, sql string, args ...any) error
  • func (t *Transaction) Query(ctx context.Context, sql string, args ...any) (mrstorage.DbQueryRows, error)
  • func (t *Transaction) QueryRow(ctx context.Context, sql string, args ...any) mrstorage.DbQueryRow
  • func (t *Transaction) Rollback(ctx context.Context) error
  • func (t *Transaction) SqExec(ctx context.Context, query mrstorage.DbSqlizer) error
  • func (t *Transaction) SqQuery(ctx context.Context, query mrstorage.DbSqlizer) (mrstorage.DbQueryRows, error)
  • func (t *Transaction) SqQueryRow(ctx context.Context, query mrstorage.DbSqlizer) mrstorage.DbQueryRow

Types

type ConnAdapter

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

func New

func New() *ConnAdapter

func (*ConnAdapter) Begin

func (c *ConnAdapter) Begin(ctx context.Context) (mrstorage.DbTransaction, error)

func (*ConnAdapter) Cli

func (c *ConnAdapter) Cli() *pgxpool.Pool

func (*ConnAdapter) Close

func (c *ConnAdapter) Close() error

func (*ConnAdapter) Connect

func (c *ConnAdapter) Connect(opt Options) error

func (*ConnAdapter) Exec

func (c *ConnAdapter) Exec(ctx context.Context, sql string, args ...any) error

func (*ConnAdapter) Ping

func (c *ConnAdapter) Ping(ctx context.Context) error

func (*ConnAdapter) Query

func (c *ConnAdapter) Query(ctx context.Context, sql string, args ...any) (mrstorage.DbQueryRows, error)

func (*ConnAdapter) QueryRow

func (c *ConnAdapter) QueryRow(ctx context.Context, sql string, args ...any) mrstorage.DbQueryRow

func (*ConnAdapter) SqExec

func (c *ConnAdapter) SqExec(ctx context.Context, query mrstorage.DbSqlizer) error

func (*ConnAdapter) SqQuery

func (c *ConnAdapter) SqQuery(ctx context.Context, query mrstorage.DbSqlizer) (mrstorage.DbQueryRows, error)

func (*ConnAdapter) SqQueryRow

func (c *ConnAdapter) SqQueryRow(ctx context.Context, query mrstorage.DbSqlizer) mrstorage.DbQueryRow

type Options

type Options struct {
	Host             string
	Port             string
	Database         string
	Username         string
	Password         string
	MaxPoolSize      int32
	ConnAttempts     int32
	ConnTimeout      time.Duration
	AfterConnectFunc func() any
}

type Transaction

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

func (*Transaction) Commit

func (t *Transaction) Commit(ctx context.Context) error

func (*Transaction) Exec

func (t *Transaction) Exec(ctx context.Context, sql string, args ...any) error

func (*Transaction) Query

func (t *Transaction) Query(ctx context.Context, sql string, args ...any) (mrstorage.DbQueryRows, error)

func (*Transaction) QueryRow

func (t *Transaction) QueryRow(ctx context.Context, sql string, args ...any) mrstorage.DbQueryRow

func (*Transaction) Rollback

func (t *Transaction) Rollback(ctx context.Context) error

func (*Transaction) SqExec

func (t *Transaction) SqExec(ctx context.Context, query mrstorage.DbSqlizer) error

func (*Transaction) SqQuery

func (t *Transaction) SqQuery(ctx context.Context, query mrstorage.DbSqlizer) (mrstorage.DbQueryRows, error)

func (*Transaction) SqQueryRow

func (t *Transaction) SqQueryRow(ctx context.Context, query mrstorage.DbSqlizer) mrstorage.DbQueryRow