testutil

package

v0.0.0-...-5032dbf Latest Latest Go to latest Published: Jan 15, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Details

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

Repository

github.com/Dimkanp/dbx

Links

Open Source Insights

Documentation ¶

Index ¶

func IsSpanner[DB WithDriver](db *sql.DB) bool
func IsSqlite[DB WithDriver](db *sql.DB) bool
func RecreateSchema(ctx context.Context, t *testing.T, db SchemaHandler)
func RecreateSchemaOnce(ctx context.Context, db SchemaHandler) (err error)
func RunDBTest[T TestDB](t *testing.T, open func(driver string, source string) (db T, err error), ...)
type SchemaHandler
type T
- func Wrap(t *testing.T) *T
type TestDB
type WithDriver

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func IsSpanner ¶

func IsSpanner[DB WithDriver](db *sql.DB) bool

IsSpanner returns true of the db is a spanner db.

func IsSqlite ¶

func IsSqlite[DB WithDriver](db *sql.DB) bool

IsSqlite returns true of the db is a sqlite db.

func RecreateSchema ¶

func RecreateSchema(ctx context.Context, t *testing.T, db SchemaHandler)

RecreateSchema will drop and recreate schema. Will try it with multiple times with increased sleep time. To void errors like "Schema change operation rejected because a concurrent schema change operation or read-write transaction is already in progress.".

func RecreateSchemaOnce ¶

func RecreateSchemaOnce(ctx context.Context, db SchemaHandler) (err error)

RecreateSchemaOnce will drop and recreate schema.

func RunDBTest ¶

func RunDBTest[T TestDB](t *testing.T, open func(driver string, source string) (db T, err error), callback func(ctx context.Context, t *testing.T, db T))

Types ¶

type SchemaHandler ¶

type SchemaHandler interface {
	Schema() []string
	DropSchema() []string
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

SchemaHandler contains methods required for a schema recreation.

type T ¶

type T struct {
	*testing.T
	// contains filtered or unexported fields
}

func Wrap ¶

func Wrap(t *testing.T) *T

func (*T) Assert ¶

func (t *T) Assert(that bool)

func (*T) AssertContains ¶

func (t *T) AssertContains(msg, needle string)

func (*T) AssertError ¶

func (t *T) AssertError(err error, msg string)

func (*T) AssertNoError ¶

func (t *T) AssertNoError(err error)

func (*T) Context ¶

func (t *T) Context(name string, val string)

func (*T) Run ¶

func (t *T) Run(name string, f func(*T)) bool

func (*T) Runp ¶

func (t *T) Runp(name string, f func(*T)) bool

type TestDB ¶

type TestDB interface {
	io.Closer

	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
}

type WithDriver ¶

type WithDriver interface {
	Driver() driver.Driver
}

WithDriver represents a DB which has a driver (usually *sql.DB).

Source Files ¶

View all Source files

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