internal

type MockDBAdapter struct {
	ExecContextFn  func(ctx context.Context, query string, args ...interface{}) (ksql.Result, error)
	QueryContextFn func(ctx context.Context, query string, args ...interface{}) (ksql.Rows, error)
}

type MockResult struct {
	LastInsertIdFn func() (int64, error)
	RowsAffectedFn func() (int64, error)
}

type MockRows struct {
	ScanFn    func(...interface{}) error
	CloseFn   func() error
	NextFn    func() bool
	ErrFn     func() error
	ColumnsFn func() ([]string, error)
}