dsql

Documentation

Index

• Constants
• func AddTables(ctx context.Context, conn *pgxpool.Pool, model *metamodel.Model, ...) ([]*metamodel.StructType, error)
• func BuildConnURI(pgCfg *dconfig.Postgres) (string, error)
• func Connect(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (*pgx.Conn, error)
• func ConnectPool(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (*pgxpool.Pool, error)
• func CreateDB(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (err error)
• func DropDB(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (err error)
• func ExecSingle(ctx context.Context, querier pgxtype.Querier, sql string, args ...any) error
• func PatchField(buf *bytes.Buffer, args []any, arg any, name string) []any
• func QuerySingle(ctx context.Context, querier pgxtype.Querier, sql string, args []any, ...) error
• type PgxLoggerWrapper
  • func NewPgxLoggerWrapper(logger dlog.Logger) PgxLoggerWrapper
  • func (plw PgxLoggerWrapper) Log(_ context.Context, level pgx.LogLevel, msg string, data map[string]any)

Constants

const (
	EmptyPatch = derrors.StrError("empty patch")
	Impossible = derrors.StrError("impossible")
	NotFound   = derrors.StrError("not found")
)

Functions

func AddTables

func AddTables(ctx context.Context, conn *pgxpool.Pool, model *metamodel.Model, buf *bytes.Buffer) ([]*metamodel.StructType, error)

func BuildConnURI

func BuildConnURI(pgCfg *dconfig.Postgres) (string, error)

func Connect

func Connect(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (*pgx.Conn, error)

func ConnectPool

func ConnectPool(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (*pgxpool.Pool, error)

func CreateDB

func CreateDB(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (err error)

func DropDB

func DropDB(ctx context.Context, pgCfg *dconfig.Postgres, pgxLogger pgx.Logger) (err error)

func ExecSingle

func ExecSingle(ctx context.Context, querier pgxtype.Querier, sql string, args ...any) error

func PatchField

func PatchField(buf *bytes.Buffer, args []any, arg any, name string) []any

func QuerySingle

func QuerySingle(ctx context.Context, querier pgxtype.Querier, sql string, args []any, dest []any) error

Types

type PgxLoggerWrapper

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

func NewPgxLoggerWrapper

func NewPgxLoggerWrapper(logger dlog.Logger) PgxLoggerWrapper

func (PgxLoggerWrapper) Log

func (plw PgxLoggerWrapper) Log(_ context.Context, level pgx.LogLevel, msg string, data map[string]any)