sqlstream

Documentation

Index

• func SQLReader(rows DataRows, recordDelimiter string, lineDelimiter string) io.ReadCloser
• type DataRows
• type SQLStream
  • func NewSQLStream(username string, password string, dbName string, host string, port int, ...) (*SQLStream, error)
  • func (s *SQLStream) ExecuteQuery() (io.ReadCloser, error)

Functions

func SQLReader

func SQLReader(rows DataRows, recordDelimiter string, lineDelimiter string) io.ReadCloser

SQLReader represents a live output of a Sql query

Types

type DataRows

type DataRows interface {
	Columns() ([]string, error)
	Close() error
	Next() bool
	Err() error
	Scan(dest ...interface{}) error
}

This is all we need from sql.Rows

type SQLStream

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

func NewSQLStream

func NewSQLStream(
	username string,
	password string,
	dbName string,
	host string,
	port int,
	sqlQuery string,
	recordDelimiter string,
	lineDelimiter string) (*SQLStream, error)

func (*SQLStream) ExecuteQuery

func (s *SQLStream) ExecuteQuery() (io.ReadCloser, error)