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) 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)
• 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) 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,
)

type Query

type Query string

func (Query) String

func (q Query) String() string

func (Query) WithSpan

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