db

func CreateDB ¶

func CreateDB(dsn string, waitForDB time.Duration) (*sql.DB, error)

func CreateMigrationFiles ¶

func CreateMigrationFiles(name string) ([]migrations.File, error)

func LatestMigrationVersion ¶

func LatestMigrationVersion() (int, error)

func Migrate ¶

func Migrate(ctx context.Context, db *sql.DB) error

func MigrateUpTo ¶

func MigrateUpTo(ctx context.Context, db *sql.DB, version uint) error

func RunInTx ¶

func RunInTx(ctx context.Context, db *sql.DB, fn func(txq *queries.Queries) error) error

RunInTx executes fn within a database transaction. If fn returns an error, the transaction is rolled back. Otherwise, it is committed.

func RunInTxResult ¶

func RunInTxResult[T any](ctx context.Context, db *sql.DB, fn func(txq *queries.Queries) (T, error)) (T, error)

RunInTxResult executes fn within a database transaction, returning both a value and an error. If fn returns an error, the transaction is rolled back. Otherwise, it is committed.