db

package

v0.0.0-...-175e951 Latest Latest Go to latest Published: Dec 2, 2025 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ericls/imgdd

Links

Open Source Insights

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
type DBRepo
type RepoConn
- func NewRepoConn(conn *sql.DB) RepoConn

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL