db

Documentation

Index

• type HarmonyDB
  • func NewHarmonyDB(ctx context.Context, hCfg config.HarmonyDBConfig) (*HarmonyDB, error)
  • func (db *HarmonyDB) Close()
  • func (db *HarmonyDB) Exec(ctx context.Context, sql string, arguments ...any) (count int, err error)
  • func (db *HarmonyDB) Query(ctx context.Context, sql string, arguments ...any) (*Query, error)
  • func (db *HarmonyDB) QueryRow(ctx context.Context, sql string, arguments ...any) Row
  • func (db *HarmonyDB) Select(ctx context.Context, sliceOfStructPtr any, sql string, arguments ...any) error
• type Qry
• type Query
• type Row

Types

type HarmonyDB

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

func NewHarmonyDB

func NewHarmonyDB(ctx context.Context, hCfg config.HarmonyDBConfig) (*HarmonyDB, error)

NewHarmonyDB creates a new HarmonyDB instance. The url parameter should be a postgres connection string. "postgres://username:password@localhost:5433/database_name?search_path=curio"

func (*HarmonyDB) Close

func (db *HarmonyDB) Close()

func (*HarmonyDB) Exec

func (db *HarmonyDB) Exec(ctx context.Context, sql string, arguments ...any) (count int, err error)

func (*HarmonyDB) Query

func (db *HarmonyDB) Query(ctx context.Context, sql string, arguments ...any) (*Query, error)

func (*HarmonyDB) QueryRow

func (db *HarmonyDB) QueryRow(ctx context.Context, sql string, arguments ...any) Row

func (*HarmonyDB) Select

func (db *HarmonyDB) Select(ctx context.Context, sliceOfStructPtr any, sql string, arguments ...any) error

type Qry

type Qry interface {
	Next() bool
	Err() error
	Close()
	Scan(...any) error
	Values() ([]any, error)
}

type Query

type Query struct {
	Qry
}

type Row

type Row interface {
	Scan(...any) error
}