sql

Documentation

Index

• Constants
• type FromSQLOpSpec
  • func (s *FromSQLOpSpec) Kind() flux.OperationKind
• type FromSQLProcedureSpec
  • func (s *FromSQLProcedureSpec) Copy() plan.ProcedureSpec
  • func (s *FromSQLProcedureSpec) Kind() plan.ProcedureKind
• type SQLIterator
  • func (c *SQLIterator) Close() error
  • func (c *SQLIterator) Connect() error
  • func (c *SQLIterator) Decode() (flux.Table, error)
  • func (c *SQLIterator) Fetch() (bool, error)

Constants

const FromSQLKind = "fromSQL"

Types

type FromSQLOpSpec

type FromSQLOpSpec struct {
	DriverName     string `json:"driverName,omitempty"`
	DataSourceName string `json:"dataSourceName,omitempty"`
	Query          string `json:"query,omitempty"`
}

func (*FromSQLOpSpec) Kind

func (s *FromSQLOpSpec) Kind() flux.OperationKind

type FromSQLProcedureSpec

type FromSQLProcedureSpec struct {
	plan.DefaultCost
	DriverName     string
	DataSourceName string
	Query          string
}

func (*FromSQLProcedureSpec) Copy

func (s *FromSQLProcedureSpec) Copy() plan.ProcedureSpec

func (*FromSQLProcedureSpec) Kind

func (s *FromSQLProcedureSpec) Kind() plan.ProcedureKind

type SQLIterator

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

func (*SQLIterator) Close

func (c *SQLIterator) Close() error

func (*SQLIterator) Connect

func (c *SQLIterator) Connect() error

func (*SQLIterator) Decode

func (c *SQLIterator) Decode() (flux.Table, error)

func (*SQLIterator) Fetch

func (c *SQLIterator) Fetch() (bool, error)