sql

Documentation

Index

• Variables
• type CQRS
• type ClientOption
  • func WithRO(db DB) ClientOption
  • func WithRW(db DB) ClientOption
• type Config
  • func (c Config) DSN() string
• type DB
  • func Connect(ctx context.Context, driver string, dsn string) (DB, error)
  • func (db DB) Close(ctx context.Context) error
  • func (db DB) MultiNamedExecContext(ctx context.Context, query Query, args []map[string]any) (sql.Result, error)
  • func (db DB) NamedExecContext(ctx context.Context, query Query, args map[string]any) (sql.Result, error)
  • func (db DB) NamedQueryContext(ctx context.Context, query Query, args map[string]any) (*sqlx.Rows, error)
  • func (db DB) Ping(ctx context.Context) error
• type Query
  • func (q Query) String() string
  • func (q Query) WithSpan(span trace.Span) string

Variables

var NewCQRS = c.NewWithValidate[cqrs, ClientOption]

Types

type CQRS

type CQRS interface {
	RW() DB
	RO() DB
}

type ClientOption

type ClientOption c.Option[cqrs]

func WithRO

func WithRO(db DB) ClientOption

func WithRW

func WithRW(db DB) ClientOption

type Config

type Config struct {
	Driver   string `validate:"oneof=noop mysql pgx"`
	Host     string `validate:"required"`
	Database string `validate:"required"`
	User     string `validate:"required"`
	Password string `validate:"required"`
	Port     int64  `validate:"gt=1000,lt=65536"`
}

func (Config) DSN

func (c Config) DSN() string

type DB

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

func Connect

func Connect(
	ctx context.Context,
	driver string,
	dsn string,
) (DB, error)

func (DB) Close

func (db DB) Close(ctx context.Context) error

func (DB) MultiNamedExecContext

func (db DB) MultiNamedExecContext(
	ctx context.Context,
	query Query,
	args []map[string]any,
) (
	sql.Result,
	error,
)

func (DB) NamedExecContext

func (db DB) NamedExecContext(
	ctx context.Context,
	query Query,
	args map[string]any,
) (
	sql.Result,
	error,
)

func (DB) NamedQueryContext

func (db DB) NamedQueryContext(
	ctx context.Context,
	query Query,
	args map[string]any,
) (
	*sqlx.Rows,
	error,
)

func (DB) Ping

func (db DB) Ping(ctx context.Context) error

type Query

type Query string

func (Query) String

func (q Query) String() string

func (Query) WithSpan

func (q Query) WithSpan(span trace.Span) string