sql

Documentation

Index

• func Splitter(separator string) func(rune) bool
• type Main
  • func NewMain() *Main
• type Source
  • func NewSource(driver, connString, cmd, separator string, c chan []interface{}, ...) (*Source, error)
  • func (s *Source) Close() error
  • func (s *Source) Open() error
  • func (s *Source) Record() (idk.Record, error)
  • func (s *Source) Schema() []idk.Field

Functions

func Splitter

func Splitter(separator string) func(rune) bool

Splitter returns a splitter based on runes in a separator

Types

type Main

type Main struct {
	idk.Main             `flag:"!embed"`
	Driver               string `help:"key used for finding go sql database driver"`
	ConnectionString     string `short:"g" help:"credentials for connecting to sql database"`
	RowExpr              string `short:"w" help:"sql + type description on input"`
	StringArraySeparator string `help:"separator used to delineate values in string array"`
}

func NewMain

func NewMain() *Main

type Source

type Source struct {
	// contains filtered or unexported fields
}

func NewSource

func NewSource(driver, connString, cmd, separator string, c chan []interface{}, log logger.Logger) (*Source, error)

func (*Source) Close

func (s *Source) Close() error

func (*Source) Open

func (s *Source) Open() error

func (*Source) Record

func (s *Source) Record() (idk.Record, error)

func (*Source) Schema

func (s *Source) Schema() []idk.Field