pgkit

type DB interface {
	QueryRow(ctx context.Context, query string, args ...any) Row
	Query(ctx context.Context, query string, args ...any) (Rows, error)
	Exec(ctx context.Context, query string, args ...any) (sql.Result, error)
	Close() error
}

type DBOption func(*dbOptions)

type FakeDB struct {
	QueryRowFake func(ctx context.Context, query string, args ...any) Row
	QueryFake    func(ctx context.Context, query string, args ...any) (Rows, error)
	ExecFake     func(ctx context.Context, query string, args ...any) (sql.Result, error)
	CloseFake    func() error
}

type FakeMigrator struct {
	RunMigrationsFake          func(db DB, dirPath string) error
	RunMigrationsToVersionFake func(db DB, dirPath string, toVersion int) error
	ListMigrationsFake         func(db DB, dirPath string) ([]Migration, error)
}

type FakeRow struct {
	ScanFake func(dest ...any) error
}

type FakeRows struct {
	NextFake  func() bool
	ScanFake  func(dest ...any) error
	CloseFake func() error
	ErrFake   func() error
}

type Migration struct {
	Version     int
	Description string
	Filename    string
	Applied     bool
	AppliedAt   *time.Time
}

type Migrator interface {
	RunMigrations(db DB, dirPath string) error
	RunMigrationsToVersion(db DB, dirPath string, toVersion int) error
	ListMigrations(db DB, dirPath string) ([]Migration, error)
}

type Row interface {
	Scan(dest ...any) error
}

type Rows interface {
	Next() bool
	Scan(dest ...any) error
	Close() error
	Err() error
}