database

Documentation

Index

• func BatchInsert(ctx context.Context, db *pgxpool.Pool, createTmp func(pgx.Tx) error, ...) error
• func GetMigrations(namespace string) ([]migration, error)
• func UniqueTableName(table string) string
• func UpdateDatabase(ctx context.Context, db pgxtype.Querier, migrations []migration) error
• func WithTestDb(migrations []migration, action func(db *pgxpool.Pool) error) error

Functions

func BatchInsert

func BatchInsert(ctx context.Context, db *pgxpool.Pool, createTmp func(pgx.Tx) error,
	insertTmp func(pgx.Tx) error, copyToDest func(pgx.Tx) error) error

func GetMigrations

func GetMigrations(namespace string) ([]migration, error)

func UniqueTableName

func UniqueTableName(table string) string

func UpdateDatabase

func UpdateDatabase(ctx context.Context, db pgxtype.Querier, migrations []migration) error

func WithTestDb

func WithTestDb(migrations []migration, action func(db *pgxpool.Pool) error) error