db

Documentation

Index

• func CreateMigration(name string)
• func GetConnection(c *DBConfigDef) *sql.DB
• func ILIKE(lhs, rhs StringExpression) BoolExpression
• func JetGenerate(conf DBConfigDef)
• func MigrateToVersion(conf *DBConfigDef, version uint)
• func PopulateBuiltInRoles(dbConfig *DBConfigDef)
• func RunInTransaction[Ret any, Repo DBRepo](repo Repo, fn func(txRepo Repo) (Ret, error)) (Ret, error)
• func RunMigrationUp(conf *DBConfigDef)
• type DBConfigDef
  • func ReadConfigFromEnv() DBConfigDef
  • func (c *DBConfigDef) ConnectString() string
  • func (c *DBConfigDef) EnvLines() []string
  • func (c *DBConfigDef) SetLogQueries()
  • func (c *DBConfigDef) URI() string
• type DBRepo
• type RepoConn
  • func NewRepoConn(conn *sql.DB) RepoConn
  • func (repo *RepoConn) GetConn() *sql.DB
  • func (repo *RepoConn) GetDB() qrm.DB
  • func (repo *RepoConn) GetIsInTransaction() bool
  • func (repo *RepoConn) WithTransaction(tx *sql.Tx) RepoConn

Functions

func CreateMigration

func CreateMigration(name string)

func GetConnection

func GetConnection(c *DBConfigDef) *sql.DB

func ILIKE

func ILIKE(lhs, rhs StringExpression) BoolExpression

func JetGenerate

func JetGenerate(conf DBConfigDef)

func MigrateToVersion

func MigrateToVersion(conf *DBConfigDef, version uint)

func PopulateBuiltInRoles

func PopulateBuiltInRoles(dbConfig *DBConfigDef)

func RunInTransaction

func RunInTransaction[Ret any, Repo DBRepo](repo Repo, fn func(txRepo Repo) (Ret, error)) (Ret, error)

func RunMigrationUp

func RunMigrationUp(conf *DBConfigDef)

Types

type DBConfigDef

type DBConfigDef struct {
	POSTGRES_DB       string
	POSTGRES_PASSWORD string
	POSTGRES_USER     string
	POSTGRES_HOST     string
	POSTGRES_PORT     string
	LOG_QUERIES       *bool
}

func ReadConfigFromEnv

func ReadConfigFromEnv() DBConfigDef

func (*DBConfigDef) ConnectString

func (c *DBConfigDef) ConnectString() string

func (*DBConfigDef) EnvLines

func (c *DBConfigDef) EnvLines() []string

func (*DBConfigDef) SetLogQueries

func (c *DBConfigDef) SetLogQueries()

func (*DBConfigDef) URI

func (c *DBConfigDef) URI() string

type DBRepo

type DBRepo interface {
	GetDB() qrm.DB
	GetConn() *sql.DB
	GetIsInTransaction() bool
	WithTransaction(tx *sql.Tx) DBRepo
}

type RepoConn

type RepoConn struct {
	DB   qrm.DB
	Conn *sql.DB
	// contains filtered or unexported fields
}

func NewRepoConn

func NewRepoConn(conn *sql.DB) RepoConn

func (*RepoConn) GetConn

func (repo *RepoConn) GetConn() *sql.DB

func (*RepoConn) GetDB

func (repo *RepoConn) GetDB() qrm.DB

Implmenting the DBRepo interface

func (*RepoConn) GetIsInTransaction

func (repo *RepoConn) GetIsInTransaction() bool

func (*RepoConn) WithTransaction

func (repo *RepoConn) WithTransaction(tx *sql.Tx) RepoConn